core: services: commander: main: Add new remove_log_stream

Signed-off-by: Patrick José Pereira <patrickelectric@gmail.com>

Author: patrickelectric

core/services/commander/main.py

@@ -1,4 +1,5 @@
 #! /usr/bin/env python3
+import json
 import logging
 import os
 import shutil
@@ -12,10 +13,10 @@
 import uvicorn
 from commonwealth.utils.apis import GenericErrorHandlingRoute
 from commonwealth.utils.commands import run_command
-from commonwealth.utils.general import delete_everything
+from commonwealth.utils.general import delete_everything, delete_everything_stream
 from commonwealth.utils.logs import InterceptHandler, init_logger
 from fastapi import FastAPI, HTTPException, status
-from fastapi.responses import HTMLResponse
+from fastapi.responses import HTMLResponse, StreamingResponse
 from fastapi_versioning import VersionedFastAPI, version
 from loguru import logger
 
@@ -257,6 +258,19 @@ def setup_ssh() -> None:
     logger.info("SSH setup done")
 
 
+@app.post("/services/remove_log_stream", status_code=status.HTTP_200_OK)
+@version(1, 0)
+async def remove_log_services_stream(i_know_what_i_am_doing: bool = False) -> StreamingResponse:
+    """Stream the deletion of log files, providing real-time updates about each file being deleted."""
+    check_what_i_am_doing(i_know_what_i_am_doing)
+
+    async def generate():
+        async for info in delete_everything_stream(Path(LOG_FOLDER_PATH)):
+            yield json.dumps(info) + "\n"
+
+    return StreamingResponse(generate(), media_type="application/x-ndjson")
+
+
 if __name__ == "__main__":
     setup_ssh()
     # Register ssh client and remove message from the following commands