Method sendWithAck

packages/core/src/v3/zodIpc.ts:289–337

(
    type: K,
    payload: z.input<GetSocketMessageSchema<TEmitCatalog, K>>,
    timeoutInMs?: number
  )

  }

  public async sendWithAck<K extends GetSocketMessagesWithCallback<TEmitCatalog>>(
    type: K,
    payload: z.input<GetSocketMessageSchema<TEmitCatalog, K>>,
    timeoutInMs?: number
  ): Promise<z.infer<GetSocketCallbackSchema<TEmitCatalog, K>>> {
    const currentId = this.#messageCounter++;

    return new Promise(async (resolve, reject) => {
      const defaultTimeoutInMs = 2000;

      // Timeout if the ACK takes too long to get back to us
      const timeout = setTimeout(() => {
        reject(
          JSON.stringify({
            reason: "sendWithAck() timeout",
            timeoutInMs: timeoutInMs ?? defaultTimeoutInMs,
            type,
            payload,
          })
        );
      }, timeoutInMs ?? defaultTimeoutInMs);

      this.#acks.set(currentId, { resolve, reject, timeout });

      const schema = this.opts.emitSchema[type]["message"];

      if (!schema) {
        clearTimeout(timeout);
        return reject(`Unknown message type: ${type as string}`);
      }

      const parsedPayload = schema.safeParse(payload);

      if (!parsedPayload.success) {
        clearTimeout(timeout);
        return reject(`Failed to parse message payload: ${JSON.stringify(parsedPayload.error)}`);
      }

      await this.#sendPacket({
        type: "EVENT",
        message: {
          type,
          payload,
          version: "v1",
        },
        id: currentId,
      });
    });
  }
}