Don't stop turn on errors that Codex is handling (#82)

There are two classes of errors. One, `EventMsg::Error` is a signal that
it is the end of the turn.

But `EventMsg::StreamError` are errors that are being handled by Codex
(like retries) so we should let them through.

Author: benbrandt

src/conversation.rs

@@ -463,9 +463,11 @@ impl PromptState {
                     response_tx.send(Ok(StopReason::EndTurn)).ok();
                 }
             }
-            EventMsg::Error(ErrorEvent { message })
-            | EventMsg::StreamError(StreamErrorEvent { message }) => {
-                error!("Error during turn: {}", message);
+            EventMsg::StreamError(StreamErrorEvent { message }) => {
+                error!("Handled error during turn: {}", message);
+            }
+            EventMsg::Error(ErrorEvent { message }) => {
+                error!("Unhandled error during turn: {}", message);
                 if let Some(response_tx) = self.response_tx.take() {
                     response_tx.send(Err(Error::internal_error().with_data(message))).ok();
                 }
@@ -1195,9 +1197,11 @@ impl TaskState {
             EventMsg::AgentReasoning(AgentReasoningEvent { text }) => {
                 client.send_agent_thought(text).await;
             }
-            EventMsg::Error(ErrorEvent { message })
-            | EventMsg::StreamError(StreamErrorEvent { message }) => {
-                error!("Error during turn: {}", message);
+            EventMsg::StreamError(StreamErrorEvent { message }) => {
+                error!("Handled error during turn: {}", message);
+            }
+            EventMsg::Error(ErrorEvent { message }) => {
+                error!("Unhandled error during turn: {}", message);
                 if let Some(response_tx) = self.response_tx.take() {
                     response_tx
                         .send(Err(Error::internal_error().with_data(message)))