[plugin] add basic retry to candleUploader

askmike · Jan 9, 2019 · 1d5f9ce · 1d5f9ce
1 parent 25bb888
commit 1d5f9ce
Showing 1 changed file with 23 additions and 7 deletions.
diff --git a/plugins/candleUploader.js b/plugins/candleUploader.js
@@ -21,11 +21,7 @@ CandleUploader.prototype.schedule = function() {
   this.timer = setTimeout(this.upload, 10 * 1000);
 }
 
-CandleUploader.prototype.upload = function() {
-  const amount = this.candles.length;
-  if(!amount) {
-    return this.schedule();
-  }
+CandleUploader.prototype.rawUpload = function(candles, count, next) {
 
   axios({
     url: config.candleUploader.url,
@@ -41,12 +37,32 @@ CandleUploader.prototype.upload = function() {
         console.log('error uploading:', r.data);
       }
       console.log(new Date, 'uploaded', amount, 'candles');
-      this.schedule();
+
+      next();
     })
     .catch(e => {
       console.log('error uploading:', e.message);
-      this.schedule();
+
+      count++;
+
+      if(count > 10) {
+        console.log('FINAL error uploading:', e.message);
+        return next();
+      }
+
+      setTimeout(() => this.rawUpload(candles, count, next), 2000);
     });
+}
+
+CandleUploader.prototype.upload = function() {
+  const amount = this.candles.length;
+  if(!amount) {
+    return this.schedule();
+  }
+
+  this.rawUpload(this.candles, 0, () => {
+    this.schedule();
+  });
 
   this.candles = [];
 }