Hello Who could to explain how to add message hander in

Question

Hello Who could to explain how to add message hander in

multi thread bot?

i have this code, and he is working
accounts = tuple(TelegramClient(StringSession(x.strip()), api_id, api_hash) for x in sessions_strings)

async def work(client):
async with client:
me = await client.get_me()
await client.send_message("@Gumbl4", me.first_name)
starttime = time.time()
# while True:
# print('Working with', me.first_name)
# delay = 0.1
# time.sleep(delay - ((time.time() - starttime) % delay))

def main(client):
asyncio.run(work(client))

thread_list = []
for acc in accounts:
thread_list.append(Thread(target=main, args=(acc,)))
for t in thread_list:
t.start()
for t in thread_list:
t.join()

but this is not working already
async def work(client):
async with client:
me = await client.get_me()
while True:
@events.register(events.NewMessage('(?i)hello'))
async def handler(event):
client = event.client
await event.respond('Hey!')
await client.send_message('me', 'I said hello to someone')
await client.send_message("@Gumbl4", me.first_name)
starttime = time.time()
# while True:
# print('Working with', me.first_name)
# delay = 0.1
# time.sleep(delay - ((time.time() - starttime) % delay))

def main(client):
asyncio.run(work(client))

thread_list = []
for acc in accounts:
thread_list.append(Thread(target=main, args=(acc,)))
for t in thread_list:
t.start()
for t in thread_list:
t.join()

0

19.11.2023

10 ответов

81 просмотр

Sergo [AFK] Автор вопроса

⎞ .·. ⎝ ⎝
Just don't use threads, asyncio tasks will do

How, if i need to use 2+ accounts?

0

19.11.2023

⎞ .·. ⎝ ⎝

Sergo [AFK]
How, if i need to use 2+ accounts?

it isn't your main issue, but still, using asyncio is more fitting for async library. so same way as now, just replace running parts async def work(client): .... same stuff, but at last line add await client.run_until_disconnected() async def main(client): await asyncio.gather(*[work(client) for client in accounts]) asyncio.run(main()) and replace any time.sleep with await asyncio.sleep, and why do you have while True in second one? remove that too

0

19.11.2023

Sergo [AFK] Автор вопроса

⎞ .·. ⎝ ⎝
it isn't your main issue, but still, using asyncio...

logging.info('Reading sessions...!') sessions_strings = open("string_sessions.txt", "r").readlines() accounts = tuple(TelegramClient(StringSession(x.strip()), api_id, api_hash) for x in sessions_strings) async def work(client): async with client: me = await client.get_me() @events.register(events.NewMessage('(?i)hello')) async def handler(event): client = event.client await event.respond('Hey!') await client.send_message('me', 'I said hello to someone') await client.send_message("@Gumbl4", me.first_name) await client.run_until_disconnected() async def main(client): #asyncio.run(work(client)) await asyncio.gather(*[work(client) for client in accounts]) asyncio.run(main()) Intresting, but TypeError: main() missing 1 required positional argument: 'client' why, if i give it him?

0

20.11.2023

⎞ .·. ⎝ ⎝

Sergo [AFK]
logging.info('Reading sessions...!') sessions_stri...

yeah, remove that too async def main(client): -> async def main():

0

20.11.2023

Sergo [AFK] Автор вопроса

⎞ .·. ⎝ ⎝
yeah, remove that too async def main(client): ->...

ok, i fixed it with ur advice or self with add arg. But handler message dont work, and online hold approximately 10-20 seconds and accounts going get offline status

0

20.11.2023

⎞ .·. ⎝ ⎝

Sergo [AFK]
ok, i fixed it with ur advice or self with add arg...

which sort of "offline status" also why are you using @events.register() without add_event_handler, make that @client.on(events.NewMessage('(?i)hello')) if this is all of the code.

0

20.11.2023

Sergo [AFK] Автор вопроса

⎞ .·. ⎝ ⎝
which sort of "offline status" also why are you u...

Стикер

0

20.11.2023

⎞ .·. ⎝ ⎝

That's normal, status setting needs to be done by a seperate request manually. fix your @events.register() first if the command isn't working

0

20.11.2023

Sergo [AFK] Автор вопроса