Try to send a request to the daemon. Returns error if daemon is not running.
(request: &DaemonRequest)
| 31 | |
| 32 | /// Try to send a request to the daemon. Returns error if daemon is not running. |
| 33 | pub async fn send_to_daemon(request: &DaemonRequest) -> Result<DaemonResponse> { |
| 34 | let mut stream = connect_daemon().await?; |
| 35 | |
| 36 | let req_bytes = serde_json::to_vec(request)?; |
| 37 | write_msg(&mut stream, &req_bytes).await?; |
| 38 | |
| 39 | let resp_bytes = read_msg(&mut stream).await?; |
| 40 | let response: DaemonResponse = serde_json::from_slice(&resp_bytes)?; |
| 41 | Ok(response) |
| 42 | } |
| 43 | |
| 44 | /// Spawn the daemon process in the background. |
| 45 | pub fn spawn_daemon(ws_url: &str) -> Result<()> { |
no test coverage detected