From 3b0495fe5e7310fb42c130fd83cf56f46d8305ce Mon Sep 17 00:00:00 2001 From: Andrey Date: Thu, 11 Jul 2024 13:17:45 +0300 Subject: [PATCH] Add topic 3. --- .../versions/27086791044c_add_topic_3.py | 68 +++++++++++++++++++ .../moonstreamdbv3/models_indexes.py | 1 + moonstreamdb-v3/moonstreamdbv3/version.txt | 2 +- 3 files changed, 70 insertions(+), 1 deletion(-) create mode 100644 moonstreamdb-v3/moonstreamdbv3/alembic_indexes/versions/27086791044c_add_topic_3.py diff --git a/moonstreamdb-v3/moonstreamdbv3/alembic_indexes/versions/27086791044c_add_topic_3.py b/moonstreamdb-v3/moonstreamdbv3/alembic_indexes/versions/27086791044c_add_topic_3.py new file mode 100644 index 00000000..6a61eb3e --- /dev/null +++ b/moonstreamdb-v3/moonstreamdbv3/alembic_indexes/versions/27086791044c_add_topic_3.py @@ -0,0 +1,68 @@ +"""Add topic 3 + +Revision ID: 27086791044c +Revises: e02c90ea67bb +Create Date: 2024-07-11 13:15:45.273275 + +""" + +from typing import Sequence, Union + +from alembic import op +import sqlalchemy as sa + + +# revision identifiers, used by Alembic. +revision: str = "27086791044c" +down_revision: Union[str, None] = "e02c90ea67bb" +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.add_column( + "arbitrum_one_logs", sa.Column("topic3", sa.VARCHAR(length=256), nullable=True) + ) + op.add_column( + "arbitrum_sepolia_logs", + sa.Column("topic3", sa.VARCHAR(length=256), nullable=True), + ) + op.add_column( + "ethereum_logs", sa.Column("topic3", sa.VARCHAR(length=256), nullable=True) + ) + op.add_column( + "game7_orbit_arbitrum_sepolia_logs", + sa.Column("topic3", sa.VARCHAR(length=256), nullable=True), + ) + op.add_column( + "mantle_logs", sa.Column("topic3", sa.VARCHAR(length=256), nullable=True) + ) + op.add_column( + "mantle_sepolia_logs", + sa.Column("topic3", sa.VARCHAR(length=256), nullable=True), + ) + op.add_column( + "polygon_logs", sa.Column("topic3", sa.VARCHAR(length=256), nullable=True) + ) + op.add_column( + "xai_logs", sa.Column("topic3", sa.VARCHAR(length=256), nullable=True) + ) + op.add_column( + "xai_sepolia_logs", sa.Column("topic3", sa.VARCHAR(length=256), nullable=True) + ) + # ### end Alembic commands ### + + +def downgrade() -> None: + # ### commands auto generated by Alembic - please adjust! ### + op.drop_column("xai_sepolia_logs", "topic3") + op.drop_column("xai_logs", "topic3") + op.drop_column("polygon_logs", "topic3") + op.drop_column("mantle_sepolia_logs", "topic3") + op.drop_column("mantle_logs", "topic3") + op.drop_column("game7_orbit_arbitrum_sepolia_logs", "topic3") + op.drop_column("ethereum_logs", "topic3") + op.drop_column("arbitrum_sepolia_logs", "topic3") + op.drop_column("arbitrum_one_logs", "topic3") + # ### end Alembic commands ### diff --git a/moonstreamdb-v3/moonstreamdbv3/models_indexes.py b/moonstreamdb-v3/moonstreamdbv3/models_indexes.py index 3ac1bcfe..254bdba5 100644 --- a/moonstreamdb-v3/moonstreamdbv3/models_indexes.py +++ b/moonstreamdb-v3/moonstreamdbv3/models_indexes.py @@ -86,6 +86,7 @@ class EvmBasedLogs(Base): selector = Column(VARCHAR(256), nullable=True, index=False) topic1 = Column(VARCHAR(256), nullable=True, index=False) topic2 = Column(VARCHAR(256), nullable=True, index=False) + topic3 = Column(VARCHAR(256), nullable=True, index=False) log_index = Column(BigInteger, nullable=False, index=False) path = Column(Text, nullable=False) indexed_at = Column( diff --git a/moonstreamdb-v3/moonstreamdbv3/version.txt b/moonstreamdb-v3/moonstreamdbv3/version.txt index 2cfabea2..8cbf02c3 100644 --- a/moonstreamdb-v3/moonstreamdbv3/version.txt +++ b/moonstreamdb-v3/moonstreamdbv3/version.txt @@ -1 +1 @@ -0.0.11 +0.0.12