add to streaming

Povilaszva · Jun 1, 2023 · c0fd158 · c0fd158
1 parent 7529c43
commit c0fd158
Show file tree

Hide file tree

Showing 5 changed files with 310 additions and 301 deletions.
diff --git a/ethereumetl/streaming/enrich.py b/ethereumetl/streaming/enrich.py
@@ -84,7 +84,12 @@ def enrich_transactions(transactions, receipts):
             ('contract_address', 'receipt_contract_address'),
             ('root', 'receipt_root'),
             ('status', 'receipt_status'),
-            ('effective_gas_price', 'receipt_effective_gas_price')
+            ('effective_gas_price', 'receipt_effective_gas_price'),
+            ('l1_fee', 'receipt_l1_fee'),
+            ('l1_gas_used', 'receipt_l1_gas_used'),
+            ('l1_gas_price', 'receipt_l1_gas_price'),
+            ('l1_fee_scalar', 'receipt_l1_fee_scalar')
+
         ]))
 
     if len(result) != len(transactions):

diff --git a/ethereumetl/streaming/postgres_tables.py b/ethereumetl/streaming/postgres_tables.py
@@ -74,6 +74,10 @@
     Column('max_priority_fee_per_gas', BigInteger),
     Column('transaction_type', BigInteger),
     Column('receipt_effective_gas_price', BigInteger),
+    Column('receipt_l1_fee', BigInteger),
+    Column('receipt_l1_gas_used', BigInteger),
+    Column('receipt_l1_gas_price', BigInteger),
+    Column('receipt_l1_fee_scalar', BigInteger),
 )
 
 LOGS = Table(

diff --git a/tests/resources/test_export_receipts_job/.DS_Store b/tests/resources/test_export_receipts_job/.DS_Store