ensure conat clients ack the initial info message

- i think sometimes this message is missed, so clients remain
  non-initialized

Author: williamstein

src/packages/conat/core/client.ts

@@ -510,7 +510,10 @@ export class Client extends EventEmitter {
       reconnection: true,
     });
 
-    this.conn.on("info", (info) => {
+    this.conn.on("info", (info, ack) => {
+      if (typeof ack == "function") {
+        ack();
+      }
       const firstTime = this.info == null;
       this.info = info;
       this.emit("info", info);

src/packages/conat/core/server.ts

@@ -53,7 +53,7 @@ import {
 import { Patterns } from "./patterns";
 import { is_array } from "@cocalc/util/misc";
 import { UsageMonitor } from "@cocalc/conat/monitor/usage";
-import { once } from "@cocalc/util/async-utils";
+import { once, until } from "@cocalc/util/async-utils";
 import {
   clusterLink,
   type ClusterLink,
@@ -940,7 +940,7 @@ export class ConatServer extends EventEmitter {
       this.subscriptions[id] = new Set<string>();
     }
 
-    socket.emit("info", { ...this.info(), user });
+    this.sendInfo(socket, user);
 
     socket.on("stats", ({ recv0 }) => {
       const s = this.stats[socket.id];
@@ -1086,6 +1086,38 @@ export class ConatServer extends EventEmitter {
     });
   };
 
+  sendInfo = async (socket, user) => {
+    // we send info with an ack because I think sometimes the initial "info"
+    // message gets dropped, leaving a broken hanging connection that never
+    // does anything (until the user explicitly refreshes their browser).
+    // I did see what is probably this in production frequently.
+    try {
+      await until(
+        async () => {
+          if (!socket.conn?.readyState.startsWith("o")) {
+            // logger.debug(`failed to send "info" message to ${socket.id}`);
+            // readyState not defined or not opened or opening, so connection must
+            // have been closed before success.
+            return true;
+          }
+          try {
+            await socket
+              .timeout(7500)
+              .emitWithAck("info", { ...this.info(), user });
+            return true;
+          } catch (err) {
+            // logger.debug(`error sending "info" message to ${socket.id}`, err);
+            return false;
+          }
+        },
+        { min: 5000, max: 30000, timeout: 120_000 },
+      );
+    } catch {
+      // never ack'd "info" after a few minutes -- could just be an old client,
+      // so don't do anything at this point.
+    }
+  };
+
   address = () => getServerAddress(this.options);
 
   // create new client in the same process connected to this server.
@@ -1349,8 +1381,8 @@ export class ConatServer extends EventEmitter {
     const usage = async () => {
       return { [this.id]: this.usage.stats() };
     };
-    // user has to explicitly refresh there browser after
-    // being disconnected this way
+    // user has to explicitly refresh their browser after
+    // being disconnected this way:
     const disconnect = async (ids: string | string[]) => {
       if (typeof ids == "string") {
         ids = [ids];

src/packages/frontend/client/idle.ts

@@ -84,7 +84,7 @@ export class IdleClient {
 
     if (NEVER_TIMEOUT_VISIBLE) {
       // If the document is visible right now, then we
-      // reset the idle timeout., just as if the mouse moved.  This means
+      // reset the idle timeout, just as if the mouse moved.  This means
       // that users never get the standby timeout if their current browser
       // tab is considered visible according to the Page Visibility API
       // https://developer.mozilla.org/en-US/docs/Web/API/Page_Visibility_API
@@ -110,6 +110,7 @@ export class IdleClient {
       // so that if the user sees the idle banner and immediately
       // dismisses it, then the experience is less disruptive.
       this.delayed_disconnect = setTimeout(() => {
+        this.delayed_disconnect = undefined;
         console.log("Entering standby mode");
         this.standbyMode = true;
         // console.log("idle timeout: disconnect!");

src/scripts/g-tmux.sh

@@ -12,14 +12,8 @@ sleep 2
 tmux send-keys -t mysession:1 'pnpm database' C-m
 
 if [ -n "$NO_RSPACK_DEV_SERVER" ]; then
-sleep 2
-tmux send-keys -t mysession:2 'pnpm rspack' C-m
-
-else
-
-# no longer needed, due to using rspack for nextjs
-#sleep 2
-#tmux send-keys -t mysession:2 '$PWD/scripts/memory_monitor.py' C-m
+    sleep 2
+    tmux send-keys -t mysession:2 'pnpm rspack' C-m
 fi
 
 tmux attach -t mysession:1