Method #handlePacket

packages/core/src/v3/zodIpc.ts:192–256

(packet: Packet)

  }

  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": {
        // Check our list of ACKs and resolve with the message
        const ack = this.#acks.get(parsedPacket.data.id);

        if (!ack) {
          return;
        }

        clearTimeout(ack.timeout);
        ack.resolve(parsedPacket.data.message);

        break;
      }
      case "CONNECT": {
        if (!parsedPacket.data.sessionId) {
          // This is a client trying to connect, so we generate and send back a session ID
          const id = randomUUID();

          await this.#sendPacket({ type: "CONNECT", sessionId: id });

          return;
        }

        // This is a server replying to our connect message
        if (this.#sessionId) {
          // We're already connected
          return;
        }

        this.#sessionId = parsedPacket.data.sessionId;

        break;
      }
      case "EVENT": {
        const result = await this.#handler.handleMessage(parsedPacket.data.message);

        if (typeof parsedPacket.data.id === "undefined") {
          return;
        }

        // There's an ID so we should ACK
        await this.#sendPacket({
          type: "ACK",
          id: parsedPacket.data.id,
          message: result,
        });