fix

subsquid · Jan 27, 2025 · d212036 · d212036
1 parent 5396d88
commit d212036
Show file tree

Hide file tree

Showing 2 changed files with 38 additions and 34 deletions.
diff --git a/evm/evm-processor/src/processor.ts b/evm/evm-processor/src/processor.ts
@@ -596,40 +596,40 @@ export class EvmBatchProcessor<F extends FieldSelection = {}> {
         let log = this.getLogger()
 
         runProgram(async () => {
-                let chain = this.getChain()
-                let mappingLog = log.child('mapping')
-
-                if (this.archive == null && this.rpcEndpoint == null) {
-                    throw new Error(
-                        'No data source where specified. ' +
-                            'Use .setArchive() to specify Subsquid Archive and/or .setRpcEndpoint() to specify RPC endpoint.'
-                    )
-                }
-
-                if (this.archive == null && this.rpcIngestSettings?.disabled) {
-                    throw new Error('Subsquid Archive is required when RPC data ingestion is disabled')
-                }
-
-                return new Runner({
-                    database,
-                    requests: this.getBatchRequests(),
-                    archive: this.archive ? this.getArchiveDataSource() : undefined,
-                hotDataSource: this.rpcEndpoint && !this.rpcIngestSettings?.disabled
-                    ? this.getHotDataSource()
-                    : undefined,
-                    allBlocksAreFinal: this.finalityConfirmation === 0,
-                    prometheus: this.getPrometheusServer(),
-                    log,
-                    process(store, batch) {
-                        return handler({
-                            _chain: chain,
-                            log: mappingLog,
-                            store,
-                            blocks: batch.blocks as any,
-                        isHead: batch.isHead
-                        })
-                }
-                }).run()
+            let chain = this.getChain()
+            let mappingLog = log.child('mapping')
+
+            if (this.archive == null && this.rpcEndpoint == null) {
+                throw new Error(
+                    'No data source where specified. ' +
+                        'Use .setArchive() to specify Subsquid Archive and/or .setRpcEndpoint() to specify RPC endpoint.'
+                )
+            }
+
+            if (this.archive == null && this.rpcIngestSettings?.disabled) {
+                throw new Error('Subsquid Archive is required when RPC data ingestion is disabled')
+            }
+
+            return new Runner({
+                database,
+                requests: this.getBatchRequests(),
+                archive: this.archive ? this.getArchiveDataSource() : undefined,
+            hotDataSource: this.rpcEndpoint && !this.rpcIngestSettings?.disabled
+                ? this.getHotDataSource()
+                : undefined,
+                allBlocksAreFinal: this.finalityConfirmation === 0,
+                prometheus: this.getPrometheusServer(),
+                log,
+                process(store, batch) {
+                    return handler({
+                        _chain: chain,
+                        log: mappingLog,
+                        store,
+                        blocks: batch.blocks as any,
+                    isHead: batch.isHead
+                    })
+            }
+            }).run()
         }, err => log.fatal(err))
     }
 }

diff --git a/util/portal-client/src/client.ts b/util/portal-client/src/client.ts
@@ -348,6 +348,10 @@ class PortalStreamBuffer<B extends Block> {
     }
 
     async put(blocks: B[], bytes: number) {
+        if (this.state !== 'open') {
+            throw new Error('buffer is closed')
+        }
+
         this.lastChunkTimestamp = Date.now()
         if (this.idleInterval == null) {
             this.idleInterval = setInterval(() => {