| Server IP : 82.148.16.210 / Your IP : 216.73.217.15 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 makeTest = require('./context')
var Bottleneck = require('./bottleneck')
var assert = require('assert')
var Redis = require('redis')
if (process.env.DATASTORE === 'redis') {
describe('node_redis-only', function () {
var c
afterEach(function () {
return c.limiter.disconnect(false)
})
it('Should accept node_redis lib override', function () {
c = makeTest({
maxConcurrent: 2,
Redis,
clientOptions: {}
})
c.mustEqual(c.limiter.datastore, 'redis')
})
it('Should accept existing connections', function () {
var connection = new Bottleneck.RedisConnection()
connection.id = 'super-connection'
c = makeTest({
minTime: 50,
connection
})
c.pNoErrVal(c.limiter.schedule(c.promise, null, 1), 1)
c.pNoErrVal(c.limiter.schedule(c.promise, null, 2), 2)
return c.last()
.then(function (results) {
c.checkResultsOrder([[1], [2]])
c.checkDuration(50)
c.mustEqual(c.limiter.connection.id, 'super-connection')
c.mustEqual(c.limiter.datastore, 'redis')
return c.limiter.disconnect()
})
.then(function () {
// Shared connections should not be disconnected by the limiter
c.mustEqual(c.limiter.clients().client.ready, true)
return connection.disconnect()
})
})
it('Should accept existing redis clients', function () {
var client = Redis.createClient()
client.id = 'super-client'
var connection = new Bottleneck.RedisConnection({ client })
connection.id = 'super-connection'
c = makeTest({
minTime: 50,
connection
})
c.pNoErrVal(c.limiter.schedule(c.promise, null, 1), 1)
c.pNoErrVal(c.limiter.schedule(c.promise, null, 2), 2)
return c.last()
.then(function (results) {
c.checkResultsOrder([[1], [2]])
c.checkDuration(50)
c.mustEqual(c.limiter.clients().client.id, 'super-client')
c.mustEqual(c.limiter.connection.id, 'super-connection')
c.mustEqual(c.limiter.datastore, 'redis')
return c.limiter.disconnect()
})
.then(function () {
// Shared connections should not be disconnected by the limiter
c.mustEqual(c.limiter.clients().client.ready, true)
return connection.disconnect()
})
})
it('Should trigger error events on the shared connection', function (done) {
var connection = new Bottleneck.RedisConnection({
clientOptions: {
port: 1
}
})
connection.on('error', function (err) {
c.mustEqual(c.limiter.datastore, 'redis')
connection.disconnect()
done()
})
c = makeTest({ connection })
c.limiter.on('error', function (err) {
done(err)
})
})
})
}