Class ZodIpcConnection

packages/core/src/v3/zodIpc.ts:146–338

}

export class ZodIpcConnection<
  TListenCatalog extends ZodSocketMessageCatalogSchema,
  TEmitCatalog extends ZodSocketMessageCatalogSchema,
> {
  #sessionId?: string;
  #messageCounter: number = 0;

  #handler: ZodIpcMessageHandler<TListenCatalog, TEmitCatalog>;

  #acks: Map<
    number,
    {
      resolve: (value: unknown) => void;
      reject: (reason?: any) => void;
      timeout: NodeJS.Timeout;
    }
  > = new Map();

  constructor(private opts: ZodIpcConnectionOptions<TListenCatalog, TEmitCatalog>) {
    this.#handler = new ZodIpcMessageHandler({
      schema: opts.listenSchema,
      handlers: opts.handlers,
      sender: {
        send: this.send.bind(this),
        sendWithAck: this.sendWithAck.bind(this),
      },
    });

    this.#registerHandlers();
    // this.connect();
  }

  async #registerHandlers() {
    if (!this.opts.process.on) {
      return;
    }

    this.opts.process.on("message", async (message) => {
      this.#handlePacket(message);
    });
  }

  async connect() {
    this.#sendPacket({ type: "CONNECT" });
  }

  async #handlePacket(packet: Packet): Promise<void> {
    const parsedPacket = Packet.safeParse(packet);

    if (!parsedPacket.success) {
      // console.error("dropping invalid packet", packet);
      return;
    }

    // console.log("<-", packet);

    switch (parsedPacket.data.type) {
      case "ACK": {