Function testRemoveOnFinish

test/test_queue.js:497–562

(opts, expectedCount, fail)

    describe('auto job removal', () => {
      async function testRemoveOnFinish(opts, expectedCount, fail) {
        const clock = sinon.useFakeTimers();
        clock.reset();

        queue.process(async job => {
          await job.log('test log');
          if (fail) {
            throw new Error('job failed');
          }
        });

        const datas = [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14];

        const processing = new Promise(resolve => {
          queue.on(fail ? 'failed' : 'completed', async job => {
            clock.tick(1000);

            if (job.data == 14) {
              const counts = await queue.getJobCounts(
                fail ? 'failed' : 'completed'
              );

              if (fail) {
                expect(counts.failed).to.be.equal(expectedCount);
              } else {
                expect(counts.completed).to.be.equal(expectedCount);
              }

              await Promise.all(
                jobIds.map(async (jobId, index) => {
                  const job = await queue.getJob(jobId);
                  const logs = await queue.getJobLogs(jobId);

                  try {
                    if (index >= datas.length - expectedCount) {
                      expect(job).to.not.be.equal(null);
                      expect(logs.logs).to.not.be.empty;
                    } else {
                      expect(job).to.be.equal(null);
                      expect(logs.logs).to.be.empty;
                    }
                  } catch (err) {
                    console.error(err);
                  }
                })
              );

              resolve();
            }
          });
        });

        const jobOpts = {};
        if (fail) {
          jobOpts.removeOnFail = opts;
        } else {
          jobOpts.removeOnComplete = opts;
        }