Add baseFeePerGas for block export

dbfreem · Jun 24, 2021 · 4dba6a1 · 4dba6a1
1 parent b568101
commit 4dba6a1
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 1 deletion.
diff --git a/docs/schema.md b/docs/schema.md
@@ -22,6 +22,7 @@ gas_limit         | bigint             |
 gas_used          | bigint             |
 timestamp         | bigint             |
 transaction_count | bigint             |
+baseFeePerGas     | bigint             |
 
 ---
 

diff --git a/ethereumetl/domain/block.py b/ethereumetl/domain/block.py
@@ -43,3 +43,4 @@ def __init__(self):
 
         self.transactions = []
         self.transaction_count = 0
+        self.baseFeePerGas = 0
diff --git a/ethereumetl/jobs/exporters/blocks_and_transactions_item_exporter.py b/ethereumetl/jobs/exporters/blocks_and_transactions_item_exporter.py
@@ -41,7 +41,8 @@
     'gas_limit',
     'gas_used',
     'timestamp',
-    'transaction_count'
+    'transaction_count',
+    'baseFeePerGas'
 ]
 
 TRANSACTION_FIELDS_TO_EXPORT = [

diff --git a/ethereumetl/mappers/block_mapper.py b/ethereumetl/mappers/block_mapper.py
@@ -52,6 +52,7 @@ def json_dict_to_block(self, json_dict):
         block.gas_limit = hex_to_dec(json_dict.get('gasLimit'))
         block.gas_used = hex_to_dec(json_dict.get('gasUsed'))
         block.timestamp = hex_to_dec(json_dict.get('timestamp'))
+        block.baseFeePerGas = hex_to_dec(json_dict.get('baseFeePerGas'))
 
         if 'transactions' in json_dict:
             block.transactions = [
@@ -85,4 +86,5 @@ def block_to_dict(self, block):
             'gas_used': block.gas_used,
             'timestamp': block.timestamp,
             'transaction_count': block.transaction_count,
+            'baseFeePerGas': block.baseFeePerGas
         }
Original file line number	Diff line number	Diff line change
Expand Up		@@ -43,3 +43,4 @@ def __init__(self):

		self.transactions = []
		self.transaction_count = 0
		self.baseFeePerGas = 0