fusion-plugin-rpc/dist/browser.es2017.es.js

import { createToken, createPlugin } from 'fusion-core';
import { UniversalEventsToken } from 'fusion-plugin-universal-events';
import { FetchToken } from 'fusion-tokens';
import mapObject from 'just-map-object';
import isEqual from 'just-compare';

/** Copyright (c) 2018 Uber Technologies, Inc.
 *
 * This source code is licensed under the MIT license found in the
 * LICENSE file in the root directory of this source tree.
 *
 * 
 */
const RPCToken = createToken('RPCToken');
const RPCHandlersToken = createToken('RPCHandlersToken');
const BodyParserOptionsToken = createToken('BodyParserOptionsToken');
const RPCHandlersConfigToken = createToken('RPCHandlersConfigToken');

const formatApiPath = apiPath => `/${apiPath}/`.replace(/\/{2,}/g, '/');

function _objectSpread(target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i] != null ? arguments[i] : {}; var ownKeys = Object.keys(source); if (typeof Object.getOwnPropertySymbols === 'function') { ownKeys = ownKeys.concat(Object.getOwnPropertySymbols(source).filter(function (sym) { return Object.getOwnPropertyDescriptor(source, sym).enumerable; })); } ownKeys.forEach(function (key) { _defineProperty(target, key, source[key]); }); } return target; }

function _defineProperty(obj, key, value) { if (key in obj) { Object.defineProperty(obj, key, { value: value, enumerable: true, configurable: true, writable: true }); } else { obj[key] = value; } return obj; }

/** Copyright (c) 2018 Uber Technologies, Inc.
 *
 * This source code is licensed under the MIT license found in the
 * LICENSE file in the root directory of this source tree.
 *
 * 
 */

/* eslint-env browser */
const statKey = 'rpc:method-client';

class RPC {
  constructor({
    fetch,
    emitter,
    rpcConfig
  }) {
    this.fetch = fetch;
    this.config = rpcConfig || {};
    this.emitter = emitter;
    this.apiPath = formatApiPath(rpcConfig && rpcConfig.apiPath ? rpcConfig.apiPath : 'api');
  }

  request(rpcId, args, headers) {
    if (!this.fetch) {
      throw new Error('fusion-plugin-rpc requires `fetch`');
    }

    if (!this.emitter) {
      throw new Error('Missing emitter registered to UniversalEventsToken');
    }

    const fetch = this.fetch;
    const emitter = this.emitter;
    const apiPath = this.apiPath;
    const startTime = Date.now(); // TODO(#3) handle args instanceof FormData

    return fetch(`${apiPath}${rpcId}`, {
      method: 'POST',
      headers: _objectSpread({
        'Content-Type': 'application/json'
      }, headers || {}),
      body: JSON.stringify(args || {})
    }).then(r => r.json()).then(args => {
      const {
        status,
        data
      } = args;

      if (status === 'success') {
        emitter.emit(statKey, {
          method: rpcId,
          status: 'success',
          timing: Date.now() - startTime
        });
        return data;
      } else {
        emitter.emit(statKey, {
          method: rpcId,
          error: data,
          status: 'failure',
          timing: Date.now() - startTime
        });
        return Promise.reject(data);
      }
    });
  }

}

const pluginFactory = () => createPlugin({
  deps: {
    fetch: FetchToken,
    emitter: UniversalEventsToken,
    rpcConfig: RPCHandlersConfigToken.optional
  },
  provides: deps => {
    const {
      fetch = window.fetch,
      emitter,
      rpcConfig
    } = deps;
    return {
      from: () => new RPC({
        fetch,
        emitter,
        rpcConfig
      })
    };
  }
});

var browserDataFetching = true && pluginFactory();

/** Copyright (c) 2018 Uber Technologies, Inc.
 *
 * This source code is licensed under the MIT license found in the
 * LICENSE file in the root directory of this source tree.
 *
 * 
 */
class MissingHandlerError extends Error {
  constructor(method) {
    super(`Missing RPC handler for ${method}`);
    this.code = 'ERR_MISSING_HANDLER';
    Error.captureStackTrace(this, MissingHandlerError);
  }

}

/** Copyright (c) 2018 Uber Technologies, Inc.
 *
 * This source code is licensed under the MIT license found in the
 * LICENSE file in the root directory of this source tree.
 *
 * 
 */
class ResponseError extends Error {
  constructor(message) {
    super(message);
    this.code = null;
    this.meta = null;
    Error.captureStackTrace(this, ResponseError);
  }

}

/** Copyright (c) 2018 Uber Technologies, Inc.
 *
 * This source code is licensed under the MIT license found in the
 * LICENSE file in the root directory of this source tree.
 *
 * 
 */

/* eslint-env node */

/** Copyright (c) 2018 Uber Technologies, Inc.
 *
 * This source code is licensed under the MIT license found in the
 * LICENSE file in the root directory of this source tree.
 *
 * 
 */
class RPC$2 {
  constructor(handlers) {
    this.handlers = handlers;
  }

  async request(method, args) {
    if (!this.handlers) {
      throw new Error('fusion-plugin-rpc requires `handlers`');
    }

    if (!this.handlers[method]) {
      throw new MissingHandlerError(method);
    }

    return this.handlers[method](args);
  }

}

const plugin = createPlugin({
  deps: {
    handlers: RPCHandlersToken,
    emitter: UniversalEventsToken
  },
  provides: ({
    handlers
  } = {}) => {
    return {
      from: () => new RPC$2(handlers)
    };
  }
});

function _objectSpread$1(target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i] != null ? arguments[i] : {}; var ownKeys = Object.keys(source); if (typeof Object.getOwnPropertySymbols === 'function') { ownKeys = ownKeys.concat(Object.getOwnPropertySymbols(source).filter(function (sym) { return Object.getOwnPropertyDescriptor(source, sym).enumerable; })); } ownKeys.forEach(function (key) { _defineProperty$1(target, key, source[key]); }); } return target; }

function _defineProperty$1(obj, key, value) { if (key in obj) { Object.defineProperty(obj, key, { value: value, enumerable: true, configurable: true, writable: true }); } else { obj[key] = value; } return obj; }

const getMockRpcHandlers = (fixtures, onMockRpc) => fixtures.reduce((rpcHandlers, fixture) => _objectSpread$1({}, rpcHandlers, mapObject(fixture, (rpcId, responseDetails) => async (...args) => {
  const response = Array.isArray(responseDetails) ? responseDetails.filter(item => isEqual(item.args, args))[0].response : responseDetails;
  onMockRpc && onMockRpc(rpcId, args, response);

  if (response instanceof Error) {
    throw response;
  }

  return response;
})), {});

/** Copyright (c) 2018 Uber Technologies, Inc.
 *
 * This source code is licensed under the MIT license found in the
 * LICENSE file in the root directory of this source tree.
 *
 * 
 */
var index = browserDataFetching;

export default index;
export { plugin as mock, ResponseError, BodyParserOptionsToken, RPCToken, RPCHandlersToken, RPCHandlersConfigToken, getMockRpcHandlers };