Template
Compare commits
4
Commits
4ac6be06cf
...
markup
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d3ed6e4006 | ||
|
|
a8f39d4630 | ||
|
|
b3a1ea1309 | ||
|
|
c309d4975e |
@@ -3,5 +3,6 @@ __pycache__/
|
|||||||
venv/
|
venv/
|
||||||
.venv/
|
.venv/
|
||||||
logs/
|
logs/
|
||||||
|
data/
|
||||||
*.env
|
*.env
|
||||||
*.db
|
*.db
|
||||||
|
|||||||
+13
-12
@@ -19,20 +19,21 @@ RUN --mount=type=cache,target=/root/.cache/pip \
|
|||||||
--mount=type=bind,source=requirements.txt,target=requirements.txt \
|
--mount=type=bind,source=requirements.txt,target=requirements.txt \
|
||||||
pip install -r requirements.txt
|
pip install -r requirements.txt
|
||||||
|
|
||||||
# copy i18n files
|
# copy sources
|
||||||
COPY --chown=bot i18n.yaml /i18n/i18n.yaml
|
COPY --chown=bot --chmod=774 docker-entrypoint.sh /app/
|
||||||
|
COPY --chown=bot migrations /app/migrations
|
||||||
|
COPY --chown=bot mybot /app/mybot
|
||||||
|
COPY --chown=bot i18n.yaml /app/
|
||||||
|
|
||||||
# copy default configs
|
# prepare environment
|
||||||
WORKDIR /app
|
ENV I18N_PATH=/data/i18n.yaml
|
||||||
COPY --chown=bot mybot mybot
|
ENV DB_URL=sqlite:////data/bot.db
|
||||||
|
|
||||||
# preapre environment
|
RUN mkdir -p /data
|
||||||
ENV SS_TYPE=memory
|
RUN chown bot:bot /data
|
||||||
ENV I18N_PATH=/i18n/i18n.yaml
|
VOLUME /data
|
||||||
|
|
||||||
# set user
|
|
||||||
USER bot
|
USER bot
|
||||||
|
WORKDIR /app
|
||||||
|
|
||||||
CMD ["python3", "-m", "mybot"]
|
ENTRYPOINT ["./docker-entrypoint.sh"]
|
||||||
|
|
||||||
VOLUME i18n/
|
|
||||||
|
|||||||
@@ -0,0 +1,17 @@
|
|||||||
|
#!/bin/sh
|
||||||
|
|
||||||
|
if [ ! -f ${I18N_PATH} ]; then
|
||||||
|
cp i18n.yaml ${I18N_PATH}
|
||||||
|
fi
|
||||||
|
|
||||||
|
alembic -c migrations/alembic.ini upgrade head
|
||||||
|
|
||||||
|
if [ $# -eq 0 ]; then
|
||||||
|
if [ -z "${USE_WEBHOOK}" ]; then
|
||||||
|
exec python3 -m mybot
|
||||||
|
else
|
||||||
|
exec gunicorn -b 0.0.0.0:8080 "mybot:main()"
|
||||||
|
fi
|
||||||
|
else
|
||||||
|
exec $1
|
||||||
|
fi
|
||||||
+4
-2
@@ -8,6 +8,7 @@ from .states import get_state_storage
|
|||||||
from .handlers import register_handlers
|
from .handlers import register_handlers
|
||||||
from .middlewares import setup_middlewares
|
from .middlewares import setup_middlewares
|
||||||
from .filters import add_custom_filters
|
from .filters import add_custom_filters
|
||||||
|
from .markup import setup_markup
|
||||||
from .webhook import create_app
|
from .webhook import create_app
|
||||||
|
|
||||||
|
|
||||||
@@ -21,10 +22,11 @@ def create_bot(config: Config, i18n: I18N, engine):
|
|||||||
state_storage=state_storage,
|
state_storage=state_storage,
|
||||||
threaded=False if config.use_webhook else True)
|
threaded=False if config.use_webhook else True)
|
||||||
register_handlers(bot)
|
register_handlers(bot)
|
||||||
setup_middlewares(bot, i18n, engine)
|
markup = setup_markup(bot, i18n)
|
||||||
|
setup_middlewares(bot, i18n, engine, markup)
|
||||||
add_custom_filters(bot, config)
|
add_custom_filters(bot, config)
|
||||||
if config.use_webhook:
|
|
||||||
bot.delete_webhook()
|
bot.delete_webhook()
|
||||||
|
if config.use_webhook:
|
||||||
bot.set_webhook(config.webhook.url,
|
bot.set_webhook(config.webhook.url,
|
||||||
drop_pending_updates=config.webhook.drop_pending_updates,
|
drop_pending_updates=config.webhook.drop_pending_updates,
|
||||||
max_connections=config.webhook.max_connections)
|
max_connections=config.webhook.max_connections)
|
||||||
|
|||||||
@@ -1,9 +1,13 @@
|
|||||||
from telebot import TeleBot
|
from telebot import TeleBot
|
||||||
from telebot.types import Message
|
from telebot.types import Message, CallbackQuery
|
||||||
|
|
||||||
|
|
||||||
def start(message: Message, bot: TeleBot, t, **kwargs):
|
def start(message: Message, bot: TeleBot, t, m, **kwargs):
|
||||||
bot.send_message(message.chat.id, t("start"))
|
bot.send_message(message.chat.id, t("start"), reply_markup=m("start"))
|
||||||
|
|
||||||
|
|
||||||
|
def start_call(call: CallbackQuery, bot: TeleBot, t, m, **kwargs):
|
||||||
|
bot.send_message(call.message.chat.id, t("start"), reply_markup=m("start"))
|
||||||
|
|
||||||
|
|
||||||
def help_(message, bot, t, **kwargs):
|
def help_(message, bot, t, **kwargs):
|
||||||
@@ -13,3 +17,5 @@ def help_(message, bot, t, **kwargs):
|
|||||||
def register_handlers(bot: TeleBot):
|
def register_handlers(bot: TeleBot):
|
||||||
bot.register_message_handler(start, commands=["start"], pass_bot=True)
|
bot.register_message_handler(start, commands=["start"], pass_bot=True)
|
||||||
bot.register_message_handler(help_, commands=["help"], pass_bot=True)
|
bot.register_message_handler(help_, commands=["help"], pass_bot=True)
|
||||||
|
|
||||||
|
bot.register_callback_query_handler(start_call, lambda call: call.data == "start")
|
||||||
|
|||||||
@@ -0,0 +1,11 @@
|
|||||||
|
from telebot import TeleBot
|
||||||
|
|
||||||
|
from ..i18n import I18N
|
||||||
|
from .base import MarkupManager
|
||||||
|
from .simple import SimpleMarkup
|
||||||
|
|
||||||
|
|
||||||
|
def setup_markup(bot: TeleBot, i18n: I18N):
|
||||||
|
markup_mg = MarkupManager(bot, i18n)
|
||||||
|
markup_mg.register_prototype(SimpleMarkup)
|
||||||
|
return markup_mg
|
||||||
@@ -0,0 +1,55 @@
|
|||||||
|
import abc
|
||||||
|
from typing import Optional, Type
|
||||||
|
|
||||||
|
from telebot import TeleBot
|
||||||
|
from telebot.types import CallbackQuery, InlineKeyboardMarkup
|
||||||
|
|
||||||
|
from ..i18n import I18N
|
||||||
|
|
||||||
|
|
||||||
|
class Markup (metaclass=abc.ABCMeta):
|
||||||
|
tag: str
|
||||||
|
|
||||||
|
def __init__(self, bot: TeleBot, i18n: I18N):
|
||||||
|
self.bot = bot
|
||||||
|
self.t = i18n
|
||||||
|
|
||||||
|
def __call__(self, *args, **kwargs):
|
||||||
|
return self.build(*args, **kwargs)
|
||||||
|
|
||||||
|
def check(self, call: CallbackQuery) -> bool:
|
||||||
|
return call.data == self.tag
|
||||||
|
|
||||||
|
@abc.abstractmethod
|
||||||
|
def build(self, *args, **kwargs) -> Optional[InlineKeyboardMarkup]:
|
||||||
|
pass
|
||||||
|
|
||||||
|
|
||||||
|
class DummyMarkup (Markup):
|
||||||
|
tag = "__dummy"
|
||||||
|
|
||||||
|
def check(self, call: CallbackQuery) -> bool:
|
||||||
|
return True
|
||||||
|
|
||||||
|
def build(self, *args, **kwargs) -> Optional[InlineKeyboardMarkup]:
|
||||||
|
return None
|
||||||
|
|
||||||
|
|
||||||
|
class MarkupManager:
|
||||||
|
def __init__(self, bot: TeleBot, i18n: I18N):
|
||||||
|
self.bot = bot
|
||||||
|
self.i18n = i18n
|
||||||
|
self._prototypes: list[Markup] = []
|
||||||
|
self._dummy = DummyMarkup(self.bot, self.i18n)
|
||||||
|
|
||||||
|
def register_prototype(self, markup_proto_class: Type[Markup]):
|
||||||
|
self._prototypes.append(markup_proto_class(self.bot, self.i18n))
|
||||||
|
|
||||||
|
def __call__(self, tag: str, *args, **kwargs):
|
||||||
|
return self.get(tag).build(*args, **kwargs)
|
||||||
|
|
||||||
|
def get(self, tag: str) -> Optional[Markup]:
|
||||||
|
for mp in self._prototypes:
|
||||||
|
if mp.tag == tag:
|
||||||
|
return mp
|
||||||
|
return None
|
||||||
@@ -0,0 +1,15 @@
|
|||||||
|
from typing import Optional
|
||||||
|
|
||||||
|
from telebot.types import InlineKeyboardMarkup, InlineKeyboardButton
|
||||||
|
|
||||||
|
from .base import Markup
|
||||||
|
|
||||||
|
|
||||||
|
class SimpleMarkup (Markup):
|
||||||
|
tag = "start"
|
||||||
|
|
||||||
|
def build(self, *args, **kwargs) -> Optional[InlineKeyboardMarkup]:
|
||||||
|
return (InlineKeyboardMarkup()
|
||||||
|
.add(InlineKeyboardButton("start", callback_data="start"))
|
||||||
|
.add(InlineKeyboardButton("help", callback_data="help"))
|
||||||
|
)
|
||||||
@@ -5,6 +5,6 @@ from .arguments import ArgumentsMiddleware
|
|||||||
from .database import DatabaseMiddleware
|
from .database import DatabaseMiddleware
|
||||||
|
|
||||||
|
|
||||||
def setup_middlewares(bot: TeleBot, i18n: I18N, engine):
|
def setup_middlewares(bot: TeleBot, i18n: I18N, engine, markup):
|
||||||
bot.setup_middleware(ArgumentsMiddleware(i18n))
|
bot.setup_middleware(ArgumentsMiddleware(i18n, markup))
|
||||||
bot.setup_middleware(DatabaseMiddleware(engine))
|
bot.setup_middleware(DatabaseMiddleware(engine))
|
||||||
|
|||||||
@@ -3,16 +3,24 @@ from telebot.types import Message, CallbackQuery
|
|||||||
|
|
||||||
|
|
||||||
class ArgumentsMiddleware (BaseMiddleware):
|
class ArgumentsMiddleware (BaseMiddleware):
|
||||||
def __init__(self, i18n):
|
def __init__(self, i18n, markup):
|
||||||
super().__init__()
|
super().__init__()
|
||||||
self.i18n = i18n
|
self.i18n = i18n
|
||||||
|
self.markup = markup
|
||||||
self.update_types = ["message", "callback_query"]
|
self.update_types = ["message", "callback_query"]
|
||||||
|
|
||||||
def pre_process(self, obj, data: dict):
|
def pre_process(self, obj, data: dict):
|
||||||
if isinstance(obj, Message):
|
if isinstance(obj, Message):
|
||||||
data["t"] = self.i18n.customized_call(message=obj)
|
self.pre_process_message(obj, data)
|
||||||
elif isinstance(obj, CallbackQuery):
|
elif isinstance(obj, CallbackQuery):
|
||||||
data["t"] = self.i18n.customized_call(callback=obj)
|
self.pre_process_callback(obj, data)
|
||||||
|
data["m"] = self.markup
|
||||||
|
|
||||||
|
def pre_process_message(self, message: Message, data: dict):
|
||||||
|
data["t"] = self.i18n.customized_call(message=message)
|
||||||
|
|
||||||
|
def pre_process_callback(self, call: CallbackQuery, data: dict):
|
||||||
|
data["t"] = self.i18n.customized_call(callback=call)
|
||||||
|
|
||||||
def post_process(self, message, data: dict, exception: BaseException):
|
def post_process(self, message, data: dict, exception: BaseException):
|
||||||
pass
|
pass
|
||||||
|
|||||||
Reference in New Issue
Block a user