@polkadot/api-provider/ws/send.js

"use strict";

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

var _promise = _interopRequireDefault(require("@babel/runtime/core-js/promise"));

// Copyright 2017-2018 Jaco Greeff
// This software may be modified and distributed under the terms
// of the ISC license. See the LICENSE file for details.
module.exports = async function send(self, method, params, subscription) {
  return new _promise.default((resolve, reject) => {
    try {
      const json = self.coder.encodeJson(method, params);
      const id = self.coder.getId();

      const callback = (error, result) => {
        if (error) {
          reject(error);
        } else {
          resolve(result);
        }
      };

      self.l.debug(() => ['calling', method, params, json, !!subscription]);
      self.handlers[id] = {
        callback,
        subscription
      };

      if (self.isConnected) {
        self.websocket.send(json);
      } else {
        self.queued[id] = json;
      }
    } catch (error) {
      reject(error);
    }
  });
};