Function main

examples/codex-memory-plugin/scripts/session-start-commit.mjs:224–353

()

}

async function main() {
  let input;
  try {
    const chunks = [];
    for await (const chunk of process.stdin) chunks.push(chunk);
    input = JSON.parse(Buffer.concat(chunks).toString());
  } catch {
    log("skip", { stage: "stdin_parse", reason: "invalid input" });
    noop();
    return;
  }

  const source = input.source || "unknown";
  const newSessionId = input.session_id || "unknown";
  log("start", { source, newSessionId, activeWindowMs: ACTIVE_WINDOW_MS, idleTtlMs: IDLE_TTL_MS });

  try {
    await detectRecallCompressorProfile(cfg, { log, logError });
  } catch (err) {
    logError("compress_profile_detect_uncaught", err);
  }

  if (source === "resume") {
    await injectResumeArchive(newSessionId);
    return;
  }

  // Other non-startup sources are hard no-ops. We don't sweep there, because
  // reconnect-like sources may fire often and sweep should stay tied to a new
  // session boundary.
  if (source !== "startup" && source !== "clear") {
    log("skip", { stage: "source_check", reason: `source=${source} (only startup|clear act)` });
    noop();
    return;
  }

  const health = await fetchJSON("/health");
  if (!health) {
    logError("health_check", "server unreachable; skipping commit + sweep");
    noop();
    return;
  }

  const now = Date.now();
  const states = await listStates();

  // -------------------------------------------------------------------------
  // Active-window heuristic (DESIGN.md §3)
  // -------------------------------------------------------------------------
  const otherStates = states.filter(
    (s) => s?.codexSessionId && s.codexSessionId !== newSessionId,
  );

  const recentlyActive = otherStates.filter(
    (s) => typeof s.lastUpdatedAt === "number"
      && (now - s.lastUpdatedAt) <= ACTIVE_WINDOW_MS,
  );