Function start_cli_http_server

src-tauri/src/cli.rs:192–236

CLI HTTP server (no AppHandle dependency)

(port: u16, mut shutdown_rx: tokio::sync::watch::Receiver<bool>)

/// CLI HTTP server (no AppHandle dependency)
async fn start_cli_http_server(port: u16, mut shutdown_rx: tokio::sync::watch::Receiver<bool>) {
    use tokio::io::{AsyncReadExt, AsyncWriteExt};
    use tokio::net::TcpListener;

    let addr = format!("0.0.0.0:{}", port);
    let listener = match TcpListener::bind(&addr).await {
        Ok(l) => l,
        Err(e) => {
            cli_log(&format!("❌ HTTP 服务启动失败: {}", e));
            return;
        }
    };

    loop {
        tokio::select! {
            result = listener.accept() => {
                match result {
                    Ok((mut stream, _)) => {
                        let mut buf = [0u8; 4096];
                        let _ = stream.read(&mut buf).await;
                        let request = String::from_utf8_lossy(&buf);

                        let path = request
                            .lines()
                            .next()
                            .and_then(|line| line.split_whitespace().nth(1))
                            .unwrap_or("/");

                        let (status, content_type, body) = services::handle_http_request(path);

                        let response = format!(
                            "HTTP/1.1 {}\r\nContent-Type: {}\r\nContent-Length: {}\r\nAccess-Control-Allow-Origin: *\r\n\r\n{}",
                            status, content_type, body.len(), body
                        );
                        let _ = stream.write_all(response.as_bytes()).await;
                    }
                    Err(_) => break,
                }
            }
            _ = shutdown_rx.changed() => {
                break;
            }
        }
    }
}

/// Print log with timestamp to stdout
fn cli_log(msg: &str) {