diff --git a/crates/service/web/storyteller_web/src/http_server/endpoints/webhooks/fal_webhook_handler.rs b/crates/service/web/storyteller_web/src/http_server/endpoints/webhooks/fal_webhook_handler.rs index 4768f36687..5ed7102c30 100644 --- a/crates/service/web/storyteller_web/src/http_server/endpoints/webhooks/fal_webhook_handler.rs +++ b/crates/service/web/storyteller_web/src/http_server/endpoints/webhooks/fal_webhook_handler.rs @@ -142,6 +142,8 @@ pub async fn fal_webhook_handler( if let Some(payload_obj) = payload.as_object() { if payload_obj.contains_key("image") { handle_image_payload(payload_obj, &job, &server_state).await?; + } else if payload_obj.contains_key("video") { + handle_video_payload(payload_obj, &job, &server_state).await?; } if payload_obj.contains_key("video") { handle_video_payload(payload_obj, &job, &server_state).await?; diff --git a/crates/service/web/storyteller_web/src/http_server/endpoints/webhooks/handle_image_payload.rs b/crates/service/web/storyteller_web/src/http_server/endpoints/webhooks/handle_image_payload.rs index 53b585b83e..28951a796b 100644 --- a/crates/service/web/storyteller_web/src/http_server/endpoints/webhooks/handle_image_payload.rs +++ b/crates/service/web/storyteller_web/src/http_server/endpoints/webhooks/handle_image_payload.rs @@ -39,11 +39,11 @@ pub async fn handle_image_payload( let image_value = payload.get("image") .ok_or_else(|| anyhow!("no `image` key in payload"))?; + + info!("Fal Image Payload: {:?}", image_value); let image: FalWebhookImage = serde_json::from_value(image_value.clone())?; - - info!("Image payload received: {:?}", image); - + let image_url = image.url .as_deref() .ok_or_else(|| anyhow!("no `url` in image payload"))?; diff --git a/crates/service/web/storyteller_web/src/http_server/endpoints/webhooks/handle_video_payload.rs b/crates/service/web/storyteller_web/src/http_server/endpoints/webhooks/handle_video_payload.rs index 959aa487eb..d08c5ce01a 100644 --- a/crates/service/web/storyteller_web/src/http_server/endpoints/webhooks/handle_video_payload.rs +++ b/crates/service/web/storyteller_web/src/http_server/endpoints/webhooks/handle_video_payload.rs @@ -44,12 +44,10 @@ pub async fn handle_video_payload( let video_value = payload.get("video") .ok_or_else(|| anyhow!("no `image` key in payload"))?; - info!("Video: {:?}", video_value); + info!("Fal Video Payload: {:?}", video_value); let video: FalWebhookVideo = serde_json::from_value(video_value.clone())?; - info!("Video payload received: {:?}", video); - let video_url = video.url .as_deref() .ok_or_else(|| anyhow!("no `url` in video payload"))?;