fix bot err log
This commit is contained in:
@@ -40,12 +40,25 @@ impl ClaudeSession {
|
|||||||
.current_dir(&work_dir)
|
.current_dir(&work_dir)
|
||||||
.stdin(Stdio::piped())
|
.stdin(Stdio::piped())
|
||||||
.stdout(Stdio::piped())
|
.stdout(Stdio::piped())
|
||||||
.stderr(Stdio::null())
|
.stderr(Stdio::piped())
|
||||||
.spawn()
|
.spawn()
|
||||||
.context("failed to start claude process")?;
|
.context("failed to start claude process")?;
|
||||||
|
|
||||||
let stdin = child.stdin.take().context("failed to capture claude stdin")?;
|
let stdin = child.stdin.take().context("failed to capture claude stdin")?;
|
||||||
let stdout = child.stdout.take().context("failed to capture claude stdout")?;
|
let stdout = child.stdout.take().context("failed to capture claude stdout")?;
|
||||||
|
let stderr = child.stderr.take().context("failed to capture claude stderr")?;
|
||||||
|
|
||||||
|
// Background task: log stderr
|
||||||
|
tokio::spawn(async move {
|
||||||
|
let reader = BufReader::new(stderr);
|
||||||
|
let mut lines = reader.lines();
|
||||||
|
while let Ok(Some(line)) = lines.next_line().await {
|
||||||
|
eprintln!("bot: claude stderr: {}", line);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
// Brief wait to check if the process exits immediately
|
||||||
|
tokio::time::sleep(std::time::Duration::from_millis(500)).await;
|
||||||
|
|
||||||
let (tx, rx) = tokio::sync::mpsc::channel::<String>(16);
|
let (tx, rx) = tokio::sync::mpsc::channel::<String>(16);
|
||||||
|
|
||||||
@@ -58,8 +71,14 @@ impl ClaudeSession {
|
|||||||
loop {
|
loop {
|
||||||
let line = match lines.next_line().await {
|
let line = match lines.next_line().await {
|
||||||
Ok(Some(l)) => l,
|
Ok(Some(l)) => l,
|
||||||
Ok(None) => break,
|
Ok(None) => {
|
||||||
Err(_) => break,
|
eprintln!("bot: claude stdout closed");
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
Err(e) => {
|
||||||
|
eprintln!("bot: claude stdout error: {}", e);
|
||||||
|
break;
|
||||||
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
if line.trim().is_empty() {
|
if line.trim().is_empty() {
|
||||||
@@ -106,7 +125,8 @@ impl ClaudeSession {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Wait for child to exit
|
// Wait for child to exit
|
||||||
let _ = child.wait().await;
|
let status = child.wait().await;
|
||||||
|
eprintln!("bot: claude process exited: {:?}", status);
|
||||||
});
|
});
|
||||||
|
|
||||||
Ok(Self {
|
Ok(Self {
|
||||||
|
|||||||
Reference in New Issue
Block a user