Function AtomicHooksPlugin

packages/opencode-atomic-hooks/src/index.ts:58–795

({ $, directory })

}

export const AtomicHooksPlugin: Plugin = async ({ $, directory }) => {
  const ATOMIC = "atomic";
  const atomicDir = join(directory, ".atomic");
  const logFile = join(atomicDir, "plugin.log");
  const debugFile = join(atomicDir, "plugin-debug.log");
  try {
    mkdirSync(atomicDir, { recursive: true });
  } catch {}

  // Set of messageIDs that belong to user messages (from chat.message hook).
  // Used to distinguish user text parts from assistant text parts in the event stream.
  const userMessageIDs = new Set<string>();

  const log = (msg: string) => {
    const line = `${new Date().toISOString()} ${msg}\n`;
    try {
      appendFileSync(logFile, line);
    } catch {}
  };

  // DEBUG: Separate debug log with full object inspection
  const debug = (label: string, data?: unknown) => {
    const ts = new Date().toISOString();
    const body = data !== undefined ? `\n${inspect(data)}` : "";
    try {
      appendFileSync(debugFile, `${ts} [${label}]${body}\n---\n`);
    } catch {}
  };

  const hook = async (
    sessionID: string,
    verb: string,
    extra: Record<string, unknown> = {},
  ) => {
    const payload = JSON.stringify({
      session_id: sessionID,
      cwd: directory,
      timestamp: new Date().toISOString(),
      ...extra,
    });
    try {
      const result =
        await $`echo ${payload} | ${ATOMIC} agent hooks opencode ${verb}`
          .cwd(directory)
          .quiet()
          .nothrow();
      const ok = result.exitCode === 0;
      const stderr = result.stderr.toString().trim();
      log(
        `${verb} session=${sessionID} exit=${result.exitCode}${stderr ? " stderr=" + stderr : ""}`,
      );
      return ok;
    } catch (err) {
      log(`${verb} session=${sessionID} error=${err}`);
      return false;
    }
  };