Added request options for DataSource retry info

lib/Model.js

@@ -355,7 +355,7 @@ Model.prototype._hasValidParentReference = require("./deref/hasValidParentRefere
  * @param {Path} path - the path to retrieve
  * @return {Observable.<*>} - the value for the path
  * @example
- var model = new falcor.Model({source: new falcor.HttpDataSource("/model.json") });
+ var model = new falcor.Model({source: new HttpDataSource("/model.json") });
 
  model.
      getValue('user.name').
@@ -373,7 +373,7 @@ Model.prototype.getValue = require("./get/getValue");
  * @param {Object} value - the value to set
  * @return {Observable.<*>} - the value for the path
  * @example
- var model = new falcor.Model({source: new falcor.HttpDataSource("/model.json") });
+ var model = new falcor.Model({source: new HttpDataSource("/model.json") });
 
  model.
      setValue('user.name', 'Jim').

lib/request/GetRequestV2.js

@@ -11,6 +11,11 @@ var $error = require("./../types/error");
 var emptyArray = [];
 var InvalidSourceError = require("./../errors/InvalidSourceError");
 
+/**
+ * @typedef DataSourceRequestOptions
+ * @property {number} retryCount The retry count for this get request based on the request cycle.
+ */
+
 /**
  * Creates a new GetRequest.  This GetRequest takes a scheduler and
  * the request queue.  Once the scheduler fires, all batched requests
@@ -19,15 +24,17 @@ var InvalidSourceError = require("./../errors/InvalidSourceError");
  *
  * @param {Scheduler} scheduler -
  * @param {RequestQueueV2} requestQueue -
+ * @param {DataSourceRequestOptions} dsRequestOpts
  */
-var GetRequestV2 = function(scheduler, requestQueue) {
+var GetRequestV2 = function(scheduler, requestQueue, dsRequestOpts) {
     this.sent = false;
     this.scheduled = false;
     this.requestQueue = requestQueue;
     this.id = ++REQUEST_ID;
     this.type = GetRequestType;
 
     this._scheduler = scheduler;
+    this._dataSourceRequestOptions = dsRequestOpts;
     this._pathMap = {};
     this._optimizedPaths = [];
     this._requestedPaths = [];

lib/request/RequestQueueV2.js

@@ -3,6 +3,11 @@ var sendSetRequest = require("./sendSetRequest");
 var GetRequest = require("./GetRequestV2");
 var falcorPathUtils = require("falcor-path-utils");
 
+/**
+ * @typedef DataSourceRequestOptions
+ * @property {number} retryCount The retry count for this request based on the get/set request cycle.
+ */
+
 /**
  * The request queue is responsible for queuing the operations to
  * the model"s dataSource.
@@ -29,24 +34,32 @@ RequestQueueV2.prototype = {
      * currently could be batched potentially in the future.  Since no batching
      * is required the setRequest action is simplified significantly.
      *
-     * @param {JSONGraphEnvelope) jsonGraph -
+     * @param {JSONGraphEnvelope} jsonGraph -
+     * @param {DataSourceRequestOptions} dsRequestOpts
+     * @param {Function} cb
      */
-    set: function(jsonGraph, cb) {
+    set: function(jsonGraph, dsRequestOpts, cb) {
         if (this.model._enablePathCollapse) {
             jsonGraph.paths = falcorPathUtils.collapse(jsonGraph.paths);
         }
 
-        return sendSetRequest(jsonGraph, this.model, cb);
+        if (cb === undefined) {
+            cb = dsRequestOpts;
+            dsRequestOpts = undefined;
+        }
+
+        return sendSetRequest(jsonGraph, this.model, dsRequestOpts, cb);
     },
 
     /**
      * Creates a get request to the dataSource.  Depending on the current
      * scheduler is how the getRequest will be flushed.
      * @param {Array} requestedPaths -
      * @param {Array} optimizedPaths -
+     * @param {DataSourceRequestOptions} dsRequestOpts
      * @param {Function} cb -
      */
-    get: function(requestedPaths, optimizedPaths, cb) {
+    get: function(requestedPaths, optimizedPaths, dsRequestOpts, cb) {
         var self = this;
         var disposables = [];
         var count = 0;
@@ -57,6 +70,11 @@ RequestQueueV2.prototype = {
         var disposed = false;
         var request;
 
+        if (cb === undefined) {
+            cb = dsRequestOpts;
+            dsRequestOpts = undefined;
+        }
+
         for (i = 0, len = requests.length; i < len; ++i) {
             request = requests[i];
             if (request.type !== RequestTypes.GetRequest) {
@@ -99,7 +117,7 @@ RequestQueueV2.prototype = {
         // After going through all the available requests if there are more
         // paths to process then a new request must be made.
         if (oRemainingPaths && oRemainingPaths.length) {
-            request = new GetRequest(self.scheduler, self);
+            request = new GetRequest(self.scheduler, self, dsRequestOpts);
             requests[requests.length] = request;
             ++count;
             var disposable = request.batch(rRemainingPaths, oRemainingPaths, refCountCallback);

lib/request/flushGetRequest.js

@@ -83,7 +83,7 @@ module.exports = function flushGetRequest(request, pathSetArrayBatch, callback)
     // we cancel at the callback above.
     var getRequest;
     try {
-        getRequest = model._source.get(requestPaths);
+        getRequest = model._source.get(requestPaths, request._dataSourceRequestOptions);
     } catch (e) {
         callback(new InvalidSourceError());
         return null;

lib/request/sendSetRequest.js

@@ -6,16 +6,22 @@ var InvalidSourceError = require("./../errors/InvalidSourceError");
 var emptyArray = [];
 var emptyDisposable = {dispose: function() {}};
 
+/**
+ * @typedef DataSourceRequestOptions
+ * @property {number} retryCount The retry count for this set request based on the request cycle.
+ */
+
 /**
  * A set request is not an object like GetRequest.  It simply only needs to
  * close over a couple values and its never batched together (at least not now).
  *
  * @private
  * @param {JSONGraphEnvelope} jsonGraph -
  * @param {Model} model -
+ * @param {DataSourceRequestOptions} dsRequestOpts
  * @param {Function} callback -
  */
-var sendSetRequest = function(originalJsonGraph, model, callback) {
+var sendSetRequest = function(originalJsonGraph, model, dsRequestOpts, callback) {
     var paths = originalJsonGraph.paths;
     var modelRoot = model._root;
     var errorSelector = modelRoot.errorSelector;
@@ -28,7 +34,7 @@ var sendSetRequest = function(originalJsonGraph, model, callback) {
     var setObservable;
     try {
         setObservable = model._source.
-            set(originalJsonGraph);
+            set(originalJsonGraph, dsRequestOpts);
     } catch (e) {
         callback(new InvalidSourceError());
         return emptyDisposable;

lib/response/get/getRequestCycle.js

@@ -51,7 +51,7 @@ module.exports = function getRequestCycle(getResponse, model, results, observer,
     }
 
     var currentRequestDisposable = requestQueue.
-        get(boundRequestedMissingPaths, optimizedMissingPaths, function(err, data, hasInvalidatedResult) {
+        get(boundRequestedMissingPaths, optimizedMissingPaths, { retryCount: count }, function(err, data, hasInvalidatedResult) {
             if (model._treatDataSourceErrorsAsJSONGraphErrors ? err instanceof InvalidSourceError : !!err) {
                 if (results.hasValues) {
                     observer.onNext(results.values && results.values[0]);

lib/response/set/SetResponse.js

@@ -84,7 +84,7 @@ SetResponse.prototype._subscribe = function _subscribe(observer) {
 
     // Starts the async request cycle.
     return setRequestCycle(
-        model, observer, groups, isJSONGraph, isProgressive, 0);
+        model, observer, groups, isJSONGraph, isProgressive, 1);
 };
 
 /**

lib/response/set/setRequestCycle.js

@@ -17,7 +17,7 @@ module.exports = function setRequestCycle(model, observer, groups,
     var requestedPaths = requestedAndOptimizedPaths.requestedPaths;
 
     // we have exceeded the maximum retry limit.
-    if (count === model._maxRetries) {
+    if (count > model._maxRetries) {
         observer.onError(new MaxRetryExceededError(optimizedPaths));
         return {
             dispose: function() {}
@@ -59,7 +59,7 @@ module.exports = function setRequestCycle(model, observer, groups,
         // If disposed before this point then the sendSetRequest will not
         // further any callbacks.  Therefore, if we are at this spot, we are
         // not disposed yet.
-        set(currentJSONGraph, function(error, jsonGraphEnv) {
+        set(currentJSONGraph, { retryCount: count }, function(error, jsonGraphEnv) {
             if (error instanceof InvalidSourceError) {
                 observer.onError(error);
                 return;

test/data/LocalDataSource.js

@@ -29,7 +29,7 @@ LocalSource.prototype = {
             this.model = new falcor.Model({cache: modelOrCache});
         }
     },
-    get: function(paths) {
+    get: function(paths, dsRequestOpts) {
         var self = this;
         var options = this._options;
         var miss = options.miss;
@@ -42,7 +42,7 @@ LocalSource.prototype = {
                 var results;
                 var values = [{}];
                 if (self._missCount >= miss) {
-                    onGet(self, paths);
+                    onGet(self, paths, dsRequestOpts);
                     self.model._getPathValuesAsJSONG(self.model, paths, values, errorSelector);
                 } else {
                     self._missCount++;
@@ -68,7 +68,7 @@ LocalSource.prototype = {
             }
         });
     },
-    set: function(jsongEnv) {
+    set: function(jsongEnv, dsRequestOpts) {
         var self = this;
         var options = this._options;
         var miss = options.miss;
@@ -82,7 +82,7 @@ LocalSource.prototype = {
                 var tempModel = new falcor.Model({
                     cache: jsongEnv.jsonGraph,
                     errorSelector: errorSelector});
-                jsongEnv = onSet(self, tempModel, jsongEnv);
+                jsongEnv = onSet(self, tempModel, jsongEnv, dsRequestOpts);
 
                 tempModel.set(jsongEnv).subscribe();
                 tempModel._getPathValuesAsJSONG(