SIGN IN SIGN UP
Unitech / pm2 UNCLAIMED

Node.js Production Process Manager with a built-in Load Balancer.

43014 0 44 JavaScript
2016-03-22 23:33:43 +01:00
/**
2022-01-19 11:41:33 +01:00
* Copyright 2013-2022 the PM2 project authors. All rights reserved.
2016-03-22 23:33:43 +01:00
* Use of this source code is governed by a license that
* can be found in the LICENSE file.
*/
var path = require('path');
var eachLimit = require('async/eachLimit');
var forEachLimit = require('async/forEachLimit');
2018-09-25 20:50:59 +02:00
2016-06-08 19:21:37 +02:00
var Configuration = require('../../Configuration.js');
2018-09-25 20:50:59 +02:00
var cst = require('../../../constants.js');
var Common = require('../../Common');
var NPM = require('./NPM.js')
var TAR = require('./TAR.js')
2018-09-25 20:50:59 +02:00
var LOCAL = require('./LOCAL.js')
2018-07-24 15:26:17 +03:00
2016-06-04 14:04:26 +02:00
var Modularizer = module.exports = {};
2017-12-04 01:47:44 +01:00
/**
* PM2 Module System.
*/
2018-09-25 20:50:59 +02:00
Modularizer.install = function (CLI, module_name, opts, cb) {
module_name = module_name.replace(/[;`|]/g, "");
if (typeof(opts) == 'function') {
cb = opts;
opts = {};
}
2018-09-25 20:50:59 +02:00
if (LOCAL.INTERNAL_MODULES.hasOwnProperty(module_name)) {
Common.logMod(`Adding dependency ${module_name} to PM2 Runtime`);
2018-09-25 20:50:59 +02:00
var currentModule = LOCAL.INTERNAL_MODULES[module_name];
if (currentModule && currentModule.hasOwnProperty('dependencies')) {
LOCAL.installMultipleModules(currentModule.dependencies, cb);
} else {
LOCAL.install(currentModule, cb);
}
2015-02-08 14:06:38 -05:00
}
2018-09-25 20:50:59 +02:00
else if (module_name == '.') {
Common.logMod(`Installing local NPM module`);
2018-09-25 20:50:59 +02:00
return NPM.localStart(CLI, opts, cb)
}
else if (opts.tarball || /\.tar\.gz$/i.test(module_name)) {
Common.logMod(`Installing TAR module`);
TAR.install(CLI, module_name, opts, cb)
}
else {
Common.logMod(`Installing NPM ${module_name} module`);
NPM.install(CLI, module_name, opts, cb)
2015-02-10 18:22:08 -05:00
}
2018-09-25 20:50:59 +02:00
};
2015-02-07 22:37:38 -05:00
/**
* Launch All Modules
* Used PM2 at startup
*/
Modularizer.launchModules = function(CLI, cb) {
var modules = Modularizer.listModules();
if (!modules) return cb();
2018-09-25 20:50:59 +02:00
// 1#
function launchNPMModules(cb) {
if (!modules.npm_modules) return launchTARModules(cb)
eachLimit(Object.keys(modules.npm_modules), 1, function(module_name, next) {
2018-09-25 20:50:59 +02:00
NPM.start(CLI, modules, module_name, next)
}, function() {
launchTARModules(cb)
});
}
2018-09-25 20:50:59 +02:00
// 2#
function launchTARModules(cb) {
if (!modules.tar_modules) return cb()
eachLimit(Object.keys(modules.tar_modules), 1, function(module_name, next) {
2018-09-25 00:07:45 +02:00
TAR.start(CLI, module_name, next)
}, function() {
return cb ? cb(null) : false;
});
}
2017-12-04 01:47:44 +01:00
launchNPMModules(cb)
}
2017-12-04 01:47:44 +01:00
Modularizer.package = function(CLI, module_path, cb) {
var fullpath = process.cwd()
if (module_path)
fullpath = require('path').resolve(module_path)
TAR.package(fullpath, process.cwd(), cb)
}
/**
* Uninstall module
*/
2016-06-08 19:21:37 +02:00
Modularizer.uninstall = function(CLI, module_name, cb) {
Common.printOut(cst.PREFIX_MSG_MOD + 'Uninstalling module ' + module_name);
2018-09-25 20:50:59 +02:00
var modules_list = Modularizer.listModules();
2015-09-11 14:20:50 +02:00
if (module_name == 'all') {
2018-09-25 20:50:59 +02:00
if (!modules_list) return cb();
2018-09-25 20:50:59 +02:00
return forEachLimit(Object.keys(modules_list.npm_modules), 1, function(module_name, next) {
NPM.uninstall(CLI, module_name, next)
}, () => {
2018-09-25 20:50:59 +02:00
forEachLimit(Object.keys(modules_list.tar_modules), 1, function(module_name, next) {
TAR.uninstall(CLI, module_name, next)
}, cb)
});
2015-09-11 14:20:50 +02:00
}
2018-09-25 20:50:59 +02:00
if (modules_list.npm_modules[module_name]) {
NPM.uninstall(CLI, module_name, cb)
2018-09-25 20:50:59 +02:00
} else if (modules_list.tar_modules[module_name]) {
TAR.uninstall(CLI, module_name, cb)
}
else {
Common.errMod('Unknown module')
CLI.exitCli(1)
}
2018-09-25 20:50:59 +02:00
};
2017-12-04 01:47:44 +01:00
/**
* List modules based on modules present in ~/.pm2/modules/ folder
*/
Modularizer.listModules = function() {
return {
npm_modules: Configuration.getSync(cst.MODULE_CONF_PREFIX) || {},
tar_modules: Configuration.getSync(cst.MODULE_CONF_PREFIX_TAR) || {}
}
2017-12-04 01:47:44 +01:00
};
Modularizer.getAdditionalConf = function(app_name) {
2018-09-25 20:50:59 +02:00
return NPM.getModuleConf(app_name)
};
Modularizer.publish = function(PM2, folder, opts, cb) {
if (opts.npm == true) {
NPM.publish(opts, cb)
}
else {
TAR.publish(PM2, folder, cb)
}
2015-02-09 17:23:54 -05:00
};
Modularizer.generateSample = function(app_name, cb) {
2018-09-25 20:50:59 +02:00
NPM.generateSample(app_name, cb)
2015-02-07 22:37:38 -05:00
};