allow to configure archive timeout and increase it to 180 seconds by …

…default
subsquid · Aug 8, 2023 · cc00d66 · cc00d66
1 parent 11893f0
commit cc00d66
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 3 deletions.
diff --git a/common/changes/@subsquid/evm-processor/master_2023-08-08-21-19.json b/common/changes/@subsquid/evm-processor/master_2023-08-08-21-19.json
@@ -0,0 +1,10 @@
+{
+  "changes": [
+    {
+      "packageName": "@subsquid/evm-processor",
+      "comment": "allow to configure archive request timeout and increase the default up to 180 seconds",
+      "type": "minor"
+    }
+  ],
+  "packageName": "@subsquid/evm-processor"
+}
diff --git a/evm/evm-processor/src/processor.ts b/evm/evm-processor/src/processor.ts
@@ -32,11 +32,17 @@ type ChainRpc = string | {
 }
 
 
+type ArchiveConnection = string | {
+    url: string
+    requestTimeout?: number
+}
+
+
 interface ArchiveDataSource {
     /**
      * Subsquid evm archive endpoint URL
      */
-    archive: string
+    archive: ArchiveConnection
     /**
      * Chain node RPC endpoint URL
      */
@@ -298,15 +304,20 @@ export class EvmBatchProcessor<F extends FieldSelection = {}> {
 
     @def
     private getArchiveDataSource(): EvmArchive {
+        let archive = assertNotNull(this.getDataSource().archive)
+        if (typeof archive == 'string') {
+            archive = {url: archive}
+        }
+
         let http = new HttpClient({
-            baseUrl: assertNotNull(this.getDataSource().archive),
+            baseUrl: archive.url,
             headers: {
                 'x-squid-id': this.getSquidId()
             },
             agent: new HttpAgent({
                 keepAlive: true
             }),
-            httpTimeout: 30_000,
+            httpTimeout: archive.requestTimeout || 180_000,
             retryAttempts: Number.MAX_SAFE_INTEGER,
             log: this.getLogger().child('archive')
         })