feat: add nix-collect-garbage job

@@ -0,0 +5,4 @@
+
+
+COMPLETED_WITH_ERROR = "Completed with an error"
+RESULT_WAAS_NOT_FOUND_ERROR = "We are sorry, result was not found :("

@@ -0,0 +67,4 @@
+
+    for line in stream:
+        if "deleting '/nix/store/" in line:
+            percent += package_equal_to_percent

@@ -0,0 +191,4 @@
+        (JobStatus.RUNNING, 10, "Сleaning...", ""),
+        (JobStatus.RUNNING, 15, "Сleaning...", ""),
+        (JobStatus.RUNNING, 20, "Сleaning...", ""),
+        (JobStatus.RUNNING, 25, "Сleaning...", ""),

@@ -0,0 +222,4 @@
+    assert log_event == reference
+
+
+# андр конcтракнш

@@ -127,2 +130,4 @@
             code=500,
         )
+
+    @strawberry.mutation(permission_classes=[IsAuthenticated])

@@ -0,0 +19,4 @@
+    )
+
+
+def run_nix_collect_garbage():

@@ -0,0 +25,4 @@
+    ).stdout
+
+
+def parse_line(line):

@@ -0,0 +31,4 @@
+
+    if match is None:
+        return (
+            JobStatus.FINISHED,

@@ -0,0 +40,4 @@
+    else:
+        return (
+            JobStatus.FINISHED,
+            100,

@@ -0,0 +43,4 @@
+            100,
+            CLEAR_COMPLETED,
+            f"{match.group(0)} have been cleared",
+        )

@@ -0,0 +46,4 @@
+        )
+
+
+def stream_process(job, stream, total_dead_packages):

@@ -0,0 +129,4 @@
+    response = authorized_client.post(
+        "/graphql",
+        json={
+            "query": RUN_NIX_COLLECT_GARBAGE_QUERY,

@@ -0,0 +137,4 @@
+    assert response.json().get("data") is not None
+    assert response.json()["data"]["system"]["nixCollectGarbage"]["success"] is True
+    assert response.json()["data"]["system"]["nixCollectGarbage"]["message"] is not None
+    assert response.json()["data"]["system"]["nixCollectGarbage"]["success"] == True

@@ -0,0 +69,4 @@
+    mock = mocker.patch(
+        "selfprivacy_api.jobs.nix_collect_garbage.set_job_status_wrapper",
+        autospec=True,
+        return_value=set_job_status,

@@ -129,0 +137,4 @@
+        return GenericJobMutationReturn(
+            success=True,
+            code=200,
+            message="Cleaning started..,",

@@ -0,0 +7,4 @@
+
+
+COMPLETED_WITH_ERROR = "Completed with an error"
+RESULT_WAS_NOT_FOUND_ERROR = "We are sorry, result was not found :("

@@ -0,0 +100,4 @@
+
+    if dead_packages == 0:
+        Jobs.update(
+            job=job,

@@ -0,0 +14,4 @@
+CLEAR_COMPLETED = "Cleaning completed."
+
+
+def run_nix_store_print_dead() -> PIPE:

@@ -0,0 +25,4 @@
+    )
+
+
+def run_nix_collect_garbage() -> subprocess.Popen:

@@ -0,0 +58,4 @@
+        )
+
+
+def process_stream(job, stream, total_dead_packages):

@@ -0,0 +89,4 @@
+            )
+
+
+def get_dead_packages(output):

@@ -0,0 +18,4 @@
+    RESULT_WAS_NOT_FOUND_ERROR,
+)
+
+pytest_plugins = ("pytest_asyncio",)

@@ -194,0 +201,4 @@
+
+        return GenericJobMutationReturn(
+            success=True,
+            code=200,

@@ -0,0 +46,4 @@
+    if match is None:
+        Jobs.update(
+            job=job,
+            status=JobStatus.ERROR,

@@ -0,0 +124,4 @@
+"""
+
+
+def test_graphql_nix_collect_garbage(authorized_client, mock_delete_old_gens_and_print_dead):

@@ -0,0 +56,4 @@
+
+
+@pytest.fixture
+def mock_delete_old_gens_and_return_dead_report(mocker):

@@ -0,0 +127,4 @@
+"""
+
+
+def test_graphql_nix_collect_garbage(authorized_client, mock_delete_old_gens_and_return_dead_report):