mirror of
https://github.com/civsocit/olgram.git
synced 2023-07-22 01:29:12 +03:00
test
This commit is contained in:
parent
122c05de19
commit
2edc9dec38
@ -5,21 +5,21 @@ from aiogram import exceptions
|
|||||||
from aiogram import types
|
from aiogram import types
|
||||||
from contextvars import ContextVar
|
from contextvars import ContextVar
|
||||||
from aiohttp.web_exceptions import HTTPNotFound
|
from aiohttp.web_exceptions import HTTPNotFound
|
||||||
import aioredis
|
from aioredis.commands import create_redis_pool
|
||||||
|
from aioredis import Redis
|
||||||
import typing as ty
|
import typing as ty
|
||||||
from olgram.settings import ServerSettings
|
from olgram.settings import ServerSettings
|
||||||
|
|
||||||
|
|
||||||
from olgram.models.models import Bot
|
from olgram.models.models import Bot
|
||||||
|
|
||||||
db_bot_instance: ContextVar[Bot] = ContextVar('db_bot_instance')
|
db_bot_instance: ContextVar[Bot] = ContextVar('db_bot_instance')
|
||||||
|
|
||||||
_redis: ty.Optional[aioredis.Redis] = None
|
_redis: ty.Optional[Redis] = None
|
||||||
|
|
||||||
|
|
||||||
async def init_redis():
|
async def init_redis():
|
||||||
global _redis
|
global _redis
|
||||||
_redis = await aioredis.create_redis_pool(ServerSettings.redis_path())
|
_redis = await create_redis_pool(ServerSettings.redis_path())
|
||||||
|
|
||||||
|
|
||||||
def _message_unique_id(bot_id: int, message_id: int) -> str:
|
def _message_unique_id(bot_id: int, message_id: int) -> str:
|
||||||
|
Loading…
Reference in New Issue
Block a user