kjuulh/dagger-rs
1
0
Fork 0
mirror of https://github.com/kjuulh/dagger-rs.git synced 2024-11-08 19:11:47 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(core): cli session keep session alive

Browse Source
This commit is contained in:
Kasper Juul Hermansen 2023-02-20 11:54:22 +01:00
parent 085a998bc6
commit 8dfecf976c
Signed by: kjuulh
GPG Key ID: 57B6E1465221F912
1 changed files with 9 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
crates/dagger-core/src/cli_session.rs
View File

@ -1,8 +1,7 @@
use std::{ use std::{
fs::canonicalize, fs::canonicalize,
io::{BufRead, BufReader},
path::PathBuf, path::PathBuf,
process::{Child, Stdio}, process::Stdio,
sync::Arc, sync::Arc,
}; };
@ -89,26 +88,21 @@ impl InnerCliSession {
let (sender, mut receiver) = tokio::sync::mpsc::channel(1); let (sender, mut receiver) = tokio::sync::mpsc::channel(1);
tokio::spawn(async move { tokio::spawn(async move {
let stdout_bufr = tokio::io::BufReader::new(stdout); let mut stdout_bufr = tokio::io::BufReader::new(stdout).lines();
for line in stdout_bufr.lines().next_line().await { while let Ok(Some(line)) = stdout_bufr.next_line().await {
let out = line.as_ref().unwrap(); if let Ok(conn) = serde_json::from_str::<ConnectParams>(&line) {
if let Ok(conn) = serde_json::from_str::<ConnectParams>(&out) {
sender.send(conn).await.unwrap(); sender.send(conn).await.unwrap();
} }
if let Some(line) = line {
println!("dagger: {}", line); println!("dagger: {}", line);
} }
}
}); });
tokio::spawn(async move { tokio::spawn(async move {
let stdout_bufr = tokio::io::BufReader::new(stderr); let mut stdout_bufr = tokio::io::BufReader::new(stderr).lines();
for line in stdout_bufr.lines().next_line().await { while let Ok(Some(line)) = stdout_bufr.next_line().await {
if let Some(line) = line {
println!("dagger: {}", line); println!("dagger: {}", line);
} }
//panic!("could not start dagger session: {}", out)
}
}); });
let conn = receiver.recv().await.ok_or(eyre::anyhow!("could not receive ok signal from dagger-engine"))?; let conn = receiver.recv().await.ok_or(eyre::anyhow!("could not receive ok signal from dagger-engine"))?;