Method send

packages/core/src/v3/zodMessageHandler.ts:159–176

(
    type: K,
    payload: z.input<TMessageCatalog[K]>
  )

  }

  public async send<K extends keyof TMessageCatalog>(
    type: K,
    payload: z.input<TMessageCatalog[K]>
  ) {
    const schema = this.#schema[type];

    if (!schema) {
      throw new Error(`Unknown message type: ${type as string}`);
    }

    const parsedPayload = schema.safeParse(payload);

    if (!parsedPayload.success) {
      throw new ZodSchemaParsedError(parsedPayload.error, payload);
    }

    await this.#sender({ type, payload, version: "v1" });
  }

  public async forwardMessage(message: unknown) {
    const parsedMessage = ZodMessageSchema.safeParse(message);