From 3bd8a68bd7649197b42e9fe3dc0bd975bf2765d3 Mon Sep 17 00:00:00 2001 From: Andrey Date: Wed, 17 Apr 2024 04:14:36 +0300 Subject: [PATCH] Add migration file. --- ...1d9fab5f904_proofofplay_apex_blockchain.py | 285 ++++++++++++++++++ 1 file changed, 285 insertions(+) create mode 100644 moonstreamdb/alembic/versions/a1d9fab5f904_proofofplay_apex_blockchain.py diff --git a/moonstreamdb/alembic/versions/a1d9fab5f904_proofofplay_apex_blockchain.py b/moonstreamdb/alembic/versions/a1d9fab5f904_proofofplay_apex_blockchain.py new file mode 100644 index 00000000..140e871a --- /dev/null +++ b/moonstreamdb/alembic/versions/a1d9fab5f904_proofofplay_apex_blockchain.py @@ -0,0 +1,285 @@ +"""ProofOfPlay Apex blockchain + +Revision ID: a1d9fab5f904 +Revises: c8eaa4ff9d76 +Create Date: 2024-04-17 02:35:52.418934 + +""" + +from alembic import op +import sqlalchemy as sa +from sqlalchemy.dialects import postgresql + +# revision identifiers, used by Alembic. +revision = "a1d9fab5f904" +down_revision = "c8eaa4ff9d76" +branch_labels = None +depends_on = None + + +def upgrade(): + # ### commands auto generated by Alembic - please adjust! ### + op.create_table( + "proofofplay_apex_blocks", + sa.Column("block_number", sa.BigInteger(), nullable=False), + sa.Column("difficulty", sa.BigInteger(), nullable=True), + sa.Column("extra_data", sa.VARCHAR(length=128), nullable=True), + sa.Column("gas_limit", sa.BigInteger(), nullable=True), + sa.Column("gas_used", sa.BigInteger(), nullable=True), + sa.Column("base_fee_per_gas", sa.Numeric(precision=78, scale=0), nullable=True), + sa.Column("hash", sa.VARCHAR(length=256), nullable=True), + sa.Column("logs_bloom", sa.VARCHAR(length=1024), nullable=True), + sa.Column("miner", sa.VARCHAR(length=256), nullable=True), + sa.Column("nonce", sa.VARCHAR(length=256), nullable=True), + sa.Column("parent_hash", sa.VARCHAR(length=256), nullable=True), + sa.Column("receipt_root", sa.VARCHAR(length=256), nullable=True), + sa.Column("uncles", sa.VARCHAR(length=256), nullable=True), + sa.Column("size", sa.Integer(), nullable=True), + sa.Column("state_root", sa.VARCHAR(length=256), nullable=True), + sa.Column("timestamp", sa.BigInteger(), nullable=True), + sa.Column("total_difficulty", sa.VARCHAR(length=256), nullable=True), + sa.Column("transactions_root", sa.VARCHAR(length=256), nullable=True), + sa.Column( + "indexed_at", + sa.DateTime(timezone=True), + server_default=sa.text("TIMEZONE('utc', statement_timestamp())"), + nullable=False, + ), + sa.Column("sha3_uncles", sa.VARCHAR(length=256), nullable=True), + sa.Column("l1_block_number", sa.BigInteger(), nullable=True), + sa.Column("send_count", sa.BigInteger(), nullable=True), + sa.Column("send_root", sa.VARCHAR(length=256), nullable=True), + sa.Column("mix_hash", sa.VARCHAR(length=256), nullable=True), + sa.PrimaryKeyConstraint( + "block_number", name=op.f("pk_proofofplay_apex_blocks") + ), + ) + op.create_index( + op.f("ix_proofofplay_apex_blocks_block_number"), + "proofofplay_apex_blocks", + ["block_number"], + unique=True, + ) + op.create_index( + op.f("ix_proofofplay_apex_blocks_hash"), + "proofofplay_apex_blocks", + ["hash"], + unique=False, + ) + op.create_index( + op.f("ix_proofofplay_apex_blocks_timestamp"), + "proofofplay_apex_blocks", + ["timestamp"], + unique=False, + ) + op.create_table( + "proofofplay_apex_labels", + sa.Column("id", sa.UUID(), nullable=False), + sa.Column("label", sa.VARCHAR(length=256), nullable=False), + sa.Column("block_number", sa.BigInteger(), nullable=True), + sa.Column("address", sa.VARCHAR(length=256), nullable=True), + sa.Column("transaction_hash", sa.VARCHAR(length=256), nullable=True), + sa.Column("label_data", postgresql.JSONB(astext_type=sa.Text()), nullable=True), + sa.Column("block_timestamp", sa.BigInteger(), nullable=True), + sa.Column("log_index", sa.Integer(), 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_proofofplay_apex_labels")), + sa.UniqueConstraint("id", name=op.f("uq_proofofplay_apex_labels_id")), + ) + op.create_index( + op.f("ix_proofofplay_apex_labels_address"), + "proofofplay_apex_labels", + ["address"], + unique=False, + ) + op.create_index( + "ix_proofofplay_apex_labels_address_block_number", + "proofofplay_apex_labels", + ["address", "block_number"], + unique=False, + ) + op.create_index( + "ix_proofofplay_apex_labels_address_block_timestamp", + "proofofplay_apex_labels", + ["address", "block_timestamp"], + unique=False, + ) + op.create_index( + op.f("ix_proofofplay_apex_labels_block_number"), + "proofofplay_apex_labels", + ["block_number"], + unique=False, + ) + op.create_index( + op.f("ix_proofofplay_apex_labels_block_timestamp"), + "proofofplay_apex_labels", + ["block_timestamp"], + unique=False, + ) + op.create_index( + op.f("ix_proofofplay_apex_labels_label"), + "proofofplay_apex_labels", + ["label"], + unique=False, + ) + op.create_index( + op.f("ix_proofofplay_apex_labels_transaction_hash"), + "proofofplay_apex_labels", + ["transaction_hash"], + unique=False, + ) + op.create_table( + "proofofplay_apex_transactions", + sa.Column("hash", sa.VARCHAR(length=256), nullable=False), + sa.Column("block_number", sa.BigInteger(), nullable=False), + sa.Column("from_address", sa.VARCHAR(length=256), nullable=True), + sa.Column("to_address", sa.VARCHAR(length=256), nullable=True), + sa.Column("gas", sa.Numeric(precision=78, scale=0), nullable=True), + sa.Column("gas_price", sa.Numeric(precision=78, scale=0), nullable=True), + sa.Column("max_fee_per_gas", sa.Numeric(precision=78, scale=0), nullable=True), + sa.Column( + "max_priority_fee_per_gas", sa.Numeric(precision=78, scale=0), nullable=True + ), + sa.Column("input", sa.Text(), nullable=True), + sa.Column("nonce", sa.VARCHAR(length=256), nullable=True), + sa.Column("transaction_index", sa.BigInteger(), nullable=True), + sa.Column("transaction_type", sa.Integer(), nullable=True), + sa.Column("value", sa.Numeric(precision=78, scale=0), nullable=True), + sa.Column( + "indexed_at", + sa.DateTime(timezone=True), + server_default=sa.text("TIMEZONE('utc', statement_timestamp())"), + nullable=False, + ), + sa.Column("y_parity", sa.BigInteger(), nullable=True), + sa.ForeignKeyConstraint( + ["block_number"], + ["proofofplay_apex_blocks.block_number"], + name=op.f( + "fk_proofofplay_apex_transactions_block_number_proofofplay_apex_blocks" + ), + ondelete="CASCADE", + ), + sa.PrimaryKeyConstraint("hash", name=op.f("pk_proofofplay_apex_transactions")), + ) + op.create_index( + op.f("ix_proofofplay_apex_transactions_block_number"), + "proofofplay_apex_transactions", + ["block_number"], + unique=False, + ) + op.create_index( + op.f("ix_proofofplay_apex_transactions_from_address"), + "proofofplay_apex_transactions", + ["from_address"], + unique=False, + ) + op.create_index( + op.f("ix_proofofplay_apex_transactions_gas"), + "proofofplay_apex_transactions", + ["gas"], + unique=False, + ) + op.create_index( + op.f("ix_proofofplay_apex_transactions_gas_price"), + "proofofplay_apex_transactions", + ["gas_price"], + unique=False, + ) + op.create_index( + op.f("ix_proofofplay_apex_transactions_hash"), + "proofofplay_apex_transactions", + ["hash"], + unique=True, + ) + op.create_index( + op.f("ix_proofofplay_apex_transactions_to_address"), + "proofofplay_apex_transactions", + ["to_address"], + unique=False, + ) + op.create_index( + op.f("ix_proofofplay_apex_transactions_value"), + "proofofplay_apex_transactions", + ["value"], + unique=False, + ) + # ### end Alembic commands ### + + +def downgrade(): + # ### commands auto generated by Alembic - please adjust! ### + op.drop_index( + op.f("ix_proofofplay_apex_transactions_value"), + table_name="proofofplay_apex_transactions", + ) + op.drop_index( + op.f("ix_proofofplay_apex_transactions_to_address"), + table_name="proofofplay_apex_transactions", + ) + op.drop_index( + op.f("ix_proofofplay_apex_transactions_hash"), + table_name="proofofplay_apex_transactions", + ) + op.drop_index( + op.f("ix_proofofplay_apex_transactions_gas_price"), + table_name="proofofplay_apex_transactions", + ) + op.drop_index( + op.f("ix_proofofplay_apex_transactions_gas"), + table_name="proofofplay_apex_transactions", + ) + op.drop_index( + op.f("ix_proofofplay_apex_transactions_from_address"), + table_name="proofofplay_apex_transactions", + ) + op.drop_index( + op.f("ix_proofofplay_apex_transactions_block_number"), + table_name="proofofplay_apex_transactions", + ) + op.drop_table("proofofplay_apex_transactions") + op.drop_index( + op.f("ix_proofofplay_apex_labels_transaction_hash"), + table_name="proofofplay_apex_labels", + ) + op.drop_index( + op.f("ix_proofofplay_apex_labels_label"), table_name="proofofplay_apex_labels" + ) + op.drop_index( + op.f("ix_proofofplay_apex_labels_block_timestamp"), + table_name="proofofplay_apex_labels", + ) + op.drop_index( + op.f("ix_proofofplay_apex_labels_block_number"), + table_name="proofofplay_apex_labels", + ) + op.drop_index( + "ix_proofofplay_apex_labels_address_block_timestamp", + table_name="proofofplay_apex_labels", + ) + op.drop_index( + "ix_proofofplay_apex_labels_address_block_number", + table_name="proofofplay_apex_labels", + ) + op.drop_index( + op.f("ix_proofofplay_apex_labels_address"), table_name="proofofplay_apex_labels" + ) + op.drop_table("proofofplay_apex_labels") + op.drop_index( + op.f("ix_proofofplay_apex_blocks_timestamp"), + table_name="proofofplay_apex_blocks", + ) + op.drop_index( + op.f("ix_proofofplay_apex_blocks_hash"), table_name="proofofplay_apex_blocks" + ) + op.drop_index( + op.f("ix_proofofplay_apex_blocks_block_number"), + table_name="proofofplay_apex_blocks", + ) + op.drop_table("proofofplay_apex_blocks") + # ### end Alembic commands ###