advatroniks/Telegram-Scrapper
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add fix

Browse Source
This commit is contained in:
harold 2025-05-05 17:07:03 +05:00
parent 7bc7e5b09f
commit 16855d1de9
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
telegram-application/src/core/tg_service/service.py
View File

@ -1,3 +1,4 @@
import asyncio
import uuid import uuid
from pyrogram.types.user_and_chats import User as PyroUser, Chat as PyroChat 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.rabbitmq.connect import message_handler_publisher
from src.core.redis_helper.redis_connect import redis_client 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.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.tg_service.schemas import UserFromMessageSchema, MessagesForSendToWorkersSchema, MessageFromChatSchema
from src.core.database.connect import db_helper from src.core.database.connect import db_helper
from src.core.tg_service import crud as tg_crud from src.core.tg_service import crud as tg_crud
lock = asyncio.Lock()
async def check_user_exists( async def check_user_exists(
user_pyrogram: PyroUser, user_pyrogram: PyroUser,