-
Notifications
You must be signed in to change notification settings - Fork 2.6k
/
Utility.js
70 lines (62 loc) · 1.86 KB
/
Utility.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
var Stringify = require('json-stringify-safe');
var fs = require('fs');
var path = require('path');
var cst = require('../constants.js');
var async = require('async');
var Utility = module.exports = {
getDate : function() {
return Math.round(Date.now() / 1000);
},
serialize : function(data) {
return JSON.parse(Stringify(data));
},
startLogging : function(stds, callback) {
/**
* Start log outgoing messages
* @method startLogging
* @param {} callback
* @return
*/
// Make sure directories of `logs` and `pids` exist.
try {
['logs', 'pids'].forEach(function(n){
(function(_path){
!fs.existsSync(_path) && fs.mkdirSync(_path, '0755');
})(path.resolve(cst.PM2_ROOT_PATH, n));
});
}catch(err){
return callback(new Error('can not create directories (logs/pids):' + err.message));
}
// waterfall.
var flows = [];
// types of stdio, should be sorted as `std(entire log)`, `out`, `err`.
var types = Object.keys(stds).sort(function(x, y){
return -x.charCodeAt(0) + y.charCodeAt(0);
});
// Create write streams.
(function createWS(io){
if(io.length != 1){
return false;
}
io = io[0];
// If `std` is a Stream type, try next `std`.
// compatible with `pm2 reloadLogs`
if(typeof stds[io] == 'object' && !isNaN(stds[io].fd)){
return createWS(types.splice(0, 1));
}
flows.push(function(next){
var file = stds[io];
stds[io] = fs.createWriteStream(file, {flags: 'a'})
.on('error', function(err){
next(err);
})
.on('open', function(){
next();
});
stds[io]._file = file;
});
return createWS(types.splice(0, 1));
})(types.splice(0, 1));
async.waterfall(flows, callback);
}
};