Function makeMailboxStore

test/syncEngineLoopResilience.test.js:59–75

(overrides = {})

}

function makeMailboxStore(overrides = {}) {
  const state = { node_id: 'node_aaaaaaaaaaaa' };
  return Object.assign({
    getState: (key) => (state[key] !== undefined ? state[key] : null),
    setState: (key, value) => { state[key] = value; },
    getCursor: () => null,
    setCursor: () => {},
    writeInboundBatch: () => {},
    writeInbound: () => {},
    list: () => [],
    pollOutbound: () => [],
    countPending: () => 0,
    incrementRetry: () => {},
    updateStatusBatch: () => {},
    _state: state,
  }, overrides);
}

function makeTextResponse(status, contentType, body) {
  return {