Function notify_hook_event_inner

src/daemon.rs:276–321

(project_path: &Path, event: DaemonHookEvent)

#[cfg(unix)]
async fn notify_hook_event_inner(project_path: &Path, event: DaemonHookEvent) {
    let Ok(socket_path) = default_socket_path() else {
        return;
    };
    if !socket_path.exists() {
        return;
    }
    let Ok(handshake) =
        DaemonHandshake::for_current_client(Some(project_path.to_path_buf()), None, false, false)
    else {
        return;
    };
    let Ok(params) = serde_json::to_value(event) else {
        return;
    };
    let request = JsonRpcRequest {
        jsonrpc: "2.0".to_string(),
        id: None,
        method: HOOK_EVENT_METHOD.to_string(),
        params: Some(params),
    };
    let Ok(line) = serde_json::to_string(&request) else {
        return;
    };
    let Ok(stream) = UnixStream::connect(socket_path).await else {
        return;
    };
    let Ok(handshake_line) = handshake.to_line() else {
        return;
    };
    let (_reader, mut writer) = stream.into_split();
    if writer.write_all(handshake_line.as_bytes()).await.is_err() {
        return;
    }
    if writer.write_all(b"\n").await.is_err() {
        return;
    }
    if writer.write_all(line.as_bytes()).await.is_err() {
        return;
    }
    if writer.write_all(b"\n").await.is_err() {
        return;
    }
    let _ = writer.flush().await;
    let _ = writer.shutdown().await;
}

#[cfg(not(unix))]
pub async fn notify_hook_event(project_path: &Path, event: DaemonHookEvent) {