runtime: store extracted swap pairs

oasisprotocol · May 15, 2024 · 9c6302a · 9c6302a
1 parent 5a6982e
commit 9c6302a
Showing 1 changed file with 23 additions and 0 deletions.
diff --git a/analyzer/runtime/runtime.go b/analyzer/runtime/runtime.go
@@ -472,4 +472,27 @@ func (m *processor) queueDbUpdates(batch *storage.QueryBatch, data *BlockData) {
 			)
 		}
 	}
+
+	// Insert swap pairs.
+	for pairAddress, pair := range data.SwapPairs {
+		batch.Queue(
+			queries.RuntimeEVMSwapPairUpsertCreated,
+			m.runtime,
+			pairAddress,
+			pair.Factory,
+			pair.Token0,
+			pair.Token1,
+			data.Header.Round,
+		)
+	}
+	for pairAddress, sync := range data.SwapSyncs {
+		batch.Queue(
+			queries.RuntimeEVMSwapPairUpsertSync,
+			m.runtime,
+			pairAddress,
+			sync.Reserve0,
+			sync.Reserve1,
+			data.Header.Round,
+		)
+	}
 }