forgot to commit these

This commit is contained in:
Brandon Thomas committed 2025-06-04 09:31:34 -04:00
1 parent 14a27ee803
commit 221aa347bf
3 files changed
+6 -6

No files matched your search

@@ -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?;
@@ -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"))?;
@@ -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"))?;