call_response_handlers.js

import { RequestFailure, SearchTimeout, ShardFailure } from 'ui/errors';

import { ReqStatusProvider } from './req_status';
import { CourierNotifierProvider } from './notifier';

export function CallResponseHandlersProvider(Private, Promise) {
  const ABORTED = Private(ReqStatusProvider).ABORTED;
  const INCOMPLETE = Private(ReqStatusProvider).INCOMPLETE;
  const notify = Private(CourierNotifierProvider);


  function callResponseHandlers(requests, responses) {
    return Promise.map(requests, function (req, i) {
      if (req === ABORTED || req.aborted) {
        return ABORTED;
      }

      let resp = responses[i];

      if (resp.timed_out) {
        notify.warning(new SearchTimeout());
      }

      if (resp._shards && resp._shards.failed) {
        notify.warning(new ShardFailure(resp));
      }

      function progress() {
        if (req.isIncomplete()) {
          return INCOMPLETE;
        }

        req.complete();
        return resp;
      }

      if (resp.error) {
        if (req.filterError(resp)) {
          return progress();
        } else {
          return req.handleFailure(new RequestFailure(null, resp));
        }
      }

      return Promise.try(function () {
        return req.transformResponse(resp);
      })
      .then(function () {
        resp = arguments[0];
        return req.handleResponse(resp);
      })
      .then(progress);
    });
  }

  return callResponseHandlers;
}