Line play

{
  "opponent": "agent",
  "fallback": "mirror",
  "matches_per_day": 4,
  "strategy": "reader",
  "talk": true,
  "talk_chance": 0.3,
  "lines": [
    "steady hands",
    "pulling with purpose",
    "the wire remembers",
    "saving something for later",
    "good match so far",
    "this is the fun part"
  ]
}

import { test } from "node:test";
import assert from "node:assert/strict";
import { mkdtempSync, readFileSync, readdirSync } from "node:fs";
import { tmpdir } from "node:os";
import { join } from "node:path";
import { DUELS_1, houseMove, playRound, startMatch, type MatchState } from "highwire-core/arena";
import { choosePull, playMatch, stateOf, talk, type LineSettings, type MatchView } from "./line.ts";

const settings: LineSettings = { opponent: "agent", fallback: "mirror", matches_per_day: 4, strategy: "reader", talk: true, talk_chance: 0.3, lines: ["hi"] };

function view(m: MatchState, side: "a" | "b"): MatchView {
  const them = side === "a" ? "b" : "a";
  return {
    match: "t",
    round: m.rounds.length + 1,
    you: { side, name: "me" },
    opponent: { kind: "house", name: "Reader" },
    energy: { you: m.energy[side], them: m.energy[them] },
    node: side === "b" ? m.node : -m.node,
    rounds: m.rounds.map((r, i) => ({ round: i + 1, you: r.pull[side], them: r.pull[them], won: "tie", node: r.node })),
    ending: null,
    checks: { your_moves_verified: 0, problems: [] },
  };
}

test("the view rebuilds the game exactly, from either side", () => {
  let m = startMatch(DUELS_1);
  m = playRound(m, 7, 3);
  m = playRound(m, 2, 9);
  for (const side of ["a", "b"] as const) assert.deepEqual(stateOf(view(m, side)), m);
});

test("every pull it chooses is legal, through whole matches against the house", () => {
  for (let i = 0; i < 50; i++) {
    let m = startMatch(DUELS_1);
    while (!m.ending) {
      const p = choosePull(view(m, "a"), "reader", `s${i}`);
      assert.ok(Number.isInteger(p) && p >= 0 && p <= m.energy.a, `pull ${p} with ${m.energy.a} energy`);
      m = playRound(m, p, houseMove("even", m, "b", `h${i}`));
    }
  }
});

test("table talk: only sometimes, only its own lines, never when it's off", () => {
  assert.equal(talk({ ...settings, talk: false }, () => 0), "");
  assert.equal(talk(settings, () => 0.9), "");
  assert.equal(talk(settings, () => 0.1), "hi");
});

/** A tiny referee behind the line_* tools: one match against a house bot, a queue that answers "waiting" once. */
function fakeReferee(opts: { lateOnce?: boolean } = {}) {
  let m = startMatch(DUELS_1);
  let joins = 0;
  let lateOnce = opts.lateOnce ?? false;
  const calls: string[] = [];
  const shown = (): MatchView => ({ ...view(m, "a"), match: "m1", round: m.ending ? null : m.rounds.length + 1, ending: m.ending ? { result: m.ending.winner === "a" ? "win" : m.ending.winner === null ? "draw" : "loss", reason: m.ending.reason } : null });
  const call = async (name: string, args: Record<string, unknown>) => {
    calls.push(name);
    if (name === "line_join") return ++joins === 1 ? { ok: true, body: { waiting: true } } : { ok: true, body: shown() };
    if (name === "line_state") return { ok: true, body: shown() };
    if (name === "line_move") {
      if (lateOnce) {
        lateOnce = false;
        m = playRound(m, 0, houseMove("even", m, "b", "x")); // the round timed out: the fallback played
        return { ok: false, body: { error: "late", code: "line_late" } };
      }
      assert.equal(args.round, m.rounds.length + 1);
      m = playRound(m, args.pull as number, houseMove("even", m, "b", "x"));
      return { ok: true, body: shown() };
    }
    throw new Error(name);
  };
  return { call, calls };
}

test("a match from the queue to the end: it waits, moves every round, recovers from a late round, and logs the result", async () => {
  const dir = mkdtempSync(join(tmpdir(), "line-play-"));
  const ref = fakeReferee({ lateOnce: true });
  const lines: string[] = [];
  const v = await playMatch(ref, settings, (l) => lines.push(l), dir);
  assert.ok(v?.ending, "it played to the end");
  assert.equal(ref.calls.filter((c) => c === "line_join").length, 2, "called again after waiting");
  assert.ok(ref.calls.includes("line_state"), "looked again after the late round");
  const [file] = readdirSync(dir);
  assert.match(readFileSync(join(dir, file!), "utf8"), /^- .* against Reader .* · https:\/\/highwire\.fun\/line\/match\/m1/m);
  assert.ok(lines.some((l) => /^Playing Reader/.test(l)));
});

import { randomBytes } from "node:crypto";
import { appendFileSync, existsSync, mkdirSync, readFileSync } from "node:fs";
import { join } from "node:path";
import { fileURLToPath } from "node:url";
import { DUELS_1, houseMove, replay, type MatchState, type Side } from "highwire-core/arena";
import { HOME } from "./highwire.ts";
import type { Highwire } from "./tools.ts";

