Sync from GitHub via hub-sync

api/auth-service/alembic/versions/0006_create_refresh_tokens.py

@@ -0,0 +1,59 @@
+from alembic import op
+import sqlalchemy as sa
+
+revision = "0006_create_refresh_tokens"
+down_revision = "0005_create_email_verification_codes"
+branch_labels = None
+depends_on = None
+
+
+def upgrade() -> None:
+    op.create_table(
+        "refresh_tokens",
+        sa.Column("id", sa.Integer(), primary_key=True),
+        sa.Column("user_id", sa.Integer(), nullable=False),
+        sa.Column("token_hash", sa.String(length=64), nullable=False),
+        sa.Column("expires_at", sa.DateTime(timezone=True), nullable=False),
+        sa.Column("revoked_at", sa.DateTime(timezone=True), nullable=True),
+        sa.Column(
+            "created_at",
+            sa.DateTime(timezone=True),
+            nullable=False,
+            server_default=sa.text("now()"),
+        ),
+        sa.ForeignKeyConstraint(["user_id"], ["users.id"], ondelete="CASCADE"),
+    )
+    op.create_index(
+        "ix_refresh_tokens_user_id",
+        "refresh_tokens",
+        ["user_id"],
+        unique=False,
+    )
+    op.create_index(
+        "ix_refresh_tokens_token_hash",
+        "refresh_tokens",
+        ["token_hash"],
+        unique=True,
+    )
+    op.create_index(
+        "ix_refresh_tokens_expires_at",
+        "refresh_tokens",
+        ["expires_at"],
+        unique=False,
+    )
+
+
+def downgrade() -> None:
+    op.drop_index(
+        "ix_refresh_tokens_expires_at",
+        table_name="refresh_tokens",
+    )
+    op.drop_index(
+        "ix_refresh_tokens_token_hash",
+        table_name="refresh_tokens",
+    )
+    op.drop_index(
+        "ix_refresh_tokens_user_id",
+        table_name="refresh_tokens",
+    )
+    op.drop_table("refresh_tokens")

api/auth-service/alembic/versions/0007_create_community_tables.py

