Function inventoryAgents

apps/vis/server/src/lib/session-store.ts:257–295

(sessionDir: string, state: StateJson, deriveHomedir = false)

}

async function inventoryAgents(sessionDir: string, state: StateJson, deriveHomedir = false): Promise<AgentInfo[]> {
  const result: AgentInfo[] = [];
  for (const [id, meta] of Object.entries(state.agents ?? {})) {
    if (!isSafeAgentId(id)) continue;
    // A type-corrupt entry (e.g. `{ "main": null }`) must not throw on the
    // field dereferences below; skip it so the empty-inventory fallback in
    // readImportedDetail can recover the agent from disk instead.
    if (typeof meta !== 'object' || meta === null) continue;
    const wirePath = join(sessionDir, 'agents', id, 'wire.jsonl');
    const exists = await pathExists(wirePath);
    let readable = exists;
    let info: { count: number; protocolVersion: string | null } = { count: 0, protocolVersion: null };
    if (exists) {
      try {
        info = await scanWire(wirePath);
      } catch {
        // The file exists but is unreadable / malformed. Report it as
        // unavailable so wire/context routes return 404 ("wire missing")
        // instead of 500 ("READ_ERROR") and the UI shows the "no wire"
        // badge consistently with the missing-file path.
        readable = false;
      }
    }
    result.push({
      agentId: id,
      type: meta.type,
      parentAgentId: meta.parentAgentId,
      // For imported bundles the persisted homedir is the exporting machine's
      // absolute path; re-derive it from the local extraction so blob reads
      // (which join homedir) resolve under the imported directory.
      homedir: deriveHomedir ? join(sessionDir, 'agents', id) : meta.homedir,
      wireExists: readable,
      wireRecordCount: info.count,
      wireProtocolVersion: info.protocolVersion,
      swarmItem: meta.swarmItem ?? null,
    });
  }
  return result.sort((a, b) => compareAgentIds(a.agentId, b.agentId));
}

async function readState(sessionDir: string): Promise<StateJson | null> {
  try {