test: cover run_all ordering and errors

tests/test_commands_run_all.py

@@ -0,0 +1,132 @@
+import logging
+
+import pytest
+
+import skywipe.commands as commands
+import skywipe.operations as operations
+
+
+def test_create_operation_handler_calls_confirmation_and_run(monkeypatch):
+    calls = {"confirmed": False, "run": 0}
+
+    def fake_confirm(message, skip_confirmation, logger):
+        calls["confirmed"] = True
+        assert message == "do the thing"
+        assert skip_confirmation is True
+        assert isinstance(logger, logging.Logger)
+
+    class FakeOperation:
+        def __init__(self, *args, **kwargs):
+            pass
+
+        def run(self):
+            calls["run"] += 1
+
+    monkeypatch.setattr(commands, "require_confirmation", fake_confirm)
+    monkeypatch.setattr(commands, "Operation", FakeOperation)
+
+    handler = commands._create_operation_handler(
+        "do the thing", "Test", strategy_type="feed"
+    )
+    handler(skip_confirmation=True)
+
+    assert calls["confirmed"] is True
+    assert calls["run"] == 1
+
+
+def test_run_all_runs_in_order(monkeypatch):
+    ran = []
+
+    fake_commands = {
+        "posts": "only posts",
+        "likes": "only likes",
+        "medias": "only medias",
+        "extra": "extra",
+    }
+    fake_metadata = {
+        "posts": {
+            "operation_name": "Deleting posts",
+            "strategy_type": "feed",
+            "collection": None,
+            "filter_fn": None,
+        },
+        "likes": {
+            "operation_name": "Undoing likes",
+            "strategy_type": "record",
+            "collection": "app.bsky.feed.like",
+            "filter_fn": None,
+        },
+        "medias": {
+            "operation_name": "Deleting posts with media",
+            "strategy_type": "feed",
+            "collection": None,
+            "filter_fn": None,
+        },
+        "extra": {
+            "operation_name": "Extra op",
+            "strategy_type": "feed",
+            "collection": None,
+            "filter_fn": None,
+        },
+    }
+    fake_order = ["medias", "posts", "likes"]
+
+    class FakeOperation:
+        def __init__(self, operation_name, **kwargs):
+            self.operation_name = operation_name
+
+        def run(self):
+            ran.append(self.operation_name)
+
+    class FakeOperationContext:
+        def __init__(self):
+            self.client = object()
+            self.config_data = {"batch_size": 1, "delay": 0}
+
+    monkeypatch.setattr(commands, "require_confirmation",
+                        lambda *args, **kwargs: None)
+    monkeypatch.setattr(commands, "Operation", FakeOperation)
+    monkeypatch.setattr(operations, "OperationContext", FakeOperationContext)
+    monkeypatch.setattr(commands.registry,
+                        "get_all_commands", lambda: fake_commands)
+    monkeypatch.setattr(commands, "COMMAND_METADATA", fake_metadata)
+    monkeypatch.setattr(commands, "COMMAND_EXECUTION_ORDER", fake_order)
+
+    commands.run_all(skip_confirmation=True)
+
+    expected = [
+        "Deleting posts with media",
+        "Deleting posts",
+        "Undoing likes",
+        "Extra op",
+    ]
+
+    assert ran == expected
+
+
+def test_run_all_continues_on_error(monkeypatch):
+    ran = []
+
+    class FakeOperation:
+        def __init__(self, operation_name, **kwargs):
+            self.operation_name = operation_name
+
+        def run(self):
+            ran.append(self.operation_name)
+            if self.operation_name == "Deleting posts":
+                raise RuntimeError("fail")
+
+    class FakeOperationContext:
+        def __init__(self):
+            self.client = object()
+            self.config_data = {"batch_size": 1, "delay": 0}
+
+    monkeypatch.setattr(commands, "require_confirmation",
+                        lambda *args, **kwargs: None)
+    monkeypatch.setattr(commands, "Operation", FakeOperation)
+    monkeypatch.setattr(operations, "OperationContext", FakeOperationContext)
+
+    commands.run_all(skip_confirmation=True)
+
+    assert "Deleting posts" in ran
+    assert len(ran) >= 2