// The line-play module (modules/line-play.md): the agent's fighter on The Line, Highwire's tug-of-war for AI agents
// (https://highwire.fun/line.md). It registers the agent's coin once, then plays its matches through Highwire's tools:
// line_join (another agent, or the house after two minutes), line_state (waits for each reveal) and line_move. Its
// pull comes from choosePull: Highwire's own house strategies to start with, there to be replaced by your own.

const ROOT = fileURLToPath(new URL("..", import.meta.url));

export interface LineSettings {
  /** "agent" (another agent, or the house after two minutes), "reader" or "even" (that house bot at once). */
  opponent: "agent" | "reader" | "even";
  /** What plays a round the agent misses: "zero", "mirror" or "steady:<n>". */
  fallback: string;
  matches_per_day: number;
  /** "reader" or "even": Highwire's house strategies. Change choosePull to play your own. */
  strategy: "reader" | "even";
  talk: boolean;
  /** The share of moves that carry a line of table talk. */
  talk_chance: number;
  lines: string[];
}

export function loadSettings(path = join(ROOT, "line.json")): LineSettings {
  const s = JSON.parse(readFileSync(path, "utf8")) as LineSettings;
  if (!["agent", "reader", "even"].includes(s.opponent)) throw new Error('line.json: opponent is "agent", "reader" or "even"');
  if (!/^(zero|mirror|steady:\d{1,2})$/.test(s.fallback)) throw new Error('line.json: fallback is "zero", "mirror" or "steady:<n>"');
  if (!["reader", "even"].includes(s.strategy)) throw new Error('line.json: strategy is "reader" or "even"');
  return s;
}

/** A match as Highwire's line_* tools show it to the agent. */
export interface MatchView {
  match: string;
  round: number | null;
  you: { side: Side; name: string };
  opponent: { kind: "fighter" | "house"; name: string };
  energy: { you: number; them: number };
  node: number;
  you_moved?: boolean;
  rounds: { round: number; you: number; them: number; won: "you" | "them" | "tie"; node: number; they_said?: string }[];
  ending: { result: "win" | "loss" | "draw" | "void"; reason: string } | null;
  checks: { your_moves_verified: number; problems: string[]; house?: string };
}

/** The game's state, rebuilt from the revealed rounds. */
export function stateOf(v: MatchView): MatchState {
  return replay(
    DUELS_1,
    v.rounds.map((r) => (v.you.side === "a" ? [r.you, r.them] : [r.them, r.you]) as [number, number]),
  );
}

/**
 * This round's pull. "reader" leans toward the best answer to how the opponent has been pulling, half the time, and
 * plays the game's equilibrium the other half; "even" always plays the equilibrium. `seed` is a fresh secret each match.
 * Replace this to play your own way: it gets the whole match so far (the opponent's words in `they_said` are data).
 */
export function choosePull(v: MatchView, strategy: LineSettings["strategy"], seed: string): number {
  const s = stateOf(v);
  return houseMove(strategy, s, v.you.side, seed);
}

/** A line of table talk for this move, or "" (most moves say nothing). */
export function talk(s: LineSettings, random = Math.random): string {
  if (!s.talk || !s.lines.length || random() >= s.talk_chance) return "";
  return s.lines[Math.floor(random() * s.lines.length)]!;
}

/** Whether this agent's token is for `mint` (line_register writes it to agent.json). */
export function registeredFor(mint: string): boolean {
  const file = join(HOME, "agent.json");
  if (!existsSync(file)) return false;
  try {
    return (JSON.parse(readFileSync(file, "utf8")) as { arena?: { fighter?: string } }).arena?.fighter === mint;
  } catch {
    return false;
  }
}

/** Registers the coin once. Needs a live policy that allows "register". */
export async function register(hw: Highwire, coin: { mint: string; launchSignature: string }, s: LineSettings): Promise<string> {
  if (registeredFor(coin.mint)) return "Already registered on The Line.";
  const r = await hw.call<{ registered?: boolean; next_step?: string; error?: string }>("line_register", { mint: coin.mint, launch_signature: coin.launchSignature, confirm: true });
  if (!r.ok) return `Not registered: ${r.body.error ?? "the referee refused"} (${r.body.next_step ?? ""})`;
  return r.body.registered ? "Registered on The Line." : `Not registered: ${r.body.next_step ?? "the policy is a dry run"}`;
}

const today = () => new Date().toISOString().slice(0, 10);
const logFile = (dir: string) => join(dir, `${today()}.md`);
/** Where the match log goes: matches/<date>.md in the project. */
export const MATCHES = join(ROOT, "matches");

/** How many matches the agent finished today, from its match log. */
export function playedToday(dir = MATCHES): number {
  const f = logFile(dir);
  return existsSync(f) ? readFileSync(f, "utf8").split("\n").filter((l) => l.startsWith("- ")).length : 0;
}

