diff --git a/telegram-application/src/core/tg_service/service.py b/telegram-application/src/core/tg_service/service.py index 96bb5b5..f72e4ba 100644 --- a/telegram-application/src/core/tg_service/service.py +++ b/telegram-application/src/core/tg_service/service.py @@ -1,3 +1,4 @@ +import asyncio import uuid from pyrogram.types.user_and_chats import User as PyroUser, Chat as PyroChat @@ -6,11 +7,13 @@ from src.core.database import TgChat, User from src.core.rabbitmq.connect import message_handler_publisher from src.core.redis_helper.redis_connect import redis_client from src.core.tg_service.constants import MESSAGE_CHANG_SIZE -from src.core.tg_service.messages_handler import lock from src.core.tg_service.schemas import UserFromMessageSchema, MessagesForSendToWorkersSchema, MessageFromChatSchema from src.core.database.connect import db_helper from src.core.tg_service import crud as tg_crud +lock = asyncio.Lock() + + async def check_user_exists( user_pyrogram: PyroUser,