diff --git a/services/auth/app/services/admin_delete.py b/services/auth/app/services/admin_delete.py index 36fc89b3..ba130ef9 100644 --- a/services/auth/app/services/admin_delete.py +++ b/services/auth/app/services/admin_delete.py @@ -34,9 +34,10 @@ router = APIRouter() class AdminUserDeleteService: """Service to handle complete admin user deletion across all microservices""" - def __init__(self, db: AsyncSession): + def __init__(self, db: AsyncSession, event_publisher=None): self.db = db self.clients = AuthServiceClientFactory(settings) + self.event_publisher = event_publisher async def delete_admin_user_complete(self, user_id: str, requesting_user_id: str) -> Dict[str, Any]: """ @@ -459,10 +460,7 @@ class AdminUserDeleteService: return summary - def __init__(self, database_manager, event_publisher=None): - """Initialize service with database manager and optional event publisher""" - self.database_manager = database_manager - self.event_publisher = event_publisher + async def _publish_user_deleted_event(self, user_id: str, deletion_results: Dict[str, Any]): """Publish user deletion event to message queue"""