Method send

src/proxy/mailbox/store.js:332–353

({ type, payload, channel, priority, refId, expiresAt })

  // --- Public API: send / writeInbound ---

  send({ type, payload, channel, priority, refId, expiresAt }) {
    const id = generateUUIDv7();
    const now = Date.now();
    const msg = {
      id,
      channel: channel || DEFAULT_CHANNEL,
      direction: 'outbound',
      type,
      status: 'pending',
      payload: safeParse(payload),
      priority: priority || 'normal',
      ref_id: refId || null,
      created_at: now,
      synced_at: null,
      expires_at: expiresAt || null,
      retry_count: 0,
      next_retry_at: null,
      error: null,
    };
    this._appendMessage(msg);
    return { message_id: id, status: 'pending' };
  }

  writeInbound({ id, type, payload, channel, priority, refId, expiresAt }) {
    const msgId = id || generateUUIDv7();