Function proxy_request_line_to_daemon

src/daemon.rs:1010–1051

(
    socket_path: &Path,
    handshake: &DaemonHandshake,
    line: &str,
    transport: &mut impl McpTransport,
)

#[cfg(unix)]
async fn proxy_request_line_to_daemon(
    socket_path: &Path,
    handshake: &DaemonHandshake,
    line: &str,
    transport: &mut impl McpTransport,
) -> Result<()> {
    if line.trim().is_empty() {
        return Ok(());
    }

    match send_daemon_request_line(socket_path, handshake, line).await {
        Ok(responses) => {
            if let Some(warning) = daemon_version_skew_warning(line, &responses, binary_version()) {
                eprintln!("[tracedecay] warning: {warning}");
            }
            for response in responses {
                transport.write_line(&response).await?;
                if !response.ends_with('\n') {
                    transport.write_line("\n").await?;
                }
            }
            transport.flush().await?;
        }
        Err(err) => {
            if let Some(response) = daemon_proxy_error_response(line, &err) {
                let json_line = serde_json::to_string(&response)?;
                transport.write_line(&json_line).await?;
                transport.write_line("\n").await?;
                transport.flush().await?;
            } else {
                log_daemon_event(
                    "daemon_proxy_drop",
                    &[
                        ("outcome", "dropped_notification".to_string()),
                        ("error", err.to_string()),
                    ],
                );
            }
        }
    }
    Ok(())
}

#[cfg(unix)]
async fn send_daemon_request_line(