mohammadian7/freqtrade
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

_update_msg to async

Browse Source
This commit is contained in:
Matthias
2023-04-15 09:52:14 +02:00
parent 5134bf8ec3
commit e7e6f719e4
1 changed files with 5 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
freqtrade/rpc/telegram.py
+5 -8
View File
@@ -103,7 +103,6 @@ class Telegram(RPCHandler):
""" """
super().__init__(rpc, config) super().__init__(rpc, config)
self._updater: Updater
self._app: Application self._app: Application
self._init_keyboard() self._init_keyboard()
self._init() self._init()
@@ -164,8 +163,6 @@ class Telegram(RPCHandler):
and starts polling for message updates and starts polling for message updates
""" """
self._app = Application.builder().token(self._config['telegram']['token']).build() self._app = Application.builder().token(self._config['telegram']['token']).build()
# self._updater = Updater(token=, workers=0,
# use_context=True)
# Register command handler and start telegram message polling # Register command handler and start telegram message polling
handles = [ handles = [
@@ -1650,8 +1647,8 @@ class Telegram(RPCHandler):
f"*Current state:* `{val['state']}`" f"*Current state:* `{val['state']}`"
) )
def _update_msg(self, query: CallbackQuery, msg: str, callback_path: str = "", async def _update_msg(self, query: CallbackQuery, msg: str, callback_path: str = "",
reload_able: bool = False, parse_mode: str = ParseMode.MARKDOWN) -> None: reload_able: bool = False, parse_mode: str = ParseMode.MARKDOWN) -> None:
if reload_able: if reload_able:
reply_markup = InlineKeyboardMarkup([ reply_markup = InlineKeyboardMarkup([
[InlineKeyboardButton("Refresh", callback_data=callback_path)], [InlineKeyboardButton("Refresh", callback_data=callback_path)],
@@ -1665,7 +1662,7 @@ class Telegram(RPCHandler):
message_id = query.message.message_id message_id = query.message.message_id
try: try:
self._updater.bot.edit_message_text( await self._app.bot.edit_message_text(
chat_id=chat_id, chat_id=chat_id,
message_id=message_id, message_id=message_id,
text=msg, text=msg,
@@ -1695,8 +1692,8 @@ class Telegram(RPCHandler):
""" """
reply_markup: Union[InlineKeyboardMarkup, ReplyKeyboardMarkup] reply_markup: Union[InlineKeyboardMarkup, ReplyKeyboardMarkup]
if query: if query:
self._update_msg(query=query, msg=msg, parse_mode=parse_mode, await self._update_msg(query=query, msg=msg, parse_mode=parse_mode,
callback_path=callback_path, reload_able=reload_able) callback_path=callback_path, reload_able=reload_able)
return return
if reload_able and self._config['telegram'].get('reload', True): if reload_able and self._config['telegram'].get('reload', True):
reply_markup = InlineKeyboardMarkup([ reply_markup = InlineKeyboardMarkup([