index.js

//
// Imports
//

const Client = require('./lib');
const plugins = require('./plugins');


//
// Plugins
//

const Plugins = {
    gracefulShutdown: plugins.GracefulShutdown,
    connectionRetry: plugins.ConnectionRetry,
    duplex: plugins.Duplex,
    dlx: plugins.DLX,
    encoding: plugins.Encoding,
    rpc: plugins.RPC,
    confirm: plugins.Confirm,
    retry: plugins.Retry
};

const resolvePlugins = (plugins) => plugins
    .filter(Boolean)
    .map((plugin) => {
        if (typeof plugin === 'string') {
            return new Plugins[plugin]();
        } else return plugin;
    });


//
// Exports
//

module.exports.connect = (url, options) => Client.start(url, {
    logger: console,
    plugins: resolvePlugins([
        'gracefulShutdown',
        'connectionRetry',
        'duplex',
        'encoding',
        'rpc',
        'confirm',
        'retry'
    ]),
    ...options
});

module.exports.Client = function(url, { plugins = [], ...options } = {}) {
    return Client(url, { plugins: resolvePlugins(plugins), ...options });
};

module.exports.Client.start = function(url, { plugins = [], ...options } = {}) {
    return Client.start(url, { plugins: resolvePlugins(plugins), ...options });
};

module.exports.constants = require('./lib/constants');
module.exports.errors = require('./lib/errors');
module.exports.plugins = plugins;