| Server IP : 82.148.16.210 / Your IP : 216.73.217.54 Web Server : nginx/1.29.5 System : Linux mail.sarafai.ru 6.1.0-43-amd64 #1 SMP PREEMPT_DYNAMIC Debian 6.1.162-1 (2026-02-08) x86_64 User : www-data ( 33) PHP Version : 7.4.33 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, MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : OFF Directory : /srv/projects/env4/src/dev/frontend3/node_modules/table/node_modules/bottleneck/test/ |
Upload File : |
var States = require('../lib/States')
var assert = require('assert')
var c = require('./context')({datastore: 'local'})
var Bottleneck = require('./bottleneck')
describe('States', function () {
it('Should be created and be empty', function () {
var states = new States(["A", "B", "C"])
c.mustEqual(states.statusCounts(), { A: 0, B: 0, C: 0 })
})
it('Should start new series', function () {
var states = new States(["A", "B", "C"])
states.start('x')
states.start('y')
c.mustEqual(states.statusCounts(), { A: 2, B: 0, C: 0 })
})
it('Should increment', function () {
var states = new States(["A", "B", "C"])
states.start('x')
states.start('y')
states.next('x')
states.next('y')
states.next('x')
c.mustEqual(states.statusCounts(), { A: 0, B: 1, C: 1 })
states.next('z')
c.mustEqual(states.statusCounts(), { A: 0, B: 1, C: 1 })
states.next('x')
c.mustEqual(states.statusCounts(), { A: 0, B: 1, C: 0 })
states.next('x')
c.mustEqual(states.statusCounts(), { A: 0, B: 1, C: 0 })
states.next('y')
states.next('y')
c.mustEqual(states.statusCounts(), { A: 0, B: 0, C: 0 })
})
it('Should remove', function () {
var states = new States(["A", "B", "C"])
states.start('x')
states.start('y')
states.next('x')
states.next('y')
states.next('x')
c.mustEqual(states.statusCounts(), { A: 0, B: 1, C: 1 })
states.remove('x')
c.mustEqual(states.statusCounts(), { A: 0, B: 1, C: 0 })
states.remove('y')
c.mustEqual(states.statusCounts(), { A: 0, B: 0, C: 0 })
})
it('Should return current status', function () {
var states = new States(["A", "B", "C"])
states.start('x')
states.start('y')
states.next('x')
states.next('y')
states.next('x')
c.mustEqual(states.statusCounts(), { A: 0, B: 1, C: 1 })
c.mustEqual(states.jobStatus('x'), 'C')
c.mustEqual(states.jobStatus('y'), 'B')
c.mustEqual(states.jobStatus('z'), null)
})
it('Should return job ids for a status', function (done) {
var states = new States(["A", "B", "C"])
states.start('x')
states.start('y')
states.start('z')
states.next('x')
states.next('y')
states.next('x')
states.next('z')
c.mustEqual(states.statusCounts(), { A: 0, B: 2, C: 1 })
c.mustEqual(states.statusJobs().sort(), ['x', 'y', 'z'])
c.mustEqual(states.statusJobs('A'), [])
c.mustEqual(states.statusJobs('B').sort(), ['y', 'z'])
c.mustEqual(states.statusJobs('C'), ['x'])
try {
states.statusJobs('Z')
} catch (err) {
if (process.env.BUILD !== 'es5' && process.env.BUILD !== 'light') {
assert(err instanceof Bottleneck.BottleneckError)
}
done()
}
})
})