Generated by XState Viz: https://xstate.js.org/viz

machine.js

const websocketMachine = Machine({
  id: 'websocket',
  initial: 'CONNECTING',
  context: {
    lastEventId: null,
    socket: null,
  },
  invoke: {
    src: 'initializeWebSocket',
    onDone: 'CONNECTED',
  },
  states: {
    CONNECTING: {
      on: {
        CONNECTED: {
          target: 'CONNECTED.idle',
          actions: 'storeSocket',
        },
      }
    },
    CONNECTED: {
      onEntry: 'startStream',
      on: {
        DISCONNECT: {
          target: 'CONNECTING',
        },
      },
      initial: 'idle',
      states: {
        idle: {
          on: {
            NEW_VERTEX_ACCEPTED: {
              actions: ['storeEvent'],
              target: 'handlingVertexAccepted',
            },
            VERTEX_METADATA_CHANGED: {
              actions: ['storeEvent'],
              target: 'handlingMetadataChanged',
            },
            LOAD_STARTED: {
              actions: ['storeEvent'],
              target: 'success',
            },
            REORG_STARTED: {
              actions: ['storeEvent'],
              target: 'success',
            },
            REORG_ENDED: {
              actions: ['storeEvent'],
              target: 'success',
            },
            ACK: {
              actions: 'sendAck'
            },
            '*': {
              actions: ['storeEvent'],
              target: 'success',
            }
          }
        },
        handlingMetadataChanged: {
          invoke: {
            src: 'handleMetadataChanged',
            data: (_context, event) => event,
            onDone: 'success',
            onError: 'error',
          },
        },
        handlingVertexAccepted: {
          invoke: {
            src: 'handleVertexAccepted',
            data: (_context, event) => event,
            onDone: 'success',
            onError: 'error',
          },
        },
        success: {
          entry: 'sendAck',
          always: [
            { target: 'idle' }
          ],
        },
        error: {
          type: 'final',
          entry: 'logError',
        },
      }
    }
  }
}, {
  actions: {
  }, 
  services: {
  },
});