Добавил при отвязке метода входа удаление юзердаты

auth_backend/auth_method/outer.py

@@ -2,13 +2,16 @@
 from abc import ABCMeta, abstractmethod
 from typing import Any
 
+from event_schema.auth import UserInfo, UserLogin, 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.kafka.kafka import get_kafka_producer
 from auth_backend.models.db import AuthMethod, UserSession
 from auth_backend.utils.security import UnionAuth
 
@@ -165,7 +168,7 @@ async def _get_link(
 
         Получить данные может администратор или сам пользователь
         """
-        if cls.get_scope() not in (s.name for s in request_user.scopes) and request_user.id != user_id:
+        if cls.get_scope() not in (s.name for s in request_user.scopes) and request_user.user_id != user_id:
             raise HTTPException(status_code=HTTP_403_FORBIDDEN, detail="Not authorized")
         username = await cls.__get_username(user_id)
         if not username:
@@ -197,6 +200,7 @@ async def _link(
     async def _unlink(
         cls,
         user_id: int,
+        background_tasks: BackgroundTasks,
         request_user: UserSession = Depends(UnionAuth()),
     ):
         """Отвязать внешний аккаунт пользователю
@@ -210,3 +214,9 @@ async def _unlink(
             raise UserNotLinked(user_id)
         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),
+            UserLogin(source=cls.get_name(), items=[UserInfo(category=cls.get_name(), param="username", value=None)]),
+        )

auth_backend/settings.py

@@ -7,7 +7,6 @@
 
 from annotated_types import Gt
 from pydantic import PostgresDsn
-from pydantic.types import PathType
 from pydantic_settings import BaseSettings, SettingsConfigDict