Function probeServer

app/src/modules/hub.js:296–339

(server)

}

function probeServer(server) {
  return new Promise(resolve => {
    if (!server.wsUrl) { resolve({ ok: false, latencyMs: null }); return; }
    let done = false;
    const startedAt = (typeof performance !== 'undefined' && performance.now) ? performance.now() : Date.now();
    const finish = (ok) => {
      if (done) return;
      done = true;
      const endedAt = (typeof performance !== 'undefined' && performance.now) ? performance.now() : Date.now();
      resolve({
        ok,
        latencyMs: ok ? Math.max(1, Math.round(endedAt - startedAt)) : null,
      });
    };
    try {
      const ws = new WebSocket(server.wsUrl);
      const timer = setTimeout(() => { try { ws.close(); } catch {} finish(false); }, HUB_PROBE_TIMEOUT_MS);
      ws.onopen = () => {
        try {
          ws.send(JSON.stringify({
            type: 'hello',
            clientInstanceId: `hub_probe_${Date.now().toString(36)}`,
            token: server.token || '',
            page: '/hub-probe',
            userAgent: navigator.userAgent || '',
          }));
        } catch {
          clearTimeout(timer);
          finish(false);
        }
      };
      ws.onmessage = (event) => {
        let msg;
        try { msg = JSON.parse(event.data); } catch { return; }
        if (!isAuthReadyMessage(msg)) return;
        clearTimeout(timer);
        try { ws.close(); } catch {}
        finish(true);
      };
      ws.onerror = () => { clearTimeout(timer); finish(false); };
      ws.onclose = () => { clearTimeout(timer); if (!done) finish(false); };
    } catch { finish(false); }
  });
}

function applyHubProbeResult(server, result) {
  const info = getHubProbeInfo(server.id);