Function buildMcpLifecycleSnapshot

src/server/mcp-lifecycle.ts:274–316

(options: {
  phase: McpStartupPhase;
  shutdownReason: McpShutdownReason | null;
  startedAtMs: number;
  commandExecutor?: CommandExecutor;
})

}

export async function buildMcpLifecycleSnapshot(options: {
  phase: McpStartupPhase;
  shutdownReason: McpShutdownReason | null;
  startedAtMs: number;
  commandExecutor?: CommandExecutor;
}): Promise<McpLifecycleSnapshot> {
  const memoryUsage = process.memoryUsage();
  const activitySnapshot = getDaemonActivitySnapshot();
  const peerSample = await sampleMcpPeerProcesses(
    options.commandExecutor ?? getDefaultCommandExecutor(),
    process.pid,
  );
  const simulatorLaunchOsLogSessions = await listActiveSimulatorLaunchOsLogSessions();

  const snapshotWithoutAnomalies = {
    pid: process.pid,
    ppid: process.ppid,
    orphaned: process.ppid === 1,
    phase: options.phase,
    shutdownReason: options.shutdownReason,
    uptimeMs: Math.max(0, Date.now() - options.startedAtMs),
    rssBytes: memoryUsage.rss,
    heapUsedBytes: memoryUsage.heapUsed,
    watcherRunning: isWatcherRunning(),
    watchedPath: getWatchedPath(),
    activeOperationCount: activitySnapshot.activeOperationCount,
    activeOperationByCategory: activitySnapshot.byCategory,
    debuggerSessionCount: getDefaultDebuggerManager().listSessions().length,
    simulatorLaunchOsLogSessionCount: simulatorLaunchOsLogSessions.length,
    ownedSimulatorLaunchOsLogSessionCount: simulatorLaunchOsLogSessions.filter(
      (session) => session.ownedByCurrentProcess,
    ).length,
    videoCaptureSessionCount: listActiveVideoCaptureSessionIds().length,
    swiftPackageProcessCount: activeProcesses.size,
    matchingMcpProcessCount: peerSample.count,
    matchingMcpPeerSummary: peerSample.peers,
  };

  return {
    ...snapshotWithoutAnomalies,
    anomalies: classifyMcpLifecycleAnomalies(snapshotWithoutAnomalies),
  };
}

export function createMcpLifecycleCoordinator(
  options: McpLifecycleCoordinatorOptions,