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

use redis message cache for chat ids retrieval

Browse Source
This commit is contained in:
arĉi 2022-10-29 17:56:00 +06:00
parent 992daa5b30
commit 58a9bc81b0
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
olgram/commands/bot_actions.py
View File

@ -5,8 +5,9 @@ import asyncio
from aiogram import types from aiogram import types
from aiogram.utils.exceptions import TelegramAPIError, Unauthorized from aiogram.utils.exceptions import TelegramAPIError, Unauthorized
from aiogram import Bot as AioBot from aiogram import Bot as AioBot
from olgram.models.models import Bot, User from olgram.models.models import Bot
from server.server import unregister_token from server.server import unregister_token
from server.custom import _redis
from typing import Optional from typing import Optional
from locales.locale import _ from locales.locale import _
@ -93,7 +94,8 @@ async def start_broadcast(bot: Bot, call: types.CallbackQuery, text: Optional[st
if not text: if not text:
return await call.answer(_("Отправьте текст для рассылки")) return await call.answer(_("Отправьте текст для рассылки"))
user_chat_ids = await User.all().values_list("telegram_id", flat=True) keys = [key async for key in _redis.iscan(match=f"{bot.id}_*")]
user_chat_ids = await _redis.mget(*keys)
a_bot = AioBot(bot.decrypted_token()) a_bot = AioBot(bot.decrypted_token())
count = 0 count = 0
await call.answer(_("Рассылка начата")) await call.answer(_("Рассылка начата"))