refactor: replace unmaintained SSE dependencies to restore stream reliability

Cargo.toml

@@ -73,8 +73,7 @@ reqwest = { version = "0.12.23", features = [
     "http2",
 ], default-features = false }
 rustls = { version = "0.23", features = ["ring"], default-features = false }
-reqwest-eventsource = "0.6.0"
-eventsource-stream = "0.2.3"
+eventsource-client = "0.17.2"
 include_dir = "0.7.4"
 schemars = "1.2"
 serde = { version = "1.0.217", features = ["derive"] }

crates/forge_app/Cargo.toml

@@ -41,7 +41,7 @@ dashmap.workspace = true
 url.workspace = true
 reqwest.workspace = true
 bytes.workspace = true
-reqwest-eventsource.workspace = true
+eventsource-client.workspace = true
 schemars.workspace = true
 glob.workspace = true
 lazy_static.workspace = true

crates/forge_app/src/infra.rs

@@ -10,11 +10,10 @@ use forge_domain::{
 };
 use reqwest::Response;
 use reqwest::header::HeaderMap;
-use reqwest_eventsource::EventSource;
 use serde::de::DeserializeOwned;
 use url::Url;
 
-use crate::{WalkedFile, Walker};
+use crate::{EventSource, WalkedFile, Walker};
 
 /// Infrastructure trait for accessing environment configuration, system
 /// variables, and persisted application configuration.

crates/forge_app/src/lib.rs

@@ -1,3 +1,11 @@
+use std::pin::Pin;
+
+use eventsource_client::SSE;
+use futures::Stream;
+
+/// Type alias for a server-sent events stream
+pub type EventSource = Pin<Box<dyn Stream<Item = anyhow::Result<SSE>> + Send + Sync>>;
+
 mod agent;
 mod agent_executor;
 mod agent_provider_resolver;

crates/forge_app/src/services.rs

@@ -12,11 +12,10 @@ use forge_domain::{
 };
 use reqwest::Response;
 use reqwest::header::HeaderMap;
-use reqwest_eventsource::EventSource;
 use url::Url;
 
 use crate::user::{User, UserUsage};
-use crate::{EnvironmentInfra, Walker};
+use crate::{EnvironmentInfra, EventSource, Walker};
 
 #[derive(Debug, Clone)]
 pub struct ShellOutput {