tron: fix block ingestion

subsquid · Oct 15, 2024 · f68a0e6 · f68a0e6
1 parent e70f499
commit f68a0e6
Show file tree

Hide file tree

Showing 4 changed files with 24 additions and 4 deletions.
diff --git a/common/changes/@subsquid/tron-data/master_2024-10-15-07-18.json b/common/changes/@subsquid/tron-data/master_2024-10-15-07-18.json
@@ -0,0 +1,10 @@
+{
+  "changes": [
+    {
+      "packageName": "@subsquid/tron-data",
+      "comment": "fix missing transactions info",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@subsquid/tron-data"
+}
diff --git a/common/changes/@subsquid/tron-processor/master_2024-10-15-07-18.json b/common/changes/@subsquid/tron-processor/master_2024-10-15-07-18.json
@@ -0,0 +1,10 @@
+{
+  "changes": [
+    {
+      "packageName": "@subsquid/tron-processor",
+      "comment": "handle transactions with no logs",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@subsquid/tron-processor"
+}
diff --git a/tron/tron-data/src/data-source.ts b/tron/tron-data/src/data-source.ts
@@ -189,7 +189,7 @@ export class HttpDataSource {
         }
 
         if (req.request.transactionsInfo) {
-            this.addTransactionsInfo(blocks)
+            await this.addTransactionsInfo(blocks)
         }
 
         return blocks

diff --git a/tron/tron-processor/src/http/filter.ts b/tron/tron-processor/src/http/filter.ts
@@ -121,7 +121,7 @@ export function filterBlock(block: Block, dataRequest: DataRequest): void {
     let include = new IncludeSet()
 
     let transactions = new Map(block.transactions.map(tx => [tx.transactionIndex, tx]))
-    let internalTxByTx = groupBy(block.internalTransactions, input => input.transactionIndex)
+    let internalTxByTx = groupBy(block.internalTransactions, internalTx => internalTx.transactionIndex)
     let logsByTx = groupBy(block.logs, log => log.transactionIndex)
 
     if (items.logs.present()) {
@@ -142,13 +142,13 @@ export function filterBlock(block: Block, dataRequest: DataRequest): void {
             if (rel == null) continue
             include.addTransaction(tx)
             if (rel.logs) {
-                let logs = assertNotNull(logsByTx.get(tx.transactionIndex))
+                let logs = logsByTx.get(tx.transactionIndex) ?? []
                 for (let log of logs) {
                     include.addLog(log)
                 }
             }
             if (rel.internalTransactions) {
-                let internalTxs = assertNotNull(internalTxByTx.get(tx.transactionIndex))
+                let internalTxs = internalTxByTx.get(tx.transactionIndex) ?? []
                 for (let internalTx of internalTxs) {
                     include.addInternalTransaction(internalTx)
                 }