constants.js 3.0 KB

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