From 4716325c5fe635bdff51c4b9228f9bf820ed4b77 Mon Sep 17 00:00:00 2001
From: Klesti Selimaj <klesti.selimay@icloud.com>
Date: Thu, 23 Jul 2026 21:08:43 +0200
Subject: [PATCH] Engine

---
 src/engine/engine.rs |  42 ++++++++++++++++
 src/engine/main.rs   | 111 +++----------------------------------------
 2 files changed, 48 insertions(+), 105 deletions(-)
 create mode 100644 src/engine/engine.rs

diff --git a/src/engine/engine.rs b/src/engine/engine.rs
new file mode 100644
index 0000000..19fb10a
--- /dev/null
+++ b/src/engine/engine.rs
@@ -0,0 +1,42 @@
+use crate::terminal::TerminalServer;
+
+pub struct Engine {
+    pub terminal_server: TerminalServer,
+}
+
+impl Engine {
+    pub fn new() -> Self {
+        Self {
+            terminal_server: TerminalServer::new(),
+        }
+    }
+
+    pub fn spawn_terminal_server(&self) {
+        let terminal_server = self.terminal_server.clone();
+
+        tokio::spawn(async move {
+            terminal_server
+                .run()
+                .await
+                .expect("Failed to run terminal server");
+        });
+    }
+
+    pub fn spawn_broadcaster(&mut self) {
+        let terminal_server = self.terminal_server.clone();
+
+        tokio::spawn(async move {
+            loop {
+                tokio::time::sleep(tokio::time::Duration::from_millis(5000)).await;
+            }
+        });
+    }
+
+    pub async fn run_engine(&mut self) -> tokio::io::Result<()> {
+        loop {
+            tokio::time::sleep(tokio::time::Duration::from_millis(5000)).await;
+        }
+
+        Ok(())
+    }
+}
diff --git a/src/engine/main.rs b/src/engine/main.rs
index 85c45ff..55247d7 100644
--- a/src/engine/main.rs
+++ b/src/engine/main.rs
@@ -1,114 +1,15 @@
-use pulse_wire::terminal::{ActivePosition, Signal, WatchListItem};
-
+pub mod engine;
 pub mod terminal;
 
 #[tokio::main]
 async fn main() -> tokio::io::Result<()> {
-    let terminal_server = terminal::TerminalServer::new();
+    let mut engine = engine::Engine::new();
 
-    {
-        let terminal_server = terminal_server.clone();
+    engine.spawn_terminal_server();
 
-        tokio::spawn(async move {
-            terminal_server
-                .run()
-                .await
-                .expect("Failed to run terminal server");
-        });
-    }
+    engine.spawn_broadcaster();
 
-    loop {
-        tokio::time::sleep(tokio::time::Duration::from_millis(1500)).await;
+    engine.run_engine().await?;
 
-        terminal_server
-            .broadcast(
-                pulse_wire::terminal::TerminalServerMessage::WatchListUpdated(vec![
-                    WatchListItem {
-                        symbol: "BTC".to_string(),
-                        price: 118_402.12,
-                        trend: 0.82,
-                    },
-                    WatchListItem {
-                        symbol: "ETH".to_string(),
-                        price: 3_912.48,
-                        trend: -0.41,
-                    },
-                    WatchListItem {
-                        symbol: "SOL".to_string(),
-                        price: 182.91,
-                        trend: 2.18,
-                    },
-                    WatchListItem {
-                        symbol: "XRP".to_string(),
-                        price: 2.84,
-                        trend: 1.22,
-                    },
-                ]),
-            )
-            .await?;
-
-        terminal_server
-            .broadcast(
-                pulse_wire::terminal::TerminalServerMessage::PositionsUpdated(vec![
-                    ActivePosition {
-                        symbol: "BTC".to_string(),
-                        profit: 125.50,
-                        amount: 0.25,
-                    },
-                    ActivePosition {
-                        symbol: "SOL".to_string(),
-                        profit: 84.20,
-                        amount: 5.0,
-                    },
-                    ActivePosition {
-                        symbol: "ETH".to_string(),
-                        profit: -32.75,
-                        amount: 1.0,
-                    },
-                    ActivePosition {
-                        symbol: "XRP".to_string(),
-                        profit: 12.30,
-                        amount: 0.75,
-                    },
-                ]),
-            )
-            .await?;
-
-        terminal_server
-            .broadcast(pulse_wire::terminal::TerminalServerMessage::SignalsUpdated(
-                vec![
-                    Signal {
-                        kind: pulse_wire::terminal::SignalKind::Buy,
-                        symbol: "BTC".to_string(),
-                        param: pulse_wire::terminal::SignalParameter::Lim,
-                        price: 118_800.0,
-                    },
-                    Signal {
-                        kind: pulse_wire::terminal::SignalKind::Buy,
-                        symbol: "BTC".to_string(),
-                        param: pulse_wire::terminal::SignalParameter::Tap,
-                        price: 120_000.0,
-                    },
-                    Signal {
-                        kind: pulse_wire::terminal::SignalKind::Buy,
-                        symbol: "BTC".to_string(),
-                        param: pulse_wire::terminal::SignalParameter::Stl,
-                        price: 118_000.0,
-                    },
-                ],
-            ))
-            .await?;
-
-        terminal_server
-            .broadcast(pulse_wire::terminal::TerminalServerMessage::AddLog(
-                pulse_wire::terminal::EventLog {
-                    kind: pulse_wire::terminal::LogKind::Debug,
-                    name: "Engine".to_string(),
-                    message: "Hello, world!".to_string(),
-                },
-            ))
-            .await?;
-
-        println!("Ok");
-    }
+    Ok(())
 }