MORPH
SIGN IN SIGN UP
Unitech / pm2 UNCLAIMED

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

0 0 16 JavaScript
Normal View History Raw
add Copyright header to each file
2016-03-22 23:33:43 +01:00
/**
v7 refactor
2026-02-08 15:04:58 +01:00
* Copyright 2013-present the PM2 project authors. All rights reserved.
add Copyright header to each file
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.
*/
configuration system
2015-02-09 16:01:23 -05:00
var Configuration = module.exports = {};
var fs = require('fs');
var Common = require('./Common');
refactor: only import the necessary methods from async.
2018-07-19 09:44:06 -04:00
var eachSeries = require('async/eachSeries');
configuration system
2015-02-09 16:01:23 -05:00
var cst = require('../constants.js');
omit what is inside double quotes for configuration system
2015-09-18 17:31:50 +02:00
function splitKey(key) {
pm2 multiset
2015-09-26 14:08:44 +02:00
var values = [key];
omit what is inside double quotes for configuration system
2015-09-18 17:31:50 +02:00
if (key.indexOf('.') > -1)
values = key.match(/(?:[^."]+|"[^"]*")+/g).map(function(dt) { return dt.replace(/"/g, '') });
else if (key.indexOf(':') > -1)
values = key.match(/(?:[^:"]+|"[^"]*")+/g).map(function(dt) { return dt.replace(/"/g, '') });
return values;
}
always flush pm2 configuration in pretty format
2019-06-10 23:36:09 +02:00
function serializeConfiguration(json_conf) {
return JSON.stringify(json_conf, null, 4)
}
npm 3.x fix - #1674 #1692 #1675
2015-10-15 02:13:41 +02:00
Configuration.set = function(key, value, cb) {
fs.readFile(cst.PM2_MODULE_CONF_FILE, function(err, data) {
if (err) return cb(err);
var json_conf = JSON.parse(data);
var values = splitKey(key);
if (values.length > 0) {
var levels = values;
var tmp = json_conf;
levels.forEach(function(key, index) {
if (index == levels.length -1)
tmp[key] = value;
else if (!tmp[key]) {
tmp[key] = {};
tmp = tmp[key];
}
else {
if (typeof(tmp[key]) != 'object')
tmp[key] = {};
tmp = tmp[key];
}
});
}
else {
if (json_conf[key] && typeof(json_conf[key]) === 'string')
Common.printOut(cst.PREFIX_MSG + 'Replacing current value key %s by %s', key, value);
json_conf[key] = value;
}
always flush pm2 configuration in pretty format
2019-06-10 23:36:09 +02:00
fs.writeFile(cst.PM2_MODULE_CONF_FILE, serializeConfiguration(json_conf), function(err, data) {
npm 3.x fix - #1674 #1692 #1675
2015-10-15 02:13:41 +02:00
if (err) return cb(err);
return cb(null, json_conf);
});
return false;
});
};
configuration system
2015-02-09 16:01:23 -05:00
Configuration.unset = function(key, cb) {
fs.readFile(cst.PM2_MODULE_CONF_FILE, function(err, data) {
if (err) return cb(err);
better doc for modules - replace JSON5 by pure JSON for configuration - avoid copy an [Object] String when restoring previous environment (Common.extend)
2015-03-01 18:56:53 -05:00
var json_conf = JSON.parse(data);
configuration system
2015-02-09 16:01:23 -05:00
omit what is inside double quotes for configuration system
2015-09-18 17:31:50 +02:00
var values = splitKey(key);
PM2 scoped actions (+tests) + Password encryption methods(+tests) + Unset works(+tests) for config sys
2015-07-12 21:07:08 +02:00
if (values.length > 0) {
var levels = values;
var tmp = json_conf;
levels.forEach(function(key, index) {
if (index == levels.length -1)
delete tmp[key];
else if (!tmp[key]) {
tmp[key] = {};
tmp = tmp[key];
}
else {
if (typeof(tmp[key]) != 'object')
tmp[key] = {};
tmp = tmp[key];
}
});
}
else
delete json_conf[key];
if (err) return cb(err);
configuration system
2015-02-09 16:01:23 -05:00
if (key === 'all')
json_conf = {};
always flush pm2 configuration in pretty format
2019-06-10 23:36:09 +02:00
fs.writeFile(cst.PM2_MODULE_CONF_FILE, serializeConfiguration(json_conf), function(err, data) {
configuration system
2015-02-09 16:01:23 -05:00
if (err) return cb(err);
return cb(null, json_conf);
});
return false;
});
npm 3.x fix - #1674 #1692 #1675
2015-10-15 02:13:41 +02:00
}
2844 Flush default module configuration to pm2 config
2017-04-21 18:29:23 +02:00
Configuration.setSyncIfNotExist = function(key, value) {
try {
var conf = JSON.parse(fs.readFileSync(cst.PM2_MODULE_CONF_FILE));
} catch(e) {
return null;
}
var values = splitKey(key);
var exists = false;
if (values.length > 1 && conf && conf[values[0]]) {
exists = Object.keys(conf[values[0]]).some(function(key) {
if (key == values[1])
return true;
return false;
});
}
if (exists === false)
return Configuration.setSync(key, value);
return null;
};
npm 3.x fix - #1674 #1692 #1675
2015-10-15 02:13:41 +02:00
Configuration.setSync = function(key, value) {
try {
var data = fs.readFileSync(cst.PM2_MODULE_CONF_FILE);
} catch(e) {
return null;
}
var json_conf = JSON.parse(data);
var values = splitKey(key);
if (values.length > 0) {
var levels = values;
var tmp = json_conf;
levels.forEach(function(key, index) {
if (index == levels.length -1)
tmp[key] = value;
else if (!tmp[key]) {
tmp[key] = {};
tmp = tmp[key];
}
else {
if (typeof(tmp[key]) != 'object')
tmp[key] = {};
tmp = tmp[key];
}
});
}
else {
if (json_conf[key] && typeof(json_conf[key]) === 'string')
Common.printOut(cst.PREFIX_MSG + 'Replacing current value key %s by %s', key, value);
json_conf[key] = value;
}
if (key === 'all')
json_conf = {};
try {
always flush pm2 configuration in pretty format
2019-06-10 23:36:09 +02:00
fs.writeFileSync(cst.PM2_MODULE_CONF_FILE, serializeConfiguration(json_conf));
npm 3.x fix - #1674 #1692 #1675
2015-10-15 02:13:41 +02:00
return json_conf;
} catch(e) {
console.error(e.message);
return null;
}
};
Configuration.unsetSync = function(key) {
try {
var data = fs.readFileSync(cst.PM2_MODULE_CONF_FILE);
} catch(e) {
return null;
}
var json_conf = JSON.parse(data);
var values = splitKey(key);
if (values.length > 0) {
var levels = values;
var tmp = json_conf;
levels.forEach(function(key, index) {
if (index == levels.length -1)
delete tmp[key];
else if (!tmp[key]) {
tmp[key] = {};
tmp = tmp[key];
}
else {
if (typeof(tmp[key]) != 'object')
tmp[key] = {};
tmp = tmp[key];
}
});
}
else
delete json_conf[key];
if (key === 'all')
json_conf = {};
try {
always flush pm2 configuration in pretty format
2019-06-10 23:36:09 +02:00
fs.writeFileSync(cst.PM2_MODULE_CONF_FILE, serializeConfiguration(json_conf));
npm 3.x fix - #1674 #1692 #1675
2015-10-15 02:13:41 +02:00
} catch(e) {
console.error(e.message);
return null;
}
configuration system
2015-02-09 16:01:23 -05:00
};
pm2 multiset
2015-09-26 14:08:44 +02:00
Configuration.multiset = function(serial, cb) {
var arrays = [];
smarter split
2015-09-26 20:02:00 +02:00
serial = serial.match(/(?:[^ "]+|"[^"]*")+/g);
pm2 multiset
2015-09-26 14:08:44 +02:00
while (serial.length > 0)
arrays.push(serial.splice(0, 2));
refactor: only import the necessary methods from async.
2018-07-19 09:44:06 -04:00
eachSeries(arrays, function(el, next) {
pm2 multiset
2015-09-26 14:08:44 +02:00
Configuration.set(el[0], el[1], next);
}, cb);
};
Add pm2 conf module.option [value] alias for configuration
2015-04-19 17:21:26 -04:00
Configuration.get = function(key, cb) {
Configuration.getAll(function(err, data) {
omit what is inside double quotes for configuration system
2015-09-18 17:31:50 +02:00
var climb = splitKey(key);
Add pm2 conf module.option [value] alias for configuration
2015-04-19 17:21:26 -04:00
climb.some(function(val) {
if (!data[val]) {
data = null;
return true;
}
data = data[val];
return false;
});
Fix all misspellings of "unknown"
2015-11-17 13:11:53 +13:00
if (!data) return cb({err : 'Unknown key'}, null);
Add pm2 conf module.option [value] alias for configuration
2015-04-19 17:21:26 -04:00
return cb(null, data);
});
};
add getSync method to get config variables (+tests) + starting implementation of password checking
2015-07-12 21:31:18 +02:00
Configuration.getSync = function(key) {
try {
var data = Configuration.getAllSync();
} catch(e) {
return null;
}
omit what is inside double quotes for configuration system
2015-09-18 17:31:50 +02:00
var climb = splitKey(key);
add getSync method to get config variables (+tests) + starting implementation of password checking
2015-07-12 21:31:18 +02:00
climb.some(function(val) {
if (!data[val]) {
data = null;
return true;
}
data = data[val];
return false;
});
if (!data) return null;
return data;
};
configuration system
2015-02-09 16:01:23 -05:00
Configuration.getAll = function(cb) {
fs.readFile(cst.PM2_MODULE_CONF_FILE, function(err, data) {
if (err) return cb(err);
better doc for modules - replace JSON5 by pure JSON for configuration - avoid copy an [Object] String when restoring previous environment (Common.extend)
2015-03-01 18:56:53 -05:00
return cb(null, JSON.parse(data));
configuration system
2015-02-09 16:01:23 -05:00
});
};
Integrate configuration system with module system
2015-02-09 17:02:06 -05:00
Configuration.getAllSync = function() {
try {
better doc for modules - replace JSON5 by pure JSON for configuration - avoid copy an [Object] String when restoring previous environment (Common.extend)
2015-03-01 18:56:53 -05:00
return JSON.parse(fs.readFileSync(cst.PM2_MODULE_CONF_FILE));
Integrate configuration system with module system
2015-02-09 17:02:06 -05:00
} catch(e) {
console.error(e.stack || e);
return {};
}
};
Reference in New Issue Copy Permalink