Function createDevTools

packages/xstate-inspect/src/server.ts:12–43

()

const serviceListeners = new Set<any>();

function createDevTools() {
  const unregister: XStateDevInterface['unregister'] = (service) => {
    services.delete(service);
    serviceMap.delete(service.sessionId);
  };
  const devTools: XStateDevInterface = {
    services,
    register: (service) => {
      services.add(service);
      serviceMap.set(service.sessionId, service);
      serviceListeners.forEach((listener) => listener(service));

      service.subscribe({
        complete: () => unregister(service),
        error: () => unregister(service)
      });
    },
    unregister,
    onRegister: (listener) => {
      serviceListeners.add(listener);
      services.forEach((service) => listener(service));

      return {
        unsubscribe: () => {
          serviceListeners.delete(listener);
        }
      };
    }
  };
  (globalThis as any).__xstate__ = devTools;
  return devTools;
}

interface ServerInspectorOptions {
  server: WebSocketServer;