Merge pull request #236 from rararulab/issue-234-event-publish

fix(meta): return error when event publishing fails (#234)

Author: crrow

crates/meta/src/handlers.rs

@@ -241,6 +241,8 @@ pub async fn mark_uploaded(
         .context(error::DatabaseSnafu)?;
 
     // Publish event so the ingestor can start transmux.
+    // Failure here is fatal: without the event the ingestor never picks up the
+    // video and the status stays stuck at "processing" forever.
     if let Err(e) = state
         .event_bus
         .send_serde_json(&DomainEvent::VideoUploaded {
@@ -249,7 +251,10 @@ pub async fn mark_uploaded(
         .await
     {
         tracing::warn!("failed to publish VideoUploaded event: {e}");
-        // Non-fatal -- the status has already been updated.
+        return error::InternalSnafu {
+            message: format!("failed to publish VideoUploaded event: {e}"),
+        }
+        .fail();
     }
 
     Ok(ApiResponse::accepted(UploadedResponse {