38 lines
912 B
Python
38 lines
912 B
Python
import asyncio
|
|
import json
|
|
|
|
# Change this:
|
|
USER_PHONE = '+19705736497'
|
|
|
|
from telethon.sync import TelegramClient, events, utils
|
|
|
|
TELETHON_SPAM = -1001382672427
|
|
BWB = -1001146421621
|
|
HORSESHOE = -1001269329011
|
|
|
|
SESSION = 'telethon'
|
|
API_ID = '929249' # semi-secret
|
|
API_HASH = '00c171d347a5140ddf2212157ab2a37a' # semi-secret
|
|
|
|
client = TelegramClient(SESSION, API_ID, API_HASH, sequential_updates=True)
|
|
client.start(USER_PHONE)
|
|
|
|
@client.on(events.NewMessage(chats=(HORSESHOE)))
|
|
async def new_message(event):
|
|
text = event.raw_text
|
|
print('[{}]: {}'.format(event.sender.first_name, text))
|
|
|
|
if text and len(text) < 1000:
|
|
m = {}
|
|
m['chat_id'] = event.chat_id
|
|
m['mid'] = event.id
|
|
m['from_id'] = event.sender_id
|
|
m['raw_text'] = event.raw_text
|
|
|
|
j = json.dumps(m)
|
|
|
|
await client.send_message(BWB, j)
|
|
|
|
print('Loaded.')
|
|
asyncio.get_event_loop().run_forever()
|