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

minor fix for prev

Browse Source
This commit is contained in:
mihalin 2022-03-18 00:21:44 +03:00
parent 1c22d2d8d7
commit db54473e0f
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
server/custom.py
View File

@ -43,10 +43,11 @@ def _on_security_policy(message: types.Message, bot):
"не делают массовых рассылок.\n\n" "не делают массовых рассылок.\n\n"
if bot.enable_additional_info: if bot.enable_additional_info:
text += "При отправке сообщения (кроме команд /start и /security_policy) оператор <b>видит</b> ваши имя " \ text += "При отправке сообщения (кроме команд /start и /security_policy) оператор <b>видит</b> ваши имя " \
"пользователя, @username и идентификатор пользователя. " "пользователя, @username и идентификатор пользователя в силу настроек, которые оператор указал при " \
"создании бота."
else: else:
text += "В зависимости от ваших настроек конфиденциальности Telegram, оператор может видеть ваш username, " \ text += "В зависимости от ваших настроек конфиденциальности Telegram, оператор может видеть ваш username, " \
"имя пользователя и другую информацию" "имя пользователя и другую информацию."
return SendMessage(chat_id=message.chat.id, return SendMessage(chat_id=message.chat.id,
text=text, text=text,
@ -92,18 +93,19 @@ async def handle_user_message(message: types.Message, super_chat_id: int, bot):
# переслать в супер-чат, отвечая на предыдущее сообщение # переслать в супер-чат, отвечая на предыдущее сообщение
try: try:
new_message = await message.copy_to(super_chat_id, reply_to_message_id=int(thread_first_message)) new_message = await message.copy_to(super_chat_id, reply_to_message_id=int(thread_first_message))
await _redis.set(_message_unique_id(bot.pk, new_message.message_id), message.chat.id,
pexpire=ServerSettings.redis_timeout_ms())
except exceptions.BadRequest: except exceptions.BadRequest:
new_message = await send_user_message(message, super_chat_id, bot) new_message = await send_user_message(message, super_chat_id, bot)
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:
# переслать супер-чат # переслать супер-чат
new_message = await send_user_message(message, super_chat_id, bot) new_message = await send_user_message(message, super_chat_id, bot)
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: # личные сообщения не поддерживают потоки сообщений: простой forward else: # личные сообщения не поддерживают потоки сообщений: простой forward
new_message = await send_user_message(message, super_chat_id, bot) await send_user_message(message, super_chat_id, bot)
bot.incoming_messages_count = F("incoming_messages_count") + 1 bot.incoming_messages_count = F("incoming_messages_count") + 1
await bot.save(update_fields=["incoming_messages_count"]) await bot.save(update_fields=["incoming_messages_count"])