valmojr/armatak
1
0
Fork 0
mirror of https://github.com/valmojr/armatak.git synced 2026-06-13 15:23:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

Improved TCP Socket Callbacks

Browse Source
This commit is contained in:
Valmo Trindade
2025-04-06 04:20:25 -03:00
parent 7831b25062
commit a8f6b04221
1 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/cot_router.rs
View File

@@ -32,7 +32,7 @@ impl TcpClient {
let tcp_thread = thread::spawn(move || match TcpStream::connect(&address) { let tcp_thread = thread::spawn(move || match TcpStream::connect(&address) {
Ok(stream) => { Ok(stream) => {
info!("Connected to TCP server at {}", address); let _ = ctx.callback_data("armatak_tcp_socket", "Connected to TCP Server", address);
*connection_clone.lock().unwrap() = Some(stream); *connection_clone.lock().unwrap() = Some(stream);
} }
Err(e) => { Err(e) => {
@@ -107,16 +107,14 @@ pub fn start(ctx: Context, address: String) -> &'static str {
let mut client_guard = TCP_CLIENT.lock().unwrap(); let mut client_guard = TCP_CLIENT.lock().unwrap();
*client_guard = Some(client); *client_guard = Some(client);
info!("TCP client started.");
"Starting TCP Client" "Starting TCP Client"
} }
pub fn send_payload(ctx: Context, payload: String) -> &'static str { pub fn send_payload(ctx: Context, payload: String) -> &'static str {
if let Some(ref client) = *TCP_CLIENT.lock().unwrap() { if let Some(ref client) = *TCP_CLIENT.lock().unwrap() {
info!("Sending payload: {}", payload);
client.send_payload(ctx, payload); client.send_payload(ctx, payload);
} else { } else {
let _ = ctx.callback_null("armatak_tcp_socket_error", "TCP Client is not running");
info!("TCP client is not running."); info!("TCP client is not running.");
} }
@@ -144,12 +142,12 @@ pub fn send_digital_pointer_cot(ctx: Context, cursor_over_time: DigitalPointerPa
"Sending Digital Pointer Cursor Over Time to TCP server" "Sending Digital Pointer Cursor Over Time to TCP server"
} }
pub fn stop() -> &'static str { pub fn stop(ctx: Context) -> &'static str {
if let Some(ref client) = *TCP_CLIENT.lock().unwrap() { if let Some(ref client) = *TCP_CLIENT.lock().unwrap() {
client.stop(); client.stop();
info!("TCP client stopped."); let _ = ctx.callback_null("armatak_tcp_socket", "TCP client stopped");
} else { } else {
info!("TCP client is not running."); let _ = ctx.callback_null("armatak_tcp_socket_error", "TCP client is not running");
} }
"Stopping TCP Client" "Stopping TCP Client"