From 5c65b19e978d5c716d8374bfe08fef0889048fe5 Mon Sep 17 00:00:00 2001 From: Klesti Selimaj Date: Tue, 28 Jul 2026 22:33:19 +0200 Subject: [PATCH] Renamed pulse wire to sdk --- Cargo.lock | 22 +++++++++++----------- Cargo.toml | 8 ++++---- {pulse-wire => pulse-sdk}/Cargo.toml | 2 +- {pulse-wire => pulse-sdk}/src/general.rs | 0 {pulse-wire => pulse-sdk}/src/lib.rs | 0 {pulse-wire => pulse-sdk}/src/plugin.rs | 0 {pulse-wire => pulse-sdk}/src/terminal.rs | 0 {pulse-wire => pulse-sdk}/src/units.rs | 0 src/engine/engine/command.rs | 4 ++-- src/engine/engine/mod.rs | 6 +++--- src/engine/engine/plugin.rs | 2 +- src/engine/fetch.rs | 2 +- src/engine/store/plugin.rs | 2 +- src/engine/terminal.rs | 16 ++++++++-------- src/terminal/command.rs | 2 +- src/terminal/formatting.rs | 2 +- src/terminal/main.rs | 5 +++-- src/terminal/terminal.rs | 4 ++-- 18 files changed, 39 insertions(+), 38 deletions(-) rename {pulse-wire => pulse-sdk}/Cargo.toml (90%) rename {pulse-wire => pulse-sdk}/src/general.rs (100%) rename {pulse-wire => pulse-sdk}/src/lib.rs (100%) rename {pulse-wire => pulse-sdk}/src/plugin.rs (100%) rename {pulse-wire => pulse-sdk}/src/terminal.rs (100%) rename {pulse-wire => pulse-sdk}/src/units.rs (100%) diff --git a/Cargo.lock b/Cargo.lock index 5b95774..eac0541 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -3941,6 +3941,16 @@ dependencies = [ "syn 1.0.109", ] +[[package]] +name = "pulse-sdk" +version = "0.1.0-alpha.0" +dependencies = [ + "hypersdk", + "postcard", + "serde", + "tokio", +] + [[package]] name = "pulse-trader" version = "0.1.0-alpha.0" @@ -3950,8 +3960,8 @@ dependencies = [ "crossterm", "hypersdk", "postcard", + "pulse-sdk", "pulse-ui", - "pulse-wire", "rand 0.8.7", "serde", "serde_json", @@ -3967,16 +3977,6 @@ dependencies = [ "tokio", ] -[[package]] -name = "pulse-wire" -version = "0.1.0-alpha.0" -dependencies = [ - "hypersdk", - "postcard", - "serde", - "tokio", -] - [[package]] name = "quinn" version = "0.11.11" diff --git a/Cargo.toml b/Cargo.toml index 33d3eee..9badfe3 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -5,7 +5,7 @@ edition = "2024" [dependencies] pulse-ui = { workspace = true } -pulse-wire = { workspace = true } +pulse-sdk = { workspace = true } crossterm = { workspace = true } hypersdk = { workspace = true } serde = { workspace = true } @@ -26,12 +26,12 @@ rand = "0.8.7" toml = "1.1.3" [workspace] -members = ["pulse-ui", "pulse-wire"] +members = ["pulse-ui", "pulse-sdk"] [workspace.dependencies] -postcard = { version = "1.1.3", features = ["alloc"]} +postcard = { version = "1.1.3", features = ["alloc"] } pulse-ui = { path = "pulse-ui", version = "0.1.0-alpha.0" } -pulse-wire = { path = "pulse-wire", version = "0.1.0-alpha.0" } +pulse-sdk = { path = "pulse-sdk", version = "0.1.0-alpha.0" } hypersdk = "0.2.14" tokio = "1.52.3" crossterm = "0.29.0" diff --git a/pulse-wire/Cargo.toml b/pulse-sdk/Cargo.toml similarity index 90% rename from pulse-wire/Cargo.toml rename to pulse-sdk/Cargo.toml index bd40410..bb06f35 100644 --- a/pulse-wire/Cargo.toml +++ b/pulse-sdk/Cargo.toml @@ -1,5 +1,5 @@ [package] -name = "pulse-wire" +name = "pulse-sdk" version = "0.1.0-alpha.0" edition = "2024" diff --git a/pulse-wire/src/general.rs b/pulse-sdk/src/general.rs similarity index 100% rename from pulse-wire/src/general.rs rename to pulse-sdk/src/general.rs diff --git a/pulse-wire/src/lib.rs b/pulse-sdk/src/lib.rs similarity index 100% rename from pulse-wire/src/lib.rs rename to pulse-sdk/src/lib.rs diff --git a/pulse-wire/src/plugin.rs b/pulse-sdk/src/plugin.rs similarity index 100% rename from pulse-wire/src/plugin.rs rename to pulse-sdk/src/plugin.rs diff --git a/pulse-wire/src/terminal.rs b/pulse-sdk/src/terminal.rs similarity index 100% rename from pulse-wire/src/terminal.rs rename to pulse-sdk/src/terminal.rs diff --git a/pulse-wire/src/units.rs b/pulse-sdk/src/units.rs similarity index 100% rename from pulse-wire/src/units.rs rename to pulse-sdk/src/units.rs diff --git a/src/engine/engine/command.rs b/src/engine/engine/command.rs index 836f104..bd39825 100644 --- a/src/engine/engine/command.rs +++ b/src/engine/engine/command.rs @@ -1,6 +1,6 @@ use crate::{engine::Engine, store::config::Config}; -use pulse_wire::terminal::{ItemState, Mode, Strategy}; +use pulse_sdk::terminal::{ItemState, Mode, Strategy}; use toml::Value; impl Engine { @@ -100,7 +100,7 @@ impl Engine { self.config.lock().await.cooldown = cooldown; self.terminal_server.broadcast( - pulse_wire::terminal::TerminalServerMessage::StrategyUpdated(Strategy { + pulse_sdk::terminal::TerminalServerMessage::StrategyUpdated(Strategy { strategy: self.strategy.strategy.manifest.lock().await.clone(), risk: self.strategy.risk.manifest.lock().await.clone(), mode: Mode::Auto, diff --git a/src/engine/engine/mod.rs b/src/engine/engine/mod.rs index c38e5dd..bb1d46f 100644 --- a/src/engine/engine/mod.rs +++ b/src/engine/engine/mod.rs @@ -6,7 +6,7 @@ use crate::{ store::{accounts::AccountList, config::Config}, terminal::TerminalServer, }; -use pulse_wire::prelude::*; +use pulse_sdk::prelude::*; use std::sync::Arc; use tokio::{sync::Mutex, task::JoinHandle}; @@ -60,7 +60,7 @@ impl Engine { if let Err(error) = self .terminal_server .broadcast( - pulse_wire::terminal::TerminalServerMessage::WatchListUpdated( + pulse_sdk::terminal::TerminalServerMessage::WatchListUpdated( watch_list, ), ) @@ -92,7 +92,7 @@ impl Engine { Ok(state) => { self.terminal_server .broadcast( - pulse_wire::terminal::TerminalServerMessage::PositionsUpdated( + pulse_sdk::terminal::TerminalServerMessage::PositionsUpdated( state .asset_positions .into_iter() diff --git a/src/engine/engine/plugin.rs b/src/engine/engine/plugin.rs index 4109b13..2c30d1b 100644 --- a/src/engine/engine/plugin.rs +++ b/src/engine/engine/plugin.rs @@ -1,5 +1,5 @@ use hypersdk::hypercore::{self, CandleInterval, Subscription, WebSocket}; -use pulse_wire::prelude::*; +use pulse_sdk::prelude::*; use std::{ collections::HashSet, path::PathBuf, diff --git a/src/engine/fetch.rs b/src/engine/fetch.rs index 28a3733..d8be404 100644 --- a/src/engine/fetch.rs +++ b/src/engine/fetch.rs @@ -1,4 +1,4 @@ -use pulse_wire::prelude::*; +use pulse_sdk::prelude::*; use serde_json::Value; use std::collections::HashMap; diff --git a/src/engine/store/plugin.rs b/src/engine/store/plugin.rs index 9763dc9..62449f6 100644 --- a/src/engine/store/plugin.rs +++ b/src/engine/store/plugin.rs @@ -1,6 +1,6 @@ use std::marker::PhantomData; -use pulse_wire::map_postcard_err; +use pulse_sdk::map_postcard_err; use serde::{Deserialize, Serialize}; use tokio::{ io::{AsyncReadExt, AsyncWriteExt}, diff --git a/src/engine/terminal.rs b/src/engine/terminal.rs index df601a7..ba14436 100644 --- a/src/engine/terminal.rs +++ b/src/engine/terminal.rs @@ -1,5 +1,5 @@ use crate::engine::Engine; -use pulse_wire::{map_postcard_err, prelude::*}; +use pulse_sdk::{map_postcard_err, prelude::*}; use std::{ collections::HashMap, sync::{Arc, Weak}, @@ -30,7 +30,7 @@ impl TerminalServer { } pub async fn run(self: &Arc) -> tokio::io::Result<()> { - let path = pulse_wire::server_path(); + let path = pulse_sdk::server_path(); if path.exists() { tokio::fs::remove_file(&path).await?; @@ -64,7 +64,7 @@ impl TerminalServer { self.send_to( id, - pulse_wire::terminal::TerminalServerMessage::StrategyUpdated(Strategy { + pulse_sdk::terminal::TerminalServerMessage::StrategyUpdated(Strategy { strategy: engine.strategy.strategy.manifest.lock().await.clone(), risk: engine.strategy.risk.manifest.lock().await.clone(), mode: Mode::Auto, @@ -76,7 +76,7 @@ impl TerminalServer { self.send_to( id, - pulse_wire::terminal::TerminalServerMessage::SetLogs(self.logs.lock().await.clone()), + pulse_sdk::terminal::TerminalServerMessage::SetLogs(self.logs.lock().await.clone()), ) .await?; @@ -124,7 +124,7 @@ impl TerminalServer { pub async fn broadcast( self: &Arc, - message: pulse_wire::terminal::TerminalServerMessage, + message: pulse_sdk::terminal::TerminalServerMessage, ) -> tokio::io::Result<()> { let msg = map_postcard_err(postcard::to_allocvec(&message))?; @@ -149,7 +149,7 @@ impl TerminalServer { pub async fn send_to( self: &Arc, id: &usize, - message: pulse_wire::terminal::TerminalServerMessage, + message: pulse_sdk::terminal::TerminalServerMessage, ) -> tokio::io::Result<()> { Self::send_to_client( self.clients.lock().await.get_mut(id).ok_or_else(|| { @@ -185,14 +185,14 @@ impl TerminalServer { self.logs.lock().await.push(log.clone()); - self.broadcast(pulse_wire::terminal::TerminalServerMessage::AddLog(log)) + self.broadcast(pulse_sdk::terminal::TerminalServerMessage::AddLog(log)) .await } pub async fn log_raw(self: &Arc, log: EventLog) -> tokio::io::Result<()> { self.logs.lock().await.push(log.clone()); - self.broadcast(pulse_wire::terminal::TerminalServerMessage::AddLog(log)) + self.broadcast(pulse_sdk::terminal::TerminalServerMessage::AddLog(log)) .await } diff --git a/src/terminal/command.rs b/src/terminal/command.rs index b8849df..c0e01c3 100644 --- a/src/terminal/command.rs +++ b/src/terminal/command.rs @@ -16,7 +16,7 @@ impl PulseTradeApp { .sock .as_mut() .unwrap() - .send(pulse_wire::terminal::TerminalClientMessage::ExecuteCommand( + .send(pulse_sdk::terminal::TerminalClientMessage::ExecuteCommand( command.to_string(), )) .await diff --git a/src/terminal/formatting.rs b/src/terminal/formatting.rs index b807ead..50211d6 100644 --- a/src/terminal/formatting.rs +++ b/src/terminal/formatting.rs @@ -1,4 +1,4 @@ -use pulse_wire::prelude::*; +use pulse_sdk::prelude::*; pub trait Formatted { fn get_formatted(&self) -> Vec; diff --git a/src/terminal/main.rs b/src/terminal/main.rs index 979c8a6..25ae2f5 100644 --- a/src/terminal/main.rs +++ b/src/terminal/main.rs @@ -21,7 +21,7 @@ use pulse_ui::{ use crate::formatting::{Formatted, apply_padding}; -use pulse_wire::prelude::*; +use pulse_sdk::prelude::*; pub struct PulseTradeApp { sock: Option, @@ -144,7 +144,8 @@ impl App for PulseTradeApp { ( LayoutItem::Widget(Size::Flex(1)), Box::new( - advanced_option_draw(&self.scroll, 3, "CONFIGURATION", &self.strategy).await, + advanced_option_draw(&self.scroll, 3, "CONFIGURATION", &self.strategy) + .await, ), ), ( diff --git a/src/terminal/terminal.rs b/src/terminal/terminal.rs index 5519562..3657ce2 100644 --- a/src/terminal/terminal.rs +++ b/src/terminal/terminal.rs @@ -1,5 +1,5 @@ +use pulse_sdk::{map_postcard_err, prelude::*}; use pulse_ui::state::State; -use pulse_wire::{map_postcard_err, prelude::*}; use tokio::{ io::{AsyncReadExt, AsyncWriteExt}, @@ -28,7 +28,7 @@ impl TerminalClient { pub async fn send( &mut self, - message: pulse_wire::terminal::TerminalClientMessage, + message: pulse_sdk::terminal::TerminalClientMessage, ) -> tokio::io::Result<()> { let msg = map_postcard_err(postcard::to_allocvec(&message))?; self.writer.write(&msg.len().to_le_bytes()).await?;