utils.js 2.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110
  1. const _ = require('lodash');
  2. const exec = require('node:child_process').exec;
  3. const execFile = require('node:child_process').execFile;
  4. const { Liquid } = require('liquidjs');
  5. const logger = require('../logger').global;
  6. const error = require('./error');
  7. module.exports = {
  8. exec: async (cmd, options = {}) => {
  9. logger.debug('CMD:', cmd);
  10. const { stdout, stderr } = await new Promise((resolve, reject) => {
  11. const child = exec(cmd, options, (isError, stdout, stderr) => {
  12. if (isError) {
  13. reject(new error.CommandError(stderr, isError));
  14. } else {
  15. resolve({ stdout, stderr });
  16. }
  17. });
  18. child.on('error', (e) => {
  19. reject(new error.CommandError(stderr, 1, e));
  20. });
  21. });
  22. return stdout;
  23. },
  24. /**
  25. * @param {String} cmd
  26. * @param {Array} args
  27. * @param {Object|undefined} options
  28. * @returns {Promise}
  29. */
  30. execFile: (cmd, args, options) => {
  31. logger.debug(`CMD: ${cmd} ${args ? args.join(' ') : ''}`);
  32. if (typeof options === 'undefined') {
  33. options = {};
  34. }
  35. return new Promise((resolve, reject) => {
  36. execFile(cmd, args, options, (err, stdout, stderr) => {
  37. if (err && typeof err === 'object') {
  38. reject(new error.CommandError(stderr, 1, err));
  39. } else {
  40. resolve(stdout.trim());
  41. }
  42. });
  43. });
  44. },
  45. /**
  46. * Used in objection query builder
  47. *
  48. * @param {Array} omissions
  49. * @returns {Function}
  50. */
  51. omitRow: (omissions) => {
  52. /**
  53. * @param {Object} row
  54. * @returns {Object}
  55. */
  56. return (row) => {
  57. return _.omit(row, omissions);
  58. };
  59. },
  60. /**
  61. * Used in objection query builder
  62. *
  63. * @param {Array} omissions
  64. * @returns {Function}
  65. */
  66. omitRows: (omissions) => {
  67. /**
  68. * @param {Array} rows
  69. * @returns {Object}
  70. */
  71. return (rows) => {
  72. rows.forEach((row, idx) => {
  73. rows[idx] = _.omit(row, omissions);
  74. });
  75. return rows;
  76. };
  77. },
  78. /**
  79. * @returns {Object} Liquid render engine
  80. */
  81. getRenderEngine: () => {
  82. const renderEngine = new Liquid({
  83. root: `${__dirname}/../templates/`
  84. });
  85. /**
  86. * nginxAccessRule expects the object given to have 2 properties:
  87. *
  88. * directive string
  89. * address string
  90. */
  91. renderEngine.registerFilter('nginxAccessRule', (v) => {
  92. if (typeof v.directive !== 'undefined' && typeof v.address !== 'undefined' && v.directive && v.address) {
  93. return `${v.directive} ${v.address};`;
  94. }
  95. return '';
  96. });
  97. return renderEngine;
  98. }
  99. };