from telethon import TelegramClient, eventsfrom telethon.errors.rpcerrorlist import AuthKeyErrorfrom telethon.sync import TelegramClient as SyncTelegramClient
api_id = xxxxapi_hash = 'xxxxxx'session_name = 'my_session'chat_names = ['Test', 'groupid']keywords = ['123', 'keyword2']
try:    client = TelegramClient(session_name, api_id, api_hash)    client.start()except AuthKeyError:    client = SyncTelegramClient(session_name, api_id, api_hash)    client.start()
@client.on(events.NewMessage(chats=chat_names))async def handle_new_message(event):    message_text = event.message.message    for keyword in keywords:        if keyword in message_text:            chat = await event.get_chat()            title = chat.title            sender = await event.get_sender()            sender_name = sender.first_name            print(f"Keyword '{keyword}' found in message from {sender_name} in chat '{title}': {message_text}")
print(f"Listening for messages containing {keywords} in chats {chat_names}...")client.run_until_disconnected()