3

我想测试一个使用Kue的应用程序，以便在每次测试之前作业队列为空，并在每次测试后清除。队列应该功能齐全，我需要能够检查已经在队列中的作业的状态。

我尝试了mock-kue，它运行良好，直到我不得不从队列中获取工作并分析它们。我无法让它通过工作 ID 返回工作。

我需要能够测试的情况：

  1. 发生了一些事情，队列中应该有给定类型的作业，
  2. 某事发生并产生一份工作。发生了其他事情，该工作被删除并替换为另一个工作（重新安排或现有工作）。

接缝很简单，但我很难解决这个问题。欢迎所有指针。

4

2 回答 2

3

以我的经验，在任何你想运行测试的地方简单地让 redis 在 localhost 上运行比处理 kue 的模拟版本更简单。

首先，为了确保在每次测试之前 kue 是空的，它可以像刷新 redis 一样简单，例如：

var kue = require('kue');
var queue = kue.createQueue();

queue.client.flushdb(function(err) {});

对于#1，kue 有一个 rangeByType() 方法可以解决你的问题：

var getJobs = function(type, state, cb) {
   kue.Job.rangeByType(type, state, 0, -1, 'asc', cb);    
}
// After something happens
getJobs('myJobType', 'active', function(err, jobs) {});

对于 #2，您可以使用相同的方法并简单地跟踪作业 id 以了解它已被替换：

var jobId;
getJobs('myJobType', 'active', function(err, jobs) {
    assert.lengthOf(jobs, 1);
    jobId = jobs[0].id;
});

// After the thing happens
getJobs('myJobType', 'active' function(err, jobs) {
    assert.lengthOf(jobs, 1);
    assert.notEqual(jobId, jobs[0].id);
});

如果您需要通过 ID 查询工作，您可以这样做：

kue.Job.get(jobId, function(err, job) {});
于 2015-04-13T04:08:59.430 回答
1

看一下kue-mock库，它更有可能用于集成测试而不是单元测试。

该库不会破解任何 kue 的内部结构（替换/覆盖方法等）。相反，它使用单独的 redis 命名空间创建原始队列实例，然后，在存根时，它会动态创建作业进程处理程序，放置自己的实现，使您能够控制作业处理行为。

示例用法：

const expect = require('chai').expect;

const kue = require('kue');
const KueMock = require('kue-mock');
const $queue = new KueMock(kue);

const app = require('./your-app-file');

describe('functionality that deals with kue', () => {
  before(() => $queue.clean());
  afterEach(() => $queue.clean());

  it('enqueues a job providing some correct data', () => {
    let jobData;

    $queue.stub('your job type', (job, done) => {
      jobData = job.data;
      done();
    });

    return yourJobRunnerFunction()
      .then(() => {
        expect(jobData).to.be.an('object')
          .that.is.eql({ foo: 'bar' });
      });
  });

  describe('when the job is completed', () => {
    beforeEach(() => {
      $queue.stub('your job type')
        .yields(null, { baz: 'qux' });
    });

    it('correctly handles the result', () => {
      return yourJobRunnerFunction()
        .then((result) => {
          expect(result).to.eql({ baz: 'qux' });
        });
    });

    // ...
  });

  describe('when the job is failed', () => {
    beforeEach(() => {
      $queue.stub('your job type')
        .yields(new Error('Oops!'));
    });

    it('correctly handles the job result', () => {
      return yourJobRunnerFunction()
        .catch((err) => {
          expect(err).to.be.an('error')
            .with.property('message', 'Oops!');
        });
    });

    // ...
  });
});
于 2016-12-29T19:47:53.520 回答