Fix memory issues

imports/node-app/plugins/job-queue/job-queue/createJobClass.js

@@ -621,7 +621,6 @@ export default function createJobClass() {
       let cb = rest[adjustedLength - 1];
 
       [options, cb] = Array.from(optionsHelp(options, cb));
-      if (typeof options.timeout !== "number") { options.timeout = 60 * 1000; }
       return methodCall(root, "shutdownJobServer", [options], cb);
     }
 

imports/node-app/plugins/job-queue/job-queue/createJobCollectionClass.js

@@ -463,42 +463,38 @@ export default function createJobCollectionClass({ Job, later }) {
 
     // eslint-disable-next-line camelcase
     _DDPMethod_startJobServer() {
-      // The client can't actually do this, so skip it
-      if (!this.isSimulation) {
-        if (this.stopped && (this.stopped !== true)) { clearTimeout(this.stopped); }
-        this.stopped = false;
-      }
+      this.stopped = false;
       return true;
     }
 
     // eslint-disable-next-line camelcase
-    _DDPMethod_shutdownJobServer(options = {}) {
-      if (!options.timeout) {
-        options.timeout = 60 * 1000;
-      }
+    async _DDPMethod_shutdownJobServer() {
+      this.stopped = true;
 
-      // The client can"t actually do any of this, so skip it
-      if (!this.isSimulation) {
-        if (this.stopped && (this.stopped !== true)) { clearTimeout(this.stopped); }
-        this.stopped = setTimeout(
-          async () => {
-            const cursor = this.collection.find({ status: "running" });
-            const failedJobs = await cursor.count();
+      // Fail all currently running jobs
+      if (this.collection) {
+        const runningJobs = await this.collection.find({
+          status: "running"
+        }, {
+          projection: {
+            _id: 1,
+            runId: 1
+          }
+        }).toArray();
 
-            if (failedJobs !== 0) {
-              console.warn(`Failing ${failedJobs} jobs on queue stop.`);
-            }
+        if (runningJobs.length > 0) {
+          console.warn(`Failing ${runningJobs.length} jobs on queue stop.`);
 
-            await Promise.all(cursor.map((doc) => this._DDPMethod_jobFail(doc._id, doc.runId, "Running at Job Server shutdown.")));
+          await Promise.all(runningJobs.map((doc) => this._DDPMethod_jobFail(doc._id, doc.runId, "Running at Job Server shutdown.")));
+        }
+      }
 
-            if (this.logStream !== null) { // Shutting down closes the logStream!
-              this.logStream.end();
-              this.logStream = null;
-            }
-          },
-          options.timeout
-        );
+      // Close the log stream
+      if (this.logStream !== null) {
+        this.logStream.end();
+        this.logStream = null;
       }
+
       return true;
     }
 

imports/test-utils/setupJestIntegrationTests.js

@@ -0,0 +1,4 @@
+process.on("unhandledRejection", (err) => {
+  console.error("unhandledRejection:", err); // eslint-disable-line no-console
+  process.exit(10); // eslint-disable-line no-process-exit
+});

jest-mongodb-config.js

@@ -10,6 +10,7 @@ module.exports = {
       version: "3.6.14",
       skipMD5: true
     },
-    autoStart: false
+    autoStart: false,
+    debug: true
   }
 };

jest.config.js

@@ -189,6 +189,7 @@ const jestConfig = {
 // integration tests as opposed to unit tests, which don't need MongoDB running.
 if (process.env.JEST_MONGO) {
   delete jestConfig.testEnvironment;
+  jestConfig.setupFilesAfterEnv = ["<rootDir>/imports/test-utils/setupJestIntegrationTests.js"];
   jestConfig.preset = "@shelf/jest-mongodb";
 }