Function start_http_server

src-tauri/src/services.rs:181–236

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

/// Simple HTTP server for serving hosts files (async with graceful shutdown)
#[cfg(feature = "gui")]
async fn start_http_server(port: u16, app: AppHandle, 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) => {
            let _ = app.emit(
                "server-log",
                log_payload("server.startFail", Some(serde_json::json!({"error": e.to_string()})), "error"),
            );
            return;
        }
    };

    let _ = app.emit(
        "server-log",
        log_payload("server.httpStarted", Some(serde_json::json!({"port": port})), "success"),
    );

    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) = 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;
            }
        }
    }
}

/// Handle HTTP request and return (status, content_type, body)