Class IpcRunCoordinator

src/coordinator/ipc-run-coordinator.ts:23–54

 * by each instance's parent; this only bridges child to its own parent.
 */
export class IpcRunCoordinator implements RunCoordinator {
  private pending = new Map<string, (result: CoordinatorResult) => void>();

  constructor(private channel: IpcChannel) {
    this.channel.on('message', (message: any) => {
      if (message?.type !== 'coordinator:result') return;
      const resolve = this.pending.get(message.reqId);
      if (resolve) {
        this.pending.delete(message.reqId);
        resolve(message);
      }
    });
  }

  shouldRun(key: string, ttlMs: number): Promise<boolean> {
    const reqId = createID();
    return new Promise<boolean>((resolve, reject) => {
      this.pending.set(reqId, (result) => {
        // The parent reports a coordinator error by replying with `error`; reject
        // so the runner fails closed (skips the run), mirroring the inline path.
        if (result.error) reject(new Error(result.error));
        else resolve(result.allowed);
      });
      this.channel.send?.({ type: 'coordinator:shouldRun', key, ttlMs, reqId });
    });
  }

  onComplete(key: string): Promise<void> {
    this.channel.send?.({ type: 'coordinator:complete', key });
    return Promise.resolve();
  }
}