@@ -0,0 +1,221 @@
+from alembic import op
+import sqlalchemy as sa
+from sqlalchemy.dialects import postgresql
+
+revision = "0007_create_community_tables"
+down_revision = "0006_create_refresh_tokens"
+branch_labels = None
+depends_on = None
+
+
+def _constraint_exists(bind, table_name: str, constraint_name: str) -> bool:
+    row = bind.execute(
+        sa.text(
+            """
+            SELECT 1
+            FROM pg_constraint c
+            JOIN pg_class t ON t.oid = c.conrelid
+            JOIN pg_namespace n ON n.oid = t.relnamespace
+            WHERE n.nspname = current_schema()
+              AND t.relname = :table_name
+              AND c.conname = :constraint_name
+            LIMIT 1
+            """
+        ),
+        {"table_name": table_name, "constraint_name": constraint_name},
+    ).first()
+    return row is not None
+
+
+def upgrade() -> None:
+    bind = op.get_bind()
+    inspector = sa.inspect(bind)
+
+    if not inspector.has_table("community_posts"):
+        op.create_table(
+            "community_posts",
+            sa.Column("id", sa.BigInteger(), primary_key=True),
+            sa.Column("user_id", sa.Integer(), nullable=False),
+            sa.Column("run_session_id", sa.BigInteger(), nullable=True),
+            sa.Column("route_id", sa.BigInteger(), nullable=True),
+            sa.Column("title", sa.String(length=255), nullable=False),
+            sa.Column("content", sa.Text(), nullable=False),
+            sa.Column(
+                "visibility",
+                sa.String(length=20),
+                nullable=False,
+                server_default=sa.text("'public'"),
+            ),
+            sa.Column("difficulty", sa.String(length=50), nullable=True),
+            sa.Column(
+                "tags",
+                postgresql.JSONB(astext_type=sa.Text()),
+                nullable=False,
+                server_default=sa.text("'[]'::jsonb"),
+            ),
+            sa.Column("like_count", sa.Integer(), nullable=False, server_default=sa.text("0")),
+            sa.Column("comment_count", sa.Integer(), nullable=False, server_default=sa.text("0")),
+            sa.Column("view_count", sa.Integer(), nullable=False, server_default=sa.text("0")),
+            sa.Column(
+                "created_at",
+                sa.DateTime(timezone=True),
+                nullable=False,
+                server_default=sa.text("now()"),
+            ),
+            sa.Column(
+                "updated_at",
+                sa.DateTime(timezone=True),
+                nullable=False,
+                server_default=sa.text("now()"),
+            ),
+            sa.CheckConstraint(
+                "(run_session_id IS NOT NULL) OR (route_id IS NOT NULL)",
+                name="chk_post_target",
+            ),
+            sa.CheckConstraint(
+                "visibility IN ('public', 'private')",
+                name="ck_community_posts_visibility",
+            ),
+            sa.CheckConstraint(
+                "like_count >= 0",
+                name="ck_community_posts_like_count_non_negative",
+            ),
+            sa.CheckConstraint(
+                "comment_count >= 0",
+                name="ck_community_posts_comment_count_non_negative",
+            ),
+            sa.CheckConstraint(
+                "view_count >= 0",
+                name="ck_community_posts_view_count_non_negative",
+            ),
+            sa.CheckConstraint(
+                "jsonb_typeof(tags) = 'array'",
+                name="ck_community_posts_tags_is_array",
+            ),
+            sa.ForeignKeyConstraint(["user_id"], ["users.id"], ondelete="CASCADE"),
+            sa.ForeignKeyConstraint(["run_session_id"], ["run_sessions.id"], ondelete="SET NULL"),
+            sa.ForeignKeyConstraint(["route_id"], ["routes.id"], ondelete="SET NULL"),
+        )
+
+    inspector = sa.inspect(bind)
+    post_columns = {column["name"] for column in inspector.get_columns("community_posts")}
+
+    if "difficulty" not in post_columns:
+        op.add_column("community_posts", sa.Column("difficulty", sa.String(length=50), nullable=True))
+
+    if "tags" not in post_columns:
+        op.add_column(
+            "community_posts",
+            sa.Column(
+                "tags",
+                postgresql.JSONB(astext_type=sa.Text()),
+                nullable=False,
+                server_default=sa.text("'[]'::jsonb"),
+            ),
+        )
+
+    if "view_count" not in post_columns:
+        op.add_column(
+            "community_posts",
+            sa.Column(
+                "view_count",
+                sa.Integer(),
+                nullable=False,
+                server_default=sa.text("0"),
+            ),
+        )
+
+    if not _constraint_exists(bind, "community_posts", "ck_community_posts_view_count_non_negative"):
+        op.create_check_constraint(
+            "ck_community_posts_view_count_non_negative",
+            "community_posts",
+            "view_count >= 0",
+        )
+
+    if not _constraint_exists(bind, "community_posts", "ck_community_posts_tags_is_array"):
+        op.create_check_constraint(
+            "ck_community_posts_tags_is_array",
+            "community_posts",
+            "jsonb_typeof(tags) = 'array'",
+        )
+
+    op.execute("CREATE INDEX IF NOT EXISTS idx_community_posts_user ON community_posts (user_id)")
+    op.execute("CREATE INDEX IF NOT EXISTS idx_community_posts_route ON community_posts (route_id)")
+    op.execute(
+        "CREATE INDEX IF NOT EXISTS idx_community_posts_run_session ON community_posts (run_session_id)"
+    )
+    op.execute(
+        "CREATE INDEX IF NOT EXISTS idx_community_posts_created_at "
+        "ON community_posts (created_at DESC)"
+    )
+    op.execute(
+        "CREATE INDEX IF NOT EXISTS idx_community_posts_visibility_created "
+        "ON community_posts (visibility, created_at DESC)"
+    )
+
+    if not inspector.has_table("community_reactions"):
+        op.create_table(
+            "community_reactions",
+            sa.Column("id", sa.BigInteger(), primary_key=True),
+            sa.Column("post_id", sa.BigInteger(), nullable=False),
+            sa.Column("user_id", sa.Integer(), nullable=False),
+            sa.Column("reaction_type", sa.String(length=20), nullable=False),
+            sa.Column("comment_text", sa.Text(), nullable=True),
+            sa.Column(
+                "created_at",
+                sa.DateTime(timezone=True),
+                nullable=False,
+                server_default=sa.text("now()"),
+            ),
+            sa.CheckConstraint(
+                "reaction_type IN ('like', 'comment')",
+                name="ck_community_reactions_type",
+            ),
+            sa.CheckConstraint(
+                "(reaction_type = 'like' AND comment_text IS NULL) OR "
+                "(reaction_type = 'comment' AND char_length(trim(comment_text)) > 0)",
+                name="ck_community_reactions_comment_text",
+            ),
+            sa.ForeignKeyConstraint(["post_id"], ["community_posts.id"], ondelete="CASCADE"),
+            sa.ForeignKeyConstraint(["user_id"], ["users.id"], ondelete="CASCADE"),
+        )
+
+    op.execute(
+        "CREATE INDEX IF NOT EXISTS idx_community_reactions_post_created "
+        "ON community_reactions (post_id, created_at DESC)"
+    )
+    op.execute("CREATE INDEX IF NOT EXISTS idx_community_reactions_user ON community_reactions (user_id)")
+    op.execute(
+        "CREATE INDEX IF NOT EXISTS idx_community_reactions_post_type_created "
+        "ON community_reactions (post_id, reaction_type, created_at DESC)"
+    )
+    op.execute(
+        "CREATE UNIQUE INDEX IF NOT EXISTS uq_community_reactions_like_once "
+        "ON community_reactions (post_id, user_id) WHERE reaction_type = 'like'"
+    )
+
+
+def downgrade() -> None:
+    bind = op.get_bind()
+    inspector = sa.inspect(bind)
+
+    op.execute("DROP INDEX IF EXISTS uq_community_reactions_like_once")
+    op.execute("DROP INDEX IF EXISTS idx_community_reactions_post_type_created")
+
+    if inspector.has_table("community_posts"):
+        if _constraint_exists(bind, "community_posts", "ck_community_posts_tags_is_array"):
+            op.drop_constraint(
+                "ck_community_posts_tags_is_array",
+                "community_posts",
+                type_="check",
+            )
+        if _constraint_exists(bind, "community_posts", "ck_community_posts_view_count_non_negative"):
+            op.drop_constraint(
+                "ck_community_posts_view_count_non_negative",
+                "community_posts",
+                type_="check",
+            )
+
+        op.execute("ALTER TABLE community_posts DROP COLUMN IF EXISTS view_count")
+        op.execute("ALTER TABLE community_posts DROP COLUMN IF EXISTS tags")
+        op.execute("ALTER TABLE community_posts DROP COLUMN IF EXISTS difficulty")