evm: add transactionStateDiffs to LogRequest (#350)

common/changes/@subsquid/evm-processor/transaction-statediffs_2024-10-30-15-23.json

@@ -0,0 +1,10 @@
+{
+  "changes": [
+    {
+      "packageName": "@subsquid/evm-processor",
+      "comment": "add transactionStateDiffs to LogRequest",
+      "type": "minor"
+    }
+  ],
+  "packageName": "@subsquid/evm-processor"
+}

evm/evm-processor/src/ds-rpc/filter.ts

@@ -7,6 +7,7 @@ import {DataRequest} from '../interfaces/data-request'
 function buildLogFilter(dataRequest: DataRequest): EntityFilter<Log, {
     transaction?: boolean,
     transactionLogs?: boolean,
+    transactionStateDiffs?: boolean,
     transactionTraces?: boolean
 }> {
     let items = new EntityFilter()
@@ -139,6 +140,7 @@ export function filterBlock(block: Block, dataRequest: DataRequest): void {
 
     let logsByTransaction = groupBy(block.logs, log => log.transactionIndex)
     let tracesByTransaction = groupBy(block.traces, trace => trace.transactionIndex)
+    let stateDiffsByTransaction = groupBy(block.stateDiffs, diff => diff.transactionIndex)
 
     let include = new IncludeSet()
 
@@ -162,6 +164,12 @@ export function filterBlock(block: Block, dataRequest: DataRequest): void {
                     include.addTrace(trace)
                 }
             }
+            if (rel.transactionStateDiffs) {
+                let stateDiffs = stateDiffsByTransaction.get(log.transactionIndex) ?? []
+                for (let diff of stateDiffs) {
+                    include.addStateDiff(diff)
+                }
+            }
         }
     }
 

evm/evm-processor/src/ds-rpc/request.ts

@@ -87,6 +87,11 @@ function stateDiffsRequested(req?: DataRequest): boolean {
             if (tx.stateDiffs) return true
         }
     }
+    if (req.logs) {
+        for (let log of req.logs) {
+            if (log.transactionStateDiffs) return true
+        }
+    }
     return false
 }
 

evm/evm-processor/src/interfaces/data-request.ts

@@ -22,6 +22,7 @@ export interface LogRequest {
     transaction?: boolean
     transactionTraces?: boolean
     transactionLogs?: boolean
+    transactionStateDiffs?: boolean
 }