добавил связь с kafka для удаления userdata

Author: petrCher

auth_backend/auth_method/outer.py

@@ -2,14 +2,17 @@
 from abc import ABCMeta, abstractmethod
 from typing import Any
 
+from event_schema.auth import UserLoginKey
 from fastapi import Depends
+from fastapi.background import BackgroundTasks
 from fastapi.exceptions import HTTPException
 from fastapi_sqlalchemy import db
 from starlette.status import HTTP_403_FORBIDDEN, HTTP_404_NOT_FOUND, HTTP_409_CONFLICT, HTTP_424_FAILED_DEPENDENCY
 
 from auth_backend.auth_method.base import AuthPluginMeta
 from auth_backend.base import Base
-from auth_backend.models.db import AuthMethod, User, UserSession
+from auth_backend.kafka.kafka import get_kafka_producer
+from auth_backend.models.db import AuthMethod, UserSession
 from auth_backend.utils.security import UnionAuth
 
 
@@ -197,6 +200,7 @@ async def _link(
     async def _unlink(
         cls,
         user_id: int,
+        background_tasks: BackgroundTasks,
         request_user: UserSession = Depends(UnionAuth()),
     ):
         """Отвязать внешний аккаунт пользователю
@@ -205,7 +209,14 @@ async def _unlink(
         """
         if cls.delete_scope() not in (s.name for s in request_user.scopes):
             raise HTTPException(status_code=HTTP_403_FORBIDDEN, detail="Not authorized")
-        user = User.get(user_id, session=db.session)
-        if not user:
+        username = await cls.__get_username(user_id)
+        if not username:
             raise UserNotLinked(user_id)
-        await cls._delete_auth_methods(user, db_session=db.session)
+        username.is_deleted = True
+        db.session.commit()
+        background_tasks.add_task(
+            get_kafka_producer().produce,
+            cls.settings.KAFKA_USER_LOGIN_TOPIC_NAME,
+            UserLoginKey(user_id=user_id, auth_method=cls.get_name()),
+            None,
+        )