Fix GetCandlestick

pulse-wire/src/plugin.rs

@@ -34,7 +34,7 @@ pub enum StrategyMessage {
 
     GetWatchList,
 
-    RequestCandlestick {
+    GetCandlestick {
         symbol: String,
         interval: CandleInterval,
         count: u32,

src/engine/engine/plugin.rs

@@ -106,7 +106,7 @@ impl StrategyEngine {
                     }
                 }
 
-                Some(StrategyMessage::RequestCandlestick {
+                Some(StrategyMessage::GetCandlestick {
                     symbol,
                     interval,
                     count,
@@ -118,6 +118,8 @@ impl StrategyEngine {
                         .unwrap()
                         .as_millis() as u64;
 
+                    println!("getting candlestick");
+
                     let interval_ms = match interval {
                         CandleInterval::OneMinute => 60_000,
                         CandleInterval::ThreeMinutes => 3 * 60_000,
@@ -137,8 +139,14 @@ impl StrategyEngine {
 
                     let start_time = now.saturating_sub(interval_ms * count as u64);
 
-                    client
+                    self.strategy
-                        .candle_snapshot(symbol, interval, start_time, now)
+                        .send(&StrategyEngineMessage::Candlestick {
+                            candles: client
+                                .candle_snapshot(&symbol, interval, start_time, now)
+                                .await?,
+                            symbol,
+                            interval,
+                        })
                         .await?;
                 }
             }