@lskjs/rabbit/startGoProc.js

"use strict";

var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports["default"] = startGoProc;

var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));

var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));

var _child_process = require("child_process");

var _get = _interopRequireDefault(require("lodash/get"));

var paramsToArgs = function paramsToArgs() {
  var params = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};
  return Object.keys(params).map(function (key) {
    return ["-".concat(key), params[key]].join(' ');
  });
};

var serializeData = function serializeData() {
  var data = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};
  if (typeof data === 'string') return data;
  return JSON.stringify(data);
};

var serializeDataArray = function serializeDataArray() {
  var data = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};

  if (Array.isArray(data)) {
    return data.map(serializeData);
  }

  return serializeData(data);
};

function startGoProc() {
  return _startGoProc.apply(this, arguments);
}

function _startGoProc() {
  _startGoProc = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee() {
    var _this = this;

    var debug, uri, params, cmd, args, proc;
    return _regenerator["default"].wrap(function _callee$(_context) {
      while (1) {
        switch (_context.prev = _context.next) {
          case 0:
            // const { debug } = this.config;
            debug = this.config.debug || false;
            uri = this.config.uri;

            if (uri.includes('?')) {
              uri = (0, _get["default"])(uri.split('?'), '0');
            }

            params = {
              amqp: uri
            }; // const cmd = GO_RABBIT;

            cmd = this.goRabbitPath; // const cmd = `${GO_RABBIT}`;
            // const cmd = `echo '${row}' | node /Users/isuvorov/projects/parser-cloud/packages/parser-cloud/rabbit-node.js`;

            args = paramsToArgs(params);

            if (debug) {
              this.log.trace('[RM]', "".concat(cmd, " ").concat(args.join(' '))); // echo '{"_id": "5e91cc24001c9049700945bc", "videoId": "PRsKXb4e_Bo"}' | ./rabbit -queue z-dev-TEST
            }

            proc = (0, _child_process.spawn)(cmd, args, {
              shell: true
            });
            proc.stdout.on('data', function (chunk) {
              var strings = String(chunk).split('\n');
              strings.forEach(function (str) {
                if (debug) {
                  _this.log.trace('[RM] stdout:', str);
                }

                try {
                  var json = JSON.parse(String(str));

                  if (json.type === 'response') {
                    _this.emitter.emit(json.hash, {
                      complete: json.complete
                    });
                  }
                } catch (e) {// this.log.trace(String(chunk), 'не получилось');

                  /* eslint no-empty: "error" */
                } // this.log.trace('----------------------');

              });
            });
            proc.stderr.on('data', function (chunk) {
              _this.log.error("[RM] stderr: ".concat(chunk));
            });
            proc.on('close', function () {
              if (debug) {
                _this.log.warn('что то пошло не так');
              }

              _this.emitter.emit('close');

              setTimeout(function () {
                _this.startGoProc();
              }, 100);
            });
            this.proc = proc;

          case 12:
          case "end":
            return _context.stop();
        }
      }
    }, _callee, this);
  }));
  return _startGoProc.apply(this, arguments);
}
//# sourceMappingURL=startGoProc.js.map