Search MCP Server

'use strict' const { test } = require('tap') const boot = require('..') const message = (name) => `Plugin did not start in time: '${name}'. You may have forgotten to call 'done' function or to resolve a Promise` test('timeout without calling next - callbacks', (t) => { t.plan(4) const app = boot({}, { timeout: 10 // 10 ms }) app.use(one) function one (app, opts, next) { // do not call next on purpose } app.ready((err) => { t.ok(err) t.equal(err.fn, one) t.equal(err.message, message('one')) t.equal(err.code, 'AVV_ERR_PLUGIN_EXEC_TIMEOUT') }) }) test('timeout without calling next - promises', (t) => { t.plan(4) const app = boot({}, { timeout: 10 // 10 ms }) app.use(two) function two (app, opts) { return new Promise(function (resolve) { // do not call resolve on purpose }) } app.ready((err) => { t.ok(err) t.equal(err.fn, two) t.equal(err.message, message('two')) t.equal(err.code, 'AVV_ERR_PLUGIN_EXEC_TIMEOUT') }) }) test('timeout without calling next - use file as name', (t) => { t.plan(3) const app = boot({}, { timeout: 10 // 10 ms }) app.use(require('./fixtures/plugin-no-next')) app.ready((err) => { t.ok(err) t.equal(err.message, message('noNext')) t.equal(err.code, 'AVV_ERR_PLUGIN_EXEC_TIMEOUT') }) }) test('timeout without calling next - use code as name', (t) => { t.plan(3) const app = boot({}, { timeout: 10 // 10 ms }) app.use(function (app, opts, next) { // do not call next on purpose - code as name }) app.ready((err) => { t.ok(err) t.equal(err.message, message('function (app, opts, next) { -- // do not call next on purpose - code as name')) t.equal(err.code, 'AVV_ERR_PLUGIN_EXEC_TIMEOUT') }) }) test('does not keep going', (t) => { t.plan(2) const app = boot({}, { timeout: 10 // 10 ms }) app.use(function three (app, opts, next) { next(new Error('kaboom')) }) app.ready((err) => { t.ok(err) t.equal(err.message, 'kaboom') }) }) test('throw in override without autostart', (t) => { t.plan(2) const server = { my: 'server' } const app = boot(server, { timeout: 10, autostart: false }) app.override = function (s) { throw new Error('kaboom') } app.use(function (s, opts, cb) { t.fail('this is never reached') }) setTimeout(function () { app.ready((err) => { t.ok(err) t.equal(err.message, 'kaboom') }) }, 20) }) test('timeout without calling next in ready and ignoring the error', (t) => { t.plan(11) const app = boot({}, { timeout: 10, // 10 ms autostart: false }) let preReady = false app.use(function one (app, opts, next) { t.pass('loaded') app.ready(function readyOk (err, done) { t.notOk(err) t.pass('first ready called') done() }) next() }) app.on('preReady', () => { t.pass('preReady should be called') preReady = true }) app.on('start', () => { t.pass('start should be called') }) app.ready(function onReadyWithoutDone (err, done) { t.pass('wrong ready called') t.ok(preReady, 'preReady already called') t.notOk(err) // done() // Don't call done }) app.ready(function onReadyTwo (err) { t.ok(err) t.equal(err.message, message('onReadyWithoutDone')) t.equal(err.code, 'AVV_ERR_READY_TIMEOUT') // don't rethrow the error }) app.start() }) test('timeout without calling next in ready and rethrowing the error', (t) => { t.plan(11) const app = boot({}, { timeout: 10, // 10 ms autostart: true }) app.use(function one (app, opts, next) { t.pass('loaded') app.ready(function readyOk (err, done) { t.ok(err) t.equal(err.message, message('onReadyWithoutDone')) t.equal(err.code, 'AVV_ERR_READY_TIMEOUT') done(err) }) next() }) app.on('preReady', () => { t.pass('preReady should be called') }) app.on('start', () => { t.pass('start should be called in any case') }) app.ready(function onReadyWithoutDone (err, done) { t.pass('wrong ready called') t.notOk(err) // done() // Don't call done }) app.ready(function onReadyTwo (err, done) { t.ok(err) t.equal(err.message, message('onReadyWithoutDone')) t.equal(err.code, 'AVV_ERR_READY_TIMEOUT') done(err) }) app.start() }) test('nested timeout do not crash - await', (t) => { t.plan(4) const app = boot({}, { timeout: 10 // 10 ms }) app.use(one) async function one (app, opts) { await app.use(two) } function two (app, opts, next) { // do not call next on purpose } app.ready((err) => { t.ok(err) t.equal(err.fn, two) t.equal(err.message, message('two')) t.equal(err.code, 'AVV_ERR_PLUGIN_EXEC_TIMEOUT') }) })