CTYPTO/freqtrade
1
0
Fork 0
mirror of https://github.com/freqtrade/freqtrade.git synced 2025-11-29 08:33:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Initial changes for telegram migration

Browse Source
This commit is contained in:
Matthias
2023-01-02 13:49:25 +01:00
parent 68ac934929
commit 14b501a4f7
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
freqtrade/rpc/telegram.py
View File

@@ -21,7 +21,7 @@ from telegram import (CallbackQuery, InlineKeyboardButton, InlineKeyboardMarkup,
ReplyKeyboardMarkup, Update) ReplyKeyboardMarkup, Update)
from telegram.constants import MessageLimit, ParseMode from telegram.constants import MessageLimit, ParseMode
from telegram.error import BadRequest, NetworkError, TelegramError from telegram.error import BadRequest, NetworkError, TelegramError
from telegram.ext import CallbackContext, CallbackQueryHandler, CommandHandler, Updater from telegram.ext import Application, CallbackContext, CallbackQueryHandler, CommandHandler, Updater
from telegram.helpers import escape_markdown from telegram.helpers import escape_markdown
from freqtrade.__init__ import __version__ from freqtrade.__init__ import __version__
@@ -104,6 +104,7 @@ class Telegram(RPCHandler):
super().__init__(rpc, config) super().__init__(rpc, config)
self._updater: Updater self._updater: Updater
self._app: Application
self._init_keyboard() self._init_keyboard()
self._init() self._init()
@@ -162,8 +163,9 @@ class Telegram(RPCHandler):
registers all known command handlers registers all known command handlers
and starts polling for message updates and starts polling for message updates
""" """
self._updater = Updater(token=self._config['telegram']['token'], workers=0, self._app = Application.builder().token(self._config['telegram']['token']).build
use_context=True) # 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 = [
@@ -222,12 +224,12 @@ class Telegram(RPCHandler):
CallbackQueryHandler(self._force_enter_inline, pattern=r"\S+\/\S+"), CallbackQueryHandler(self._force_enter_inline, pattern=r"\S+\/\S+"),
] ]
for handle in handles: for handle in handles:
self._updater.dispatcher.add_handler(handle) self._app.add_handler(handle)
for callback in callbacks: for callback in callbacks:
self._updater.dispatcher.add_handler(callback) self._app.add_handler(callback)
self._updater.start_polling( self._app.run_polling(
bootstrap_retries=-1, bootstrap_retries=-1,
timeout=20, timeout=20,
read_latency=60, # Assumed transmission latency read_latency=60, # Assumed transmission latency
@@ -244,7 +246,7 @@ class Telegram(RPCHandler):
:return: None :return: None
""" """
# This can take up to `timeout` from the call to `start_polling`. # This can take up to `timeout` from the call to `start_polling`.
self._updater.stop() self._app.stop()
def _exchange_from_msg(self, msg: Dict[str, Any]) -> str: def _exchange_from_msg(self, msg: Dict[str, Any]) -> str:
""" """