fix: fix more tests

taskforcesh · Jul 27, 2019 · 6a07b35 · 6a07b35
1 parent bc022d5
commit 6a07b35
Show file tree

Hide file tree

Showing 4 changed files with 210 additions and 138 deletions.
diff --git a/src/test/test_delay.ts b/src/test/test_delay.ts
@@ -5,7 +5,7 @@ import IORedis from 'ioredis';
 import { v4 } from 'node-uuid';
 import { Worker } from '@src/classes/worker';
 import { QueueEvents } from '@src/classes/queue-events';
-import { QueueKeeper } from '@src/classes/queue-keeper';
+import { QueueScheduler } from '@src/classes/queue-scheduler';
 
 describe('Delayed jobs', function() {
   this.timeout(15000);
@@ -31,7 +31,7 @@ describe('Delayed jobs', function() {
 
   it('should process a delayed job only after delayed time', async function() {
     const delay = 500;
-    const queueKeeper = new QueueKeeper(queueName);
+    const queueKeeper = new QueueScheduler(queueName);
     await queueKeeper.init();
 
     const queueEvents = new QueueEvents(queueName);
@@ -74,7 +74,7 @@ describe('Delayed jobs', function() {
   it('should process delayed jobs in correct order', async function() {
     let order = 0;
 
-    const queueKeeper = new QueueKeeper(queueName);
+    const queueKeeper = new QueueScheduler(queueName);
     await queueKeeper.init();
 
     const promise = new Promise((resolve, reject) => {
@@ -162,7 +162,7 @@ describe('Delayed jobs', function() {
   it('should process delayed jobs with exact same timestamps in correct order (FIFO)', async function() {
     let order = 1;
 
-    const queueKeeper = new QueueKeeper(queueName);
+    const queueKeeper = new QueueScheduler(queueName);
     await queueKeeper.init();
 
     const now = Date.now();

diff --git a/src/test/test_pause.ts b/src/test/test_pause.ts
@@ -1,5 +1,5 @@
 import { Job, Queue } from '@src/classes';
-import { QueueEvents, QueueKeeper } from '../classes';
+import { QueueEvents, QueueScheduler } from '../classes';
 import { Worker } from '@src/classes/worker';
 import { expect } from 'chai';
 import IORedis from 'ioredis';
@@ -280,7 +280,7 @@ describe('Pause', function() {
   it('should not processed delayed jobs', async function() {
     this.timeout(5000);
 
-    const queueKeeper = new QueueKeeper(queueName);
+    const queueKeeper = new QueueScheduler(queueName);
     await queueKeeper.init();
 
     let processed = false;

diff --git a/src/test/test_rate_limiter.ts b/src/test/test_rate_limiter.ts
@@ -6,7 +6,7 @@ import { v4 } from 'node-uuid';
 import { Worker } from '@src/classes/worker';
 import { after } from 'lodash';
 import { QueueEvents } from '@src/classes/queue-events';
-import { QueueKeeper } from '@src/classes/queue-keeper';
+import { QueueScheduler } from '@src/classes/queue-scheduler';
 
 describe('Rate Limiter', function() {
   let queue: Queue;
@@ -69,7 +69,7 @@ describe('Rate Limiter', function() {
     const numJobs = 4;
     const startTime = new Date().getTime();
 
-    const queueKeeper = new QueueKeeper(queueName);
+    const queueKeeper = new QueueScheduler(queueName);
     await queueKeeper.init();
 
     const worker = new Worker(queueName, async job => {}, {