conat: all tests updated except the sync ones

Author: williamstein

src/package.json

@@ -19,7 +19,7 @@
     "test-parallel": "unset DEBUG && pnpm run version-check && cd packages && pnpm run -r --parallel test",
     "test": "unset DEBUG && pnpm run version-check && cd packages && pnpm run -r test",
     "prettier-all": "cd packages/",
-    "nats-server": "cd ${COCALC_ROOT:=$INIT_CWD}/packages/backend && node -e \"require('@cocalc/backend/conat/install').main()\" && node -e \"require('@cocalc/backend/conat/conf').main()\" && node -e \"require('@cocalc/backend/conat/server').main()\"",
+    "nats-server": "cd ${COCALC_ROOT:=$INIT_CWD}/packages/backend && node -e \"require('@cocalc/backend/conat/server').main()\"",
     "build-nats": "cd ${COCALC_ROOT:=$INIT_CWD}/packages/util && pnpm install && pnpm build && cd ${COCALC_ROOT:=$INIT_CWD}/packages/nats && pnpm install && pnpm build && cd ${COCALC_ROOT:=$INIT_CWD}/packages/backend && pnpm install && pnpm build",
     "nats-server-ci": "pnpm run build-nats && cd ${COCALC_ROOT:=$INIT_CWD}/packages/backend && node -e \"require('@cocalc/backend/conat/install').main()\" && node -e \"require('@cocalc/backend/conat/conf').main()\" && node -e \"require('@cocalc/backend/conat/server').main()\"",
     "nats-server-daemon": "cd ${COCALC_ROOT:=$INIT_CWD}/packages/backend && node -e \"require('@cocalc/backend/conat/install').main()\" && node -e \"require('@cocalc/backend/conat/conf').main()\" && node -e \"require('@cocalc/backend/conat/server').main({daemon:true})\"",

src/packages/backend/conat/test/files/read.test.ts

@@ -4,11 +4,14 @@ Test async streaming read of files from a compute servers using NATS.
 
 DEVELOPMENT:
 
-pnpm exec jest --watch --forceExit --detectOpenHandles "read.test.ts"
+pnpm test ./read.test.ts
 
 */
 
-import "@cocalc/backend/conat";
+import { before, after } from "@cocalc/backend/conat/test/setup";
+
+beforeAll(before);
+
 import { close, createServer, readFile } from "@cocalc/conat/files/read";
 import { createReadStream } from "fs";
 import { file as tempFile } from "tmp-promise";
@@ -103,3 +106,6 @@ describe("do a larger test that involves multiple chunks and a different name",
     }
   });
 });
+
+
+afterAll(after);

src/packages/backend/conat/test/files/write.test.ts

@@ -4,11 +4,14 @@ Test async streaming writing of files to compute servers using NATS.
 
 DEVELOPMENT:
 
-  pnpm exec jest --watch --forceExit --detectOpenHandles "write.test.ts"
+  pnpm test ./write.test.ts
 
 */
 
-import "@cocalc/backend/conat";
+import { before, after } from "@cocalc/backend/conat/test/setup";
+
+beforeAll(before);
+
 import { close, createServer, writeFile } from "@cocalc/conat/files/write";
 import { createWriteStream, createReadStream } from "fs";
 import { file as tempFile } from "tmp-promise";
@@ -125,3 +128,8 @@ describe("do a more challenging test that involves a larger file that has to be
     }
   });
 });
+
+
+
+
+afterAll(after);

src/packages/util/event-iterator.ts

@@ -158,9 +158,9 @@ export class EventIterator<V extends unknown>
   drain(): void {
     // just immediately end
     this.end();
-    // for compat with nats.  I'm not sure what this should be
+    // [ ] TODO: for compat with nats.  I'm not sure what this should be
     // or if it matters...
-    console.log("WARNING: TODO -- event-iterator drain not implemented");
+    // console.log("WARNING: TODO -- event-iterator drain not implemented");
   }
 
   /**