-
Notifications
You must be signed in to change notification settings - Fork 2
/
channels_listener.py
56 lines (38 loc) · 1.99 KB
/
channels_listener.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
from telethon import TelegramClient, events
from common import environments as env
from validators.quality_channel import quality_channel_validator
from validators.alpha_trade_channel import alpha_trade_channel_validator
from validators.scalping_300_channel import scalipng_300_channel_validator
api_id = env.API_Id
api_hash = env.API_HASH
client = TelegramClient('anon', api_id, api_hash)
palantir_channel = 'https://t.me/ravand_palantir'
@client.on(events.NewMessage(chats='https://t.me/QualitySignalsChannel'))
# @client.on(events.NewMessage(chats='me'))
async def quality_signal_channel_listener(event):
new_message = event.message.message
print("-------- new signal from quality channel")
final_message = quality_channel_validator(new_message)
if final_message:
# await client.forward_messages(entity=palantir_channel, messages=event.message)
await client.send_message(entity=palantir_channel, message=final_message)
@client.on(events.NewMessage(chats='https://t.me/AlphaTradeZone_Com'))
# @client.on(events.NewMessage(chats='me'))
async def alpha_trade_channel_listener(event):
new_message = event.message.message
print("-------- new signal from alpha trade")
final_message = alpha_trade_channel_validator(new_message)
if final_message:
# await client.forward_messages(entity=palantir_channel, messages=event.message)
await client.send_message(entity=palantir_channel, message=final_message)
@client.on(events.NewMessage(chats='https://t.me/Scalping_300'))
# @client.on(events.NewMessage(chats='me'))
async def scalping_300_channel_listener(event):
new_message = event.message.message
print("-------- new signal from scalping 300")
final_message = scalipng_300_channel_validator(new_message)
if final_message:
# await client.forward_messages(entity=palantir_channel, messages=event.message)
await client.send_message(entity=palantir_channel, message=final_message)
with client:
client.run_until_disconnected()