Merge pull request #32 from AnyFetch/hydration-error

Send hydration_error on ERR HYDRATING

Author: Neamar

lib/helpers/hydrater.js

@@ -185,25 +185,50 @@ module.exports = function(hydraterFunction, logger, errLogger) {
         }
       }
     ], function handleErrors(err, changes, res) {
-      // if long_poll
-      if(task.long_poll) {
-        if(err) {
-          task.next(new restify.InvalidContentError("ERR hydrating " + ((task.file_path) ? task.file_path : task.document.id) + err.toString()));
+      async.waterfall([
+        function logError(cb) {
+          if(err) {
+            errLogger("ERR hydrating " + ((task.file_path) ? task.file_path : task.document.id), err.toString());
+          }
+
+          if(res && res.statusCode && res.statusCode !== 204) {
+            errLogger("ERR hydrating: server refused data! Code:" + res.statusCode);
+          }
+
+          cb(null);
+        },
+        function forwardError(cb) {
+          if(!err) {
+            if(task.long_poll) {
+              task.res.send(changes);
+              task.next();
+            }
+
+            return cb(null);
+          }
+
+          if(task.long_poll) {
+            task.next(new restify.InvalidContentError("ERR hydrating " + ((task.file_path) ? task.file_path : task.document.id) + err.toString()));
+            cb(null);
+          }
+          else {
+            var apiUrl = url.parse(task.callback, false, true);
+
+            request(apiUrl.protocol + "//" + apiUrl.host)
+              .patch(apiUrl.path)
+              .send({
+                hydration_error: err.toString()
+              })
+              .end(cb);
+          }
         }
-        else {
-          task.res.send(changes);
-          task.next();
+      ], function(internalErr) {
+        if(internalErr) {
+          errLogger("INTERNAL ERR", internalErr);
         }
-      }
 
-      if(err) {
-        errLogger("ERR hydrating " + ((task.file_path) ? task.file_path : task.document.id), err.toString());
-      }
-
-      if(res && res.statusCode && res.statusCode !== 204) {
-        errLogger("ERR hydrating: server refused data! Code:" + res.statusCode);
-      }
-      done(err, changes);
+        done(err || internalErr, changes);
+      });
     });
   };
 };