57c599a3cb57_add_channel_table.py 1.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. """Add channel table
  2. Revision ID: 57c599a3cb57
  3. Revises: 922e7a387820
  4. Create Date: 2024-12-22 03:00:00.000000
  5. """
  6. from alembic import op
  7. import sqlalchemy as sa
  8. revision = "57c599a3cb57"
  9. down_revision = "922e7a387820"
  10. branch_labels = None
  11. depends_on = None
  12. def upgrade():
  13. op.create_table(
  14. "channel",
  15. sa.Column("id", sa.Text(), nullable=False, primary_key=True, unique=True),
  16. sa.Column("user_id", sa.Text()),
  17. sa.Column("name", sa.Text()),
  18. sa.Column("description", sa.Text(), nullable=True),
  19. sa.Column("data", sa.JSON(), nullable=True),
  20. sa.Column("meta", sa.JSON(), nullable=True),
  21. sa.Column("access_control", sa.JSON(), nullable=True),
  22. sa.Column("created_at", sa.BigInteger(), nullable=True),
  23. sa.Column("updated_at", sa.BigInteger(), nullable=True),
  24. )
  25. op.create_table(
  26. "message",
  27. sa.Column("id", sa.Text(), nullable=False, primary_key=True, unique=True),
  28. sa.Column("user_id", sa.Text()),
  29. sa.Column("channel_id", sa.Text(), nullable=True),
  30. sa.Column("content", sa.Text()),
  31. sa.Column("data", sa.JSON(), nullable=True),
  32. sa.Column("meta", sa.JSON(), nullable=True),
  33. sa.Column("created_at", sa.BigInteger(), nullable=True),
  34. sa.Column("updated_at", sa.BigInteger(), nullable=True),
  35. )
  36. def downgrade():
  37. op.drop_table("channel")
  38. op.drop_table("message")