delete the support code for using the socketio cluster module

- confusing
- not needed for anything anymore

Author: williamstein

src/package.json

@@ -22,7 +22,6 @@
     "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/server/conat/persist/index.ts

@@ -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/socketio/cluster.ts

@@ -26,19 +26,15 @@
     "./settings": "./dist/settings/index.js",
     "./settings/*": "./dist/settings/*.js"
   },
-  "keywords": [
-    "utilities",
-    "cocalc"
-  ],
+  "keywords": ["utilities", "cocalc"],
   "scripts": {
     "preinstall": "npx only-allow pnpm",
     "clean": "rm -rf node_modules dist",
     "build": "../node_modules/.bin/tsc --build",
     "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",