admin: spears: Remove unused entries when updating from config

Author: ximion

src/lkadmin/spears.py

@@ -27,7 +27,7 @@ def spears():
     '''Configure automatic package migration.'''
 
 
-def _add_migration_task(repo_name: str, source_suites: T.List[str], target_suite: str, delays: dict[str, int]):
+def _add_migration_task(repo_name: str, source_suites: T.List[str], target_suite: str, delays: dict[str, int]) -> str:
     """Add or update a migration task."""
 
     from laniakea.db import ChangesUrgency, SpearsMigrationTask
@@ -58,6 +58,8 @@ def _add_migration_task(repo_name: str, source_suites: T.List[str], target_suite
                 raise ValueError('The priority value "{}" is unknown!'.format(prio_name))
             stask.delays[prio_name] = days
 
+        return stask.make_migration_unique_name()
+
 
 @spears.command()
 def configure_all():
@@ -133,13 +135,31 @@ def remove_hint(source_suite, target_suite, hint):
 
 @spears.command()
 @click.argument('config_fname', nargs=1)
-def add_from_config(config_fname):
+def update_from_config(config_fname):
     """Add/update migration tasks from a TOML config file."""
+    from laniakea.db import SpearsHint, SpearsExcuse, SpearsMigrationTask
+
     try:
         with open(config_fname, 'r', encoding='utf-8') as f:
             conf = tomlkit.load(f)
     except Exception as e:
         print_error_exit('Unable to load data from configuration file: {}'.format(str(e)))
 
-    for task_d in conf.get('MigrationTasks', []):
-        _add_migration_task(**task_d)
+    with session_scope() as session:
+        entries = session.query(SpearsMigrationTask).all()
+        known_tasks = {}
+        for e in entries:
+            known_tasks[e.make_migration_unique_name()] = e
+
+        for task_d in conf.get('MigrationTasks', []):
+            unq_name = _add_migration_task(**task_d)
+            known_tasks.pop(unq_name, None)
+
+        # delete the remaining, orphaned entries
+        for task in known_tasks.values():
+            hints = session.query(SpearsHint).filer(SpearsHint.migration_id == task.id).all()
+            excuses = session.query(SpearsExcuse).filer(SpearsExcuse.migration_id == task.id).all()
+
+            session.delete(hints)
+            session.delete(excuses)
+            session.delete(task)