Source: components/request-factory.js

  1. "use strict";
  2. var Request = require("./request");
  4. /**
  5.  * Construct a factory which can create {@link Request} objects. Useful for
  6.  * adding "default" handlers to requests.
  7.  * @constructor
  8.  */
  9. function RequestFactory() {
  10.     this._resolves = [];
  11.     this._rejects = [];
  12.     this._timeouts = [];
  13. }
  15. /**
  16.  * Generate a new request.
  17.  * @param {Object=} opts The options to pass to the Request constructor, if any.
  18.  * @return {Request} A new request object
  19.  */
  20. RequestFactory.prototype.newRequest = function(opts) {
  21.     var req = new Request(opts);
  22.     req.getPromise().then((res) => {
  23.         this._resolves.forEach((resolveFn) => {
  24.             resolveFn(req, res);
  25.         });
  26.     }).catch((err) => {
  27.         this._rejects.forEach((rejectFn) => {
  28.             rejectFn(req, err);
  29.         });
  30.     });
  32.     this._timeouts.forEach(function(timeoutObj) {
  33.         setTimeout(function() {
  34.             var promise = req.getPromise();
  35.             if (!promise.isPending()) {
  36.                 return;
  37.             }
  38.             timeoutObj.fn(req);
  39.         }, timeoutObj.timeout);
  40.     });
  41.     return req;
  42. }
  44. /**
  45.  * Add a function which will be invoked for every request that is resolved.
  46.  * @param {Function} fn The function to invoke. The first argument will be the
  47.  * Request object, the second will be the resolve argument.
  48.  */
  49. RequestFactory.prototype.addDefaultResolveCallback = function(fn) {
  50.     this._resolves.push(fn);
  51. };
  53. /**
  54.  * Add a function which will be invoked for every request that is rejected.
  55.  * @param {Function} fn The function to invoke. The first argument will be the
  56.  * Request object, the second will be the rejection argument.
  57.  */
  58. RequestFactory.prototype.addDefaultRejectCallback = function(fn) {
  59.     this._rejects.push(fn);
  60. };
  62. /**
  63.  * Add a function which will be invoked for every request that has not been
  64.  * resolved or rejected within a certain amount of time.
  65.  * @param {Function} fn The function to invoke. The first argument will be the
  66.  * Request object.
  67.  * @param {number} durationMs The number of milliseconds to wait for a
  68.  * resolution to the request.
  69.  */
  70. RequestFactory.prototype.addDefaultTimeoutCallback = function(fn, durationMs) {
  71.     this._timeouts.push({
  72.         fn: fn,
  73.         timeout: durationMs
  74.     });
  75. };
  77. module.exports = RequestFactory;