@kiwicom/relay/src/createRequestHandler.js

"use strict";

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.default = createRequestHandler;

var _relayRuntime = require("relay-runtime");

var _helpers = require("./helpers");

function createRequestHandler(customFetcher) {
  var burstCache = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : new _relayRuntime.QueryResponseCache({
    size: 250,
    ttl: 2 * 1000 // 2 seconds

  });

  function cleanup() {// noop, do anything here
  }

  return function handleRequest(requestNode, variables, cacheConfig, uploadables) {
    return _relayRuntime.Observable.create(function (sink) {
      var queryID = requestNode.text;

      if ((0, _helpers.isMutation)(requestNode)) {
        // mutations should always erase burst cache
        burstCache.clear();
      } else {
        // otherwise we'll try to read from the burst cache and return without
        // any additional fetching
        var fromCache = burstCache.get(queryID, variables);

        if ((0, _helpers.isQuery)(requestNode) && fromCache !== null && !(0, _helpers.forceFetch)(cacheConfig)) {
          sink.next(fromCache);
          sink.complete();
          return cleanup; // that's it - we are done here (no network call)
        }
      } // this should be executed only when the request is a mutation or
      // when there is no content in the burst cache


      customFetcher(requestNode, variables, uploadables).then(function (response) {
        if (response.errors) {
          // What should we do with these partial errors?
          // eslint-disable-next-line no-console
          response.errors.map(function (error) {
            return console.error(error.message, error);
          });
        } else {
          // set burst cache only if there are no errors
          burstCache.set(queryID, variables, response);
        }

        sink.next(response);
        sink.complete();
      }).catch(function (error) {
        sink.error(error);
        sink.complete();
      });
      return cleanup;
    });
  };
}