fix: WHIP not cleaning up

Cargo.lock

@@ -2906,7 +2906,7 @@ dependencies = [
 
 [[package]]
 name = "server"
-version = "0.3.0"
+version = "0.4.0"
 dependencies = [
  "argon2",
  "async-broadcast",

crates/server/src/http.rs

@@ -201,7 +201,6 @@ async fn catalog_handler(
             user: x.stream_key_user.clone(),
             started_at: x.started_at,
         })
-        .into_iter()
         .collect::<Vec<_>>();
     Ok(Json(catalog))
 }

crates/server/src/webrtc_ingest.rs

@@ -28,6 +28,7 @@ use crate::{
 pub async fn handle_whip_injest_delete(
     State(state): State<Arc<HttpServer>>,
     ConnectInfo(remote): ConnectInfo<SocketAddr>,
+    Path(_slug): Path<String>,
     headers: HeaderMap,
 ) -> Result<impl IntoResponse, HttpError> {
     let token = headers
@@ -44,14 +45,19 @@ pub async fn handle_whip_injest_delete(
         .await?
         .ok_or(HttpError::Unauthorized)?;
 
-    let active_session = stream_session::Model::get_active_by_stream_key_id(&state.db, key.id)
+    // The detach task may have already cleaned up the session when ICE
-        .await?
+    // disconnected (OBS closes the PeerConnection before sending DELETE).
-        .ok_or(HttpError::NotFound)?;
+    // Deleting an already-gone session is still a successful delete.
+    if let Some(active_session) =
+        stream_session::Model::get_active_by_stream_key_id(&state.db, key.id).await?
+    {
+        active_session
+            .into_active_model()
+            .finish_stream_session(&state.db, Utc::now())
+            .await?;
+    }
 
-    active_session
+    state.appstate.lock().await.stream_sessions.remove(&key.id);
-        .into_active_model()
-        .finish_stream_session(&state.db, Utc::now())
-        .await?;
 
     Ok(StatusCode::OK)
 }