selimaj-dev/pulse-trader
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Improved command logging

Browse Source
This commit is contained in:
selimaj-dev
2026-07-31 16:16:52 +02:00
parent 4d042251b3
commit 37d8bb6c0b
1 changed files with 20 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/engine/engine/command.rs
+20 -14
View File
@@ -22,10 +22,16 @@ impl Engine {
match args[0] { match args[0] {
"reload" => { "reload" => {
*self.config.lock().await = Config::new().await?; *self.config.lock().await = Config::new().await?;
self.terminal_server
.info("engine::config", "successfully reloaded")
.await?;
} }
"save" => { "save" => {
self.config.lock().await.save().await?; self.config.lock().await.save().await?;
self.terminal_server
.info("engine::config", "successfully saved")
.await?;
} }
"set" => { "set" => {
@@ -68,7 +74,7 @@ impl Engine {
return self return self
.terminal_server .terminal_server
.error( .error(
"config::set::strategy", "config::set[strategy]",
&format!("Non existent strategy `{id}`"), &format!("Non existent strategy `{id}`"),
) )
.await; .await;
@@ -108,25 +114,25 @@ impl Engine {
} }
} }
} else { } else {
self.invalid_command_usage("config").await?; self.invalid_command_usage("engine::config").await?;
} }
} }
_ => { _ => {
self.invalid_command_usage("config").await?; self.invalid_command_usage("engine::config").await?;
} }
} }
} }
"account" | "acc" => { "account" | "acc" => {
if args.len() == 0 { if args.len() == 0 {
return self.invalid_command_usage("account man").await; return self.invalid_command_usage("engine::account").await;
} }
match args[0] { match args[0] {
"list" | "ls" => { "list" | "ls" => {
self.terminal_server self.terminal_server
.info("account man", "ACCOUNT LIST") .info("engine::account", "ACCOUNT LIST")
.await?; .await?;
let accounts = self.accounts.lock().await; let accounts = self.accounts.lock().await;
@@ -134,7 +140,7 @@ impl Engine {
for (name, acc) in &accounts.accounts { for (name, acc) in &accounts.accounts {
self.terminal_server self.terminal_server
.info( .info(
"account man", "engine::account",
&if name == &accounts.active { &if name == &accounts.active {
format!( format!(
"{} (active) -> {}", "{} (active) -> {}",
@@ -151,7 +157,7 @@ impl Engine {
"use" | "set" => { "use" | "set" => {
if args.len() < 2 { if args.len() < 2 {
return self.invalid_command_usage("account man").await; return self.invalid_command_usage("engine::account").await;
} }
let new_active = args[1]; let new_active = args[1];
@@ -161,7 +167,10 @@ impl Engine {
if !accounts.accounts.contains_key(new_active) { if !accounts.accounts.contains_key(new_active) {
return self return self
.terminal_server .terminal_server
.error("account man", &format!("Account not found ({new_active})")) .error(
"engine::account",
&format!("Account not found ({new_active})"),
)
.await; .await;
} }
@@ -169,14 +178,14 @@ impl Engine {
self.terminal_server self.terminal_server
.info( .info(
"account man", "engine::account",
&format!("Account set to {new_active} successfully!"), &format!("Account set to {new_active} successfully!"),
) )
.await?; .await?;
} }
_ => { _ => {
return self.invalid_command_usage("account man").await; return self.invalid_command_usage("engine::account").await;
} }
} }
} }
@@ -202,10 +211,7 @@ impl Engine {
_ => { _ => {
self.terminal_server self.terminal_server
.error( .error("engine::cmd", &format!("Command '{}' not found", command))
"Command executor",
&format!("Command '{}' not found", command),
)
.await?; .await?;
} }
} }