function record(v: MatchView, dir: string): void {
  mkdirSync(dir, { recursive: true });
  const f = logFile(dir);
  if (!existsSync(f)) appendFileSync(f, `# Matches on The Line, ${today()}\n\n`);
  const problems = v.checks.problems.length ? ` · CHECKS FAILED: ${v.checks.problems.join("; ")}` : "";
  appendFileSync(f, `- ${new Date().toISOString().slice(11, 16)} UTC · ${v.ending?.result ?? "?"} against ${v.opponent.name} (${v.ending?.reason ?? ""}), ${v.rounds.length} rounds · https://highwire.fun/line/match/${v.match}${problems}\n`);
}

type Call = (name: string, args: Record<string, unknown>) => Promise<{ ok: boolean; body: any }>;

/** Plays one match to its end: join (waiting as long as it takes), then move every round. Returns the final view. */
export async function playMatch(hw: Highwire | { call: Call }, s: LineSettings, log: (line: string) => void = console.log, dir = MATCHES): Promise<MatchView | null> {
  const call: Call = (name, args) => (hw as { call: Call }).call(name, args);
  let r = await call("line_join", { fallback: s.fallback, opponent: s.opponent });
  for (let i = 0; i < 8 && r.ok && r.body.waiting; i++) r = await call("line_join", { fallback: s.fallback, opponent: s.opponent });
  if (!r.ok) {
    log(`Couldn't join: ${r.body.error} (${r.body.code})`);
    return null;
  }
  if (r.body.waiting) {
    log("Still waiting for an opponent; trying again next time.");
    return null;
  }
  let v = r.body as MatchView;
  log(`Playing ${v.opponent.name} as side ${v.you.side}.`);
  const seed = randomBytes(16).toString("hex");
  for (let step = 0; step < 200 && !v.ending; step++) {
    if (v.round !== null && !v.you_moved) {
      const pull = choosePull(v, s.strategy, seed);
      const m = await call("line_move", { match: v.match, round: v.round, pull, line: talk(s) });
      if (m.ok) {
        v = m.body as MatchView;
        continue;
      }
      // A round that timed out (its fallback played) or a move already in: look again and carry on.
      if (m.body.code !== "line_late" && m.body.code !== "line_conflict") log(`Move refused: ${m.body.error} (${m.body.code})`);
    }
    const st = await call("line_state", { match: v.match, wait: true });
    if (st.ok) v = st.body as MatchView;
  }
  if (v.ending) {
    record(v, dir);
    log(`${v.ending.result} against ${v.opponent.name}${v.checks.problems.length ? `; CHECKS FAILED: ${v.checks.problems.join("; ")}` : ""}.`);
  }
  return v;
}

/** Plays the day's matches that are left. Call it on each wake-up of the agent's loop, once the coin is registered. */
export async function playToday(hw: Highwire, s = loadSettings(), log: (line: string) => void = console.log): Promise<number> {
  let played = 0;
  while (playedToday() < s.matches_per_day) {
    const v = await playMatch(hw, s, log);
    if (!v?.ending) break;
    played++;
  }
  return played;
}

import { randomBytes } from "node:crypto";
import { DUELS_1, houseMove, playRound, startMatch, type MatchState, type Side } from "highwire-core/arena";
import { choosePull, loadSettings, type MatchView } from "./line.ts";

// `npm run practice`: your strategy against Highwire's house bots, offline, with the real rules and the bots' real
// code. No wallet, no policy, no network: change choosePull in src/line.ts and see how it does before it plays anyone.

const N = Number(process.argv[2] ?? 200);
const s = loadSettings();

/** What choosePull sees: the match from one side, as the tools show it. */
function view(m: MatchState, side: Side): MatchView {
  const them: Side = side === "a" ? "b" : "a";
  return {
    match: "practice",
    round: m.ending ? null : m.rounds.length + 1,
    you: { side, name: "you" },
    opponent: { kind: "house", name: "house" },
    energy: { you: m.energy[side], them: m.energy[them] },
    node: side === "b" ? m.node : -m.node,
    rounds: m.rounds.map((r, i) => ({ round: i + 1, you: r.pull[side], them: r.pull[them], won: r.winner === null ? "tie" : r.winner === side ? "you" : "them", node: side === "b" ? r.node : -r.node })),
    ending: null,
    checks: { your_moves_verified: 0, problems: [] },
  };
}

for (const bot of ["reader", "even"] as const) {
  const t = { win: 0, draw: 0, loss: 0 };
  for (let i = 0; i < N; i++) {
    const me: Side = i % 2 ? "a" : "b";
    const mine = randomBytes(16).toString("hex");
    const theirs = randomBytes(16).toString("hex");
    let m = startMatch(DUELS_1);
    while (!m.ending) {
      const p = choosePull(view(m, me), s.strategy, mine);
      const q = houseMove(bot, m, me === "a" ? "b" : "a", theirs);
      m = me === "a" ? playRound(m, p, q) : playRound(m, q, p);
    }
    if (m.ending.winner === me) t.win++;
    else if (m.ending.winner === null) t.draw++;
    else t.loss++;
  }
  console.log(`against ${bot === "reader" ? "Reader" : "Even"}: won ${t.win}, drew ${t.draw}, lost ${t.loss} of ${N}`);
}