Das deutsche Python-Forum

Code: Alles auswählen

#!/usr/bin/env python
import asyncio
import logging
import datetime
import hashlib

from telethon import TelegramClient, events

import config

logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__)

client = TelegramClient(config.SESSION_NAME, config.API_ID, config.API_HASH)
client.start()

RELAY_MAP = {}


async def setup():
    user = await client.get_me()
    logger.info(' Starte Server durch {}'.format(user.first_name))
    await client.get_dialogs()

    for x in config.RELAY_MAP.split(';'):
        if not x:
            return

        key, values = x.split(':', 1)
        values = values.split(',')
        RELAY_MAP[int(key)] = [int(x) for x in values]


@client.on(events.NewMessage)
async def my_event_handler(event):
    for chat_id, relays in RELAY_MAP.items():
        if event.chat and event.chat.id == chat_id:
            for relay in relays:

                # Prüfen ob die angekommene Nachricht überhaupt Text enthält...
                if event.raw_text == "":
                    print(
                        "🅾️ " + datetime.datetime.now().strftime('%X') + ": Nachricht enthält keinen Text...")

                # Sonst diese Benachrichtigung ausgeben und die Nachricht posten
                else:
                    print("✅ " + datetime.datetime.now().strftime(
                        '%X') + ": Nachricht '{}...' wurde von {} zu {} gesendet".format(event.raw_text[:50].replace("\n", " "), event.chat.id, relay))

                # Die Nachricht wird gepostet
                await client.send_message(relay, event.message)

                break


loop = asyncio.get_event_loop()
loop.run_until_complete(setup())
client.run_until_disconnected()

Code: Alles auswählen

#!/usr/bin/env python3
import asyncio
import logging
import datetime
from telethon import TelegramClient, events
from functools import partial
import config

logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__)

async def relay_event_handler(queue, relay_map, event):
    for chat_id, relays in relay_map.items():
        if event.chat and event.chat.id == chat_id:
            now = datetime.datetime.now()
            # Prüfen ob die angekommene Nachricht überhaupt Text enthält...
            if event.raw_text == "":
                print(f"🅾️ {now:%X}: Nachricht enthält keinen Text...")
            # Sonst diese Benachrichtigung ausgeben und die Nachricht posten
            else:
                raw = event.raw_text[:50].replace("\n", " ")
                print(f"✅ {now:%X}: Nachricht '{raw}...' wurde von {event.chat.id} zu {relays} gesendet")
                queue.put((relays, event.message))

async def send_messages(client, queue):
    while True:
        relays, message = await queue.get()
        for relay in relays:
            # Die Nachricht wird gepostet
            await client.send_message(relay, message)
        await asyncio.sleep(10)

async def main():
    client = TelegramClient(config.SESSION_NAME, config.API_ID, config.API_HASH)
    client.start()
    user = await client.get_me()
    logger.info(' Starte Server durch {}'.format(user.first_name))
    await client.get_dialogs()

    relay_map = {}
    for relay in config.RELAY_MAP.split(';'):
        if not relay:
            break
        key, values = relay.split(':', 1)
        relay_map[int(key)] = [int(k) for k in values.split(',')]
    
    queue = asyncio.Queue()
    asyncio.create_task(send_messages(client, queue))
    client.add_event_handler(partial(relay_event_handler, relay_map, queue), events.NewMessage)
    await client.run_until_disconnected()

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())