DicXmlRpc.js

Filename	Percent	Threshold	Total	Covered	Uncovered
src/DicXmlRpc.js	89.21%	80%	139	124	15

"use strict";

const
  { DicXmlRpc, xml } = require('dim-xml'),
  { invoke, get, omit, has } = require('lodash');

/**
 * @typedef {import('@node-red/registry').NodeAPI} Red
 * @typedef {import('./DimXmlConf').ConfNode} ConfNode
 *
 * @typedef {import('@node-red/registry').NodeMessageInFlow & {
 *  key: number,
 *  error: number,
 *  status: number,
 * }} AckMsg
 */

/**
 * @param {Red} RED
 */
module.exports = function(RED) {

  /**
   * @brief constructor function of DIM-XML RPC Client Node
   * @param {nodeRedDimXml.DimXmlClientDef} c
   * @this {nodeRedDimXml.DimXmlClientNode}
   */
  function DimXmlRpcClient(c) {
    RED.nodes.createNode(this, c);
    this.cnf = /** @type {ConfNode} */(RED.nodes.getNode(c.cnf));
    this.serviceName = c.serviceName;
    this.timeout = c.timeout; /* ms */

    const node = this;

    if (node.cnf) {
      node._removeConnStatus = node.cnf.addConnStatus(node);
      node.dnsClient = node.cnf.getDnsClient();
      if (node.dnsClient) {
        node.cnf.ref();
        /* query service to check connection status */
        node.dnsClient.query(node.serviceName + '/RpcIn')
        .catch((err) => {
          node.error(err);
        });

        node.on('input', function(msg, send, done) {
          if (msg.hasOwnProperty("payload")) {
            DicXmlRpc.invoke(node.serviceName, msg.payload, node.dnsClient,
              null, node.timeout)
            .catch((err) => {
              if (!has(err, 'key')) { throw err; }
              else { return err; } /* request rejected */
            })
            .then((rep) => {
              const ret = xml.toJs(rep.xml);
              /** @type {AckMsg} */(msg).key = get(rep, 'key');
              /** @type {AckMsg} */(msg).error = rep.error;
              /** @type {AckMsg} */(msg).status = rep.status;
              msg.payload = get(rep, 'message') ||
                omit(ret, [ '$' ]); /* returns */

              send(msg);
              done();
            }).catch(done);
          }
          else {
            done();
          }
        });

        node.on('close', (/** @type {() => void} */ done) => {
          if (node._removeConnStatus) {
            node._removeConnStatus();
            delete node._removeConnStatus;
          }
          invoke(node.cnf, 'unref');
          node.dnsClient = null;
          done();
        });
      }
    }
    else {
      node.error(RED._("node-red-dim-xml/dimXmlConf:dimXmlConf.error.config-missing"));
    }

  }
  RED.nodes.registerType("dim-xml-rpc-client", DimXmlRpcClient);
};

[{"file":"src/DicXmlRpc.js","line":42,"character":16,"text":"err","kind":1},{"file":"src/DicXmlRpc.js","line":43,"character":21,"text":"err","kind":1},{"file":"src/DicXmlRpc.js","line":50,"character":20,"text":"err","kind":1},{"file":"src/DicXmlRpc.js","line":51,"character":23,"text":"err","kind":1},{"file":"src/DicXmlRpc.js","line":51,"character":44,"text":"err","kind":1},{"file":"src/DicXmlRpc.js","line":52,"character":28,"text":"err","kind":1},{"file":"src/DicXmlRpc.js","line":54,"character":19,"text":"rep","kind":1},{"file":"src/DicXmlRpc.js","line":55,"character":35,"text":"rep","kind":1},{"file":"src/DicXmlRpc.js","line":55,"character":39,"text":"xml","kind":1},{"file":"src/DicXmlRpc.js","line":56,"character":51,"text":"rep","kind":1},{"file":"src/DicXmlRpc.js","line":57,"character":49,"text":"rep","kind":1},{"file":"src/DicXmlRpc.js","line":57,"character":53,"text":"error","kind":1},{"file":"src/DicXmlRpc.js","line":58,"character":50,"text":"rep","kind":1},{"file":"src/DicXmlRpc.js","line":58,"character":54,"text":"status","kind":1},{"file":"src/DicXmlRpc.js","line":59,"character":32,"text":"rep","kind":1}]

TypeScript coverage report