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

"use strict";

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

var _keys = _interopRequireDefault(require("@babel/runtime/core-js/object/keys"));

require("core-js/modules/web.dom.iterable");

// 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 = function onOpen(self) {
  return () => {
    self.l.debug(() => ['connected to', self.endpoint]);
    self.isConnected = true;
    self.emitter.emit('connected');
    (0, _keys.default)(self.queued).forEach(id => {
      try {
        self.websocket.send( // flowlint-next-line unclear-type:off
        self.queued[id]); // flowlint-next-line unclear-type:off

        delete self.queued[id];
      } catch (error) {
        self.l.error(error);
      }
    });
    return true;
  };
};