Server : Apache/2.4.6 (CentOS) OpenSSL/1.0.2k-fips PHP/7.4.20 System : Linux st2.domain.com 3.10.0-1127.10.1.el7.x86_64 #1 SMP Wed Jun 3 14:28:03 UTC 2020 x86_64 User : apache ( 48) PHP Version : 7.4.20 Disable Function : NONE Directory : /lib/node_modules/forever/node_modules/broadway/test/helpers/ |
/*
* macros.js: Test macros for using broadway and vows
*
* (C) 2011, Nodejitsu Inc.
* MIT LICENSE
*
*/
var events = require('eventemitter2'),
assert = require('./assert'),
helpers = require('./helpers'),
broadway = require('../../lib/broadway');
var macros = exports;
macros.shouldExtend = function (app, plugin, vows) {
if (arguments.length === 1) {
plugin = app;
app = vows = null;
}
else if (arguments.length === 2) {
app = helpers.mockApp();
vows = plugin;
plugin = app;
}
var context = {
topic: function () {
app = app || helpers.mockApp();
broadway.plugins[plugin].attach.call(app, app.options[plugin] || {});
if (broadway.plugins[plugin].init) {
return broadway.plugins[plugin].init.call(app, this.callback.bind(this, null, app));
}
this.callback(null, app);
},
"should add the appropriate properties and methods": function (_, app) {
assert.plugins.has[plugin](app);
}
}
return extendContext(context, vows);
};
macros.shouldLogEvent = function (app, event, vow) {
return {
topic: function () {
app = app || helpers.findApp.apply(null, arguments);
var logger = app.log.get('default');
this.event = event;
app.once('broadway::logged', this.callback.bind(this, null));
app.emit.apply(app, event);
},
"should log the appropriate info": vow
};
};
function extendContext (context, vows) {
if (vows) {
if (vows.topic) {
console.log('Cannot include topic at top-level of nested vows:');
console.dir(vows, 'vows');
process.exit(1);
}
Object.keys(vows).forEach(function (key) {
context[key] = vows[key];
});
}
return context;
}