aboutsummaryrefslogtreecommitdiff
path: root/node_modules/seq-queue/test
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/seq-queue/test')
-rw-r--r--node_modules/seq-queue/test/seq-queue-test.js307
1 files changed, 307 insertions, 0 deletions
diff --git a/node_modules/seq-queue/test/seq-queue-test.js b/node_modules/seq-queue/test/seq-queue-test.js
new file mode 100644
index 0000000..d91724a
--- /dev/null
+++ b/node_modules/seq-queue/test/seq-queue-test.js
@@ -0,0 +1,307 @@
+var should = require('should');
+var SeqQueue = require('../lib/seq-queue');
+
+var timeout = 1000;
+
+describe('seq-queue', function() {
+
+ describe('#createQueue', function() {
+ it('should return a seq-queue instance with init properties', function() {
+ var queue = SeqQueue.createQueue(timeout);
+ should.exist(queue);
+ queue.should.have.property('timeout', timeout);
+ queue.should.have.property('status', SeqQueue.IDLE);
+ });
+ });
+
+ describe('#push' , function() {
+ it('should change the queue status from idle to busy and invoke the task at once when task finish when queue idle', function(done) {
+ var queue = SeqQueue.createQueue(timeout);
+ queue.should.have.property('status', SeqQueue.IDLE);
+ queue.push(function(task) {
+ should.exist(task);
+ task.done();
+ queue.should.have.property('status', SeqQueue.IDLE);
+ done();
+ });
+ queue.should.have.property('status', SeqQueue.BUSY);
+ });
+
+ it('should keep the status busy and keep the new task wait until the former tasks finish when queue busy', function(done) {
+ var queue = SeqQueue.createQueue(timeout);
+ var formerTaskFinished = false;
+ //add first task
+ queue.push(function(task) {
+ formerTaskFinished = true;
+ task.done();
+ });
+ queue.should.have.property('status', SeqQueue.BUSY);
+ //add second task
+ queue.push(function(task) {
+ formerTaskFinished.should.be.true;
+ queue.should.have.property('status', SeqQueue.BUSY);
+ task.done();
+ queue.should.have.property('status', SeqQueue.IDLE);
+ done();
+ });
+ queue.should.have.property('status', SeqQueue.BUSY);
+ });
+
+ it('should ok if the task call done() directly', function(done) {
+ var queue = SeqQueue.createQueue();
+ var taskCount = 0;
+ queue.push(function(task) {
+ taskCount++;
+ task.done();
+ });
+ queue.push(function(task) {
+ taskCount++;
+ task.done();
+ });
+ setTimeout(function() {
+ taskCount.should.equal(2);
+ done();
+ }, 500);
+ });
+ });
+
+ describe('#close', function() {
+ it('should not accept new request but should execute the rest task in queue when close gracefully', function(done) {
+ var queue = SeqQueue.createQueue(timeout);
+ var closedEventCount = 0;
+ var drainedEventCount = 0;
+ queue.on('closed', function() {
+ closedEventCount++;
+ });
+ queue.on('drained', function() {
+ drainedEventCount++;
+ });
+ var executedTaskCount = 0;
+ queue.push(function(task) {
+ executedTaskCount++;
+ task.done();
+ }).should.be.true;
+ queue.close(false);
+ queue.should.have.property('status', SeqQueue.CLOSED);
+
+ queue.push(function(task) {
+ // never should be executed
+ executedTaskCount++;
+ task.done();
+ }).should.be.false;
+
+ // wait all task finished
+ setTimeout(function() {
+ executedTaskCount.should.equal(1);
+ closedEventCount.should.equal(1);
+ drainedEventCount.should.equal(1);
+ done();
+ }, 1000);
+ });
+
+ it('should not execute any task and emit a drained event when close forcefully', function(done) {
+ var queue = SeqQueue.createQueue(timeout);
+ var drainedEventCount = 0;
+ queue.on('drained', function() {
+ drainedEventCount++;
+ });
+ var executedTaskCount = 0;
+ queue.push(function(task) {
+ //never should be executed
+ executedTaskCount++;
+ task.done();
+ }).should.be.true;
+ queue.close(true);
+ queue.should.have.property('status', SeqQueue.DRAINED);
+
+ // wait all task finished
+ setTimeout(function() {
+ executedTaskCount.should.equal(0);
+ drainedEventCount.should.equal(1);
+ done();
+ }, 1000);
+ });
+ });
+
+ describe('#timeout', function() {
+ it('should emit timeout event and execute the next task when a task timeout by default', function(done) {
+ var queue = SeqQueue.createQueue();
+ var executedTaskCount = 0;
+ var timeoutCount = 0;
+ var onTimeoutCount = 0;
+ //add timeout listener
+ queue.on('timeout', function(task) {
+ task.should.be.a('object');
+ task.fn.should.be.a('function');
+ timeoutCount++;
+ });
+
+ queue.push(function(task) {
+ executedTaskCount++;
+ //no task.done() invoke to cause a timeout
+ }, function() {
+ onTimeoutCount++;
+ }).should.be.true;
+
+ queue.push(function(task) {
+ executedTaskCount++;
+ task.done();
+ }).should.be.true;
+
+ setTimeout(function() {
+ //wait all task finish
+ executedTaskCount.should.be.equal(2);
+ timeoutCount.should.be.equal(1);
+ onTimeoutCount.should.be.equal(1);
+ done();
+ }, 4000); //default timeout is 3s
+ });
+
+ it('should return false when invoke task.done() if task has already timeout', function(done) {
+ var queue = SeqQueue.createQueue();
+ var executedTaskCount = 0;
+ var timeoutCount = 0;
+ var timeout = 1000;
+
+ //add timeout listener
+ queue.on('timeout', function(task) {
+ task.should.be.a('object');
+ task.fn.should.be.a('function');
+ timeoutCount++;
+ });
+
+ queue.push(function(task) {
+ executedTaskCount++;
+ task.done().should.be.true;
+ }).should.be.true;
+
+ queue.push(function(task) {
+ //sleep to make a timeout
+ setTimeout(function() {
+ executedTaskCount++;
+ task.done().should.be.false;
+ }, timeout + 1000);
+ }, null, timeout).should.be.true;
+
+ setTimeout(function() {
+ //wait all task finish
+ executedTaskCount.should.be.equal(2);
+ timeoutCount.should.be.equal(1);
+ done();
+ }, 4000);
+ });
+
+ it('should never timeout after close forcefully', function(done) {
+ var queue = SeqQueue.createQueue(timeout);
+ var timeoutCount = 0;
+ //add timeout listener
+ queue.on('timeout', function(task) {
+ //should never enter here
+ timeoutCount++;
+ });
+
+ queue.push(function(task) {
+ //no task.done() invoke to cause a timeout
+ }).should.be.true;
+
+ queue.close(true);
+
+ setTimeout(function() {
+ //wait all task finish
+ timeoutCount.should.be.equal(0);
+ done();
+ }, timeout * 2);
+ });
+
+ it('should use the global timeout value by default', function(done) {
+ var globalTimeout = timeout + 100;
+ var queue = SeqQueue.createQueue(globalTimeout);
+ //add timeout listener
+ queue.on('timeout', function(task) {
+ (Date.now() - start).should.not.be.below(globalTimeout);
+ done();
+ });
+
+ queue.push(function(task) {
+ //no task.done() invoke to cause a timeout
+ }).should.be.true;
+ var start = Date.now();
+ });
+
+ it('should use the timeout value in #push if it was assigned', function(done) {
+ var localTimeout = timeout / 2;
+ var queue = SeqQueue.createQueue(timeout);
+ //add timeout listener
+ queue.on('timeout', function(task) {
+ var diff = Date.now() - start;
+ diff.should.not.be.below(localTimeout);
+ diff.should.not.be.above(timeout);
+ done();
+ });
+
+ queue.push(function(task) {
+ //no task.done() invoke to cause a timeout
+ }, null, localTimeout).should.be.true;
+ var start = Date.now();
+ });
+ });
+
+ describe('#error', function() {
+ it('should emit an error event and invoke next task when a task throws an event', function(done) {
+ var queue = SeqQueue.createQueue();
+ var errorCount = 0;
+ var taskCount = 0;
+ //add timeout listener
+ queue.on('error', function(err, task) {
+ errorCount++;
+ should.exist(err);
+ should.exist(task);
+ });
+
+ queue.push(function(task) {
+ taskCount++;
+ throw new Error('some error');
+ }).should.be.true;
+
+ queue.push(function(task) {
+ taskCount++;
+ task.done();
+ });
+
+ setTimeout(function() {
+ taskCount.should.equal(2);
+ errorCount.should.equal(1);
+ done();
+ }, 500);
+ });
+
+ it('should be ok when task throw a error after done was invoked', function(done) {
+ var queue = SeqQueue.createQueue();
+ var errorCount = 0;
+ var taskCount = 0;
+ //add timeout listener
+ queue.on('error', function(err, task) {
+ errorCount++;
+ should.exist(err);
+ should.exist(task);
+ });
+
+ queue.push(function(task) {
+ taskCount++;
+ task.done();
+ throw new Error('some error');
+ }).should.be.true;
+
+ queue.push(function(task) {
+ taskCount++;
+ task.done();
+ });
+
+ setTimeout(function() {
+ taskCount.should.equal(2);
+ errorCount.should.equal(1);
+ done();
+ }, 500);
+ });
+ });
+}); \ No newline at end of file
generated by cgit v1.2.3 (git 2.25.1) at 2025-01-21 11:02:18 +0000