UNPKG

3.1 kBJavaScriptView Raw
1/**
2 * Copyright Keymetrics Team. All rights reserved.
3 * Use of this source code is governed by a license that
4 * can be found in the LICENSE file.
5 */
6
7'use strict'
8
9const path = require('path')
10let PM2_HOME
11
12if (process.env.PM2_HOME) {
13 PM2_HOME = process.env.PM2_HOME
14} else if (process.env.HOME && !process.env.HOMEPATH) {
15 PM2_HOME = path.resolve(process.env.HOME, '.pm2')
16} else if (process.env.HOME || process.env.HOMEPATH) {
17 PM2_HOME = path.resolve(process.env.HOMEDRIVE, process.env.HOME || process.env.HOMEPATH, '.pm2')
18} else {
19 PM2_HOME = path.resolve('/etc', '.pm2')
20}
21
22const getUniqueId = () => {
23 var s = []
24 var hexDigits = '0123456789abcdef'
25 for (var i = 0; i < 36; i++) {
26 s[i] = hexDigits.substr(Math.floor(Math.random() * 0x10), 1)
27 }
28 s[14] = '4'
29 s[19] = hexDigits.substr((s[19] & 0x3) | 0x8, 1)
30 s[8] = s[13] = s[18] = s[23] = '-'
31 return s.join('')
32}
33
34/**
35 * Convert value to boolean but false if undefined
36 * @param {String} value
37 * @param {String} fallback default value
38 * @return {Boolean}
39 */
40const useIfDefined = (value, fallback) => {
41 if (typeof value === 'undefined') {
42 return fallback
43 } else {
44 return value === 'true'
45 }
46}
47
48let cst = {
49 DEBUG: process.env.PM2_DEBUG || false,
50 KEYMETRICS_ROOT_URL: process.env.KEYMETRICS_NODE || 'https://root.keymetrics.io',
51
52 PROTOCOL_VERSION: 1,
53 COMPRESS_PROTOCOL: false,
54 STATUS_INTERVAL: 1000,
55 PACKET_QUEUE_SIZE: 200,
56 PROXY: process.env.PM2_PROXY,
57
58 LOGS_BUFFER: 8,
59 CONTEXT_ON_ERROR: 4,
60 TRANSACTION_FLUSH_INTERVAL: useIfDefined(process.env.PM2_DEBUG, process.env.NODE_ENV === 'local_test') ? 1000 : 30000,
61 AGGREGATION_DURATION: useIfDefined(process.env.PM2_DEBUG, process.env.NODE_ENV === 'test' || process.env.NODE_ENV === 'development') ? 0 : 60 * 10,
62 TRACE_FLUSH_INTERVAL: useIfDefined(process.env.PM2_DEBUG, process.env.NODE_ENV === 'local_test') ? 1000 : 60000,
63
64 PM2_HOME: PM2_HOME,
65 DAEMON_RPC_PORT: path.resolve(PM2_HOME, 'rpc.sock'),
66 DAEMON_PUB_PORT: path.resolve(PM2_HOME, 'pub.sock'),
67 INTERACTOR_RPC_PORT: path.resolve(PM2_HOME, 'interactor.sock'),
68 INTERACTOR_LOG_FILE_PATH: path.resolve(PM2_HOME, 'agent.log'),
69 INTERACTOR_PID_PATH: path.resolve(PM2_HOME, 'agent.pid'),
70 INTERACTION_CONF: path.resolve(PM2_HOME, 'agent.json5'),
71
72 DUMP_FILE_PATH: path.resolve(PM2_HOME, 'dump.pm2'),
73
74 UNIQUE_SERVER_ID: getUniqueId(),
75
76 ENABLE_CONTEXT_ON_ERROR: useIfDefined(process.env.PM2_AGENT_ENABLE_CONTEXT_ON_ERROR, true),
77
78 SUCCESS_EXIT: 0,
79 ERROR_EXIT: 1
80}
81
82// allow overide of file paths via environnement
83let keys = Object.keys(cst)
84keys.forEach((key) => {
85 var envKey = key.indexOf('PM2_') > -1 ? key : 'PM2_' + key
86 if (process.env[envKey] && key !== 'PM2_HOME' && key !== 'PM2_ROOT_PATH') {
87 cst[key] = process.env[envKey]
88 }
89})
90
91if (process.platform === 'win32' || process.platform === 'win64') {
92 // @todo instead of static unique rpc/pub file custom with PM2_HOME or UID
93 cst.DAEMON_RPC_PORT = '\\\\.\\pipe\\rpc.sock'
94 cst.DAEMON_PUB_PORT = '\\\\.\\pipe\\pub.sock'
95 cst.INTERACTOR_RPC_PORT = '\\\\.\\pipe\\interactor.sock'
96}
97
98module.exports = cst