fix trading strategy

Haehnchen · Mar 31, 2019 · c9a91b1 · c9a91b1
1 parent 080465f
commit c9a91b1
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/bot.sql b/bot.sql
@@ -16,8 +16,8 @@ CREATE TABLE IF NOT EXISTS candlesticks (
 CREATE UNIQUE INDEX unique_candle
   ON candlesticks (exchange, symbol, period, time);
 
-CREATE INDEX time_idx ON candlesticks  (time);
-
+CREATE INDEX time_idx ON candlesticks (time);
+CREATE INDEX exchange_symbol_idx ON candlesticks (exchange, symbol);
 
 CREATE TABLE IF NOT EXISTS candlesticks_log (
   id         INTEGER PRIMARY KEY AUTOINCREMENT,
@@ -56,6 +56,7 @@ CREATE TABLE IF NOT EXISTS ticker_log (
   income_at  BIGINT       NULL
 );
 CREATE INDEX ticker_log_idx ON ticker_log (exchange, symbol);
+CREATE INDEX ticker_log_time_idx ON ticker_log (exchange, symbol, income_at);
 
 CREATE TABLE IF NOT EXISTS signals (
   id         INTEGER PRIMARY KEY AUTOINCREMENT,

diff --git a/modules/listener/tick_listener.js b/modules/listener/tick_listener.js
@@ -118,7 +118,7 @@ module.exports = class TickListener {
             .filter(symbol => symbol.trade && symbol.trade.strategies && symbol.trade.strategies.length > 0)
             .forEach(symbol => {
                 symbol.trade.strategies.forEach(strategy => {
-                        promises.push(async () => { await this.visitStrategy(strategy, symbol)})
+                        promises.push(async () => { await this.visitTradeStrategy(strategy, symbol)})
                     }
                 )}
             )