conat core sticky router -- add logging so we know what is going on

Author: williamstein

src/packages/conat/core/sticky.ts

@@ -4,6 +4,8 @@ import { type Client } from "./client";
 import { reuseInFlight } from "@cocalc/util/reuse-in-flight";
 import { getLogger } from "@cocalc/conat/client";
 
+const DEBUG = true;
+
 const logger = getLogger("conat:core:sticky");
 
 export function consistentHashingChoice(
@@ -85,9 +87,13 @@ export async function createStickyRouter({
   choiceTtl?: number;
   clientTtl?: number;
 }) {
+  logger.debug("Creating Sticky Router: ", { choiceTtl, clientTtl });
+  await client.waitUntilConnected();
   const sub = await client.subscribe(SUBJECT);
+  logger.debug("Creating Sticky Router: subscription created");
   const stickyCache: { [key: string]: { target: string; expire: number } } = {};
 
+  let counter = 0;
   const handle = async (mesg) => {
     try {
       const { pattern, subject, targets } = mesg.data;
@@ -97,11 +103,24 @@ export async function createStickyRouter({
         pattern,
         subject,
       });
+      let madeChoice = false;
       if (target == null || !targets.includes(target)) {
         // make a new choice
+        madeChoice = true;
         target = consistentHashingChoice(targets, subject);
         stickyCache[key] = { target, expire: Date.now() + choiceTtl };
       }
+      counter++;
+      if (DEBUG) {
+        logger.debug("handle request", {
+          counter,
+          madeChoice,
+          pattern,
+          subject,
+          targets,
+          target,
+        });
+      }
       await mesg.respond({ target, ttl: clientTtl });
     } catch (err) {
       logger.debug("WARNING: unable to handle routing message", err);
@@ -113,7 +132,6 @@ export async function createStickyRouter({
     }
   };
   listen();
-  return sub;
 }
 
 const stickyRequest = reuseInFlight(

src/packages/conat/package.json

@@ -24,9 +24,17 @@
     "test": "pnpm exec jest",
     "depcheck": "pnpx depcheck --ignores events,bufferutil,utf-8-validate"
   },
-  "files": ["dist/**", "README.md", "package.json"],
+  "files": [
+    "dist/**",
+    "README.md",
+    "package.json"
+  ],
   "author": "SageMath, Inc.",
-  "keywords": ["utilities", "conat", "cocalc"],
+  "keywords": [
+    "utilities",
+    "conat",
+    "cocalc"
+  ],
   "license": "SEE LICENSE.md",
   "dependencies": {
     "@cocalc/comm": "workspace:*",
@@ -37,13 +45,15 @@
     "ascii-table3": "^1.0.1",
     "awaiting": "^3.0.0",
     "bufferutil": "^4.0.9",
+    "build": "^0.1.4",
     "consistent-hash": "^1.2.2",
     "dayjs": "^1.11.11",
     "events": "3.3.0",
     "immutable": "^4.3.0",
     "js-base64": "^3.7.7",
     "json-stable-stringify": "^1.0.1",
     "lodash": "^4.17.21",
+    "pnpm": "^10.17.1",
     "socket.io": "^4.8.1",
     "socket.io-client": "^4.8.1",
     "utf-8-validate": "^6.0.5"