Method writeInbound

src/proxy/mailbox/store.js:355–381

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

  }

  writeInbound({ id, type, payload, channel, priority, refId, expiresAt }) {
    const msgId = id || generateUUIDv7();
    // At-least-once delivery from the Hub / retry loops can send the same
    // message id twice. Without idempotency, poll() and countPending() would
    // double-count the retry. See community PR #515.
    if (this._messages.has(msgId)) return msgId;

    const now = Date.now();
    const msg = {
      id: msgId,
      channel: channel || DEFAULT_CHANNEL,
      direction: 'inbound',
      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 msgId;
  }

  writeInboundBatch(messages) {
    const ids = [];