You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
async def setup():
user = await client.get_me()
logger.info('Started serving as {}'.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:
logger.info('Sending message from {} to {}'.format(event.chat.id, relay))
if config.FORWARD:
await client.forward_messages(relay, event.message)
else:
await client.send_message(relay, event.message)
break
else:
for relay in RELAY_MAP.get('default', []):
logger.info('Sending message from {} to {}'.format(event.chat.id, relay))
if config.FORWARD:
await client.forward_messages(relay, event.message)
else:
await client.send_message(relay, event.message)
#!/usr/bin/env python
import asyncio
import logging
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('Started serving as {}'.format(user.first_name))
await client.get_dialogs()
@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:
logger.info('Sending message from {} to {}'.format(event.chat.id, relay))
if config.FORWARD:
await client.forward_messages(relay, event.message)
else:
await client.send_message(relay, event.message)
break
else:
for relay in RELAY_MAP.get('default', []):
logger.info('Sending message from {} to {}'.format(event.chat.id, relay))
if config.FORWARD:
await client.forward_messages(relay, event.message)
else:
await client.send_message(relay, event.message)
loop = asyncio.get_event_loop()
loop.run_until_complete(setup())
client.run_until_disconnected()
The text was updated successfully, but these errors were encountered: