Function startWebsocket

lib/src/websockets.ts:5–20

(store: Store)

/** Opens a Websocket Connection at `/ws` for the current Drive */
export function startWebsocket(store: Store): WebSocket {
  const wsURL = new URL(store.getServerUrl());
  // Default to a secure WSS connection, but allow WS for unsecured server connections
  if (wsURL.protocol == 'http:') {
    wsURL.protocol = 'ws';
  } else {
    wsURL.protocol = 'wss';
  }
  wsURL.pathname = '/ws';
  const client = new WebSocket(wsURL.toString());
  client.onopen = _e => handleOpen(store);
  client.onmessage = (ev: MessageEvent) => handleMessage(ev, store);
  client.onerror = handleError;
  // client.onclose = handleClose;
  return client;
}

function handleOpen(store: Store) {
  // TODO: Add a way to subscribe to multiple resources in one request