delete the support code for using the socketio cluster module

- confusing
- not needed for anything anymore

Author: williamstein

src/package.json

@@ -18,11 +18,10 @@
     "version-check": "pip3 install typing_extensions mypy  || pip3 install --break-system-packages typing_extensions mypy && ./workspaces.py version-check && mypy scripts/check_npm_packages.py",
     "test-parallel": "unset DEBUG && pnpm run version-check && cd packages && pnpm run -r --parallel test",
     "test": "unset DEBUG && pnpm run depcheck && pnpm run version-check && ./workspaces.py test",
-    "test-github-ci": "unset DEBUG && pnpm run depcheck && pnpm run version-check && ./workspaces.py test --exclude=jupyter --retries=1",
+    "test-github-ci": "unset DEBUG && pnpm run depcheck && pnpm run version-check && ./workspaces.py test --exclude=jupyter,file-server --retries=1",
     "depcheck": "cd packages && pnpm run -r --parallel depcheck",
     "prettier-all": "cd packages/",
     "local-ci": "./scripts/ci.sh",
-    "conat-server": "cd packages/server && pnpm conat-server",
     "conat-connections": "cd packages/backend && pnpm conat-connections",
     "conat-watch": "cd packages/backend && pnpm conat-watch",
     "conat-inventory": "cd packages/backend && pnpm conat-inventory"

src/packages/pnpm-lock.yaml

@@ -0,0 +1,35 @@
+import { loadConatConfiguration } from "./configuration";
+import { initPersistServer } from "@cocalc/backend/conat/persist";
+import { conatPersistCount } from "@cocalc/backend/data";
+
+import getLogger from "@cocalc/backend/logger";
+
+const logger = getLogger("server:conat:persist");
+
+export async function initConatPersist() {
+  logger.debug("initPersistServer: sqlite3 stream persistence", {
+    conatPersistCount,
+  });
+  if (!conatPersistCount || conatPersistCount <= 1) {
+    // only 1, so no need to use separate processes
+    await loadConatConfiguration();
+    initPersistServer();
+    return;
+  }
+
+  // more than 1 so no possible value to multiple servers if we don't
+  // use separate processes
+  createPersistCluster();
+}
+
+async function createPersistCluster() {
+  logger.debug(
+    "initPersistServer: creating cluster with",
+    conatPersistCount,
+    "nodes",
+  );
+  await loadConatConfiguration();
+  for (let i = 0; i < conatPersistCount; i++) {
+    initPersistServer();
+  }
+}

src/packages/server/conat/persist/index.ts

@@ -37,8 +37,7 @@
     "tsc": "../node_modules/.bin/tsc --watch --pretty --preserveWatchOutput ",
     "test": "TZ=UTC jest --forceExit --runInBand",
     "depcheck": "pnpx depcheck",
-    "prepublishOnly": "test",
-    "conat-server": "node ./dist/conat/socketio/cluster.js"
+    "prepublishOnly": "test"
   },
   "author": "SageMath, Inc.",
   "license": "SEE LICENSE.md",
@@ -68,8 +67,6 @@
     "@passport-next/passport-oauth2": "^2.1.4",
     "@sendgrid/client": "^8.1.4",
     "@sendgrid/mail": "^8.1.4",
-    "@socket.io/cluster-adapter": "^0.2.2",
-    "@socket.io/sticky": "^1.0.4",
     "@zxcvbn-ts/core": "^3.0.4",
     "@zxcvbn-ts/language-common": "^3.0.4",
     "@zxcvbn-ts/language-en": "^3.0.2",