Dependencies/olgram
1
0
Fork 1
mirror of https://github.com/civsocit/olgram.git synced 2023-07-22 01:29:12 +03:00
Code Issues Packages Projects Releases Wiki Activity

threads first iteration

Browse Source
This commit is contained in:
mihalin 2022-02-16 20:52:08 +03:00
parent d4582d9a9d
commit 878abc6a0f
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/custom.py
View File

@ -55,18 +55,18 @@ async def message_handler(message: types.Message, *args, **kwargs):
return SendMessage(chat_id=message.chat.id, return SendMessage(chat_id=message.chat.id,
text="Вы заблокированы в этом боте") text="Вы заблокированы в этом боте")
# Пересылаем сообщение в супер-чат
if is_super_group: if is_super_group:
thread_first_message = await _redis.get(_thread_uniqie_id(bot.pk, message.chat.id)) thread_first_message = await _redis.get(_thread_uniqie_id(bot.pk, message.chat.id))
if thread_first_message: if thread_first_message:
# переслать в супер-чат, отвечая на предыдущее сообщение # переслать в супер-чат, отвечая на предыдущее сообщение
new_message = await message.copy_to(super_chat_id, reply_to_message_id=thread_first_message) new_message = await message.copy_to(super_chat_id, reply_to_message_id=int(thread_first_message))
else: else:
# переслать супер-чат # переслать супер-чат
new_message = await message.forward(super_chat_id) new_message = await message.forward(super_chat_id)
await _redis.set(_thread_uniqie_id(bot.pk, message.chat.id), new_message.message_id, await _redis.set(_thread_uniqie_id(bot.pk, message.chat.id), new_message.message_id,
pexpire=ServerSettings.thread_timeout_ms()) pexpire=ServerSettings.thread_timeout_ms())
else: else: # личные сообщения не поддерживают потоки сообщений: простой forward
# сообщение нужно переслать в супер-чат
new_message = await message.forward(super_chat_id) new_message = await message.forward(super_chat_id)
await _redis.set(_message_unique_id(bot.pk, new_message.message_id), message.chat.id, await _redis.set(_message_unique_id(bot.pk, new_message.message_id), message.chat.id,