kopia lustrzana https://github.com/bugout-dev/moonstream
Merge pull request #1137 from moonstream-to/add-ronin-chain
Add ronin chain models.main moonstreamdbv3/v0.1.2
Andrey Dolgolev
GitHub
commit
43c0511fbc
|
|
@ -48,6 +48,8 @@ from moonstreamdbv3.models import (
|
|||
MumbaiLabel,
|
||||
PolygonLabel,
|
||||
ProofOfPlayApexLabel,
|
||||
RoninLabel,
|
||||
RoninSaigonLabel,
|
||||
SepoliaLabel,
|
||||
StarknetLabel,
|
||||
StarknetSepoliaLabel,
|
||||
|
|
@ -91,6 +93,8 @@ def include_symbol(tablename, schema):
|
|||
ImxZkevmSepoliaLabel.__tablename__,
|
||||
B3Label.__tablename__,
|
||||
B3SepoliaLabel.__tablename__,
|
||||
RoninLabel.__tablename__,
|
||||
RoninSaigonLabel.__tablename__,
|
||||
}
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -0,0 +1,324 @@
|
|||
"""add ronin chain
|
||||
|
||||
Revision ID: e6d3c285e7cc
|
||||
Revises: d816689b786a
|
||||
Create Date: 2024-11-12 12:54:33.415972
|
||||
|
||||
"""
|
||||
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
from sqlalchemy.dialects import postgresql
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = "e6d3c285e7cc"
|
||||
down_revision: Union[str, None] = "d816689b786a"
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.create_table(
|
||||
"ronin_labels",
|
||||
sa.Column("id", sa.UUID(), nullable=False),
|
||||
sa.Column("label", sa.VARCHAR(length=256), nullable=False),
|
||||
sa.Column("transaction_hash", sa.VARCHAR(length=128), nullable=False),
|
||||
sa.Column("log_index", sa.Integer(), nullable=True),
|
||||
sa.Column("block_number", sa.BigInteger(), nullable=False),
|
||||
sa.Column("block_hash", sa.VARCHAR(length=256), nullable=False),
|
||||
sa.Column("block_timestamp", sa.BigInteger(), nullable=False),
|
||||
sa.Column("caller_address", sa.LargeBinary(), nullable=True),
|
||||
sa.Column("origin_address", sa.LargeBinary(), nullable=True),
|
||||
sa.Column("address", sa.LargeBinary(), nullable=False),
|
||||
sa.Column("label_name", sa.Text(), nullable=True),
|
||||
sa.Column("label_type", sa.VARCHAR(length=64), nullable=True),
|
||||
sa.Column("label_data", postgresql.JSONB(astext_type=sa.Text()), nullable=True),
|
||||
sa.Column(
|
||||
"created_at",
|
||||
sa.DateTime(timezone=True),
|
||||
server_default=sa.text("TIMEZONE('utc', statement_timestamp())"),
|
||||
nullable=False,
|
||||
),
|
||||
sa.PrimaryKeyConstraint("id", name=op.f("pk_ronin_labels")),
|
||||
sa.UniqueConstraint("id", name=op.f("uq_ronin_labels_id")),
|
||||
)
|
||||
op.create_index(
|
||||
"ix_ronin_labels_addr_block_num",
|
||||
"ronin_labels",
|
||||
["address", "block_number"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
"ix_ronin_labels_addr_block_ts",
|
||||
"ronin_labels",
|
||||
["address", "block_timestamp"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_labels_address"), "ronin_labels", ["address"], unique=False
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_labels_block_number"),
|
||||
"ronin_labels",
|
||||
["block_number"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_labels_caller_address"),
|
||||
"ronin_labels",
|
||||
["caller_address"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_labels_label"), "ronin_labels", ["label"], unique=False
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_labels_label_name"), "ronin_labels", ["label_name"], unique=False
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_labels_label_type"), "ronin_labels", ["label_type"], unique=False
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_labels_origin_address"),
|
||||
"ronin_labels",
|
||||
["origin_address"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_labels_transaction_hash"),
|
||||
"ronin_labels",
|
||||
["transaction_hash"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
"uk_ronin_labels_tx_hash_log_idx_evt",
|
||||
"ronin_labels",
|
||||
["transaction_hash", "log_index"],
|
||||
unique=True,
|
||||
postgresql_where=sa.text("label='seer' and label_type='event'"),
|
||||
)
|
||||
op.create_index(
|
||||
"uk_ronin_labels_tx_hash_log_idx_evt_raw",
|
||||
"ronin_labels",
|
||||
["transaction_hash", "log_index"],
|
||||
unique=True,
|
||||
postgresql_where=sa.text("label='seer-raw' and label_type='event'"),
|
||||
)
|
||||
op.create_index(
|
||||
"uk_ronin_labels_tx_hash_tx_call",
|
||||
"ronin_labels",
|
||||
["transaction_hash"],
|
||||
unique=True,
|
||||
postgresql_where=sa.text("label='seer' and label_type='tx_call'"),
|
||||
)
|
||||
op.create_index(
|
||||
"uk_ronin_labels_tx_hash_tx_call_raw",
|
||||
"ronin_labels",
|
||||
["transaction_hash"],
|
||||
unique=True,
|
||||
postgresql_where=sa.text("label='seer-raw' and label_type='tx_call'"),
|
||||
)
|
||||
op.create_table(
|
||||
"ronin_saigon_labels",
|
||||
sa.Column("id", sa.UUID(), nullable=False),
|
||||
sa.Column("label", sa.VARCHAR(length=256), nullable=False),
|
||||
sa.Column("transaction_hash", sa.VARCHAR(length=128), nullable=False),
|
||||
sa.Column("log_index", sa.Integer(), nullable=True),
|
||||
sa.Column("block_number", sa.BigInteger(), nullable=False),
|
||||
sa.Column("block_hash", sa.VARCHAR(length=256), nullable=False),
|
||||
sa.Column("block_timestamp", sa.BigInteger(), nullable=False),
|
||||
sa.Column("caller_address", sa.LargeBinary(), nullable=True),
|
||||
sa.Column("origin_address", sa.LargeBinary(), nullable=True),
|
||||
sa.Column("address", sa.LargeBinary(), nullable=False),
|
||||
sa.Column("label_name", sa.Text(), nullable=True),
|
||||
sa.Column("label_type", sa.VARCHAR(length=64), nullable=True),
|
||||
sa.Column("label_data", postgresql.JSONB(astext_type=sa.Text()), nullable=True),
|
||||
sa.Column(
|
||||
"created_at",
|
||||
sa.DateTime(timezone=True),
|
||||
server_default=sa.text("TIMEZONE('utc', statement_timestamp())"),
|
||||
nullable=False,
|
||||
),
|
||||
sa.PrimaryKeyConstraint("id", name=op.f("pk_ronin_saigon_labels")),
|
||||
sa.UniqueConstraint("id", name=op.f("uq_ronin_saigon_labels_id")),
|
||||
)
|
||||
op.create_index(
|
||||
"ix_ronin_saigon_labels_addr_block_num",
|
||||
"ronin_saigon_labels",
|
||||
["address", "block_number"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
"ix_ronin_saigon_labels_addr_block_ts",
|
||||
"ronin_saigon_labels",
|
||||
["address", "block_timestamp"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_saigon_labels_address"),
|
||||
"ronin_saigon_labels",
|
||||
["address"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_saigon_labels_block_number"),
|
||||
"ronin_saigon_labels",
|
||||
["block_number"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_saigon_labels_caller_address"),
|
||||
"ronin_saigon_labels",
|
||||
["caller_address"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_saigon_labels_label"),
|
||||
"ronin_saigon_labels",
|
||||
["label"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_saigon_labels_label_name"),
|
||||
"ronin_saigon_labels",
|
||||
["label_name"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_saigon_labels_label_type"),
|
||||
"ronin_saigon_labels",
|
||||
["label_type"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_saigon_labels_origin_address"),
|
||||
"ronin_saigon_labels",
|
||||
["origin_address"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_saigon_labels_transaction_hash"),
|
||||
"ronin_saigon_labels",
|
||||
["transaction_hash"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
"uk_ronin_saigon_labels_tx_hash_log_idx_evt",
|
||||
"ronin_saigon_labels",
|
||||
["transaction_hash", "log_index"],
|
||||
unique=True,
|
||||
postgresql_where=sa.text("label='seer' and label_type='event'"),
|
||||
)
|
||||
op.create_index(
|
||||
"uk_ronin_saigon_labels_tx_hash_log_idx_evt_raw",
|
||||
"ronin_saigon_labels",
|
||||
["transaction_hash", "log_index"],
|
||||
unique=True,
|
||||
postgresql_where=sa.text("label='seer-raw' and label_type='event'"),
|
||||
)
|
||||
op.create_index(
|
||||
"uk_ronin_saigon_labels_tx_hash_tx_call",
|
||||
"ronin_saigon_labels",
|
||||
["transaction_hash"],
|
||||
unique=True,
|
||||
postgresql_where=sa.text("label='seer' and label_type='tx_call'"),
|
||||
)
|
||||
op.create_index(
|
||||
"uk_ronin_saigon_labels_tx_hash_tx_call_raw",
|
||||
"ronin_saigon_labels",
|
||||
["transaction_hash"],
|
||||
unique=True,
|
||||
postgresql_where=sa.text("label='seer-raw' and label_type='tx_call'"),
|
||||
)
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.drop_index(
|
||||
"uk_ronin_saigon_labels_tx_hash_tx_call_raw",
|
||||
table_name="ronin_saigon_labels",
|
||||
postgresql_where=sa.text("label='seer-raw' and label_type='tx_call'"),
|
||||
)
|
||||
op.drop_index(
|
||||
"uk_ronin_saigon_labels_tx_hash_tx_call",
|
||||
table_name="ronin_saigon_labels",
|
||||
postgresql_where=sa.text("label='seer' and label_type='tx_call'"),
|
||||
)
|
||||
op.drop_index(
|
||||
"uk_ronin_saigon_labels_tx_hash_log_idx_evt_raw",
|
||||
table_name="ronin_saigon_labels",
|
||||
postgresql_where=sa.text("label='seer-raw' and label_type='event'"),
|
||||
)
|
||||
op.drop_index(
|
||||
"uk_ronin_saigon_labels_tx_hash_log_idx_evt",
|
||||
table_name="ronin_saigon_labels",
|
||||
postgresql_where=sa.text("label='seer' and label_type='event'"),
|
||||
)
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_saigon_labels_transaction_hash"),
|
||||
table_name="ronin_saigon_labels",
|
||||
)
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_saigon_labels_origin_address"), table_name="ronin_saigon_labels"
|
||||
)
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_saigon_labels_label_type"), table_name="ronin_saigon_labels"
|
||||
)
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_saigon_labels_label_name"), table_name="ronin_saigon_labels"
|
||||
)
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_saigon_labels_label"), table_name="ronin_saigon_labels"
|
||||
)
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_saigon_labels_caller_address"), table_name="ronin_saigon_labels"
|
||||
)
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_saigon_labels_block_number"), table_name="ronin_saigon_labels"
|
||||
)
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_saigon_labels_address"), table_name="ronin_saigon_labels"
|
||||
)
|
||||
op.drop_index(
|
||||
"ix_ronin_saigon_labels_addr_block_ts", table_name="ronin_saigon_labels"
|
||||
)
|
||||
op.drop_index(
|
||||
"ix_ronin_saigon_labels_addr_block_num", table_name="ronin_saigon_labels"
|
||||
)
|
||||
op.drop_table("ronin_saigon_labels")
|
||||
op.drop_index(
|
||||
"uk_ronin_labels_tx_hash_tx_call_raw",
|
||||
table_name="ronin_labels",
|
||||
postgresql_where=sa.text("label='seer-raw' and label_type='tx_call'"),
|
||||
)
|
||||
op.drop_index(
|
||||
"uk_ronin_labels_tx_hash_tx_call",
|
||||
table_name="ronin_labels",
|
||||
postgresql_where=sa.text("label='seer' and label_type='tx_call'"),
|
||||
)
|
||||
op.drop_index(
|
||||
"uk_ronin_labels_tx_hash_log_idx_evt_raw",
|
||||
table_name="ronin_labels",
|
||||
postgresql_where=sa.text("label='seer-raw' and label_type='event'"),
|
||||
)
|
||||
op.drop_index(
|
||||
"uk_ronin_labels_tx_hash_log_idx_evt",
|
||||
table_name="ronin_labels",
|
||||
postgresql_where=sa.text("label='seer' and label_type='event'"),
|
||||
)
|
||||
op.drop_index(op.f("ix_ronin_labels_transaction_hash"), table_name="ronin_labels")
|
||||
op.drop_index(op.f("ix_ronin_labels_origin_address"), table_name="ronin_labels")
|
||||
op.drop_index(op.f("ix_ronin_labels_label_type"), table_name="ronin_labels")
|
||||
op.drop_index(op.f("ix_ronin_labels_label_name"), table_name="ronin_labels")
|
||||
op.drop_index(op.f("ix_ronin_labels_label"), table_name="ronin_labels")
|
||||
op.drop_index(op.f("ix_ronin_labels_caller_address"), table_name="ronin_labels")
|
||||
op.drop_index(op.f("ix_ronin_labels_block_number"), table_name="ronin_labels")
|
||||
op.drop_index(op.f("ix_ronin_labels_address"), table_name="ronin_labels")
|
||||
op.drop_index("ix_ronin_labels_addr_block_ts", table_name="ronin_labels")
|
||||
op.drop_index("ix_ronin_labels_addr_block_num", table_name="ronin_labels")
|
||||
op.drop_table("ronin_labels")
|
||||
# ### end Alembic commands ###
|
||||
|
|
@ -74,6 +74,12 @@ from moonstreamdbv3.models_indexes import (
|
|||
PolygonLogIndex,
|
||||
PolygonReorgs,
|
||||
PolygonTransactionIndex,
|
||||
RoninBlockIndex,
|
||||
RoninReorgs,
|
||||
RoninContracts,
|
||||
RoninSaigonBlockIndex,
|
||||
RoninSaigonReorgs,
|
||||
RoninSaigonContracts,
|
||||
XaiBlockIndex,
|
||||
XaiLogIndex,
|
||||
XaiReorgs,
|
||||
|
|
@ -143,6 +149,12 @@ def include_symbol(tablename, schema):
|
|||
B3Reorgs.__tablename__,
|
||||
B3SepoliaBlockIndex.__tablename__,
|
||||
B3SepoliaReorgs.__tablename__,
|
||||
RoninBlockIndex.__tablename__,
|
||||
RoninReorgs.__tablename__,
|
||||
RoninContracts.__tablename__,
|
||||
RoninSaigonBlockIndex.__tablename__,
|
||||
RoninSaigonReorgs.__tablename__,
|
||||
RoninSaigonContracts.__tablename__,
|
||||
}
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -0,0 +1,292 @@
|
|||
"""add ronin chain
|
||||
|
||||
Revision ID: 8610f3c98043
|
||||
Revises: 5ce23893771f
|
||||
Create Date: 2024-11-12 12:54:26.532910
|
||||
|
||||
"""
|
||||
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
from sqlalchemy.dialects import postgresql
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = "8610f3c98043"
|
||||
down_revision: Union[str, None] = "5ce23893771f"
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.create_table(
|
||||
"ronin_blocks",
|
||||
sa.Column("block_number", sa.BigInteger(), nullable=False),
|
||||
sa.Column("block_hash", sa.VARCHAR(length=256), nullable=False),
|
||||
sa.Column("block_timestamp", sa.BigInteger(), nullable=False),
|
||||
sa.Column("parent_hash", sa.VARCHAR(length=256), nullable=False),
|
||||
sa.Column("row_id", sa.BigInteger(), nullable=False),
|
||||
sa.Column("path", sa.Text(), nullable=False),
|
||||
sa.Column("transactions_indexed_at", sa.DateTime(timezone=True), nullable=True),
|
||||
sa.Column("logs_indexed_at", sa.DateTime(timezone=True), nullable=True),
|
||||
sa.Column(
|
||||
"indexed_at",
|
||||
sa.DateTime(timezone=True),
|
||||
server_default=sa.text("TIMEZONE('utc', statement_timestamp())"),
|
||||
nullable=False,
|
||||
),
|
||||
sa.PrimaryKeyConstraint("block_number", name=op.f("pk_ronin_blocks")),
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_blocks_block_number"),
|
||||
"ronin_blocks",
|
||||
["block_number"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_blocks_block_timestamp"),
|
||||
"ronin_blocks",
|
||||
["block_timestamp"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_table(
|
||||
"ronin_reorgs",
|
||||
sa.Column("id", sa.UUID(), nullable=False),
|
||||
sa.Column("block_number", sa.BigInteger(), nullable=False),
|
||||
sa.Column("block_hash", sa.VARCHAR(length=256), nullable=False),
|
||||
sa.PrimaryKeyConstraint("id", name=op.f("pk_ronin_reorgs")),
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_reorgs_block_hash"), "ronin_reorgs", ["block_hash"], unique=False
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_reorgs_block_number"),
|
||||
"ronin_reorgs",
|
||||
["block_number"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_table(
|
||||
"ronin_saigon_blocks",
|
||||
sa.Column("block_number", sa.BigInteger(), nullable=False),
|
||||
sa.Column("block_hash", sa.VARCHAR(length=256), nullable=False),
|
||||
sa.Column("block_timestamp", sa.BigInteger(), nullable=False),
|
||||
sa.Column("parent_hash", sa.VARCHAR(length=256), nullable=False),
|
||||
sa.Column("row_id", sa.BigInteger(), nullable=False),
|
||||
sa.Column("path", sa.Text(), nullable=False),
|
||||
sa.Column("transactions_indexed_at", sa.DateTime(timezone=True), nullable=True),
|
||||
sa.Column("logs_indexed_at", sa.DateTime(timezone=True), nullable=True),
|
||||
sa.Column(
|
||||
"indexed_at",
|
||||
sa.DateTime(timezone=True),
|
||||
server_default=sa.text("TIMEZONE('utc', statement_timestamp())"),
|
||||
nullable=False,
|
||||
),
|
||||
sa.PrimaryKeyConstraint("block_number", name=op.f("pk_ronin_saigon_blocks")),
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_saigon_blocks_block_number"),
|
||||
"ronin_saigon_blocks",
|
||||
["block_number"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_saigon_blocks_block_timestamp"),
|
||||
"ronin_saigon_blocks",
|
||||
["block_timestamp"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_table(
|
||||
"ronin_saigon_reorgs",
|
||||
sa.Column("id", sa.UUID(), nullable=False),
|
||||
sa.Column("block_number", sa.BigInteger(), nullable=False),
|
||||
sa.Column("block_hash", sa.VARCHAR(length=256), nullable=False),
|
||||
sa.PrimaryKeyConstraint("id", name=op.f("pk_ronin_saigon_reorgs")),
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_saigon_reorgs_block_hash"),
|
||||
"ronin_saigon_reorgs",
|
||||
["block_hash"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_saigon_reorgs_block_number"),
|
||||
"ronin_saigon_reorgs",
|
||||
["block_number"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_table(
|
||||
"ronin_contracts",
|
||||
sa.Column("address", sa.LargeBinary(length=20), nullable=False),
|
||||
sa.Column("deployed_by", sa.LargeBinary(length=20), nullable=False),
|
||||
sa.Column("deployed_bytecode", sa.Text(), nullable=False),
|
||||
sa.Column("deployed_bytecode_hash", sa.VARCHAR(length=32), nullable=False),
|
||||
sa.Column("bytecode_storage_id", sa.UUID(), nullable=True),
|
||||
sa.Column("abi", postgresql.JSONB(astext_type=sa.Text()), nullable=True),
|
||||
sa.Column("deployed_at_block_number", sa.BigInteger(), nullable=False),
|
||||
sa.Column("deployed_at_block_hash", sa.VARCHAR(length=256), nullable=False),
|
||||
sa.Column("deployed_at_block_timestamp", sa.BigInteger(), nullable=False),
|
||||
sa.Column("transaction_hash", sa.VARCHAR(length=256), nullable=False),
|
||||
sa.Column("transaction_index", sa.BigInteger(), nullable=False),
|
||||
sa.Column("name", sa.VARCHAR(length=256), nullable=True),
|
||||
sa.Column("statistics", postgresql.JSONB(astext_type=sa.Text()), nullable=True),
|
||||
sa.Column(
|
||||
"supported_standards",
|
||||
postgresql.JSONB(astext_type=sa.Text()),
|
||||
nullable=True,
|
||||
),
|
||||
sa.Column(
|
||||
"created_at",
|
||||
sa.DateTime(timezone=True),
|
||||
server_default=sa.text("TIMEZONE('utc', statement_timestamp())"),
|
||||
nullable=False,
|
||||
),
|
||||
sa.Column(
|
||||
"updated_at",
|
||||
sa.DateTime(timezone=True),
|
||||
server_default=sa.text("TIMEZONE('utc', statement_timestamp())"),
|
||||
nullable=False,
|
||||
),
|
||||
sa.ForeignKeyConstraint(
|
||||
["bytecode_storage_id"],
|
||||
["bytecode_storage.id"],
|
||||
name=op.f("fk_ronin_contracts_bytecode_storage_id_bytecode_storage"),
|
||||
),
|
||||
sa.PrimaryKeyConstraint("address", name=op.f("pk_ronin_contracts")),
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_contracts_deployed_by"),
|
||||
"ronin_contracts",
|
||||
["deployed_by"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_contracts_deployed_bytecode_hash"),
|
||||
"ronin_contracts",
|
||||
["deployed_bytecode_hash"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_contracts_name"), "ronin_contracts", ["name"], unique=False
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_contracts_transaction_hash"),
|
||||
"ronin_contracts",
|
||||
["transaction_hash"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_table(
|
||||
"ronin_saigon_contracts",
|
||||
sa.Column("address", sa.LargeBinary(length=20), nullable=False),
|
||||
sa.Column("deployed_by", sa.LargeBinary(length=20), nullable=False),
|
||||
sa.Column("deployed_bytecode", sa.Text(), nullable=False),
|
||||
sa.Column("deployed_bytecode_hash", sa.VARCHAR(length=32), nullable=False),
|
||||
sa.Column("bytecode_storage_id", sa.UUID(), nullable=True),
|
||||
sa.Column("abi", postgresql.JSONB(astext_type=sa.Text()), nullable=True),
|
||||
sa.Column("deployed_at_block_number", sa.BigInteger(), nullable=False),
|
||||
sa.Column("deployed_at_block_hash", sa.VARCHAR(length=256), nullable=False),
|
||||
sa.Column("deployed_at_block_timestamp", sa.BigInteger(), nullable=False),
|
||||
sa.Column("transaction_hash", sa.VARCHAR(length=256), nullable=False),
|
||||
sa.Column("transaction_index", sa.BigInteger(), nullable=False),
|
||||
sa.Column("name", sa.VARCHAR(length=256), nullable=True),
|
||||
sa.Column("statistics", postgresql.JSONB(astext_type=sa.Text()), nullable=True),
|
||||
sa.Column(
|
||||
"supported_standards",
|
||||
postgresql.JSONB(astext_type=sa.Text()),
|
||||
nullable=True,
|
||||
),
|
||||
sa.Column(
|
||||
"created_at",
|
||||
sa.DateTime(timezone=True),
|
||||
server_default=sa.text("TIMEZONE('utc', statement_timestamp())"),
|
||||
nullable=False,
|
||||
),
|
||||
sa.Column(
|
||||
"updated_at",
|
||||
sa.DateTime(timezone=True),
|
||||
server_default=sa.text("TIMEZONE('utc', statement_timestamp())"),
|
||||
nullable=False,
|
||||
),
|
||||
sa.ForeignKeyConstraint(
|
||||
["bytecode_storage_id"],
|
||||
["bytecode_storage.id"],
|
||||
name=op.f("fk_ronin_saigon_contracts_bytecode_storage_id_bytecode_storage"),
|
||||
),
|
||||
sa.PrimaryKeyConstraint("address", name=op.f("pk_ronin_saigon_contracts")),
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_saigon_contracts_deployed_by"),
|
||||
"ronin_saigon_contracts",
|
||||
["deployed_by"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_saigon_contracts_deployed_bytecode_hash"),
|
||||
"ronin_saigon_contracts",
|
||||
["deployed_bytecode_hash"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_saigon_contracts_name"),
|
||||
"ronin_saigon_contracts",
|
||||
["name"],
|
||||
unique=False,
|
||||
)
|
||||
op.create_index(
|
||||
op.f("ix_ronin_saigon_contracts_transaction_hash"),
|
||||
"ronin_saigon_contracts",
|
||||
["transaction_hash"],
|
||||
unique=False,
|
||||
)
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_saigon_contracts_transaction_hash"),
|
||||
table_name="ronin_saigon_contracts",
|
||||
)
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_saigon_contracts_name"), table_name="ronin_saigon_contracts"
|
||||
)
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_saigon_contracts_deployed_bytecode_hash"),
|
||||
table_name="ronin_saigon_contracts",
|
||||
)
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_saigon_contracts_deployed_by"),
|
||||
table_name="ronin_saigon_contracts",
|
||||
)
|
||||
op.drop_table("ronin_saigon_contracts")
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_contracts_transaction_hash"), table_name="ronin_contracts"
|
||||
)
|
||||
op.drop_index(op.f("ix_ronin_contracts_name"), table_name="ronin_contracts")
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_contracts_deployed_bytecode_hash"), table_name="ronin_contracts"
|
||||
)
|
||||
op.drop_index(op.f("ix_ronin_contracts_deployed_by"), table_name="ronin_contracts")
|
||||
op.drop_table("ronin_contracts")
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_saigon_reorgs_block_number"), table_name="ronin_saigon_reorgs"
|
||||
)
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_saigon_reorgs_block_hash"), table_name="ronin_saigon_reorgs"
|
||||
)
|
||||
op.drop_table("ronin_saigon_reorgs")
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_saigon_blocks_block_timestamp"), table_name="ronin_saigon_blocks"
|
||||
)
|
||||
op.drop_index(
|
||||
op.f("ix_ronin_saigon_blocks_block_number"), table_name="ronin_saigon_blocks"
|
||||
)
|
||||
op.drop_table("ronin_saigon_blocks")
|
||||
op.drop_index(op.f("ix_ronin_reorgs_block_number"), table_name="ronin_reorgs")
|
||||
op.drop_index(op.f("ix_ronin_reorgs_block_hash"), table_name="ronin_reorgs")
|
||||
op.drop_table("ronin_reorgs")
|
||||
op.drop_index(op.f("ix_ronin_blocks_block_timestamp"), table_name="ronin_blocks")
|
||||
op.drop_index(op.f("ix_ronin_blocks_block_number"), table_name="ronin_blocks")
|
||||
op.drop_table("ronin_blocks")
|
||||
# ### end Alembic commands ###
|
||||
|
|
@ -1472,3 +1472,93 @@ class B3SepoliaLabel(EvmBasedLabel): # type: ignore
|
|||
postgresql_where=text("label='seer-raw' and label_type='event'"),
|
||||
),
|
||||
)
|
||||
|
||||
|
||||
class RoninLabel(EvmBasedLabel): # type: ignore
|
||||
__tablename__ = "ronin_labels"
|
||||
|
||||
__table_args__ = (
|
||||
Index(
|
||||
"ix_ronin_labels_addr_block_num",
|
||||
"address",
|
||||
"block_number",
|
||||
unique=False,
|
||||
),
|
||||
Index(
|
||||
"ix_ronin_labels_addr_block_ts",
|
||||
"address",
|
||||
"block_timestamp",
|
||||
unique=False,
|
||||
),
|
||||
Index(
|
||||
"uk_ronin_labels_tx_hash_tx_call",
|
||||
"transaction_hash",
|
||||
unique=True,
|
||||
postgresql_where=text("label='seer' and label_type='tx_call'"),
|
||||
),
|
||||
Index(
|
||||
"uk_ronin_labels_tx_hash_log_idx_evt",
|
||||
"transaction_hash",
|
||||
"log_index",
|
||||
unique=True,
|
||||
postgresql_where=text("label='seer' and label_type='event'"),
|
||||
),
|
||||
Index(
|
||||
"uk_ronin_labels_tx_hash_tx_call_raw",
|
||||
"transaction_hash",
|
||||
unique=True,
|
||||
postgresql_where=text("label='seer-raw' and label_type='tx_call'"),
|
||||
),
|
||||
Index(
|
||||
"uk_ronin_labels_tx_hash_log_idx_evt_raw",
|
||||
"transaction_hash",
|
||||
"log_index",
|
||||
unique=True,
|
||||
postgresql_where=text("label='seer-raw' and label_type='event'"),
|
||||
),
|
||||
)
|
||||
|
||||
|
||||
class RoninSaigonLabel(EvmBasedLabel): # type: ignore
|
||||
__tablename__ = "ronin_saigon_labels"
|
||||
|
||||
__table_args__ = (
|
||||
Index(
|
||||
"ix_ronin_saigon_labels_addr_block_num",
|
||||
"address",
|
||||
"block_number",
|
||||
unique=False,
|
||||
),
|
||||
Index(
|
||||
"ix_ronin_saigon_labels_addr_block_ts",
|
||||
"address",
|
||||
"block_timestamp",
|
||||
unique=False,
|
||||
),
|
||||
Index(
|
||||
"uk_ronin_saigon_labels_tx_hash_tx_call",
|
||||
"transaction_hash",
|
||||
unique=True,
|
||||
postgresql_where=text("label='seer' and label_type='tx_call'"),
|
||||
),
|
||||
Index(
|
||||
"uk_ronin_saigon_labels_tx_hash_log_idx_evt",
|
||||
"transaction_hash",
|
||||
"log_index",
|
||||
unique=True,
|
||||
postgresql_where=text("label='seer' and label_type='event'"),
|
||||
),
|
||||
Index(
|
||||
"uk_ronin_saigon_labels_tx_hash_tx_call_raw",
|
||||
"transaction_hash",
|
||||
unique=True,
|
||||
postgresql_where=text("label='seer-raw' and label_type='tx_call'"),
|
||||
),
|
||||
Index(
|
||||
"uk_ronin_saigon_labels_tx_hash_log_idx_evt_raw",
|
||||
"transaction_hash",
|
||||
"log_index",
|
||||
unique=True,
|
||||
postgresql_where=text("label='seer-raw' and label_type='event'"),
|
||||
),
|
||||
)
|
||||
|
|
|
|||
|
|
@ -904,6 +904,30 @@ class B3SepoliaContracts(evmBasedContracts):
|
|||
__tablename__ = "b3_sepolia_contracts"
|
||||
|
||||
|
||||
class RoninBlockIndex(EvmBasedBlocks):
|
||||
__tablename__ = "ronin_blocks"
|
||||
|
||||
|
||||
class RoninReorgs(EvmBasedReorgs):
|
||||
__tablename__ = "ronin_reorgs"
|
||||
|
||||
|
||||
class RoninContracts(evmBasedContracts):
|
||||
__tablename__ = "ronin_contracts"
|
||||
|
||||
|
||||
class RoninSaigonBlockIndex(EvmBasedBlocks):
|
||||
__tablename__ = "ronin_saigon_blocks"
|
||||
|
||||
|
||||
class RoninSaigonReorgs(EvmBasedReorgs):
|
||||
__tablename__ = "ronin_saigon_reorgs"
|
||||
|
||||
|
||||
class RoninSaigonContracts(evmBasedContracts):
|
||||
__tablename__ = "ronin_saigon_contracts"
|
||||
|
||||
|
||||
### ABI Jobs
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -1 +1 @@
|
|||
0.1.1
|
||||
0.1.2
|
||||
|
|
|
|||
Ładowanie…
Reference in New Issue