Mercurial > libervia-backend
view libervia/backend/memory/migration/versions/8974efc51d22_create_tables_for_pubsub_caching.py @ 4250:4b6b812f485a
plugin app manager: Add an app configuration file for PeerTube.
author | Goffi <goffi@goffi.org> |
---|---|
date | Fri, 31 May 2024 11:08:22 +0200 |
parents | 4b842c1fb686 |
children | 0d7bb4df2343 |
line wrap: on
line source
"""create tables for Pubsub caching Revision ID: 8974efc51d22 Revises: 602caf848068 Create Date: 2021-07-27 16:38:54.658212 """ from alembic import op import sqlalchemy as sa from libervia.backend.memory.sqla_mapping import JID, Xml # revision identifiers, used by Alembic. revision = '8974efc51d22' down_revision = '602caf848068' branch_labels = None depends_on = None def upgrade(): # ### commands auto generated by Alembic - please adjust! ### op.create_table('pubsub_nodes', sa.Column('id', sa.Integer(), nullable=False), sa.Column('profile_id', sa.Integer(), nullable=True), sa.Column('service', JID(), nullable=True), sa.Column('name', sa.Text(), nullable=False), sa.Column('subscribed', sa.Boolean(create_constraint=True, name='subscribed_bool'), nullable=False), sa.Column('analyser', sa.Text(), nullable=True), sa.Column('sync_state', sa.Enum('IN_PROGRESS', 'COMPLETED', 'ERROR', 'NO_SYNC', name='sync_state', create_constraint=True), nullable=True), sa.Column('sync_state_updated', sa.Float(), nullable=False), sa.Column('type', sa.Text(), nullable=True), sa.Column('subtype', sa.Text(), nullable=True), sa.Column('extra', sa.JSON(), nullable=True), sa.ForeignKeyConstraint(['profile_id'], ['profiles.id'], name=op.f('fk_pubsub_nodes_profile_id_profiles'), ondelete='CASCADE'), sa.PrimaryKeyConstraint('id', name=op.f('pk_pubsub_nodes')), sa.UniqueConstraint('profile_id', 'service', 'name', name=op.f('uq_pubsub_nodes_profile_id')) ) op.create_table('pubsub_items', sa.Column('id', sa.Integer(), nullable=False), sa.Column('node_id', sa.Integer(), nullable=False), sa.Column('name', sa.Text(), nullable=False), sa.Column('data', Xml(), nullable=False), sa.Column('created', sa.DateTime(), server_default=sa.text('(CURRENT_TIMESTAMP)'), nullable=False), sa.Column('updated', sa.DateTime(), server_default=sa.text('(CURRENT_TIMESTAMP)'), nullable=False), sa.Column('parsed', sa.JSON(), nullable=True), sa.ForeignKeyConstraint(['node_id'], ['pubsub_nodes.id'], name=op.f('fk_pubsub_items_node_id_pubsub_nodes'), ondelete='CASCADE'), sa.PrimaryKeyConstraint('id', name=op.f('pk_pubsub_items')), sa.UniqueConstraint('node_id', 'name', name=op.f('uq_pubsub_items_node_id')) ) # ### end Alembic commands ### def downgrade(): # ### commands auto generated by Alembic - please adjust! ### op.drop_table('pubsub_items') op.drop_table('pubsub_nodes') # ### end Alembic commands ###