wait on failure instead of retrying immediately (#78)

src/cache/index.ts

@@ -8,6 +8,7 @@ import { lightBlock } from "@/utils/lightBlock";
 import { LightBlock } from "@/models/lightstreamer";
 import { logger } from "@/utils/logger";
 import { RpcRequestError } from "@ironfish/sdk";
+import { wait } from "@/utils/wait";
 
 function getCachePath(): string {
   if (process.env["CACHE_PATH"] && process.env["CACHE_FOLDER"]) {
@@ -58,6 +59,7 @@ export class LightBlockCache {
           logger.warn("Rolling head back to rebuild cache.");
           await this.rollbackHead();
         }
+        wait(10000);
       }
     }
   }

src/upload/index.ts

@@ -10,6 +10,7 @@ import zlib from "zlib";
 import { LightBlockCache, lightBlockCache } from "@/cache";
 import { LightBlock } from "@/models/lightstreamer";
 import { logger } from "@/utils/logger";
+import { wait } from "@/utils/wait";
 
 class UploadError extends Error {}
 
@@ -87,6 +88,7 @@ export class LightBlockUpload {
         await this.uploadInner();
       } catch (error) {
         logger.error(`Upload failed, will retry. Error: ${error}`);
+        wait(10000);
       }
     }
   }
@@ -179,7 +181,7 @@ export class LightBlockUpload {
             `hours since last upload: ${hoursSinceLastUpload.toFixed(2)}/` +
             `${this.maxUploadLagMs / (1000 * 60 * 60)}, waiting...`,
         );
-        await this.wait();
+        await wait();
         continue;
       }
 
@@ -272,10 +274,6 @@ export class LightBlockUpload {
     return (bytes / 1024 / 1024).toFixed(4);
   }
 
-  private async wait(ms = 60000): Promise<void> {
-    await new Promise((resolve) => setTimeout(resolve, ms));
-  }
-
   async uploadFile(
     prefix: string,
     fileName: string,

src/utils/wait.ts

@@ -0,0 +1,3 @@
+export async function wait(ms = 60000): Promise<void> {
+  await new Promise((resolve) => setTimeout(resolve, ms));
+}