Update model.

Author: Andrey

moonstreamdb-v3/moonstreamdbv3/models.py

@@ -27,6 +27,7 @@
     Integer,
     LargeBinary,
     MetaData,
+    Numeric,
     Text,
 )
 from sqlalchemy.dialects.postgresql import JSONB, UUID
@@ -124,6 +125,35 @@ class EvmBasedLabel(Base):  # type: ignore
     )
 
 
+# class EthereumTransaction(Base):  # type: ignore
+#     __tablename__ = "ethereum_transactions"
+
+#     hash = Column(
+#         VARCHAR(256), primary_key=True, unique=True, nullable=False, index=True
+#     )
+#     block_number = Column(
+#         BigInteger,
+#         ForeignKey("ethereum_blocks.block_number", ondelete="CASCADE"),
+#         nullable=False,
+#         index=True,
+#     )
+#     from_address = Column(VARCHAR(256), index=True)
+#     to_address = Column(VARCHAR(256), index=True)
+#     gas = Column(Numeric(precision=78, scale=0), index=True)
+#     gas_price = Column(Numeric(precision=78, scale=0), index=True)
+#     max_fee_per_gas = Column(Numeric(precision=78, scale=0), nullable=True)
+#     max_priority_fee_per_gas = Column(Numeric(precision=78, scale=0), nullable=True)
+#     input = Column(Text)
+#     nonce = Column(VARCHAR(256))
+#     transaction_index = Column(BigInteger)
+#     transaction_type = Column(Integer, nullable=True)
+#     value = Column(Numeric(precision=78, scale=0), index=True)
+
+#     indexed_at = Column(
+#         DateTime(timezone=True), server_default=utcnow(), nullable=False
+#     )
+
+
 class EvmBasedTransaction(Base):  # type: ignore
     __abstract__ = True
 
@@ -141,15 +171,15 @@ class EvmBasedTransaction(Base):  # type: ignore
     block_hash = Column(VARCHAR(256), nullable=False, index=True)
     from_address = Column(LargeBinary, index=True)
     to_address = Column(LargeBinary, index=True)
-    gas = Column(BigInteger, index=True)
-    gas_price = Column(BigInteger, index=True)
-    max_fee_per_gas = Column(BigInteger, nullable=True)
-    max_priority_fee_per_gas = Column(BigInteger, nullable=True)
+    gas = Column(Numeric(precision=78, scale=0), index=True)
+    gas_price = Column(Numeric(precision=78, scale=0), index=True)
+    max_fee_per_gas = Column(Numeric(precision=78, scale=0), nullable=True)
+    max_priority_fee_per_gas = Column(Numeric(precision=78, scale=0), nullable=True)
     input = Column(Text)
-    nonce = Column(BigInteger)
+    nonce = Column(VARCHAR(256))
     transaction_index = Column(BigInteger)
     transaction_type = Column(Integer, nullable=True)
-    value = Column(BigInteger, index=True)
+    value = Column(Numeric(precision=78, scale=0), index=True)
 
     indexed_at = Column(
         DateTime(timezone=True), server_default=utcnow(), nullable=False