Mercurial > libervia-backend
view libervia/backend/memory/migration/versions/79e5f3313fa4_create_table_for_pubsub_subscriptions.py @ 4294:a0ed5c976bf8 default tip @
component conferences, plugin XEP-0167, XEP-0298: add stream user metadata:
A/V conference now adds user metadata about the stream it is forwarding through XEP-0298.
This is parsed and added to metadata during confirmation on client side.
rel 448
author | Goffi <goffi@goffi.org> |
---|---|
date | Tue, 06 Aug 2024 23:43:11 +0200 |
parents | 0d7bb4df2343 |
children |
line wrap: on
line source
"""create table for pubsub subscriptions Revision ID: 79e5f3313fa4 Revises: 129ac51807e4 Create Date: 2022-03-14 17:15:00.689871 """ from alembic import op import sqlalchemy as sa from libervia.backend.memory.sqla_mapping import JID # revision identifiers, used by Alembic. revision = "79e5f3313fa4" down_revision = "129ac51807e4" branch_labels = None depends_on = None def upgrade(): op.create_table( "pubsub_subs", sa.Column("id", sa.Integer(), nullable=False), sa.Column("node_id", sa.Integer(), nullable=False), sa.Column("subscriber", JID(), nullable=True), sa.Column("state", sa.Enum("SUBSCRIBED", "PENDING", name="state"), nullable=True), sa.ForeignKeyConstraint( ["node_id"], ["pubsub_nodes.id"], name=op.f("fk_pubsub_subs_node_id_pubsub_nodes"), ondelete="CASCADE", ), sa.PrimaryKeyConstraint("id", name=op.f("pk_pubsub_subs")), sa.UniqueConstraint("node_id", "subscriber", name=op.f("uq_pubsub_subs_node_id")), ) def downgrade(): op.drop_table("pubsub_subs")