Function connect

app/src/modules/websocket.js:240–481

()

}

export function connect() {
  let ws;
  let connectErrorShown = false;
  const isCurrentSocket = () => S.ws === ws;
  const failConnect = (message) => {
    if (connectErrorShown) return;
    connectErrorShown = true;
    hideHubConnectOverlay();
    renderHubCards();
    showToast(message);
  };
  try {
    ws = new WebSocket(serverWsUrl);
  } catch (e) {
    failConnect('Invalid server address');
    return;
  }
  S.ws = ws;
  S.authenticated = false;
  S.resumeRequestedFor = '';
  S.replaying = true;
  debugLog('ws_connect_start', {
    serverWsUrl,
    sessionId: S.sessionId || null,
    hidden: typeof document !== 'undefined' ? !!document.hidden : null,
    online: typeof navigator !== 'undefined' && 'onLine' in navigator ? !!navigator.onLine : null,
  });

  const connectTimeout = setTimeout(() => {
    if (!isCurrentSocket()) return;
    if (ws.readyState !== WebSocket.OPEN) {
      ws.close();
      failConnect('Connection timed out');
    }
  }, 8000);

  ws.onopen = () => {
    clearTimeout(connectTimeout);
    if (!isCurrentSocket()) {
      try { ws.close(); } catch {}
      return;
    }
    clearForegroundProbe('ws_open');
    S.lastMessageAt = Date.now();
    S.intentionalDisconnect = false;
    S.skipNextCloseHandling = false;
    setStatus('starting');
    ws.send(JSON.stringify({
      type: 'hello',
      clientInstanceId: CLIENT_INSTANCE_ID,
      token: serverToken || '',
      page: location.pathname || '/',
      userAgent: navigator.userAgent || '',
    }));
    debugLog('ws_open', {
      sessionId: S.sessionId || null,
      waiting: S.waiting,
      replaying: S.replaying,