diff --git a/.codeclimate.yml b/.codeclimate.yml deleted file mode 100644 index e2fdfb75..00000000 --- a/.codeclimate.yml +++ /dev/null @@ -1,8 +0,0 @@ -engines: - sonar-python: - enabled: true - checks: - python:S107: - enabled: false -exclude_patterns: -- "alembic/" diff --git a/alembic.ini b/alembic.ini deleted file mode 100644 index 921aaf17..00000000 --- a/alembic.ini +++ /dev/null @@ -1,71 +0,0 @@ -# A generic, single database configuration. - -[alembic] -# path to migration scripts -script_location = alembic - -# template used to generate migration files -# file_template = %%(rev)s_%%(slug)s - -# timezone to use when rendering the date -# within the migration file as well as the filename. -# string value is passed to dateutil.tz.gettz() -# leave blank for localtime -# timezone = - -# max length of characters to apply to the -# "slug" field -#truncate_slug_length = 40 - -# set to 'true' to run the environment during -# the 'revision' command, regardless of autogenerate -# revision_environment = false - -# set to 'true' to allow .pyc and .pyo files without -# a source .py file to be detected as revisions in the -# versions/ directory -# sourceless = false - -# version location specification; this defaults -# to alembic/versions. When using multiple version -# directories, initial revisions must be specified with --version-path -# version_locations = %(here)s/bar %(here)s/bat alembic/versions - -# the output encoding used when revision files -# are written from script.py.mako -# output_encoding = utf-8 - -# Logging configuration -[loggers] -keys = root,sqlalchemy,alembic - -[handlers] -keys = console - -[formatters] -keys = generic - -[logger_root] -level = WARN -handlers = console -qualname = - -[logger_sqlalchemy] -level = WARN -handlers = -qualname = sqlalchemy.engine - -[logger_alembic] -level = INFO -handlers = -qualname = alembic - -[handler_console] -class = StreamHandler -args = (sys.stderr,) -level = NOTSET -formatter = generic - -[formatter_generic] -format = %(levelname)-5.5s [%(name)s] %(message)s -datefmt = %H:%M:%S diff --git a/alembic/README b/alembic/README deleted file mode 100644 index 98e4f9c4..00000000 --- a/alembic/README +++ /dev/null @@ -1 +0,0 @@ -Generic single-database configuration. \ No newline at end of file diff --git a/alembic/env.py b/alembic/env.py deleted file mode 100644 index 9fbd478f..00000000 --- a/alembic/env.py +++ /dev/null @@ -1,86 +0,0 @@ -from alembic import context -from sqlalchemy import engine_from_config, pool -from logging.config import fileConfig - -import sys -from os.path import abspath, dirname - -sys.path.insert(0, dirname(dirname(abspath(__file__)))) - -from mautrix.util.db import Base -from mautrix_telegram.config import Config - -# this is the Alembic Config object, which provides -# access to the values within the .ini file in use. -config = context.config - -mxtg_config_path = context.get_x_argument(as_dictionary=True).get("config", "config.yaml") -mxtg_config = Config(mxtg_config_path, None, None) -mxtg_config.load() -config.set_main_option("sqlalchemy.url", mxtg_config["appservice.database"].replace("%", "%%")) - -# Interpret the config file for Python logging. -# This line sets up loggers basically. -fileConfig(config.config_file_name) - -# add your model's MetaData object here -# for 'autogenerate' support -# from myapp import mymodel -# target_metadata = mymodel.Base.metadata -target_metadata = Base.metadata - - -# other values from the config, defined by the needs of env.py, -# can be acquired: -# my_important_option = config.get_main_option("my_important_option") -# ... etc. - - -def run_migrations_offline(): - """Run migrations in 'offline' mode. - - This configures the context with just a URL - and not an Engine, though an Engine is acceptable - here as well. By skipping the Engine creation - we don't even need a DBAPI to be available. - - Calls to context.execute() here emit the given string to the - script output. - - """ - url = config.get_main_option("sqlalchemy.url") - context.configure( - url=url, target_metadata=target_metadata, literal_binds=True, - render_as_batch=True) - - with context.begin_transaction(): - context.run_migrations() - - -def run_migrations_online(): - """Run migrations in 'online' mode. - - In this scenario we need to create an Engine - and associate a connection with the context. - - """ - connectable = engine_from_config( - config.get_section(config.config_ini_section), - prefix='sqlalchemy.', - poolclass=pool.NullPool) - - with connectable.connect() as connection: - context.configure( - connection=connection, - target_metadata=target_metadata, - render_as_batch=True - ) - - with context.begin_transaction(): - context.run_migrations() - - -if context.is_offline_mode(): - run_migrations_offline() -else: - run_migrations_online() diff --git a/alembic/script.py.mako b/alembic/script.py.mako deleted file mode 100644 index 2c015630..00000000 --- a/alembic/script.py.mako +++ /dev/null @@ -1,24 +0,0 @@ -"""${message} - -Revision ID: ${up_revision} -Revises: ${down_revision | comma,n} -Create Date: ${create_date} - -""" -from alembic import op -import sqlalchemy as sa -${imports if imports else ""} - -# revision identifiers, used by Alembic. -revision = ${repr(up_revision)} -down_revision = ${repr(down_revision)} -branch_labels = ${repr(branch_labels)} -depends_on = ${repr(depends_on)} - - -def upgrade(): - ${upgrades if upgrades else "pass"} - - -def downgrade(): - ${downgrades if downgrades else "pass"} diff --git a/alembic/versions/17574c57f3f8_add_disable_updates_field_for_puppets.py b/alembic/versions/17574c57f3f8_add_disable_updates_field_for_puppets.py deleted file mode 100644 index 1cc2c949..00000000 --- a/alembic/versions/17574c57f3f8_add_disable_updates_field_for_puppets.py +++ /dev/null @@ -1,27 +0,0 @@ -"""Add disable_updates field for puppets - -Revision ID: 17574c57f3f8 -Revises: a9119be92164 -Create Date: 2019-05-15 00:24:46.967529 - -""" -from alembic import op -import sqlalchemy as sa - - -# revision identifiers, used by Alembic. -revision = '17574c57f3f8' -down_revision = 'a9119be92164' -branch_labels = None -depends_on = None - - -def upgrade(): - with op.batch_alter_table("puppet") as batch_op: - batch_op.add_column(sa.Column("disable_updates", sa.Boolean(), nullable=False, - server_default=sa.sql.expression.false())) - - -def downgrade(): - with op.batch_alter_table("puppet") as batch_op: - batch_op.drop_column("disable_updates") diff --git a/alembic/versions/1b241f7e8530_add_telegramfile_table.py b/alembic/versions/1b241f7e8530_add_telegramfile_table.py deleted file mode 100644 index c9cca21c..00000000 --- a/alembic/versions/1b241f7e8530_add_telegramfile_table.py +++ /dev/null @@ -1,28 +0,0 @@ -"""Add TelegramFile table - -Revision ID: 1b241f7e8530 -Revises: 97d2a942bcf8 -Create Date: 2018-02-19 23:52:06.605741 - -""" -from alembic import op -import sqlalchemy as sa - -# revision identifiers, used by Alembic. -revision = '1b241f7e8530' -down_revision = '97d2a942bcf8' -branch_labels = None -depends_on = None - - -def upgrade(): - op.create_table('telegram_file', - sa.Column('id', sa.String(), nullable=False), - sa.Column('mxc', sa.String(), nullable=True), - sa.Column('mime_type', sa.String(), nullable=True), - sa.Column('was_converted', sa.Boolean(), nullable=True), - sa.PrimaryKeyConstraint('id')) - - -def downgrade(): - op.drop_table('telegram_file') diff --git a/alembic/versions/1fa46383a9d3_add_is_bot_field_to_puppets.py b/alembic/versions/1fa46383a9d3_add_is_bot_field_to_puppets.py deleted file mode 100644 index 03d5ca33..00000000 --- a/alembic/versions/1fa46383a9d3_add_is_bot_field_to_puppets.py +++ /dev/null @@ -1,26 +0,0 @@ -"""Add is_bot field to puppets - -Revision ID: 1fa46383a9d3 -Revises: 30eca60587f1 -Create Date: 2018-04-29 23:44:40.102333 - -""" -from alembic import op -import sqlalchemy as sa - - -# revision identifiers, used by Alembic. -revision = '1fa46383a9d3' -down_revision = '30eca60587f1' -branch_labels = None -depends_on = None - - -def upgrade(): - with op.batch_alter_table("puppet") as batch_op: - batch_op.add_column(sa.Column('is_bot', sa.Boolean(), nullable=True)) - - -def downgrade(): - with op.batch_alter_table("puppet") as batch_op: - batch_op.drop_column('is_bot') diff --git a/alembic/versions/2228d49c383f_add_cascade_rules_to_userportal.py b/alembic/versions/2228d49c383f_add_cascade_rules_to_userportal.py deleted file mode 100644 index 3eadb5f2..00000000 --- a/alembic/versions/2228d49c383f_add_cascade_rules_to_userportal.py +++ /dev/null @@ -1,41 +0,0 @@ -"""Add cascade rules to UserPortal - -Revision ID: 2228d49c383f -Revises: bcfefa1f1299 -Create Date: 2018-05-31 11:11:59.482112 - -""" -from alembic import op -import sqlalchemy as sa - -# revision identifiers, used by Alembic. -revision = '2228d49c383f' -down_revision = 'bcfefa1f1299' -branch_labels = None -depends_on = None - - -def upgrade(): - try: - with op.batch_alter_table("user_portal") as batch_op: - batch_op.drop_constraint("user_portal_user_fkey", type_="foreignkey") - batch_op.drop_constraint("user_portal_portal_fkey", type_="foreignkey") - batch_op.create_foreign_key("user_portal_user_fkey", "user", ["user"], ["tgid"], - onupdate="CASCADE", ondelete="CASCADE") - batch_op.create_foreign_key("user_portal_portal_fkey", "portal", - ["portal", "portal_receiver"], ["tgid", "tg_receiver"], - onupdate="CASCADE", ondelete="CASCADE") - except ValueError: - return - - -def downgrade(): - try: - with op.batch_alter_table("user_portal") as batch_op: - batch_op.drop_constraint("user_portal_user_fkey", type_="foreignkey") - batch_op.drop_constraint("user_portal_portal_fkey", type_="foreignkey") - batch_op.create_foreign_key("user_portal_user_fkey", "portal", - ["portal", "portal_receiver"], ["tgid", "tg_receiver"]) - batch_op.create_foreign_key("user_portal_portal_fkey", "user", ["user"], ["tgid"]) - except ValueError: - return diff --git a/alembic/versions/24f31fc8a72b_add_encrypted_field_for_portals.py b/alembic/versions/24f31fc8a72b_add_encrypted_field_for_portals.py deleted file mode 100644 index 8cd1ba59..00000000 --- a/alembic/versions/24f31fc8a72b_add_encrypted_field_for_portals.py +++ /dev/null @@ -1,27 +0,0 @@ -"""Add encrypted field for portals - -Revision ID: 24f31fc8a72b -Revises: a7c04a56041b -Create Date: 2020-03-28 20:14:29.046699 - -""" -from alembic import op -import sqlalchemy as sa - - -# revision identifiers, used by Alembic. -revision = "24f31fc8a72b" -down_revision = "a7c04a56041b" -branch_labels = None -depends_on = None - - -def upgrade(): - with op.batch_alter_table("portal") as batch_op: - batch_op.add_column(sa.Column("encrypted", sa.Boolean(), nullable=False, - server_default=sa.sql.expression.false())) - - -def downgrade(): - with op.batch_alter_table("portal") as batch_op: - batch_op.drop_column("encrypted") diff --git a/alembic/versions/30eca60587f1_add_megagroup_field_to_portals.py b/alembic/versions/30eca60587f1_add_megagroup_field_to_portals.py deleted file mode 100644 index 2c38f5d4..00000000 --- a/alembic/versions/30eca60587f1_add_megagroup_field_to_portals.py +++ /dev/null @@ -1,25 +0,0 @@ -"""Add megagroup field to portals - -Revision ID: 30eca60587f1 -Revises: cfc972368e50 -Create Date: 2018-04-29 15:51:04.656605 - -""" -from alembic import op -import sqlalchemy as sa - -# revision identifiers, used by Alembic. -revision = '30eca60587f1' -down_revision = 'cfc972368e50' -branch_labels = None -depends_on = None - - -def upgrade(): - with op.batch_alter_table("portal") as batch_op: - batch_op.add_column(sa.Column('megagroup', sa.Boolean())) - - -def downgrade(): - with op.batch_alter_table("portal") as batch_op: - batch_op.drop_column('megagroup') diff --git a/alembic/versions/3e3745baa458_store_matrix_avatar_url_in_database.py b/alembic/versions/3e3745baa458_store_matrix_avatar_url_in_database.py deleted file mode 100644 index 31db36c2..00000000 --- a/alembic/versions/3e3745baa458_store_matrix_avatar_url_in_database.py +++ /dev/null @@ -1,32 +0,0 @@ -"""Store Matrix avatar URL in database - -Revision ID: 3e3745baa458 -Revises: dff56c93da8d -Create Date: 2020-06-15 14:32:10.454033 - -""" -from alembic import op -import sqlalchemy as sa - - -# revision identifiers, used by Alembic. -revision = '3e3745baa458' -down_revision = 'dff56c93da8d' -branch_labels = None -depends_on = None - - -def upgrade(): - # ### commands auto generated by Alembic - please adjust! ### - with op.batch_alter_table('portal', schema=None) as batch_op: - batch_op.add_column(sa.Column('avatar_url', sa.String(), nullable=True)) - - # ### end Alembic commands ### - - -def downgrade(): - # ### commands auto generated by Alembic - please adjust! ### - with op.batch_alter_table('portal', schema=None) as batch_op: - batch_op.drop_column('avatar_url') - - # ### end Alembic commands ### diff --git a/alembic/versions/4f7d7ed5792a_switch_mx_user_profile_to_native_enum.py b/alembic/versions/4f7d7ed5792a_switch_mx_user_profile_to_native_enum.py deleted file mode 100644 index 85a418b5..00000000 --- a/alembic/versions/4f7d7ed5792a_switch_mx_user_profile_to_native_enum.py +++ /dev/null @@ -1,26 +0,0 @@ -"""Switch mx_user_profile to native enum - -Revision ID: 4f7d7ed5792a -Revises: 9e9c89b0b877 -Create Date: 2019-08-04 17:47:36.568120 - -""" -from alembic import op - - -# revision identifiers, used by Alembic. -revision = '4f7d7ed5792a' -down_revision = '9e9c89b0b877' -branch_labels = None -depends_on = None - - -def upgrade(): - conn = op.get_bind() - conn.execute("UPDATE mx_user_profile SET membership=UPPER(membership)") - conn.execute("UPDATE mx_user_profile SET membership='LEAVE' WHERE membership='LEFT'") - - -def downgrade(): - conn = op.get_bind() - conn.execute("UPDATE mx_user_profile SET membership=LOWER(membership)") diff --git a/alembic/versions/501dad2868bc_move_sessions_to_main_database.py b/alembic/versions/501dad2868bc_move_sessions_to_main_database.py deleted file mode 100644 index c9883534..00000000 --- a/alembic/versions/501dad2868bc_move_sessions_to_main_database.py +++ /dev/null @@ -1,111 +0,0 @@ -"""Move sessions to main database - -Revision ID: 501dad2868bc -Revises: 7d47d84380b6 -Create Date: 2018-03-02 19:15:53.826985 - -""" -from alembic import op -import sqlalchemy as sa -import sqlite3 -import os - -# revision identifiers, used by Alembic. -revision = '501dad2868bc' -down_revision = '7d47d84380b6' -branch_labels = None -depends_on = None - - -def upgrade(): - Session = op.create_table('telethon_sessions', - sa.Column('session_id', sa.String, nullable=False), - sa.Column('dc_id', sa.Integer, nullable=False), - sa.Column('server_address', sa.String, nullable=True), - sa.Column('port', sa.Integer, nullable=True), - sa.Column('auth_key', sa.LargeBinary, nullable=True), - sa.PrimaryKeyConstraint('session_id', 'dc_id')) - SentFile = op.create_table('telethon_sent_files', - sa.Column('session_id', sa.String, nullable=False), - sa.Column('md5_digest', sa.LargeBinary, nullable=False), - sa.Column('file_size', sa.Integer, nullable=False), - sa.Column('type', sa.Integer, nullable=False), - sa.Column('id', sa.BigInteger, nullable=True), - sa.Column('hash', sa.BigInteger, nullable=True), - sa.PrimaryKeyConstraint('session_id', 'md5_digest', 'file_size', - 'type')) - Entity = op.create_table('telethon_entities', - sa.Column('session_id', sa.String, nullable=False), - sa.Column('id', sa.Integer, nullable=False), - sa.Column('hash', sa.Integer, nullable=False), - sa.Column('username', sa.String, nullable=True), - sa.Column('phone', sa.Integer, nullable=True), - sa.Column('name', sa.String, nullable=True), - sa.PrimaryKeyConstraint('session_id', 'id')) - Version = op.create_table('telethon_version', - sa.Column('version', sa.Integer, nullable=False), - sa.PrimaryKeyConstraint('version')) - conn = op.get_bind() - sessions = [os.path.basename(f) for f in os.listdir(".") if f.endswith(".session")] - for session in sessions: - session_to_sqlalchemy(conn, session, Session, SentFile, Entity) - - -def session_to_sqlalchemy(conn, path, Session, SentFile, Entity): - session_conn = sqlite3.connect(path) - session_id = os.path.splitext(path)[0] - c = session_conn.cursor() - - auth_data_tuples = c.execute("SELECT * FROM sessions").fetchall() - auth_data_dicts = [] - for row in auth_data_tuples: - dc_id, server_address, port, auth_key = row - auth_data_dicts.append({ - "session_id": session_id, - "dc_id": dc_id, - "server_address": server_address, - "port": port, - "auth_key": auth_key, - }) - if auth_data_dicts: - conn.execute(Session.insert().values(auth_data_dicts)) - - sent_file_tuples = c.execute("SELECT * FROM sent_files").fetchall() - sent_file_dicts = [] - for row in sent_file_tuples: - md5_digest, file_size, type, id, hash = row - sent_file_dicts.append({ - "session_id": session_id, - "md5_digest": md5_digest, - "file_size": file_size, - "type": type, - "id": id, - "hash": hash, - }) - if sent_file_dicts: - conn.execute(SentFile.insert().values(sent_file_dicts)) - - entity_tuples = c.execute("SELECT * FROM entities").fetchall() - entity_dicts = [] - for row in entity_tuples: - id, hash, username, phone, name = row - entity_dicts.append({ - "session_id": session_id, - "id": id, - "hash": hash, - "username": username, - "phone": phone, - "name": name, - }) - if entity_dicts: - conn.execute(Entity.insert().values(entity_dicts)) - - c.close() - session_conn.close() - - -def downgrade(): - op.drop_table('telethon_version') - op.drop_table('telethon_entities') - op.drop_table('telethon_sent_files') - op.drop_table('telethon_sessions') diff --git a/alembic/versions/6ca3d74d51e4_move_state_store_to_main_database.py b/alembic/versions/6ca3d74d51e4_move_state_store_to_main_database.py deleted file mode 100644 index b0ebf1ce..00000000 --- a/alembic/versions/6ca3d74d51e4_move_state_store_to_main_database.py +++ /dev/null @@ -1,136 +0,0 @@ -"""Move state store to main database - -Revision ID: 6ca3d74d51e4 -Revises: 2228d49c383f -Create Date: 2018-06-26 21:31:26.911307 - -""" -import json -import re - -from alembic import context, op -import sqlalchemy.orm as orm -import sqlalchemy as sa - -from mautrix.util.db import Base - -from mautrix_telegram.config import Config - -# revision identifiers, used by Alembic. -revision = "6ca3d74d51e4" -down_revision = "2228d49c383f" -branch_labels = None -depends_on = None - - -class RoomState(Base): - __tablename__ = "mx_room_state" - __table_args__ = {"extend_existing": True} - - room_id = sa.Column(sa.String, primary_key=True) - power_levels = sa.Column("power_levels", sa.Text, nullable=True) - - -class UserProfile(Base): - __tablename__ = "mx_user_profile" - __table_args__ = {"extend_existing": True} - - room_id = sa.Column(sa.String, primary_key=True) - user_id = sa.Column(sa.String, primary_key=True) - membership = sa.Column(sa.String, nullable=False, default="leave") - displayname = sa.Column(sa.String, nullable=True) - avatar_url = sa.Column(sa.String, nullable=True) - - -class Puppet(Base): - __tablename__ = "puppet" - __table_args__ = {"extend_existing": True} - - id = sa.Column(sa.Integer, primary_key=True) - displayname = sa.Column(sa.String, nullable=True) - displayname_source = sa.Column(sa.Integer, nullable=True) - username = sa.Column(sa.String, nullable=True) - photo_id = sa.Column(sa.String, nullable=True) - is_bot = sa.Column(sa.Boolean, nullable=True) - matrix_registered = sa.Column(sa.Boolean, nullable=False, default=False) - - -def upgrade(): - with op.batch_alter_table("puppet") as batch_op: - batch_op.add_column(sa.Column("matrix_registered", sa.Boolean(), nullable=False, - server_default=sa.sql.expression.false())) - op.create_table("mx_room_state", - sa.Column("room_id", sa.String(), nullable=False), - sa.Column("power_levels", sa.Text(), nullable=True), - sa.PrimaryKeyConstraint("room_id")) - op.create_table("mx_user_profile", - sa.Column("room_id", sa.String(), nullable=False), - sa.Column("user_id", sa.String(), nullable=False), - sa.Column("membership", sa.String(), nullable=False, - default="leave"), - sa.Column("displayname", sa.String(), nullable=True), - sa.Column("avatar_url", sa.String(), nullable=True), - sa.PrimaryKeyConstraint("room_id", "user_id")) - - try: - migrate_state_store() - except Exception as e: - print("Failed to migrate state store:", e) - print("Migrating the state store isn't required, but you can retry by alembic downgrading " - "to revision 2228d49c383f and upgrading again.") - - -def migrate_state_store(): - conn = op.get_bind() - session: orm.Session = orm.sessionmaker(bind=conn)() - - try: - with open("mx-state.json") as file: - data = json.load(file) - except FileNotFoundError: - return - if not data: - return - registrations = data.get("registrations", []) - - mxtg_config_path = context.get_x_argument(as_dictionary=True).get("config", "config.yaml") - mxtg_config = Config(mxtg_config_path, None, None) - mxtg_config.load() - - username_template = mxtg_config.get("bridge.username_template", "telegram_{userid}") - hs_domain = mxtg_config["homeserver.domain"] - localpart = username_template.format(userid="(.+)") - mxid_regex = re.compile("@{}:{}".format(localpart, hs_domain)) - for user in registrations: - match = mxid_regex.match(user) - if not match: - continue - - puppet = session.query(Puppet).get(match.group(1)) - if not puppet: - continue - - puppet.matrix_registered = True - session.merge(puppet) - session.commit() - - user_profiles = [UserProfile(room_id=room, user_id=user, - membership=member.get("membership", "leave"), - displayname=member.get("displayname", None), - avatar_url=member.get("avatar_url", None)) - for room, members in data.get("members", {}).items() - for user, member in members.items()] - session.add_all(user_profiles) - session.commit() - - room_state = [RoomState(room_id=room, power_levels=json.dumps(levels)) - for room, levels in data.get("power_levels", {}).items()] - session.add_all(room_state) - session.commit() - - -def downgrade(): - op.drop_table("mx_user_profile") - op.drop_table("mx_room_state") - with op.batch_alter_table("puppet") as batch_op: - batch_op.drop_column("matrix_registered") diff --git a/alembic/versions/7d47d84380b6_add_timestamp_to_telegramfile.py b/alembic/versions/7d47d84380b6_add_timestamp_to_telegramfile.py deleted file mode 100644 index 3ab6c8d3..00000000 --- a/alembic/versions/7d47d84380b6_add_timestamp_to_telegramfile.py +++ /dev/null @@ -1,26 +0,0 @@ -"""Add timestamp to TelegramFile - -Revision ID: 7d47d84380b6 -Revises: 1b241f7e8530 -Create Date: 2018-02-19 23:53:18.050871 - -""" -from alembic import op -import sqlalchemy as sa - -# revision identifiers, used by Alembic. -revision = '7d47d84380b6' -down_revision = '1b241f7e8530' -branch_labels = None -depends_on = None - - -def upgrade(): - op.add_column('telegram_file', - sa.Column('timestamp', sa.BigInteger(), nullable=True, default=0, - server_default="0")) - - -def downgrade(): - with op.batch_alter_table("telegram_file") as batch_op: - batch_op.drop_column('timestamp') diff --git a/alembic/versions/7de69cf5809e_add_matrix_redaction_state_to_message_.py b/alembic/versions/7de69cf5809e_add_matrix_redaction_state_to_message_.py deleted file mode 100644 index 15d2ecb0..00000000 --- a/alembic/versions/7de69cf5809e_add_matrix_redaction_state_to_message_.py +++ /dev/null @@ -1,25 +0,0 @@ -"""Add Matrix redaction state to message table - -Revision ID: 7de69cf5809e -Revises: 888275d58e57 -Create Date: 2020-12-19 12:39:57.368568 - -""" -from alembic import op -import sqlalchemy as sa - -# revision identifiers, used by Alembic. -revision = '7de69cf5809e' -down_revision = '888275d58e57' -branch_labels = None -depends_on = None - - -def upgrade(): - with op.batch_alter_table('message', schema=None) as batch_op: - batch_op.add_column(sa.Column('redacted', sa.Boolean(), server_default=sa.false(), nullable=True)) - - -def downgrade(): - with op.batch_alter_table('message', schema=None) as batch_op: - batch_op.drop_column('redacted') diff --git a/alembic/versions/888275d58e57_add_double_puppet_base_url_to_puppet_.py b/alembic/versions/888275d58e57_add_double_puppet_base_url_to_puppet_.py deleted file mode 100644 index 8b49d7e7..00000000 --- a/alembic/versions/888275d58e57_add_double_puppet_base_url_to_puppet_.py +++ /dev/null @@ -1,30 +0,0 @@ -"""Add double puppet base URL to puppet table - -Revision ID: 888275d58e57 -Revises: a328bf4f0932 -Create Date: 2020-10-14 18:52:00.730666 - -""" -from alembic import op -import sqlalchemy as sa -from sqlalchemy.dialects import postgresql - -# revision identifiers, used by Alembic. -revision = '888275d58e57' -down_revision = 'a328bf4f0932' -branch_labels = None -depends_on = None - - -def upgrade(): - # ### commands auto generated by Alembic - please adjust! ### - with op.batch_alter_table('puppet', schema=None) as batch_op: - batch_op.add_column(sa.Column('base_url', sa.Text(), nullable=True)) - # ### end Alembic commands ### - - -def downgrade(): - # ### commands auto generated by Alembic - please adjust! ### - with op.batch_alter_table('puppet', schema=None) as batch_op: - batch_op.drop_column('base_url') - # ### end Alembic commands ### diff --git a/alembic/versions/97d2a942bcf8_initial_revision.py b/alembic/versions/97d2a942bcf8_initial_revision.py deleted file mode 100644 index ca72c118..00000000 --- a/alembic/versions/97d2a942bcf8_initial_revision.py +++ /dev/null @@ -1,80 +0,0 @@ -"""initial revision - -Revision ID: 97d2a942bcf8 -Revises: -Create Date: 2018-02-11 18:40:55.483842 - -""" -from alembic import op -import sqlalchemy as sa - -# revision identifiers, used by Alembic. -revision = '97d2a942bcf8' -down_revision = None -branch_labels = None -depends_on = None - - -def upgrade(): - op.create_table('portal', - sa.Column('tgid', sa.Integer), - sa.Column('tg_receiver', sa.Integer), - sa.Column('peer_type', sa.String, nullable=False, default=""), - sa.Column('mxid', sa.String, nullable=True), - sa.Column('username', sa.String, nullable=True), - sa.Column('title', sa.String, nullable=True), - sa.Column('about', sa.String, nullable=True), - sa.Column('photo_id', sa.String, nullable=True), - sa.PrimaryKeyConstraint('tgid', 'tg_receiver'), - sa.UniqueConstraint('mxid')) - op.create_table('user', - sa.Column('mxid', sa.String), - sa.Column('tgid', sa.Integer, nullable=True, unique=True), - sa.Column('tg_username', sa.String, nullable=True), - sa.Column('saved_contacts', sa.Integer, nullable=False, default=0), - sa.PrimaryKeyConstraint('mxid')) - op.create_table('puppet', - sa.Column('id', sa.Integer), - sa.Column('displayname', sa.String, nullable=True), - sa.Column('username', sa.String, nullable=True), - sa.Column('photo_id', sa.String, nullable=True), - sa.PrimaryKeyConstraint('id')) - op.create_table('contact', - sa.Column('user', sa.Integer), - sa.Column('contact', sa.Integer), - sa.ForeignKeyConstraint(("user",), ("user.tgid",)), - sa.ForeignKeyConstraint(("contact",), ("puppet.id",)), - sa.PrimaryKeyConstraint('user', 'contact')) - op.create_table('user_portal', - sa.Column('user', sa.Integer), - sa.Column('portal', sa.Integer), - sa.Column('portal_receiver', sa.Integer), - sa.PrimaryKeyConstraint('user', 'portal', 'portal_receiver'), - sa.ForeignKeyConstraint(("user",), ("user.tgid",), - name="user_portal_user_fkey", - onupdate="CASCADE", ondelete="CASCADE"), - sa.ForeignKeyConstraint(("portal", "portal_receiver"), - ("portal.tgid", "portal.tg_receiver"), - name="user_portal_portal_fkey", - onupdate="CASCADE", ondelete="CASCADE")) - op.create_table('message', - sa.Column('mxid', sa.String), - sa.Column('mx_room', sa.String), - sa.Column('tgid', sa.Integer), - sa.Column('tg_space', sa.Integer), - sa.PrimaryKeyConstraint('tgid', 'tg_space'), - sa.UniqueConstraint("mxid", "mx_room", "tg_space", name="_mx_id_room")) - op.create_table('bot_chat', - sa.Column('id', sa.Integer), - sa.Column('type', sa.String, nullable=False, default=""), - sa.PrimaryKeyConstraint('id')) - - -def downgrade(): - op.drop_table('bot_chat') - op.drop_table('message') - op.drop_table('user_portal') - op.drop_table('contact') - op.drop_table('puppet') - op.drop_table('user') - op.drop_table('portal') diff --git a/alembic/versions/990f4395afc6_store_displayname_contact_status_in_.py b/alembic/versions/990f4395afc6_store_displayname_contact_status_in_.py deleted file mode 100644 index fb847b16..00000000 --- a/alembic/versions/990f4395afc6_store_displayname_contact_status_in_.py +++ /dev/null @@ -1,32 +0,0 @@ -"""Store displayname contact status in puppet table - -Revision ID: 990f4395afc6 -Revises: 7de69cf5809e -Create Date: 2021-01-01 11:56:54.610681 - -""" -from alembic import op -import sqlalchemy as sa -from sqlalchemy.dialects import postgresql - -# revision identifiers, used by Alembic. -revision = '990f4395afc6' -down_revision = '7de69cf5809e' -branch_labels = None -depends_on = None - - -def upgrade(): - # ### commands auto generated by Alembic - please adjust! ### - with op.batch_alter_table('puppet', schema=None) as batch_op: - batch_op.add_column(sa.Column('displayname_contact', sa.Boolean(), server_default=sa.true(), nullable=False)) - - # ### end Alembic commands ### - - -def downgrade(): - # ### commands auto generated by Alembic - please adjust! ### - with op.batch_alter_table('puppet', schema=None) as batch_op: - batch_op.drop_column('displayname_contact') - - # ### end Alembic commands ### diff --git a/alembic/versions/9e9c89b0b877_add_edit_index_to_messages.py b/alembic/versions/9e9c89b0b877_add_edit_index_to_messages.py deleted file mode 100644 index 5661a602..00000000 --- a/alembic/versions/9e9c89b0b877_add_edit_index_to_messages.py +++ /dev/null @@ -1,48 +0,0 @@ -"""Add edit index to messages - -Revision ID: 9e9c89b0b877 -Revises: 17574c57f3f8 -Create Date: 2019-05-29 15:28:23.128377 - -""" -from alembic import op -import sqlalchemy as sa - -# revision identifiers, used by Alembic. -revision = '9e9c89b0b877' -down_revision = '17574c57f3f8' -branch_labels = None -depends_on = None - - -def upgrade(): - op.create_table('_message_temp', - sa.Column('mxid', sa.String), - sa.Column('mx_room', sa.String), - sa.Column('tgid', sa.Integer), - sa.Column('tg_space', sa.Integer), - sa.Column('edit_index', sa.Integer), - sa.PrimaryKeyConstraint('tgid', 'tg_space', 'edit_index'), - sa.UniqueConstraint("mxid", "mx_room", "tg_space", name="_mx_id_room_2")) - c = op.get_bind() - c.execute("INSERT INTO _message_temp (mxid, mx_room, tgid, tg_space, edit_index) " - "SELECT message.mxid, message.mx_room, message.tgid, message.tg_space, 0 " - "FROM message") - c.execute("DROP TABLE message") - c.execute("ALTER TABLE _message_temp RENAME TO message") - - -def downgrade(): - op.create_table('_message_temp', - sa.Column('mxid', sa.String), - sa.Column('mx_room', sa.String), - sa.Column('tgid', sa.Integer), - sa.Column('tg_space', sa.Integer), - sa.PrimaryKeyConstraint('tgid', 'tg_space'), - sa.UniqueConstraint("mxid", "mx_room", "tg_space", name="_mx_id_room")) - c = op.get_bind() - c.execute("INSERT INTO _message_temp (mxid, mx_room, tgid, tg_space) " - "SELECT message.mxid, message.mx_room, message.tgid, message.tg_space " - "FROM message") - c.execute("DROP TABLE message") - c.execute("ALTER TABLE _message_temp RENAME TO message") diff --git a/alembic/versions/a328bf4f0932_store_encryption_state_event_in_db.py b/alembic/versions/a328bf4f0932_store_encryption_state_event_in_db.py deleted file mode 100644 index fa1c4367..00000000 --- a/alembic/versions/a328bf4f0932_store_encryption_state_event_in_db.py +++ /dev/null @@ -1,38 +0,0 @@ -"""Store encryption state event in db - -Revision ID: a328bf4f0932 -Revises: ccbaff858240 -Create Date: 2020-07-11 21:31:27.059813 - -""" -from alembic import op -import sqlalchemy as sa - -from mautrix.client.state_store.sqlalchemy import SerializableType -from mautrix.types import RoomEncryptionStateEventContent - -# revision identifiers, used by Alembic. -revision = 'a328bf4f0932' -down_revision = 'ccbaff858240' -branch_labels = None -depends_on = None - - -def upgrade(): - # ### commands auto generated by Alembic - please adjust! ### - with op.batch_alter_table('mx_room_state', schema=None) as batch_op: - batch_op.add_column(sa.Column('encryption', - SerializableType(RoomEncryptionStateEventContent), - nullable=True)) - batch_op.add_column(sa.Column('has_full_member_list', sa.Boolean(), nullable=True)) - batch_op.add_column(sa.Column('is_encrypted', sa.Boolean(), nullable=True)) - # ### end Alembic commands ### - - -def downgrade(): - # ### commands auto generated by Alembic - please adjust! ### - with op.batch_alter_table('mx_room_state', schema=None) as batch_op: - batch_op.drop_column('is_encrypted') - batch_op.drop_column('has_full_member_list') - batch_op.drop_column('encryption') - # ### end Alembic commands ### diff --git a/alembic/versions/a7c04a56041b_store_custom_puppet_next_batch_in_.py b/alembic/versions/a7c04a56041b_store_custom_puppet_next_batch_in_.py deleted file mode 100644 index 4ea75c6e..00000000 --- a/alembic/versions/a7c04a56041b_store_custom_puppet_next_batch_in_.py +++ /dev/null @@ -1,26 +0,0 @@ -"""Store custom puppet next_batch in database - -Revision ID: a7c04a56041b -Revises: 4f7d7ed5792a -Create Date: 2019-08-06 23:08:51.087651 - -""" -from alembic import op -import sqlalchemy as sa - - -# revision identifiers, used by Alembic. -revision = "a7c04a56041b" -down_revision = "4f7d7ed5792a" -branch_labels = None -depends_on = None - - -def upgrade(): - with op.batch_alter_table("puppet") as batch_op: - batch_op.add_column(sa.Column("next_batch", sa.String(), nullable=True)) - - -def downgrade(): - with op.batch_alter_table("puppet") as batch_op: - batch_op.drop_column("next_batch") diff --git a/alembic/versions/a9119be92164_add_phone_number_field_to_users.py b/alembic/versions/a9119be92164_add_phone_number_field_to_users.py deleted file mode 100644 index a8892515..00000000 --- a/alembic/versions/a9119be92164_add_phone_number_field_to_users.py +++ /dev/null @@ -1,25 +0,0 @@ -"""Add phone number field to users - -Revision ID: a9119be92164 -Revises: b54929c22c86 -Create Date: 2018-09-28 02:38:40.626282 - -""" -from alembic import op -import sqlalchemy as sa - - -# revision identifiers, used by Alembic. -revision = "a9119be92164" -down_revision = "b54929c22c86" -branch_labels = None -depends_on = None - - -def upgrade(): - op.add_column("user", sa.Column("tg_phone", sa.String(), nullable=True)) - - -def downgrade(): - with op.batch_alter_table("user") as batch_op: - batch_op.drop_column("tg_phone") diff --git a/alembic/versions/b54929c22c86_add_portal_specific_config.py b/alembic/versions/b54929c22c86_add_portal_specific_config.py deleted file mode 100644 index b5d1a420..00000000 --- a/alembic/versions/b54929c22c86_add_portal_specific_config.py +++ /dev/null @@ -1,25 +0,0 @@ -"""Add portal-specific config - -Revision ID: b54929c22c86 -Revises: d5f7b8b4b456 -Create Date: 2018-09-24 23:40:33.528710 - -""" -from alembic import op -import sqlalchemy as sa - - -# revision identifiers, used by Alembic. -revision = "b54929c22c86" -down_revision = "d5f7b8b4b456" -branch_labels = None -depends_on = None - - -def upgrade(): - op.add_column("portal", sa.Column("config", sa.Text(), nullable=True)) - - -def downgrade(): - with op.batch_alter_table("portal") as batch_op: - batch_op.drop_column("config") diff --git a/alembic/versions/bcfefa1f1299_add_displayname_source_fields_for_.py b/alembic/versions/bcfefa1f1299_add_displayname_source_fields_for_.py deleted file mode 100644 index 7f12225b..00000000 --- a/alembic/versions/bcfefa1f1299_add_displayname_source_fields_for_.py +++ /dev/null @@ -1,24 +0,0 @@ -"""Add displayname source fields for puppets - -Revision ID: bcfefa1f1299 -Revises: bdadd173ee02 -Create Date: 2018-05-19 17:00:21.078098 - -""" -from alembic import op -import sqlalchemy as sa - -# revision identifiers, used by Alembic. -revision = 'bcfefa1f1299' -down_revision = 'bdadd173ee02' -branch_labels = None -depends_on = None - - -def upgrade(): - op.add_column('puppet', sa.Column('displayname_source', sa.Integer(), nullable=True)) - - -def downgrade(): - with op.batch_alter_table("puppet") as batch_op: - batch_op.drop_column('displayname_source') diff --git a/alembic/versions/bdadd173ee02_update_telethon_update_state_table.py b/alembic/versions/bdadd173ee02_update_telethon_update_state_table.py deleted file mode 100644 index 0e1c0018..00000000 --- a/alembic/versions/bdadd173ee02_update_telethon_update_state_table.py +++ /dev/null @@ -1,43 +0,0 @@ -"""Update telethon update state table - -Revision ID: bdadd173ee02 -Revises: eeaf0dae87ce -Create Date: 2018-05-13 10:42:59.395597 - -""" -from alembic import op -import sqlalchemy as sa - -# revision identifiers, used by Alembic. -revision = 'bdadd173ee02' -down_revision = 'eeaf0dae87ce' -branch_labels = None -depends_on = None - - -def upgrade(): - with op.batch_alter_table("telethon_entities") as batch_op: - batch_op.alter_column("id", existing_type=sa.Integer, type_=sa.BigInteger) - batch_op.alter_column("hash", existing_type=sa.Integer, type_=sa.BigInteger) - - with op.batch_alter_table("telethon_update_state") as batch_op: - batch_op.alter_column("entity_id", existing_type=sa.Integer, type_=sa.BigInteger) - batch_op.alter_column("pts", existing_type=sa.Integer, type_=sa.BigInteger) - batch_op.alter_column("qts", existing_type=sa.Integer, type_=sa.BigInteger) - batch_op.alter_column("date", existing_type=sa.Integer, type_=sa.BigInteger) - batch_op.alter_column("seq", existing_type=sa.Integer, type_=sa.BigInteger) - batch_op.add_column(sa.Column("unread_count", sa.Integer)) - - -def downgrade(): - with op.batch_alter_table("telethon_entities") as batch_op: - batch_op.alter_column("id", existing_type=sa.BigInteger, type_=sa.Integer) - batch_op.alter_column("hash", existing_type=sa.BigInteger, type_=sa.Integer) - - with op.batch_alter_table("telethon_update_state") as batch_op: - batch_op.alter_column("entity_id", existing_type=sa.BigInteger, type_=sa.Integer) - batch_op.alter_column("pts", existing_type=sa.BigInteger, type_=sa.Integer) - batch_op.alter_column("qts", existing_type=sa.BigInteger, type_=sa.Integer) - batch_op.alter_column("date", existing_type=sa.BigInteger, type_=sa.Integer) - batch_op.alter_column("seq", existing_type=sa.BigInteger, type_=sa.Integer) - batch_op.drop_column("unread_count") diff --git a/alembic/versions/bfc0a39bfe02_store_displayname_quality_in_puppet_.py b/alembic/versions/bfc0a39bfe02_store_displayname_quality_in_puppet_.py deleted file mode 100644 index df30f3d7..00000000 --- a/alembic/versions/bfc0a39bfe02_store_displayname_quality_in_puppet_.py +++ /dev/null @@ -1,32 +0,0 @@ -"""Store displayname quality in puppet table - -Revision ID: bfc0a39bfe02 -Revises: ec1d3dcc77e9 -Create Date: 2021-03-23 20:03:08.825333 - -""" -from alembic import op -import sqlalchemy as sa -from sqlalchemy.dialects import postgresql - -# revision identifiers, used by Alembic. -revision = 'bfc0a39bfe02' -down_revision = 'ec1d3dcc77e9' -branch_labels = None -depends_on = None - - -def upgrade(): - # ### commands auto generated by Alembic - please adjust! ### - with op.batch_alter_table('puppet', schema=None) as batch_op: - batch_op.add_column(sa.Column('displayname_quality', sa.Integer(), server_default='0', nullable=False)) - - # ### end Alembic commands ### - - -def downgrade(): - # ### commands auto generated by Alembic - please adjust! ### - with op.batch_alter_table('puppet', schema=None) as batch_op: - batch_op.drop_column('displayname_quality') - - # ### end Alembic commands ### diff --git a/alembic/versions/ccbaff858240_switch_to_mautrix_python_crypto.py b/alembic/versions/ccbaff858240_switch_to_mautrix_python_crypto.py deleted file mode 100644 index 46d2b274..00000000 --- a/alembic/versions/ccbaff858240_switch_to_mautrix_python_crypto.py +++ /dev/null @@ -1,71 +0,0 @@ -"""Switch to mautrix-python crypto - -Revision ID: ccbaff858240 -Revises: 3e3745baa458 -Create Date: 2020-07-08 19:06:12.588047 - -""" -from alembic import op -import sqlalchemy as sa -from sqlalchemy.dialects import postgresql - -# revision identifiers, used by Alembic. -revision = 'ccbaff858240' -down_revision = '3e3745baa458' -branch_labels = None -depends_on = None - - -def upgrade(): - # ### commands auto generated by Alembic - please adjust! ### - op.drop_table('nio_account') - op.drop_table('nio_device_key') - op.drop_table('nio_outgoing_key_request') - op.drop_table('nio_olm_session') - op.drop_table('nio_megolm_inbound_session') - # ### end Alembic commands ### - - -def downgrade(): - # ### commands auto generated by Alembic - please adjust! ### - op.create_table('nio_megolm_inbound_session', - sa.Column('session_id', sa.VARCHAR(length=255), autoincrement=False, nullable=False), - sa.Column('sender_key', sa.VARCHAR(length=255), autoincrement=False, nullable=False), - sa.Column('fp_key', sa.VARCHAR(length=255), autoincrement=False, nullable=False), - sa.Column('room_id', sa.VARCHAR(length=255), autoincrement=False, nullable=False), - sa.Column('session', postgresql.BYTEA(), autoincrement=False, nullable=False), - sa.Column('forwarded_chains', postgresql.BYTEA(), autoincrement=False, nullable=False), - sa.PrimaryKeyConstraint('session_id', name='nio_megolm_inbound_session_pkey') - ) - op.create_table('nio_olm_session', - sa.Column('session_id', sa.VARCHAR(length=255), autoincrement=False, nullable=False), - sa.Column('sender_key', sa.VARCHAR(length=255), autoincrement=False, nullable=False), - sa.Column('session', postgresql.BYTEA(), autoincrement=False, nullable=False), - sa.Column('created_at', postgresql.TIMESTAMP(), autoincrement=False, nullable=False), - sa.Column('last_used', postgresql.TIMESTAMP(), autoincrement=False, nullable=False), - sa.PrimaryKeyConstraint('session_id', name='nio_olm_session_pkey') - ) - op.create_table('nio_outgoing_key_request', - sa.Column('request_id', sa.VARCHAR(length=255), autoincrement=False, nullable=False), - sa.Column('session_id', sa.VARCHAR(length=255), autoincrement=False, nullable=False), - sa.Column('room_id', sa.VARCHAR(length=255), autoincrement=False, nullable=False), - sa.Column('algorithm', sa.VARCHAR(length=255), autoincrement=False, nullable=False), - sa.PrimaryKeyConstraint('request_id', name='nio_outgoing_key_request_pkey') - ) - op.create_table('nio_device_key', - sa.Column('user_id', sa.VARCHAR(length=255), autoincrement=False, nullable=False), - sa.Column('device_id', sa.VARCHAR(length=255), autoincrement=False, nullable=False), - sa.Column('display_name', sa.VARCHAR(length=255), autoincrement=False, nullable=False), - sa.Column('deleted', sa.BOOLEAN(), autoincrement=False, nullable=False), - sa.Column('keys', postgresql.BYTEA(), autoincrement=False, nullable=False), - sa.PrimaryKeyConstraint('user_id', 'device_id', name='nio_device_key_pkey') - ) - op.create_table('nio_account', - sa.Column('user_id', sa.VARCHAR(length=255), autoincrement=False, nullable=False), - sa.Column('device_id', sa.VARCHAR(length=255), autoincrement=False, nullable=False), - sa.Column('shared', sa.BOOLEAN(), autoincrement=False, nullable=False), - sa.Column('sync_token', sa.TEXT(), autoincrement=False, nullable=False), - sa.Column('account', postgresql.BYTEA(), autoincrement=False, nullable=False), - sa.PrimaryKeyConstraint('user_id', 'device_id', name='nio_account_pkey') - ) - # ### end Alembic commands ### diff --git a/alembic/versions/cfc972368e50_add_metadata_to_telegramfile.py b/alembic/versions/cfc972368e50_add_metadata_to_telegramfile.py deleted file mode 100644 index 205cbf3a..00000000 --- a/alembic/versions/cfc972368e50_add_metadata_to_telegramfile.py +++ /dev/null @@ -1,35 +0,0 @@ -"""Add metadata to TelegramFile - -Revision ID: cfc972368e50 -Revises: 501dad2868bc -Create Date: 2018-03-09 16:07:01.236712 - -""" -from alembic import op -import sqlalchemy as sa - -# revision identifiers, used by Alembic. -revision = 'cfc972368e50' -down_revision = '501dad2868bc' -branch_labels = None -depends_on = None - - -def upgrade(): - with op.batch_alter_table("telegram_file") as batch_op: - batch_op.add_column(sa.Column('size', sa.Integer(), nullable=True)) - batch_op.add_column(sa.Column('width', sa.Integer(), nullable=True)) - batch_op.add_column(sa.Column('height', sa.Integer(), nullable=True)) - batch_op.add_column(sa.Column('thumbnail', sa.String(), nullable=True)) - batch_op.create_foreign_key(constraint_name="fk_file_thumbnail", - referent_table="telegram_file", - local_cols=['thumbnail'], - remote_cols=['id']) - - -def downgrade(): - with op.batch_alter_table("telegram_file") as batch_op: - batch_op.drop_column('size') - batch_op.drop_column('width') - batch_op.drop_column('height') - batch_op.drop_column('thumbnail') diff --git a/alembic/versions/d3c922a6acd2_add_decryption_info_field_for_.py b/alembic/versions/d3c922a6acd2_add_decryption_info_field_for_.py deleted file mode 100644 index 1469f2a8..00000000 --- a/alembic/versions/d3c922a6acd2_add_decryption_info_field_for_.py +++ /dev/null @@ -1,26 +0,0 @@ -"""Add decryption info field for reuploaded telegram files - -Revision ID: d3c922a6acd2 -Revises: 24f31fc8a72b -Create Date: 2020-03-30 20:07:17.340346 - -""" -from alembic import op -import sqlalchemy as sa - - -# revision identifiers, used by Alembic. -revision = 'd3c922a6acd2' -down_revision = '24f31fc8a72b' -branch_labels = None -depends_on = None - - -def upgrade(): - with op.batch_alter_table("telegram_file") as batch_op: - batch_op.add_column(sa.Column("decryption_info", sa.Text(), nullable=True)) - - -def downgrade(): - with op.batch_alter_table("telegram_file") as batch_op: - batch_op.drop_column("decryption_info") diff --git a/alembic/versions/d5f7b8b4b456_add_access_token_and_custom_mxid_fields_.py b/alembic/versions/d5f7b8b4b456_add_access_token_and_custom_mxid_fields_.py deleted file mode 100644 index 5c5a940a..00000000 --- a/alembic/versions/d5f7b8b4b456_add_access_token_and_custom_mxid_fields_.py +++ /dev/null @@ -1,26 +0,0 @@ -"""Add access_token and custom_mxid fields for puppets - -Revision ID: d5f7b8b4b456 -Revises: 6ca3d74d51e4 -Create Date: 2018-07-20 12:09:30.277960 - -""" -from alembic import op -import sqlalchemy as sa - -# revision identifiers, used by Alembic. -revision = "d5f7b8b4b456" -down_revision = "6ca3d74d51e4" -branch_labels = None -depends_on = None - - -def upgrade(): - op.add_column("puppet", sa.Column("access_token", sa.String(), nullable=True)) - op.add_column("puppet", sa.Column("custom_mxid", sa.String(), nullable=True)) - - -def downgrade(): - with op.batch_alter_table("puppet") as batch_op: - batch_op.drop_column("custom_mxid") - batch_op.drop_column("access_token") diff --git a/alembic/versions/dff56c93da8d_add_matrix_nio_state_store_to_main_db.py b/alembic/versions/dff56c93da8d_add_matrix_nio_state_store_to_main_db.py deleted file mode 100644 index 6a16f2dc..00000000 --- a/alembic/versions/dff56c93da8d_add_matrix_nio_state_store_to_main_db.py +++ /dev/null @@ -1,71 +0,0 @@ -"""Add matrix-nio state store to main db - -Revision ID: dff56c93da8d -Revises: d3c922a6acd2 -Create Date: 2020-03-31 22:04:04.014048 - -""" -from alembic import op -import sqlalchemy as sa - - -# revision identifiers, used by Alembic. -revision = 'dff56c93da8d' -down_revision = 'd3c922a6acd2' -branch_labels = None -depends_on = None - - -def upgrade(): - # ### commands auto generated by Alembic - please adjust! ### - op.create_table('nio_account', - sa.Column('user_id', sa.String(length=255), nullable=False), - sa.Column('device_id', sa.String(length=255), nullable=False), - sa.Column('shared', sa.Boolean(), nullable=False), - sa.Column('sync_token', sa.Text(), nullable=False), - sa.Column('account', sa.LargeBinary(), nullable=False), - sa.PrimaryKeyConstraint('user_id', 'device_id') - ) - op.create_table('nio_device_key', - sa.Column('user_id', sa.String(length=255), nullable=False), - sa.Column('device_id', sa.String(length=255), nullable=False), - sa.Column('display_name', sa.String(length=255), nullable=False), - sa.Column('deleted', sa.Boolean(), nullable=False), - sa.Column('keys', sa.PickleType(), nullable=False), - sa.PrimaryKeyConstraint('user_id', 'device_id') - ) - op.create_table('nio_megolm_inbound_session', - sa.Column('session_id', sa.String(length=255), nullable=False), - sa.Column('sender_key', sa.String(length=255), nullable=False), - sa.Column('fp_key', sa.String(length=255), nullable=False), - sa.Column('room_id', sa.String(length=255), nullable=False), - sa.Column('session', sa.LargeBinary(), nullable=False), - sa.Column('forwarded_chains', sa.PickleType(), nullable=False), - sa.PrimaryKeyConstraint('session_id') - ) - op.create_table('nio_olm_session', - sa.Column('session_id', sa.String(length=255), nullable=False), - sa.Column('sender_key', sa.String(length=255), nullable=False), - sa.Column('session', sa.LargeBinary(), nullable=False), - sa.Column('created_at', sa.DateTime(), nullable=False), - sa.Column('last_used', sa.DateTime(), nullable=False), - sa.PrimaryKeyConstraint('session_id') - ) - op.create_table('nio_outgoing_key_request', - sa.Column('request_id', sa.String(length=255), nullable=False), - sa.Column('session_id', sa.String(length=255), nullable=False), - sa.Column('room_id', sa.String(length=255), nullable=False), - sa.Column('algorithm', sa.String(length=255), nullable=False), - sa.PrimaryKeyConstraint('request_id') - ) - # ### end Alembic commands ### - - -def downgrade(): - # ### commands auto generated by Alembic - please adjust! ### - op.drop_table('nio_outgoing_key_request') - op.drop_table('nio_olm_session') - op.drop_table('nio_megolm_inbound_session') - op.drop_table('nio_device_key') - op.drop_table('nio_account') - # ### end Alembic commands ### diff --git a/alembic/versions/ec1d3dcc77e9_switch_telegram_ids_to_bigints.py b/alembic/versions/ec1d3dcc77e9_switch_telegram_ids_to_bigints.py deleted file mode 100644 index 5cffb99b..00000000 --- a/alembic/versions/ec1d3dcc77e9_switch_telegram_ids_to_bigints.py +++ /dev/null @@ -1,44 +0,0 @@ -"""Switch Telegram IDs to bigints - -Revision ID: ec1d3dcc77e9 -Revises: 990f4395afc6 -Create Date: 2021-03-09 21:36:58.443727 - -""" -from alembic import op -import sqlalchemy as sa - -# revision identifiers, used by Alembic. -revision = 'ec1d3dcc77e9' -down_revision = '990f4395afc6' -branch_labels = None -depends_on = None - - -columns_to_upgrade = ( - ("bot_chat", "id"), - ("message", "tgid"), - ("message", "tg_space"), - ("portal", "tgid"), - ("portal", "tg_receiver"), - ("puppet", "id"), - ("puppet", "displayname_source"), - ("user", "tgid"), - ("user_portal", "user"), - ("user_portal", "portal"), - ("user_portal", "portal_receiver"), - ("contact", "user"), - ("contact", "contact"), -) - - -def upgrade(): - if op.get_context().dialect.name == "postgresql": - for table, column in columns_to_upgrade: - op.alter_column(table, column, existing_type=sa.Integer, type_=sa.BigInteger) - - -def downgrade(): - if op.get_context().dialect.name == "postgresql": - for table, column in columns_to_upgrade: - op.alter_column(table, column, existing_type=sa.BigInteger, type_=sa.Integer) diff --git a/alembic/versions/eeaf0dae87ce_add_telethon_update_state_table.py b/alembic/versions/eeaf0dae87ce_add_telethon_update_state_table.py deleted file mode 100644 index 45f47953..00000000 --- a/alembic/versions/eeaf0dae87ce_add_telethon_update_state_table.py +++ /dev/null @@ -1,34 +0,0 @@ -"""Add telethon update state table - -Revision ID: eeaf0dae87ce -Revises: 1fa46383a9d3 -Create Date: 2018-04-30 17:30:59.610885 - -""" -from alembic import op -import sqlalchemy as sa - -# revision identifiers, used by Alembic. -revision = 'eeaf0dae87ce' -down_revision = '1fa46383a9d3' -branch_labels = None -depends_on = None - - -def upgrade(): - with op.batch_alter_table("telethon_entities") as batch_op: - batch_op.alter_column('phone', existing_type=sa.Integer, type_=sa.BigInteger) - op.create_table('telethon_update_state', - sa.Column('session_id', sa.String, nullable=False), - sa.Column('entity_id', sa.Integer, nullable=False), - sa.Column('pts', sa.Integer, nullable=True), - sa.Column('qts', sa.Integer, nullable=True), - sa.Column('date', sa.Integer, nullable=True), - sa.Column('seq', sa.Integer, nullable=True), - sa.PrimaryKeyConstraint('session_id', 'entity_id')) - - -def downgrade(): - with op.batch_alter_table("telethon_entities") as batch_op: - batch_op.alter_column('phone', existing_type=sa.BigInteger, type_=sa.Integer) - op.drop_table('telethon_update_state') diff --git a/setup.py b/setup.py index 7e22130d..e8394126 100644 --- a/setup.py +++ b/setup.py @@ -67,8 +67,6 @@ setuptools.setup( "example-config.yaml", ]}, data_files=[ - (".", ["alembic.ini", "mautrix_telegram/example-config.yaml"]), - ("alembic", ["alembic/env.py"]), - ("alembic/versions", glob.glob("alembic/versions/*.py")) + (".", ["mautrix_telegram/example-config.yaml"]), ], )