Adds support for retrying failures

Author: flovilmart

spec/ParsePushAdapter.spec.js

@@ -398,7 +398,7 @@ describe('ParsePushAdapter', () => {
   });
 
   // Xited till we can retry on other connections
-  xit('reports properly select connection', (done) => {
+  it('reports properly select connection', (done) => {
     var pushConfig = {
       ios: [
         {
@@ -441,7 +441,7 @@ describe('ParsePushAdapter', () => {
       expect(typeof device.deviceToken).toBe('string');
       expect(result.transmitted).toBe(true);
       done();
-    }).catch((err) => {
+    }).catch((err) => {
       fail('Should not fail');
       done();
     })

src/APNS.js

@@ -96,18 +96,40 @@ export class APNS {
       }
 
       let notification = APNS._generateNotification(coreData, expirationTime, appIdentifier);
-      let promise = providers[0]
-        .send(notification, devices.map(device => device.deviceToken))
-        .then(this._handlePromise.bind(this));
-      allPromises.push(promise);
+      const deviceIds = devices.map(device => device.deviceToken);
+      let promise = this.sendThroughProvider(notification, deviceIds, providers);
+      allPromises.push(promise.then(this._handlePromise.bind(this)));
     }
 
-    return Promise.all(allPromises).then((results) => {
+    return Promise.all(allPromises).then((results) => {
       // flatten all
       return [].concat.apply([], results);
     });
   }
 
+  sendThroughProvider(notification, devices, providers) {
+    return providers[0]
+        .send(notification, devices)
+        .then((response) => {
+          if (response.failed
+              && response.failed.length > 0
+              && providers && providers.length > 1) {
+            let devices = response.failed.map((failure) => { return failure.device; });
+            // Reset the failures as we'll try next connection
+            response.failed = [];
+            return this.sendThroughProvider(notification,
+                            devices,
+                            providers.slice(1, providers.length)).then((retryResponse) => {
+                              response.failed = response.failed.concat(retryResponse.failed);
+                              response.sent = response.sent.concat(retryResponse.sent);
+                              return response;
+                            });
+          } else {
+            return response;
+          }
+        });
+  }
+
   static _validateAPNArgs(apnsArgs) {
     if (apnsArgs.topic) {
       return true;