Delete user avatars in user deletion api

app/adapters/assets.py

@@ -0,0 +1,25 @@
+import logging
+
+import httpx
+
+from app import settings
+
+assets_service_http_client = httpx.AsyncClient(
+    base_url=settings.ASSETS_SERVICE_BASE_URL,
+)
+
+
+async def delete_avatar_by_user_id(user_id: int) -> None:
+    try:
+        response = await assets_service_http_client.delete(
+            f"/api/v1/users/{user_id}/avatar",
+        )
+        if response.status_code == 404:
+            return None
+        response.raise_for_status()
+    except Exception:
+        logging.exception(
+            "Failed to delete user avatar by user id",
+            extra={"user_id": user_id},
+        )
+        return None

app/settings.py

@@ -32,3 +32,5 @@ def read_bool(s: str) -> bool:
 AWS_S3_BUCKET_NAME = os.environ["AWS_S3_BUCKET_NAME"]
 AWS_S3_ACCESS_KEY_ID = os.environ["AWS_S3_ACCESS_KEY_ID"]
 AWS_S3_SECRET_ACCESS_KEY = os.environ["AWS_S3_SECRET_ACCESS_KEY"]
+
+ASSETS_SERVICE_BASE_URL = os.environ["ASSETS_SERVICE_BASE_URL"]

app/usecases/users.py

@@ -2,6 +2,7 @@
 
 import app.state
 from app import security
+from app.adapters import assets
 from app.common_types import UserPrivileges
 from app.errors import Error
 from app.errors import ErrorCode
@@ -314,6 +315,7 @@ async def delete_one_by_user_id(user_id: int, /) -> None | Error:
         # TODO: split this to make it more clear what's being done
         #       at the usecase layer
         await users.anonymize_one_by_user_id(user_id)
+        await assets.delete_avatar_by_user_id(user_id)
 
         # TODO: (technically required) anonymize data in data backups