Class IpcAdapter

src/runtime/adapters/ipc.ts:76–528

]);

export class IpcAdapter implements PlatformAdapter, IpcBroadcaster {
  readonly name = "ipc";

  private agent: IPackAgent | null = null;
  private rootDir = "";
  private adapterMap: Map<string, PlatformAdapter> | null = null;
  private conversationService: ConversationService | null = null;
  private readonly createdChannels = new Set<string>();
  private messageListener?: (message: unknown) => void;
  private started = false;

  async start(ctx: AdapterContext): Promise<void> {
    // IPC channel only exists when spawned via child_process.fork/spawn with stdio "ipc".
    if (typeof process.send !== "function") {
      return;
    }

    this.agent = ctx.agent;
    this.rootDir = ctx.rootDir;
    this.adapterMap = ctx.adapterMap ?? null;
    this.conversationService = new ConversationService(ctx.rootDir);

    this.messageListener = (message: unknown) => {
      if (!this.isIpcRequest(message)) return;
      void this.handleRequest(message);
    };
    process.on("message", this.messageListener);

    this.started = true;
    console.log("[IpcAdapter] Started");
  }

  async stop(): Promise<void> {
    if (this.messageListener) {
      process.off("message", this.messageListener);
      this.messageListener = undefined;
    }

    if (this.started) {
      console.log("[IpcAdapter] Stopped");
    }
    this.started = false;
  }

  notifyReady(port: number): void {
    this.sendIpc({
      type: "ready",
      port,
    });
  }

  broadcastInbound(
    channelId: string,
    platform: string,
    sender: { id: string; username: string },
    text: string,
  ): void {
    this.sendIpc({