Merge pull request #7 from wakscord/feature/delete-all-unsubscribers

구독 해지 유저 전체 삭제 API 추가

app/domain/unsubscriber/repository.py

@@ -4,14 +4,25 @@
 
 
 class UnsubscriberRepository(abc.ABC):
+    _UNSUBSCRIBERS_KEY = "unsubscribers"
+
     @abc.abstractmethod
     async def get_unsubscribers(self) -> set[str]:
         raise NotImplementedError
 
+    @abc.abstractmethod
+    async def delete_all_unsubscribers(self) -> int:
+        raise NotImplementedError
+
 
 class UnsubscriberRedisRepository(UnsubscriberRepository):
     def __init__(self, session: Redis):
         self._session = session
 
     async def get_unsubscribers(self) -> set[str]:
-        return await self._session.smembers("unsubscribers")
+        return await self._session.smembers(self._UNSUBSCRIBERS_KEY)
+
+    async def delete_all_unsubscribers(self) -> int:
+        deleted_count = await self._session.scard(self._UNSUBSCRIBERS_KEY)
+        await self._session.delete(self._UNSUBSCRIBERS_KEY)
+        return deleted_count

app/domain/unsubscriber/schemas.py

@@ -3,3 +3,7 @@
 
 class UnsubscribersResponse(BaseResponse):
     unsubscribers: list[str]
+
+
+class DeleteAllUnsubscribersResponse(BaseResponse):
+    deleted_count: int

app/router/unsubscriber.py

@@ -3,7 +3,7 @@
 
 from app.common.di import AppContainer
 from app.domain.unsubscriber.repository import UnsubscriberRepository
-from app.domain.unsubscriber.schemas import UnsubscribersResponse
+from app.domain.unsubscriber.schemas import DeleteAllUnsubscribersResponse, UnsubscribersResponse
 
 router = APIRouter(prefix="/unsubscribers", tags=["unsubscriber"])
 
@@ -17,3 +17,12 @@ async def unsubscribers(
 ) -> UnsubscribersResponse:
     unsubscribers = await unsub_repo.get_unsubscribers()
     return UnsubscribersResponse(unsubscribers=unsubscribers)
+
+
+@router.delete("", description="구독 해지 유저 전체 삭제 API")
+@inject
+async def delete_all_unsubscribers(
+    unsub_repo: UnsubscriberRepository = Depends(provide_unsub_repository),
+) -> DeleteAllUnsubscribersResponse:
+    deleted_count = await unsub_repo.delete_all_unsubscribers()
+    return DeleteAllUnsubscribersResponse(deleted_count=deleted_count)