Function main

actions/setup/js/apply_samples.cjs:542–647

()

}

async function main() {
  const samples = loadSamples();
  const workspace = process.env.GITHUB_WORKSPACE || process.cwd();
  const logPath = process.env.GH_AW_AGENT_STDIO_LOG || "";

  // Pre-stage branches/patches.
  for (let i = 0; i < samples.length; i++) {
    const sample = samples[i];
    if (PATCH_SIDECAR_TOOLS.has(sample.tool)) {
      await preStagePatch(sample, i, workspace);
    }
  }

  if (samples.length === 0) {
    core.info("apply_samples: nothing to replay; exiting cleanly.");
    writeSyntheticStdioLog(logPath, 0);
    return;
  }

  const serverPath = resolveMcpServerPath();
  core.info(`apply_samples: spawning MCP server ${serverPath}`);
  const child = spawn(process.execPath, [serverPath], {
    stdio: ["pipe", "pipe", "inherit"],
    env: process.env,
  });

  const stdoutIter = lineIterator(child.stdout);
  let nextId = 1;
  const failures = [];

  try {
    // Initialize handshake.
    const initRsp = await sendJsonRpc(
      child,
      child.stdin,
      {
        jsonrpc: "2.0",
        id: nextId++,
        method: "initialize",
        params: {
          protocolVersion: "2025-06-18",
          capabilities: {},
          clientInfo: { name: "apply_samples", version: "1.0.0" },
        },
      },
      stdoutIter
    );
    if (initRsp.error) {
      throw new Error(`${ERR_API}: MCP initialize failed: ${JSON.stringify(initRsp.error)}`);
    }

    // Send one tools/call per sample.
    for (const [i, sample] of samples.entries()) {
      const callRsp = await sendJsonRpc(
        child,
        child.stdin,
        {
          jsonrpc: "2.0",