diff --git a/freqtrade/rpc/api_server.py b/freqtrade/rpc/api_server.py
index 9810782ef..32d402719 100644
--- a/freqtrade/rpc/api_server.py
+++ b/freqtrade/rpc/api_server.py
@@ -25,78 +25,23 @@ class ApiServerSuperWrap(RPC):
"""
super().__init__(freqtrade)
- self.interval = 1
-
- thread = threading.Thread(target=self.run, args=(freqtrade,)) # extra comma as ref ! Tuple
- thread.daemon = True # Daemonize thread
- thread.start() # Start the execution
-
-
- def run(self, freqtrade):
- """ Method that runs forever """
self._config = freqtrade.config
- """
- Define the application methods here, called by app.add_url_rule
- each Telegram command should have a like local substitute
- """
- # @app.route("/")
- def hello():
- # For simple rest server testing via browser
- # cmds = 'Try uri:/daily?timescale=7 /profit /balance /status
- # /status /table /performance /count,
- # /start /stop /help'
+ thread = threading.Thread(target=self.run, daemon=True)
+ thread.start()
- rest_cmds ='Commands implemented:
' \
- '/daily?timescale=7' \
- '
' \
- '/stop' \
- '
' \
- '/start'
- return rest_cmds
+ def run(self):
+ """ Method that runs forever """
- def daily():
- try:
- timescale = request.args.get('timescale')
- logger.info("LocalRPC - Daily Command Called")
- timescale = int(timescale)
-
- stats = self._rpc_daily_profit(timescale,
- self._config['stake_currency'],
- self._config['fiat_display_currency']
- )
-
- stats = dumps(stats, indent=4, sort_keys=True, default=str)
- return stats
- except RPCException as e:
- return e
-
- def start():
- """
- Handler for /start.
- Starts TradeThread
- """
- msg = self._rpc_start()
- return msg
-
- def stop():
- """
- Handler for /stop.
- Stops TradeThread
- """
- msg = self._rpc_stop()
- return msg
-
- ## defines the url rules available on the api server
+ # defines the url rules available on the api server
'''
First two arguments passed are /URL and 'Label'
Label can be used as a shortcut when refactoring
'''
- app.add_url_rule('/', 'hello', view_func=hello, methods=['GET'])
- app.add_url_rule('/stop', 'stop', view_func=stop, methods=['GET'])
- app.add_url_rule('/start', 'start', view_func=start, methods=['GET'])
- app.add_url_rule('/daily', 'daily', view_func=daily, methods=['GET'])
-
+ app.add_url_rule('/', 'hello', view_func=self.hello, methods=['GET'])
+ app.add_url_rule('/stop', 'stop', view_func=self.stop, methods=['GET'])
+ app.add_url_rule('/start', 'start', view_func=self.start, methods=['GET'])
+ app.add_url_rule('/daily', 'daily', view_func=self.daily, methods=['GET'])
"""
Section to handle configuration and running of the Rest server
@@ -105,7 +50,8 @@ class ApiServerSuperWrap(RPC):
rest_ip = self._config['api_server']['listen_ip_address']
rest_port = self._config['api_server']['listen_port']
- if not IPv4Address(rest_ip).is_loopback :
+ logger.info('Starting HTTP Server at {}:{}'.format(rest_ip, rest_port))
+ if not IPv4Address(rest_ip).is_loopback:
logger.info("SECURITY WARNING - Local Rest Server listening to external connections")
logger.info("SECURITY WARNING - This is insecure please set to your loopback, e.g 127.0.0.1 in config.json")
@@ -113,7 +59,55 @@ class ApiServerSuperWrap(RPC):
logger.info('Starting Local Rest Server')
try:
app.run(host=rest_ip, port=rest_port)
- except:
+ except Exception:
logger.exception("Api server failed to start, exception message is:")
+ """
+ Define the application methods here, called by app.add_url_rule
+ each Telegram command should have a like local substitute
+ """
+ def hello(self):
+ # For simple rest server testing via browser
+ # cmds = 'Try uri:/daily?timescale=7 /profit /balance /status
+ # /status /table /performance /count,
+ # /start /stop /help'
+ rest_cmds = 'Commands implemented:
' \
+ '/daily?timescale=7' \
+ '
' \
+ '/stop' \
+ '
' \
+ '/start'
+ return rest_cmds
+
+ def daily(self):
+ try:
+ timescale = request.args.get('timescale')
+ logger.info("LocalRPC - Daily Command Called")
+ timescale = int(timescale)
+
+ stats = self._rpc_daily_profit(timescale,
+ self._config['stake_currency'],
+ self._config['fiat_display_currency']
+ )
+
+ stats = dumps(stats, indent=4, sort_keys=True, default=str)
+ return stats
+ except RPCException as e:
+ return e
+
+ def start(self):
+ """
+ Handler for /start.
+ Starts TradeThread
+ """
+ msg = self._rpc_start()
+ return msg
+
+ def stop(self):
+ """
+ Handler for /stop.
+ Stops TradeThread
+ """
+ msg = self._rpc_stop()
+ return msg