From 67dd65c636f3bbef816cfe2eea7fa78035e90bb1 Mon Sep 17 00:00:00 2001 From: Brandon Thomas Date: Tue, 9 Jun 2026 20:12:17 -0400 Subject: [PATCH] beeble endpoint --- ...inference_job_for_beeble_queue_with_apriori_job_token.rs | 6 +++++- .../video/edit/beeble_switchx_edit_video_gen_handler.rs | 2 ++ 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/crates/schema/database/mysql_queries/src/queries/generic_inference/api_providers/beeble/insert_generic_inference_job_for_beeble_queue_with_apriori_job_token.rs b/crates/schema/database/mysql_queries/src/queries/generic_inference/api_providers/beeble/insert_generic_inference_job_for_beeble_queue_with_apriori_job_token.rs index f59ab9ee53..01d1ec524d 100644 --- a/crates/schema/database/mysql_queries/src/queries/generic_inference/api_providers/beeble/insert_generic_inference_job_for_beeble_queue_with_apriori_job_token.rs +++ b/crates/schema/database/mysql_queries/src/queries/generic_inference/api_providers/beeble/insert_generic_inference_job_for_beeble_queue_with_apriori_job_token.rs @@ -9,6 +9,7 @@ use enums::by_table::generic_inference_jobs::inference_job_product_category::Inf use enums::by_table::generic_inference_jobs::inference_job_type::InferenceJobType; use enums::common::generation::common_model_type::CommonModelType; use enums::common::job_status_plus::JobStatusPlus; +use enums::common::platform_type::PlatformType; use enums::common::visibility::Visibility; use tokens::tokens::anonymous_visitor_tracking::AnonymousVisitorTrackingToken; use tokens::tokens::generic_inference_jobs::InferenceJobToken; @@ -46,6 +47,9 @@ pub struct InsertGenericInferenceForBeebleWithAprioriJobTokenArgs<'e, 'c, E> pub creator_ip_address: &'e str, pub creator_set_visibility: Visibility, + /// The platform the enqueuing request came from, inferred from its User-Agent. + pub maybe_platform_type: Option, + pub maybe_debug_log_event_token: Option<&'e DebugLogEventToken>, /// Override the initial job status. Defaults to `Pending` when `None`. @@ -83,7 +87,7 @@ pub async fn insert_generic_inference_job_for_beeble_queue_with_apriori_job_toke maybe_avt_token: args.maybe_avt_token, creator_ip_address: args.creator_ip_address, creator_set_visibility: args.creator_set_visibility, - maybe_platform_type: None, + maybe_platform_type: args.maybe_platform_type, maybe_debug_log_event_token: args.maybe_debug_log_event_token, maybe_frontend_failure_category: args.maybe_frontend_failure_category, maybe_failure_reason: args.maybe_failure_reason, diff --git a/crates/service/web/storyteller_web/src/http_server/endpoints/generate/video/edit/beeble_switchx_edit_video_gen_handler.rs b/crates/service/web/storyteller_web/src/http_server/endpoints/generate/video/edit/beeble_switchx_edit_video_gen_handler.rs index 94f84a4e92..670a950552 100644 --- a/crates/service/web/storyteller_web/src/http_server/endpoints/generate/video/edit/beeble_switchx_edit_video_gen_handler.rs +++ b/crates/service/web/storyteller_web/src/http_server/endpoints/generate/video/edit/beeble_switchx_edit_video_gen_handler.rs @@ -37,6 +37,7 @@ use tokens::tokens::media_files::MediaFileToken; use crate::http_server::common_responses::common_web_error::CommonWebError; use crate::http_server::endpoints::generate::common::payments_error_test::payments_error_test; use crate::http_server::validations::validate_idempotency_token_format::validate_idempotency_token_format; +use crate::http_server::web_utils::get_request_platform_type::get_request_platform_type; use crate::state::server_state::ServerState; use crate::util::http_download_url_to_bytes::http_download_url_to_bytes; use crate::util::lookup::lookup_image_urls_as_map::lookup_image_urls_as_map; @@ -317,6 +318,7 @@ pub async fn beeble_switchx_edit_video_gen_handler( maybe_avt_token: maybe_avt_token.as_ref(), creator_ip_address: &ip_address, creator_set_visibility: Visibility::Public, + maybe_platform_type: get_request_platform_type(&http_request), maybe_debug_log_event_token: None, starting_job_status_override: None, maybe_frontend_failure_category: None,