test: added tests

Author: shadowgate15

index.js

@@ -229,12 +229,13 @@ class Bree {
       if (
         typeof job.interval !== 'undefined' &&
         typeof job.cron !== 'undefined'
-      )
+      ) {
         errors.push(
           new Error(
             `${prefix} cannot have both interval and cron configuration`
           )
         );
+      }
 
       // don't allow users to mix timeout AND date
       if (typeof job.timeout !== 'undefined' && typeof job.date !== 'undefined')
@@ -306,13 +307,14 @@ class Bree {
             if (schedule.isValid()) {
               this.config.jobs[i].interval = schedule;
               // delete this.config.jobs[i].cron;
-            } else {
-              errors.push(
-                new Error(
-                  `${prefix} had an invalid cron schedule (see <https://crontab.guru> if you need help)`
-                )
-              );
-            }
+            } // else {
+            //   errors.push(
+            //     new Error(
+            //       `${prefix} had an invalid cron schedule (see <https://crontab.guru> if you need help)`
+            //     )
+            //   );
+            // }
+            // above code will never be called
           } else {
             for (const message of result.getError()) {
               errors.push(
@@ -330,7 +332,9 @@ class Bree {
           job.closeWorkerAfterMs <= 0)
       )
         errors.push(
-          `${prefix} had an invalid closeWorkerAfterMs value of ${job.closeWorkerAfterMs} (it must be a finite number > 0`
+          new Error(
+            `${prefix} had an invalid closeWorkersAfterMs value of ${job.closeWorkersAfterMs} (it must be a finite number > 0)`
+          )
         );
 
       // if timeout was undefined, cron was undefined,

package.json

@@ -7,7 +7,8 @@
     "files": [
       "test/*.js",
       "test/**/*.js",
-      "!test/jobs"
+      "!test/jobs",
+      "!test/noIndexJobs"
     ],
     "verbose": true
   },
@@ -31,13 +32,16 @@
   "devDependencies": {
     "@commitlint/cli": "latest",
     "@commitlint/config-conventional": "latest",
+    "@sinonjs/fake-timers": "^6.0.1",
     "ava": "latest",
     "codecov": "latest",
     "cross-env": "latest",
+    "delay": "^4.3.0",
     "eslint": "^7.4.0",
     "eslint-config-xo-lass": "latest",
     "fixpack": "latest",
     "husky": "latest",
+    "into-stream": "^5.1.1",
     "lint-staged": "latest",
     "nyc": "latest",
     "remark-cli": "latest",

test/jobs/done.js

@@ -0,0 +1,11 @@
+const delay = require('delay');
+const { parentPort } = require('worker_threads');
+
+(async () => {
+  await delay(1);
+
+  if (parentPort) {
+    parentPort.postMessage('get ready');
+    parentPort.postMessage('done');
+  }
+})();

test/jobs/index.js

@@ -0,0 +1,2 @@
+// eslint-disable-next-line prettier/prettier
+module.exports = [ 'basic' ];

test/jobs/infinite.js

@@ -0,0 +1,2 @@
+// eslint-disable-next-line unicorn/no-process-exit
+setInterval(() => process.exit(0), 100);

test/jobs/leroy.js/test

@@ -0,0 +1,16 @@
+const { parentPort } = require('worker_threads');
+
+setInterval(() => {}, 10);
+
+if (parentPort) {
+  parentPort.on('message', (message) => {
+    if (message === 'error') throw new Error('oops');
+    if (message === 'cancel') {
+      parentPort.postMessage('cancelled');
+      return;
+    }
+
+    parentPort.postMessage(message);
+    process.exit(0);
+  });
+}

test/jobs/message.js

@@ -0,0 +1 @@
+setInterval(() => {}, 10);

test/jobs/short.js

@@ -0,0 +1 @@
+console.log('hello');

test/noIndexJobs/basic.js

@@ -0,0 +1,35 @@
+# Snapshot report for `test/test.js`
+
+The actual snapshot is saved in `test.js.snap`.
+
+Generated by [AVA](https://avajs.dev).
+
+## creates job with cron string
+
+> Snapshot 1
+
+    {
+      isValid: Function isValid {},
+      next: Function next {},
+      nextRange: Function nextRange {},
+      prev: Function prev {},
+      prevRange: Function prevRange {},
+    }
+
+## parseValue()
+
+> Snapshot 1
+
+    {
+      isValid: Function isValid {},
+      next: Function next {},
+      nextRange: Function nextRange {},
+      prev: Function prev {},
+      prevRange: Function prevRange {},
+    }
+
+## getWorkerMetadata()
+
+> Snapshot 1
+
+    {}