adelorenzo/stable
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

remove _rpc_status_table and reuse _rpc_status instead

Browse Source
This commit is contained in:
gcarq 2018-06-23 09:28:13 +02:00 committed by creslinux
parent a92f0c2125
commit 4abfcd2462
1 changed files with 34 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
freqtrade/rpc/telegram.py
View File

@ -6,12 +6,15 @@ This module manage Telegram communication
import logging import logging
from typing import Any, Callable from typing import Any, Callable
import arrow
from pandas import DataFrame
from tabulate import tabulate from tabulate import tabulate
from telegram import Bot, ParseMode, ReplyKeyboardMarkup, Update from telegram import Bot, ParseMode, ReplyKeyboardMarkup, Update
from telegram.error import NetworkError, TelegramError from telegram.error import NetworkError, TelegramError
from telegram.ext import CommandHandler, Updater from telegram.ext import CommandHandler, Updater
from freqtrade.__init__ import __version__ from freqtrade.__init__ import __version__
from freqtrade.misc import shorten_date
from freqtrade.rpc.rpc import RPC, RPCException from freqtrade.rpc.rpc import RPC, RPCException
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
@ -137,21 +140,25 @@ class Telegram(RPC):
try: try:
results = self._rpc_trade_status() results = self._rpc_trade_status()
messages = [ messages = []
"*Trade ID:* `{trade_id}`\n" for result in results:
"*Current Pair:* [{pair}]({market_url})\n" result['open_date'] = arrow.get(result['open_date']).humanize()
"*Open Since:* `{date}`\n" messages.append(
"*Amount:* `{amount}`\n" "*Trade ID:* `{trade_id}`\n"
"*Open Rate:* `{open_rate:.8f}`\n" "*Current Pair:* [{pair}]({market_url})\n"
"*Close Rate:* `{close_rate}`\n" "*Open Since:* `{open_date}`\n"
"*Current Rate:* `{current_rate:.8f}`\n" "*Amount:* `{amount}`\n"
"*Close Profit:* `{close_profit}`\n" "*Open Rate:* `{open_rate:.8f}`\n"
"*Current Profit:* `{current_profit:.2f}%`\n" "*Close Rate:* `{close_rate}`\n"
"*Open Order:* `{open_order}`".format(**result) "*Current Rate:* `{current_rate:.8f}`\n"
for result in results "*Close Profit:* `{close_profit}`\n"
] "*Current Profit:* `{current_profit:.2f}%`\n"
"*Open Order:* `{open_order}`".format(**result)
)
for msg in messages: for msg in messages:
self._send_msg(msg, bot=bot) self._send_msg(msg, bot=bot)
except RPCException as e: except RPCException as e:
self._send_msg(str(e), bot=bot) self._send_msg(str(e), bot=bot)
@ -165,7 +172,20 @@ class Telegram(RPC):
:return: None :return: None
""" """
try: try:
df_statuses = self._rpc_status_table()
results = self._rpc_trade_status()
data = [
[
result['trade_id'],
result['pair'],
shorten_date(arrow.get(result['open_date']).humanize(only_distance=True)),
result['current_profit'],
] for result in results
]
columns = ['ID', 'Pair', 'Since', 'Profit']
df_statuses = DataFrame.from_records(data, columns=columns)
df_statuses = df_statuses.set_index(columns[0])
message = tabulate(df_statuses, headers='keys', tablefmt='simple') message = tabulate(df_statuses, headers='keys', tablefmt='simple')
self._send_msg("<pre>{}</pre>".format(message), parse_mode=ParseMode.HTML) self._send_msg("<pre>{}</pre>".format(message), parse_mode=ParseMode.HTML)
except RPCException as e: except RPCException as e: