Clean up code a bit

This commit is contained in:
Bryan Ashby 2018-07-15 11:50:04 -06:00
parent 340c6ccf76
commit 7b75f08c7e

View file

@ -2,16 +2,17 @@
'use strict'; 'use strict';
// ENiGMA½ // ENiGMA½
var moduleUtil = require('./module_util.js'); const moduleUtil = require('./module_util.js');
var Log = require('./logger.js').log; const Log = require('./logger.js').log;
var Config = require('./config.js').get; const Config = require('./config.js').get;
var asset = require('./asset.js'); const asset = require('./asset.js');
var MCIViewFactory = require('./mci_view_factory.js').MCIViewFactory; const { MCIViewFactory } = require('./mci_view_factory.js');
const { Errors } = require('./enig_error.js');
var paths = require('path'); // deps
var async = require('async'); const paths = require('path');
var assert = require('assert'); const async = require('async');
var _ = require('lodash'); const _ = require('lodash');
exports.loadMenu = loadMenu; exports.loadMenu = loadMenu;
exports.getFormConfigByIDAndMap = getFormConfigByIDAndMap; exports.getFormConfigByIDAndMap = getFormConfigByIDAndMap;
@ -19,41 +20,37 @@ exports.handleAction = handleAction;
exports.handleNext = handleNext; exports.handleNext = handleNext;
function getMenuConfig(client, name, cb) { function getMenuConfig(client, name, cb) {
var menuConfig;
async.waterfall( async.waterfall(
[ [
function locateMenuConfig(callback) { function locateMenuConfig(callback) {
if(_.has(client.currentTheme, [ 'menus', name ])) { if(_.has(client.currentTheme, [ 'menus', name ])) {
menuConfig = client.currentTheme.menus[name]; const menuConfig = client.currentTheme.menus[name];
callback(null); return callback(null, menuConfig);
} else {
callback(new Error('No menu entry for \'' + name + '\''));
} }
return callback(Errors.DoesNotExist(`No menu entry for "${name}"`));
}, },
function locatePromptConfig(callback) { function locatePromptConfig(menuConfig, callback) {
if(_.isString(menuConfig.prompt)) { if(_.isString(menuConfig.prompt)) {
if(_.has(client.currentTheme, [ 'prompts', menuConfig.prompt ])) { if(_.has(client.currentTheme, [ 'prompts', menuConfig.prompt ])) {
menuConfig.promptConfig = client.currentTheme.prompts[menuConfig.prompt]; menuConfig.promptConfig = client.currentTheme.prompts[menuConfig.prompt];
callback(null); return callback(null, menuConfig);
} else {
callback(new Error('No prompt entry for \'' + menuConfig.prompt + '\''));
} }
} else { return callback(Error.DoesNotExist(`No prompt entry for "${menuConfig.prompt}"`));
callback(null);
} }
return callback(null, menuConfig);
} }
], ],
function complete(err) { (err, menuConfig) => {
cb(err, menuConfig); return cb(err, menuConfig);
} }
); );
} }
// :TODO: name/client should not be part of options - they are required always
function loadMenu(options, cb) { function loadMenu(options, cb) {
assert(_.isObject(options)); if(!_.isString(options.name) || !_.isObject(options.client)) {
assert(_.isString(options.name)); return cb(Errors.MissingParam('Missing required options'));
assert(_.isObject(options.client)); }
async.waterfall( async.waterfall(
[ [
@ -117,16 +114,12 @@ function loadMenu(options, cb) {
} }
function getFormConfigByIDAndMap(menuConfig, formId, mciMap, cb) { function getFormConfigByIDAndMap(menuConfig, formId, mciMap, cb) {
assert(_.isObject(menuConfig));
if(!_.isObject(menuConfig.form)) { if(!_.isObject(menuConfig.form)) {
cb(new Error('Invalid or missing \'form\' member for menu')); return cb(Errors.MissingParam('Invalid or missing "form" member for menu'));
return;
} }
if(!_.isObject(menuConfig.form[formId])) { if(!_.isObject(menuConfig.form[formId])) {
cb(new Error('No form found for formId ' + formId)); return cb(Errors.DoesNotExist(`No form found for formId ${formId}`));
return;
} }
const formForId = menuConfig.form[formId]; const formForId = menuConfig.form[formId];
@ -141,8 +134,7 @@ function getFormConfigByIDAndMap(menuConfig, formId, mciMap, cb) {
// //
if(_.isObject(formForId[mciReqKey])) { if(_.isObject(formForId[mciReqKey])) {
Log.trace( { mciKey : mciReqKey }, 'Using exact configuration key match'); Log.trace( { mciKey : mciReqKey }, 'Using exact configuration key match');
cb(null, formForId[mciReqKey]); return cb(null, formForId[mciReqKey]);
return;
} }
// //
@ -153,7 +145,7 @@ function getFormConfigByIDAndMap(menuConfig, formId, mciMap, cb) {
return cb(null, formForId); return cb(null, formForId);
} }
cb(new Error('No matching form configuration found for key \'' + mciReqKey + '\'')); return cb(Errors.DoesNotExist(`No matching form configuration found for key "${mciReqKey}"`));
} }
// :TODO: Most of this should be moved elsewhere .... DRY... // :TODO: Most of this should be moved elsewhere .... DRY...
@ -176,11 +168,14 @@ function callModuleMenuMethod(client, asset, path, formData, extraArgs, cb) {
} }
function handleAction(client, formData, conf, cb) { function handleAction(client, formData, conf, cb) {
assert(_.isObject(conf)); if(!_.isObject(conf)) {
assert(_.isString(conf.action)); return cb(Errors.MissingParam('Missing config'));
}
const actionAsset = asset.parseAsset(conf.action); const actionAsset = asset.parseAsset(conf.action);
assert(_.isObject(actionAsset)); if(!_.isObject(actionAsset)) {
return cb(Errors.Invalid('Unable to parse "conf.action"'));
}
switch(actionAsset.type) { switch(actionAsset.type) {
case 'method' : case 'method' :
@ -210,7 +205,7 @@ function handleAction(client, formData, conf, cb) {
return currentModule.menuMethods[actionAsset.asset](formData, conf.extraArgs, cb); return currentModule.menuMethods[actionAsset.asset](formData, conf.extraArgs, cb);
} }
const err = new Error('Method does not exist'); const err = Errors.DoesNotExist('Method does not exist');
client.log.warn( { method : actionAsset.asset }, err.message); client.log.warn( { method : actionAsset.asset }, err.message);
return cb(err); return cb(err);
} }
@ -246,7 +241,7 @@ function handleNext(client, nextSpec, conf, cb) {
return currentModule.menuMethods[nextAsset.asset]( formData, extraArgs, cb ); return currentModule.menuMethods[nextAsset.asset]( formData, extraArgs, cb );
} }
const err = new Error('Method does not exist'); const err = Errors.DoesNotExist('Method does not exist');
client.log.warn( { method : nextAsset.asset }, err.message); client.log.warn( { method : nextAsset.asset }, err.message);
return cb(err); return cb(err);
} }
@ -255,7 +250,7 @@ function handleNext(client, nextSpec, conf, cb) {
return client.currentMenuModule.gotoMenu(nextAsset.asset, { extraArgs : extraArgs }, cb ); return client.currentMenuModule.gotoMenu(nextAsset.asset, { extraArgs : extraArgs }, cb );
} }
const err = new Error('Invalid asset type for "next"'); const err = Errors.Invalid('Invalid asset type for "next"');
client.log.error( { nextSpec : nextSpec }, err.message); client.log.error( { nextSpec : nextSpec }, err.message);
return cb(err); return cb(err);
} }