use std::{ fs::canonicalize, io::{BufRead, BufReader}, path::PathBuf, process::{Child, Stdio}, sync::{mpsc::sync_channel, Arc}, }; use crate::{config::Config, connect_params::ConnectParams}; #[derive(Clone, Debug)] pub struct CliSession { inner: Arc, } impl CliSession { pub fn new() -> Self { Self { inner: Arc::new(InnerCliSession {}), } } pub fn connect( &self, config: &Config, cli_path: &PathBuf, ) -> eyre::Result<(ConnectParams, Child)> { self.inner.connect(config, cli_path) } } #[derive(Debug)] struct InnerCliSession {} impl InnerCliSession { pub fn connect( &self, config: &Config, cli_path: &PathBuf, ) -> eyre::Result<(ConnectParams, Child)> { let proc = self.start(config, cli_path)?; let params = self.get_conn(proc)?; Ok(params) } fn start(&self, config: &Config, cli_path: &PathBuf) -> eyre::Result { let mut args: Vec = vec!["session".into()]; if let Some(workspace) = &config.workdir_path { let abs_path = canonicalize(workspace)?; args.extend(["--workdir".into(), abs_path.to_string_lossy().to_string()]) } if let Some(config_path) = &config.config_path { let abs_path = canonicalize(config_path)?; args.extend(["--project".into(), abs_path.to_string_lossy().to_string()]) } let proc = std::process::Command::new( cli_path .to_str() .ok_or(eyre::anyhow!("could not get string from path"))?, ) .args(args.as_slice()) .stdin(Stdio::piped()) .stdout(Stdio::piped()) .stderr(Stdio::piped()) .spawn()?; //TODO: Add retry mechanism return Ok(proc); } fn get_conn( &self, mut proc: std::process::Child, ) -> eyre::Result<(ConnectParams, std::process::Child)> { let stdout = proc .stdout .take() .ok_or(eyre::anyhow!("could not acquire stdout from child process"))?; let stderr = proc .stderr .take() .ok_or(eyre::anyhow!("could not acquire stderr from child process"))?; let (sender, receiver) = sync_channel(1); std::thread::spawn(move || { let stdout_bufr = BufReader::new(stdout); for line in stdout_bufr.lines() { let out = line.as_ref().unwrap(); if let Ok(conn) = serde_json::from_str::(&out) { sender.send(conn).unwrap(); } if let Ok(line) = line { println!("dagger: {}", line); } } }); std::thread::spawn(|| { let stderr_bufr = BufReader::new(stderr); for line in stderr_bufr.lines() { if let Ok(line) = line { println!("dagger: {}", line); } //panic!("could not start dagger session: {}", out) } }); let conn = receiver.recv()?; Ok((conn, proc)) } }