Feature/adding mset replacement functionality 20210615

datameta/alembic/versions/20210625_f6a70402119f.py

@@ -0,0 +1,56 @@
+"""added msetreplacements table, moved update-related fields from mset, added user.can_update flag
+
+Revision ID: f6a70402119f
+Revises: 7fdc829db18d
+Create Date: 2021-06-25 15:27:37.638601
+
+"""
+from alembic import op
+import sqlalchemy as sa
+from sqlalchemy.dialects import postgresql
+
+# revision identifiers, used by Alembic.
+revision = 'f6a70402119f'
+down_revision = '7fdc829db18d'
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.create_table(
+        'msetreplacements',
+        sa.Column('id', sa.Integer(), nullable=False),
+        sa.Column('uuid', postgresql.UUID(as_uuid=True), nullable=False),
+        sa.Column('user_id', sa.Integer(), nullable=False),
+        sa.Column('datetime', sa.DateTime(), nullable=False),
+        sa.Column('label', sa.String(length=140), nullable=False),
+        sa.Column('new_metadataset_id', sa.Integer(), nullable=False),
+        sa.ForeignKeyConstraint(['new_metadataset_id'], ['metadatasets.id'], name=op.f('fk_msetreplacements_new_metadataset_id_metadatasets')),
+        sa.ForeignKeyConstraint(['user_id'], ['users.id'], name=op.f('fk_msetreplacements_user_id_users')),
+        sa.PrimaryKeyConstraint('id', name=op.f('pk_msetreplacements')),
+        sa.UniqueConstraint('uuid', name=op.f('uq_msetreplacements_uuid'))
+    )
+    op.add_column('metadatasets', sa.Column('replaced_via_event_id', sa.Integer(), nullable=True))
+    op.drop_constraint('fk_metadatasets_replaced_by_id_metadatasets', 'metadatasets', type_='foreignkey')
+    op.create_foreign_key(op.f('fk_metadatasets_replaced_via_event_id_msetreplacements'), 'metadatasets', 'msetreplacements', ['replaced_via_event_id'], ['id'], use_alter=True)
+    op.drop_column('metadatasets', 'deprecated_label')
+    op.drop_column('metadatasets', 'replaced_by_id')
+    op.drop_column('metadatasets', 'is_deprecated')
+    op.add_column('users', sa.Column('can_update', sa.Boolean(create_constraint=False), nullable=True))
+    op.execute('UPDATE users SET can_update = site_admin;')
+    op.alter_column('users', 'can_update', nullable=False)
+    # ### end Alembic commands ###
+
+
+def downgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_column('users', 'can_update')
+    op.add_column('metadatasets', sa.Column('is_deprecated', sa.BOOLEAN(), autoincrement=False, nullable=True))
+    op.add_column('metadatasets', sa.Column('replaced_by_id', sa.INTEGER(), autoincrement=False, nullable=True))
+    op.add_column('metadatasets', sa.Column('deprecated_label', sa.VARCHAR(), autoincrement=False, nullable=True))
+    op.drop_constraint(op.f('fk_metadatasets_replaced_via_event_id_msetreplacements'), 'metadatasets', type_='foreignkey')
+    op.create_foreign_key('fk_metadatasets_replaced_by_id_metadatasets', 'metadatasets', 'metadatasets', ['replaced_by_id'], ['id'])
+    op.drop_column('metadatasets', 'replaced_via_event_id')
+    op.drop_table('msetreplacements')
+    # ### end Alembic commands ###

datameta/api/__init__.py

@@ -62,6 +62,7 @@ def includeme(config: Configurator) -> None:
     config.add_route("groups_id", base_url + "/groups/{id}")
     config.add_route("rpc_delete_files", base_url + "/rpc/delete-files")
     config.add_route("rpc_delete_metadatasets", base_url + "/rpc/delete-metadatasets")
+    config.add_route("rpc_replace_metadatasets", base_url + "/rpc/replace-metadatasets")
     config.add_route("rpc_get_file_url", base_url + "/rpc/get-file-url/{id}")
     config.add_route('register_submit', base_url + "/registrations")
     config.add_route("register_settings", base_url + "/registrationsettings")