From 1fb2ab9f2b0b315680f260449813c82571191203 Mon Sep 17 00:00:00 2001
From: Klesti Selimaj <klesti.selimay@icloud.com>
Date: Tue, 28 Jul 2026 20:13:34 +0200
Subject: [PATCH] Fix GetCandlestick

---
 pulse-wire/src/plugin.rs    |  2 +-
 src/engine/engine/plugin.rs | 14 +++++++++++---
 2 files changed, 12 insertions(+), 4 deletions(-)

diff --git a/pulse-wire/src/plugin.rs b/pulse-wire/src/plugin.rs
index c0df02a..875413c 100644
--- a/pulse-wire/src/plugin.rs
+++ b/pulse-wire/src/plugin.rs
@@ -34,7 +34,7 @@ pub enum StrategyMessage {
 
     GetWatchList,
 
-    RequestCandlestick {
+    GetCandlestick {
         symbol: String,
         interval: CandleInterval,
         count: u32,
diff --git a/src/engine/engine/plugin.rs b/src/engine/engine/plugin.rs
index 3054651..223e59b 100644
--- a/src/engine/engine/plugin.rs
+++ b/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
-                        .candle_snapshot(symbol, interval, start_time, now)
+                    self.strategy
+                        .send(&StrategyEngineMessage::Candlestick {
+                            candles: client
+                                .candle_snapshot(&symbol, interval, start_time, now)
+                                .await?,
+                            symbol,
+                            interval,
+                        })
                         .await?;
                 }
             }