(function() { 'use strict'; var DIR = __dirname + '/', DIR_ROOT = DIR + '../', DIR_SERVER = DIR + 'server/', Util = require(DIR + 'util'), cloudfunc = require(DIR + 'cloudfunc'), auth = require(DIR_SERVER + 'auth'), config = require(DIR_SERVER + 'config'), rest = require(DIR_SERVER + 'rest'), route = require(DIR_SERVER + 'route'), validate = require(DIR_SERVER + 'validate'), createPass = require(DIR_SERVER + 'password'), join = require('join-io'), ponse = require('ponse'), mollify = require('mollify'), restafary = require('restafary'), webconsole = require('console-io'), edward = require('edward'), dword = require('dword'), spero = require('spero'), remedy = require('remedy'), ishtar = require('ishtar'), root = function() { return config('root'); }, emptyFunc = function(req, res, next) { next(); }; emptyFunc.middle = function() { return emptyFunc; }; function getPrefix(prefix) { var result; if (typeof prefix === 'function') result = prefix(); else result = prefix; return result || ''; } module.exports = function(params) { var prefix, p = params || {}, options = p.config || {}, keys = Object.keys(options); keys.forEach(function(name) { var value = options[name]; switch(name) { case 'root': validate.root(value); break; case 'editor': validate.editor(value); break; case 'password': value = createPass(config('algo'), value); break; case 'prefix': if (!~value.indexOf('/')) value = '/' + value; prefix = value; break; } config(name, value); }); if (p.socket) listen(p.socket); return cloudcmd(prefix, p.socket); }; function listen(socket) { var size = cloudfunc.MAX_SIZE; Util.check(arguments, ['socket']); webconsole({ socket: socket }); edward.listen(socket, { size: size, root: root }); dword.listen(socket, { size: size, root: root }); spero.listen(socket, { root: root }); remedy.listen(socket, { root: root }); ishtar.listen(socket, { root: root }); } function cloudcmd(prefix, socket) { var isOption = function(name) { return config(name); }, isMinify = isOption.bind(null, 'minify'), isOnline = isOption.bind(null, 'online'), isCache = isOption.bind(null, 'cache'), isDiff = isOption.bind(null, 'diff'), isZip = isOption.bind(null, 'zip'), ponseStatic = ponse.static(DIR_ROOT, { cache: isCache }), funcs = [ logout, setUrl(prefix), auth(), config.middle({ socket: socket, }), restafary({ prefix : cloudfunc.apiURL + '/fs', root : root }), rest, route({ prefix: prefix }), join({ dir : DIR_ROOT, minify : isMinify }), webconsole.middle({ minify: isMinify, online: isOnline }), edward({ minify : isMinify, online : isOnline, diff : isDiff, zip : isZip }), dword({ minify : isMinify, online : isOnline, diff : isDiff, zip : isZip }), spero({ minify: isMinify, online: isOnline }), remedy({ minify: isMinify, online: isOnline }), ishtar({ minify: isMinify, online: isOnline }), mollify({ dir : DIR_ROOT, is : isMinify }), ponseStatic ]; return funcs; } function logout(req, res, next) { if (req.url === '/logout') res.sendStatus(401); else next(); } function setUrl(pref) { return function(req, res, next) { var is, prefix; prefix = getPrefix(pref); is = !req.url.indexOf(prefix); if (is) { req.url = req.url.replace(prefix, '') || '/'; if (req.url === '/cloudcmd.js') req.url = '/lib/client/cloudcmd.js'; } next(); }; } })();