Function toInboundStoreMessage

src/proxy/sync/inbound.js:19–29

(m, channel)

const DEFAULT_POLL_INTERVAL_IDLE = 60_000;

function toInboundStoreMessage(m, channel) {
  return {
    id: m.id,
    type: m.type,
    payload: m.payload,
    channel,
    priority: m.priority || 'normal',
    refId: m.ref_id,
    expiresAt: m.expires_at,
  };
}

class InboundSync {
  constructor({ store, hubUrl, getHeaders, logger }) {