@polkadot/api-provider/mock/state.js

"use strict";

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

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

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

// 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.
const EventEmitter = require('eventemitter3');

const interfaces = require('@polkadot/jsonrpc');

const u8aToHex = require('@polkadot/util/u8a/toHex');

const l = require('@polkadot/util/logger')('api-mock');

const SUBSCRIPTIONS = Array.prototype.concat.apply([], (0, _keys.default)(interfaces).map(section => {
  return (0, _keys.default)(interfaces[section].public).filter(method => interfaces[section].public[method].isSubscription).map(method => `subscribe_${method}`);
}));
const REQUESTS = {
  'state_getStorage': (storage, params) => {
    return u8aToHex( // flowlint-next-line unclear-type:off
    storage[params[0]]);
  },
  'system_chain': () => 'mockChain',
  'system_name': () => 'mockClient',
  'system_version': () => '9.8.7'
};

module.exports = function state() {
  const storage = {};
  const subscriptions = SUBSCRIPTIONS.reduce((subscriptions, name) => {
    subscriptions[name] = {
      callbacks: {},
      lastValue: null
    };
    return subscriptions;
  }, {});
  return {
    emitter: new EventEmitter(),
    l,
    requests: (0, _assign.default)({}, REQUESTS),
    storage,
    subscriptionId: 0,
    subscriptionMap: {},
    subscriptions
  };
};