wsl-clip-core 0.5.1

Core library for wsl-clip clipboard bridge
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91

// <FILE>wsl_clip_core/src/orc_bridge_runtime.rs</FILE> - <DESC>Runtime executor for bridge-related CLI commands</DESC>
// <VERS>VERSION: 0.1.0 - 2025-12-08T00:00:00Z</VERS>
// <WCTX>Splits execution from CLI parsing to align with workplan Workstream 1.</WCTX>
// <CLOG>Introduced runtime module that executes resolved bridge commands.</CLOG>

use crate::bridge::{
    build_status, run_tcp_client_stub, run_tcp_listener_stub, run_udp_client_stub, run_udp_listener_stub,
    spawn_tcp_listener_daemon, spawn_udp_listener_daemon,
};
use crate::config::{BridgeMode, ResolvedBridgeCommand};
use anyhow::Result;
use tokio::runtime::Runtime;
use serde_json;

pub fn run_bridge_command(cmd: ResolvedBridgeCommand) -> Result<()> {
    match cmd {
        ResolvedBridgeCommand::Listen(l) if l.mode == BridgeMode::Tcp => {
            if l.daemon {
                let _ = spawn_tcp_listener_daemon(l);
                println!("[bridge] tcp listener daemon started");
            } else {
                let rt = Runtime::new()?;
                rt.block_on(run_tcp_listener_stub(l))?;
                println!("[bridge] tcp listener stub finished");
            }
        }
        ResolvedBridgeCommand::Connect(c) if c.mode == BridgeMode::Tcp => {
            let rt = Runtime::new()?;
            rt.block_on(run_tcp_client_stub(c))?;
            println!("[bridge] tcp client stub finished");
        }
        ResolvedBridgeCommand::Listen(l) if l.mode == BridgeMode::Udp => {
            if l.daemon {
                let _ = spawn_udp_listener_daemon(l);
                println!("[bridge] udp listener daemon started");
            } else {
                let rt = Runtime::new()?;
                rt.block_on(run_udp_listener_stub(l))?;
                println!("[bridge] udp listener stub finished");
            }
        }
        ResolvedBridgeCommand::Connect(c) if c.mode == BridgeMode::Udp => {
            let rt = Runtime::new()?;
            rt.block_on(run_udp_client_stub(c))?;
            println!("[bridge] udp client stub finished");
        }
        ResolvedBridgeCommand::Status(s) => {
            let status = build_status(&ResolvedBridgeCommand::Status(s.clone()), None);
            let json = serde_json::to_string_pretty(&status)?;
            println!("{}", json);
        }
        _ => unreachable!(),
    }
    Ok(())
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn status_runs_without_panic() {
        let cmd = ResolvedBridgeCommand::Status(crate::config::ResolvedBridgeStatus {
            bind: "127.0.0.1:0".into(),
            socket: std::path::PathBuf::from("/tmp/wsl-clip.sock"),
            mode: BridgeMode::Tcp,
        });
        // Should not panic even though it just prints JSON.
        run_bridge_command(cmd).unwrap();
    }

    #[test]
    fn daemon_listen_returns_immediately() {
        let cmd = ResolvedBridgeCommand::Listen(crate::config::ResolvedBridgeListen {
            bind: "127.0.0.1:0".into(),
            mode: BridgeMode::Tcp,
            idle_exit: None,
            ttl: None,
            max_bytes: 1024,
            token: None,
            token_file: None,
            daemon: true,
            log_file: None,
        });
        // Should return without blocking; background thread may stay alive briefly.
        run_bridge_command(cmd).unwrap();
    }
}

// <FILE>wsl_clip_core/src/orc_bridge_runtime.rs</FILE> - <DESC>Runtime executor for bridge-related CLI commands</DESC>
// <VERS>END OF VERSION: 0.1.0 - 2025-12-08T00:00:00Z</VERS>