github link

2026-10-21 09:22:41 -04:00 · 2025-09-29 23:09:32 -04:00
1055 changed files with 12823 additions and 50147 deletions
@@ -1,7 +1,6 @@
 SERVER_ENVIRONMENT=development

 DATABASE_URL=mysql://storyteller:password@localhost/storyteller
-#DATABASE_URL=sqlite:/tmp/tasks.sqlite
 #DATABASE_URL=mysql://root:root@localhost/storyteller
 #DATABASE_URL=mysql://root@localhost/storyteller

@@ -45,9 +45,6 @@ crates/lib/sqlite_queries/target/
 # Javascript build directories
 node_modules/

-# Frontend build outputs
-frontend/apps/editor3d/bundle-report.html
-
 # Vim noise
 *.swo
 *.swp
@@ -1,12 +0,0 @@
-{
-  "db_name": "SQLite",
-  "query": "\n    UPDATE tasks\n    SET is_dismissed_by_user = 1\n    WHERE id = ?\n  ",
-  "describe": {
-    "columns": [],
-    "parameters": {
-      "Right": 1
-    },
-    "nullable": []
-  },
-  "hash": "13d435d8f681b73e4080748dcef0579e246e41049af67e1bd79ffc06aa6ba974"
-}
@@ -1,12 +0,0 @@
-{
-  "db_name": "SQLite",
-  "query": "\n    UPDATE tasks\n    SET\n      task_status = ?,\n      on_complete_batch_token = ?,\n      on_complete_primary_media_file_token = ?,\n      on_complete_primary_media_file_class = ?,\n      on_complete_primary_media_file_cdn_url = ?,\n      on_complete_primary_media_file_thumbnail_url_template = ?\n    WHERE\n      provider = ?\n      AND provider_job_id = ?\n  ",
-  "describe": {
-    "columns": [],
-    "parameters": {
-      "Right": 8
-    },
-    "nullable": []
-  },
-  "hash": "1e3758851fc8451670f86a9432009b73bdb81de4a08dcaa96a86afb5f9be7a68"
-}
@@ -1,68 +0,0 @@
-{
-  "db_name": "SQLite",
-  "query": "\n    SELECT\n      id,\n      task_status,\n      task_type,\n      model_type,\n      provider,\n      provider_job_id,\n      frontend_caller,\n      frontend_subscriber_id,\n      frontend_subscriber_payload\n    FROM tasks\n    WHERE\n      provider = ?\n      AND provider_job_id = ?\n  ",
-  "describe": {
-    "columns": [
-      {
-        "name": "id",
-        "ordinal": 0,
-        "type_info": "Text"
-      },
-      {
-        "name": "task_status",
-        "ordinal": 1,
-        "type_info": "Text"
-      },
-      {
-        "name": "task_type",
-        "ordinal": 2,
-        "type_info": "Text"
-      },
-      {
-        "name": "model_type",
-        "ordinal": 3,
-        "type_info": "Text"
-      },
-      {
-        "name": "provider",
-        "ordinal": 4,
-        "type_info": "Text"
-      },
-      {
-        "name": "provider_job_id",
-        "ordinal": 5,
-        "type_info": "Text"
-      },
-      {
-        "name": "frontend_caller",
-        "ordinal": 6,
-        "type_info": "Text"
-      },
-      {
-        "name": "frontend_subscriber_id",
-        "ordinal": 7,
-        "type_info": "Text"
-      },
-      {
-        "name": "frontend_subscriber_payload",
-        "ordinal": 8,
-        "type_info": "Text"
-      }
-    ],
-    "parameters": {
-      "Right": 2
-    },
-    "nullable": [
-      false,
-      false,
-      false,
-      true,
-      true,
-      true,
-      true,
-      true,
-      true
-    ]
-  },
-  "hash": "38ff2df237b16f077865711dd81261de1b5fa05a9787679ce9ccd4ac576b1069"
-}
@@ -1,116 +0,0 @@
-{
-  "db_name": "SQLite",
-  "query": "\n    SELECT\n      id,\n      task_status,\n      task_type,\n      model_type,\n      provider,\n      provider_job_id,\n      frontend_caller,\n      frontend_subscriber_id,\n      frontend_subscriber_payload,\n      on_complete_primary_media_file_token,\n      on_complete_primary_media_file_class,\n      on_complete_batch_token,\n      on_complete_primary_media_file_cdn_url,\n      on_complete_primary_media_file_thumbnail_url_template,\n      created_at as \"created_at: DateTime<Utc>\",\n      updated_at as \"updated_at: DateTime<Utc>\",\n      completed_at as \"completed_at: DateTime<Utc>\"\n    FROM tasks\n    WHERE is_dismissed_by_user == 0\n  ",
-  "describe": {
-    "columns": [
-      {
-        "name": "id",
-        "ordinal": 0,
-        "type_info": "Text"
-      },
-      {
-        "name": "task_status",
-        "ordinal": 1,
-        "type_info": "Text"
-      },
-      {
-        "name": "task_type",
-        "ordinal": 2,
-        "type_info": "Text"
-      },
-      {
-        "name": "model_type",
-        "ordinal": 3,
-        "type_info": "Text"
-      },
-      {
-        "name": "provider",
-        "ordinal": 4,
-        "type_info": "Text"
-      },
-      {
-        "name": "provider_job_id",
-        "ordinal": 5,
-        "type_info": "Text"
-      },
-      {
-        "name": "frontend_caller",
-        "ordinal": 6,
-        "type_info": "Text"
-      },
-      {
-        "name": "frontend_subscriber_id",
-        "ordinal": 7,
-        "type_info": "Text"
-      },
-      {
-        "name": "frontend_subscriber_payload",
-        "ordinal": 8,
-        "type_info": "Text"
-      },
-      {
-        "name": "on_complete_primary_media_file_token",
-        "ordinal": 9,
-        "type_info": "Text"
-      },
-      {
-        "name": "on_complete_primary_media_file_class",
-        "ordinal": 10,
-        "type_info": "Text"
-      },
-      {
-        "name": "on_complete_batch_token",
-        "ordinal": 11,
-        "type_info": "Text"
-      },
-      {
-        "name": "on_complete_primary_media_file_cdn_url",
-        "ordinal": 12,
-        "type_info": "Text"
-      },
-      {
-        "name": "on_complete_primary_media_file_thumbnail_url_template",
-        "ordinal": 13,
-        "type_info": "Text"
-      },
-      {
-        "name": "created_at: DateTime<Utc>",
-        "ordinal": 14,
-        "type_info": "Int64"
-      },
-      {
-        "name": "updated_at: DateTime<Utc>",
-        "ordinal": 15,
-        "type_info": "Int64"
-      },
-      {
-        "name": "completed_at: DateTime<Utc>",
-        "ordinal": 16,
-        "type_info": "Int64"
-      }
-    ],
-    "parameters": {
-      "Right": 0
-    },
-    "nullable": [
-      false,
-      false,
-      false,
-      true,
-      true,
-      true,
-      true,
-      true,
-      true,
-      true,
-      true,
-      true,
-      true,
-      true,
-      false,
-      false,
-      true
-    ]
-  },
-  "hash": "47f94c127abc20683b25c257aed3c2190b9bd29eb829d61392f08e10fd986767"
-}
@@ -1,12 +0,0 @@
-{
-  "db_name": "SQLite",
-  "query": "\n    UPDATE tasks\n    SET\n      task_status = ?,\n      on_complete_batch_token = ?,\n      on_complete_primary_media_file_token = ?,\n      on_complete_primary_media_file_class = ?,\n      on_complete_primary_media_file_cdn_url = ?,\n      on_complete_primary_media_file_thumbnail_url_template = ?\n    WHERE id = ?\n  ",
-  "describe": {
-    "columns": [],
-    "parameters": {
-      "Right": 7
-    },
-    "nullable": []
-  },
-  "hash": "50a2449b87abed7df3302a74ecd0e8ab87940077a247636680cb09b2fe488321"
-}
@@ -6,17 +6,16 @@ resolver = "2"
 members = [
  # API clients for external services
  # These might be custom implementations or wrappers over other client libraries.
-  "crates/api_clients/artcraft/artcraft_api_defs", # TODO: api_clients/{artcraft}/{api_defs,client}
-  "crates/api_clients/artcraft/storyteller_client",
+  "crates/api_clients/artcraft_api_defs", # TODO: api_clients/{artcraft}/{api_defs,client}
  "crates/api_clients/cloud_storage",
  "crates/api_clients/fal_client",
  "crates/api_clients/google_drive_common",
  "crates/api_clients/google_sign_in",
-  "crates/api_clients/grok_client",
  "crates/api_clients/midjourney_client",
  "crates/api_clients/openai_sora_client",
  "crates/api_clients/openart_client",
  "crates/api_clients/runwayml_client",
+  "crates/api_clients/storyteller_client",
  "crates/api_clients/thumbnail_generator",

  # CLI tools for operations, etc.
@@ -44,7 +43,6 @@ members = [
  "crates/lib/caching/memory_store",
  "crates/lib/caching/redis_caching",
  "crates/lib/cloudflare_errors",
-  "crates/lib/cloudflare_mitigation",
  "crates/lib/concurrency",
  "crates/lib/cookie_store",
  "crates/lib/cookies",
@@ -86,7 +84,6 @@ members = [
  "crates/lib/testing",
  "crates/lib/tts_common",
  "crates/lib/url_config",
-  "crates/lib/url_utils",
  "crates/lib/user_input_common",
  "crates/lib/web_scrapers",
  #"crates/lib/api_clients/fakeyou_client",
@@ -184,11 +181,10 @@ workspace-build-acceleration = { path = "crates/workspace-build-acceleration" }
 # Internal libs
 # Setting paths here ensures we don't need to do so in every crate's Cargo.toml
 # It makes refactoring much easier.
-artcraft_api_defs = { path = "crates/api_clients/artcraft/artcraft_api_defs" }
+artcraft_api_defs = { path = "crates/api_clients/artcraft_api_defs" }
 build_metadata = { path = "crates/lib/build_metadata" }
 cloud_storage = { path = "crates/api_clients/cloud_storage" }
 cloudflare_errors = { path = "crates/lib/cloudflare_errors" }
-cloudflare_mitigation = { path = "crates/lib/cloudflare_mitigation" }
 component_traits = { path = "crates/service/plugins/component_traits" }
 cookie_store = { path = "crates/lib/cookie_store" }
 crockford = { path = "crates/lib/data/crockford" }
@@ -198,7 +194,6 @@ errors = { path = "crates/lib/errors" }
 fal_client = { path = "crates/api_clients/fal_client" }
 file_to_base64_url = { path = "crates/lib/files/file_to_base64_url" }
 filesys = { path = "crates/lib/files/filesys" }
-grok_client = { path = "crates/api_clients/grok_client" }
 idempotency = { path = "crates/lib/idempotency" }
 images = { path = "crates/lib/files/images" }
 jwt_light = { path = "crates/lib/jwt_light" }
@@ -210,12 +205,11 @@ openai_sora_client = { path = "crates/api_clients/openai_sora_client" }
 primitives = { path = "crates/lib/data/primitives" }
 shared_service_components = { path = "crates/lib/shared_service_components" }
 sqlite_tasks = { path = "crates/schema/database/sqlite_tasks" }
-storyteller_client = { path = "crates/api_clients/artcraft/storyteller_client" }
+storyteller_client = { path = "crates/api_clients/storyteller_client" }
 subprocess_common = { path = "crates/lib/subprocess_common" }
 test_data = { path = "crates/lib/test_data" }
 testing = { path = "crates/lib/testing" }
 tokens = { path = "crates/schema/public/tokens" }
-url_utils = { path = "crates/lib/url_utils" }
 web_base64 = { path = "crates/lib/data/web_base64" }

 # External libs
@@ -233,26 +227,22 @@ actix-web-actors = "4.3.1+deprecated"
 actix-web-lab = "0.20.2"
 anyhow = "1.0.98"
 base64 = "0.22.1"
-bstr = "1.12.1"
 bytes = "1.10.1"
 chrono = { version = "0.4.41", features = ["serde"] }
 cookie = "0.18.1"
-env = "1.0.1"
-env_logger = "0.11.8"
 futures = { version = "0.3.31" }
 hex-literal = "1.0.0"
 indexmap = "2.9.0"
 log = "0.4.27"
 once_cell = "1.21.3"
 rand = "0.9.1"
-regex = "1.12.2"
-reqwest = { version = "0.12.23", default-features = false, features = [ "charset", "http2", "system-proxy", "json", "cookies", "rustls-tls" ] }
+regex = "1.11.1"
+reqwest = { version = "0.12.22", features = ["json", "cookies"] }
 reqwest-websocket = {  version = "0.5.0" }
 serde = {  version = "1.0.219", features = ["derive"] }
 serde_derive = "1.0.219"
 serde_json = "1.0.140"
 serde_yaml = "0.9.34+deprecated"
-sha2 = "0.11.0-rc.2"
 sha3 = "0.10.8"
 tauri = { version = "2.8.3", features = ["unstable", "devtools"] } # NB: "devtools" prevents App Store distribution; "ubstable" is needed for window access
 tauri-plugin-dialog = "2.3.3"
@@ -265,17 +255,3 @@ thiserror = "2.0.12"
 tokio = { version = "1.45.1", features = ["macros"] }
 toml = "0.8.22"
 url = { version = "2.5.4", features = ["serde"] }
-uuid = "1.18.1"
-
-# NB: wreq gets past fingerprinting, but we have to deal with platform-specific build issues.
-#
-# Mac:
-#   brew install --formula cmake pkg-config llvm
-# Windows:
-#   choco install cmake -y
-#   choco install strawberryperl -y
-#   choco install pkgconfiglite -y
-#   choco install llvm -y
-#   choco install nasm -y
-wreq = { version = "6.0.0-rc.20", features = ["json", "multipart", "cookies", "ws", "stream"] }
-wreq-util = "3.0.0-rc.6"
@@ -1,20 +0,0 @@
-- noinspection SqlDialectInspectionForFile
-- noinspection SqlNoDataSourceInspectionForFile
-- noinspection SqlResolveForFile
-
-select
-    u.display_name,
-    count(*) as sessions,
-    a.session_duration_seconds / 60 / 60 as hours,
-    a.measurement_count,
-    u.email_address,
-    a.os_platform,
-    a.os_version,
-    u.created_at,
-    u.maybe_source,
-    a.last_active_at
-from analytics_app_sessions as a
-left outer join users as u
-on a.user_token = u.token
-group by a.user_token
-order by hours desc;
@@ -9,14 +9,6 @@
 --   tasks_v1.sqlite - initial version
 --   tasks_v2.sqlite - added model_type (nullable)
 --   tasks_v3.sqlite - added frontend_caller, comments
--   tasks_v4.sqlite - added is_dismissed_by_user
--   tasks_v5.sqlite - added five fields:
--      on_complete_batch_token,
--      on_complete_primary_media_file_token,
--      on_complete_primary_media_file_class,
--      on_complete_primary_media_file_cdn_url,
--      on_complete_primary_media_file_thumbnail_url_template,
--

 CREATE TABLE tasks (
    -- Task auto-incrementing primary key.
@@ -58,32 +50,6 @@ CREATE TABLE tasks (
    -- will be re-emitted back to the frontend.
    frontend_subscriber_payload TEXT,

-    -- Whether the user has dismissed the task from view.
-    is_dismissed_by_user INTEGER NOT NULL DEFAULT 0,
-
-    -- OPTIONAL.
-    -- When the generation completes, the batch token (if any).
-    -- This will point to a collection of multiple files.
-    on_complete_batch_token TEXT,
-
-    -- OPTIONAL.
-    -- When the generation completes, the media token of the "primary" media file.
-    -- We'll probably always generate homogenous types, but just in case this is the first or primary item in a batch.
-    on_complete_primary_media_file_token TEXT,
-
-    -- OPTIONAL.
-    -- When the generation completes, the file type of the primary media file.
-    -- We'll probably always generate homogenous types, but just in case this is the first or primary item in a batch.
-    on_complete_primary_media_file_class TEXT,
-
-    -- OPTIONAL.
-    -- The URL to the media file.
-    on_complete_primary_media_file_cdn_url TEXT,
-
-    -- OPTIONAL.
-    -- The URL template for the thumbnail of the primary media file.
-    on_complete_primary_media_file_thumbnail_url_template TEXT,
-
    created_at INTEGER NOT NULL DEFAULT (unixepoch('now')),
    updated_at INTEGER NOT NULL DEFAULT (unixepoch('now')),
    completed_at INTEGER DEFAULT NULL
@@ -152,7 +152,6 @@ CREATE TABLE media_files (
  --   * `vmd`
  --   * `pmx`
  --   * `csv`
-  --   * `spz` Gaussian splats
  media_type VARCHAR(16) NOT NULL,

  -- Broad class of media:
@@ -1,7 +0,0 @@
-use serde_derive::{Deserialize, Serialize};
-use utoipa::ToSchema;
-
-#[derive(Serialize, Deserialize, ToSchema)]
-pub struct SimpleGenericJsonSuccess {
-  pub success: bool,
-}
@@ -1 +0,0 @@
-pub mod nano_banana_pro_multi_function_image_gen;
@@ -1,71 +0,0 @@
-use serde_derive::{Deserialize, Serialize};
-use tokens::tokens::generic_inference_jobs::InferenceJobToken;
-use tokens::tokens::media_files::MediaFileToken;
-use utoipa::ToSchema;
-
-pub const NANO_BANANA_PRO_MULTI_FUNCTION_IMAGE_GEN_PATH: &str = "/v1/generate/image/multi_function/nano_banana_pro";
-
-#[derive(Serialize, Deserialize, ToSchema)]
-pub struct NanoBananaProMultiFunctionImageGenRequest {
-  /// Idempotency token to prevent duplicate requests.
-  pub uuid_idempotency_token: String,
-
-  /// Text prompt to generate the image from.
-  pub prompt: Option<String>,
-
-  /// Image media tokens to include in the editing context.
-  /// If present, we're doing image editing (image-to-image / image-editing)
-  /// If absent, we're doing image generation (text-to-image)
-  pub image_media_tokens: Option<Vec<MediaFileToken>>,
-
-  /// Number of images to generate. Default is one.
-  pub num_images: Option<NanoBananaProMultiFunctionImageGenNumImages>,
-
-  /// Resolution of the image to generate. Default is OneK (1K).
-  pub resolution: Option<NanoBananaProMultiFunctionImageGenImageResolution>,
-
-  /// Aspect ratio of the images to generate. Default is "1:1"
-  pub aspect_ratio: Option<NanoBananaProMultiFunctionImageGenAspectRatio>,
-}
-
-#[derive(Copy, Clone, Debug, Serialize, Deserialize, ToSchema)]
-#[serde(rename_all = "snake_case")]
-pub enum NanoBananaProMultiFunctionImageGenNumImages {
-  One, // Default
-  Two,
-  Three,
-  Four,
-}
-
-#[derive(Copy, Clone, Debug, Serialize, Deserialize, ToSchema)]
-#[serde(rename_all = "snake_case")]
-pub enum NanoBananaProMultiFunctionImageGenImageResolution {
-  OneK,
-  TwoK,
-  FourK,
-}
-
-#[derive(Copy, Clone, Debug, Serialize, Deserialize, ToSchema)]
-#[serde(rename_all = "snake_case")]
-pub enum NanoBananaProMultiFunctionImageGenAspectRatio {
-  // Square
-  OneByOne, // Default
-  // Wide
-  FiveByFour,
-  FourByThree,
-  ThreeByTwo,
-  SixteenByNine,
-  TwentyOneByNine,
-  // Tall
-  FourByFive,
-  ThreeByFour,
-  TwoByThree,
-  NineBySixteen, // NB: No NineByTwentyOne ?
-}
-
-
-#[derive(Serialize, Deserialize, ToSchema)]
-pub struct NanoBananaProMultiFunctionImageGenResponse {
-  pub success: bool,
-  pub inference_job_token: InferenceJobToken,
-}
@@ -1,19 +0,0 @@
-use serde_derive::{Deserialize, Serialize};
-use utoipa::ToSchema;
-use tokens::tokens::media_files::MediaFileToken;
-
-#[derive(Serialize, Deserialize, ToSchema)]
-pub struct DeleteMediaFileRequest {
-  pub set_delete: bool,
-  
-  /// NB: this is only to disambiguate when a user is both a mod and an author.
-  pub as_mod: Option<bool>,
-}
-
-/// For the URL PathInfo
-#[derive(Serialize, Deserialize, ToSchema)]
-pub struct DeleteMediaFilePathInfo {
-  pub token: MediaFileToken,
-}
-
-
@@ -1,12 +0,0 @@
-use crate::common::responses::media_links::MediaLinks;
-
-/// Get the thumbnail template for either images or videos.
-pub fn media_links_to_thumbnail_template(links: &MediaLinks) -> Option<&str> {
-  // NB: We only populate video previews for video tasks.
-  if let Some(video) = links.maybe_video_previews.as_ref() {
-    return Some(&video.animated_thumbnail_template);
-  }
-
-  // Image case - use the image thumbnail template if it exists.
-  links.maybe_thumbnail_template.as_deref()
-}
@@ -1 +0,0 @@
-pub mod media_links_to_thumbnail_template;
@@ -1 +0,0 @@
-pub mod nano_banana_pro_multi_function_image_gen_image;
@@ -1,18 +0,0 @@
-use crate::credentials::storyteller_credential_set::StorytellerCredentialSet;
-use crate::error::storyteller_error::StorytellerError;
-use crate::utils::api_host::ApiHost;
-use crate::utils::basic_json_post_request::basic_json_post_request;
-use artcraft_api_defs::generate::image::multi_function::nano_banana_pro_multi_function_image_gen::{NanoBananaProMultiFunctionImageGenRequest, NanoBananaProMultiFunctionImageGenResponse, NANO_BANANA_PRO_MULTI_FUNCTION_IMAGE_GEN_PATH};
-
-pub async fn nano_banana_pro_multi_function_image_gen(
-  api_host: &ApiHost,
-  maybe_creds: Option<&StorytellerCredentialSet>,
-  request: NanoBananaProMultiFunctionImageGenRequest,
-) -> Result<NanoBananaProMultiFunctionImageGenResponse, StorytellerError> {
-  Ok(basic_json_post_request(
-    api_host,
-    NANO_BANANA_PRO_MULTI_FUNCTION_IMAGE_GEN_PATH,
-    maybe_creds,
-    request,
-  ).await?)
-}
@@ -1,37 +0,0 @@
-use crate::credentials::storyteller_credential_set::StorytellerCredentialSet;
-use crate::error::storyteller_error::StorytellerError;
-use crate::utils::api_host::ApiHost;
-use crate::utils::basic_json_delete_request::basic_json_delete_request;
-use artcraft_api_defs::common::responses::simple_generic_json_success::SimpleGenericJsonSuccess;
-use artcraft_api_defs::media_file::delete_media_file::DeleteMediaFileRequest;
-use artcraft_api_defs::subscriptions::get_session_subscription::GetSessionSubscriptionResponse;
-use enums::common::payments_namespace::PaymentsNamespace;
-use log::debug;
-use tokens::tokens::media_files::MediaFileToken;
-
-pub async fn delete_media_file(
-  api_host: &ApiHost,
-  maybe_creds: Option<&StorytellerCredentialSet>,
-  media_file_token: &MediaFileToken,
-) -> Result<SimpleGenericJsonSuccess, StorytellerError> {
-  let url_path = get_url_path(media_file_token);
-
-  debug!("Requesting {:?}", &url_path);
-  
-  // NB: We probably don't need to expose these options from FakeYou anymore.
-  let request = DeleteMediaFileRequest {
-    set_delete: true,
-    as_mod: None,
-  };
-
-  Ok(basic_json_delete_request(
-    api_host,
-    &url_path,
-    maybe_creds,
-    request,
-  ).await?)
-}
-
-fn get_url_path(token: &MediaFileToken) -> String {
-  format!("/v1/media_files/file/{}", token.as_str())
-}
@@ -1,71 +0,0 @@
-use crate::credentials::storyteller_credential_set::StorytellerCredentialSet;
-use crate::error::api_error::ApiError;
-use crate::error::client_error::ClientError;
-use crate::error::storyteller_error::StorytellerError;
-use crate::utils::api_host::ApiHost;
-use crate::utils::constants::{APPLICATION_JSON, USER_AGENT};
-use crate::utils::filter_bad_response::filter_bad_response;
-use artcraft_api_defs::generate::image::generate_flux_1_schnell_text_to_image::{GenerateFlux1SchnellTextToImageRequest, GenerateFlux1SchnellTextToImageResponse, GENERATE_FLUX_1_SCHNELL_TEXT_TO_IMAGE_PATH};
-use log::{debug, info};
-use reqwest::Client;
-use serde::de::DeserializeOwned;
-use serde::{Deserialize, Serialize};
-
-pub async fn basic_json_delete_request<Req: Serialize, Res: DeserializeOwned>(
-  api_host: &ApiHost,
-  route_path: &str,
-  maybe_creds: Option<&StorytellerCredentialSet>,
-  request: Req,
-) -> Result<Res, StorytellerError> {
-
-  let url = get_route(api_host, route_path);
-
-  info!("DELETE {:?}", &url);
-
-  let client = Client::builder()
-      .gzip(true)
-      .build()
-      .map_err(|err| StorytellerError::Client(ClientError::from(err)))?;
-
-  let mut request_builder = client.delete(url)
-      .header("User-Agent", USER_AGENT)
-      .header("Accept", APPLICATION_JSON)
-      .header("Content-Type", APPLICATION_JSON);
-
-  if let Some(creds) = maybe_creds {
-    if let Some(header) = &creds.maybe_as_cookie_header() {
-      request_builder = request_builder.header("Cookie", header);
-    }
-  }
-
-  let request_body = serde_json::to_string(&request)
-      .map_err(|err| StorytellerError::Client(ClientError::from(err)))?;
-
-  debug!("Request body: {:?}", request_body);
-
-  let response = request_builder
-      .body(request_body)
-      .send()
-      .await
-      .map_err(|err| StorytellerError::Api(ApiError::from(err)))?;
-
-  let response = filter_bad_response(response)
-      .await
-      .map_err(|err| StorytellerError::Api(ApiError::from(err)))?;
-
-  let response_body = &response.text()
-      .await
-      .map_err(|err| StorytellerError::Api(ApiError::from(err)))?;
-
-  debug!("Response body: {:?}", response_body);
-
-  let response = serde_json::from_str(&response_body)
-      .map_err(|err| StorytellerError::Api(ApiError::from(err)))?;
-
-  Ok(response)
-}
-
-fn get_route(api_host: &ApiHost, route_path: &str) -> String {
-  let api_hostname = api_host.to_api_hostname_and_scheme();
-  format!("{}{}", api_hostname, route_path)
-}
@@ -1,9 +0,0 @@
-pub (crate) mod basic_json_delete_request;
-pub (crate) mod basic_json_get_request;
-pub (crate) mod basic_json_post_request;
-pub (crate) mod basic_query_string_post_request;
-pub (crate) mod filter_bad_response;
-pub (crate) mod http_get_anonymous;
-pub mod api_host;
-pub mod constants;
-pub mod status_codes;
@@ -3,5 +3,4 @@ pub mod job_details;
 pub mod media_file_cover_image_details;
 pub mod media_links;
 pub mod simple_entity_stats;
-pub mod simple_generic_json_success;
 pub mod user_details_light;
@@ -5,5 +5,4 @@ pub mod generate_flux_pro_11_text_to_image;
 pub mod generate_flux_pro_11_ultra_text_to_image;
 pub mod generate_gpt_image_1_text_to_image;
 pub mod inpaint;
-pub mod multi_function;
 pub mod remove_image_background;
@@ -6,5 +6,4 @@ pub mod jobs;
 pub mod media_file;
 pub mod prompts;
 pub mod stripe_artcraft;
-pub mod subscriptions;
-pub mod utils;
+pub mod subscriptions;
@@ -1,2 +1 @@
-pub mod delete_media_file;
 pub mod list_batch_generated_media_files;
@@ -36,7 +36,7 @@ env_logger = "0.11.3"
 async-trait = "0.1.75"
 # The "never-encode-slash" feature seems to have been removed:
 # https://github.com/durch/rust-s3/pull/254
-rust-s3 = { version = "0.36.0-beta.2", default-features = false, features = ["fail-on-err", "tags", "tokio-rustls-tls"] }
+rust-s3 = { version = "0.36.0-beta.2" }

 # Runtime
 tokio.workspace = true
@@ -1,143 +0,0 @@
-use crate::creds::fal_api_key::FalApiKey;
-use crate::error::classify_fal_error::classify_fal_error;
-use crate::error::fal_error_plus::FalErrorPlus;
-use fal::endpoints::fal_ai::bytedance::seedream::bytedance_seedream_v4_edit_image::{bytedance_seedream_v4_edit_image, BytedanceSeedreamV4EditImageInput};
-use fal::webhook::WebhookResponse;
-use reqwest::IntoUrl;
-
-pub struct EnqueueBytedanceSeedreamV4EditImageArgs<'a, R: IntoUrl> {
-  // Request required
-  pub prompt: &'a str,
-  pub image_urls: Vec<String>,
-
-  // Optional args
-  pub num_images: Option<EnqueueBytedanceSeedreamV4EditImageNumImages>,
-  pub max_images: Option<EnqueueBytedanceSeedreamV4EditImageMaxImages>,
-  pub image_size: Option<EnqueueBytedanceSeedreamV4EditImageSize>,
-
-  // Fulfillment
-  pub webhook_url: R,
-  pub api_key: &'a FalApiKey,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueBytedanceSeedreamV4EditImageNumImages {
-  One,
-  Two,
-  Three,
-  Four,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueBytedanceSeedreamV4EditImageMaxImages {
-  One,
-  Two,
-  Three,
-  Four,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueBytedanceSeedreamV4EditImageSize {
-  // Square
-  Square,
-  SquareHd,
-  // Tall
-  PortraitFourThree,
-  PortraitSixteenNine,
-  // Wide
-  LandscapeFourThree,
-  LandscapeSixteenNine,
-  // Auto
-  Auto,
-  Auto2k,
-  Auto4k,
-}
-
-pub async fn enqueue_bytedance_seedream_v4_edit_image_webhook<R: IntoUrl>(
-  args: EnqueueBytedanceSeedreamV4EditImageArgs<'_, R>
-) -> Result<WebhookResponse, FalErrorPlus> {
-
-  let num_images = args.num_images
-      .map(|num_images| match num_images {
-        EnqueueBytedanceSeedreamV4EditImageNumImages::One => 1,
-        EnqueueBytedanceSeedreamV4EditImageNumImages::Two => 2,
-        EnqueueBytedanceSeedreamV4EditImageNumImages::Three => 3,
-        EnqueueBytedanceSeedreamV4EditImageNumImages::Four => 4,
-      });
-
-  let max_images = args.max_images
-      .map(|num_images| match num_images {
-        EnqueueBytedanceSeedreamV4EditImageMaxImages::One => 1,
-        EnqueueBytedanceSeedreamV4EditImageMaxImages::Two => 2,
-        EnqueueBytedanceSeedreamV4EditImageMaxImages::Three => 3,
-        EnqueueBytedanceSeedreamV4EditImageMaxImages::Four => 4,
-      });
-
-  let image_size = args.image_size
-      .map(|image_size| match image_size {
-        EnqueueBytedanceSeedreamV4EditImageSize::Square => "square",
-        EnqueueBytedanceSeedreamV4EditImageSize::SquareHd => "square_hd",
-        EnqueueBytedanceSeedreamV4EditImageSize::PortraitFourThree => "portrait_4_3",
-        EnqueueBytedanceSeedreamV4EditImageSize::PortraitSixteenNine => "portrait_16_9",
-        EnqueueBytedanceSeedreamV4EditImageSize::LandscapeFourThree => "landscape_4_3",
-        EnqueueBytedanceSeedreamV4EditImageSize::LandscapeSixteenNine => "landscape_16_9",
-        EnqueueBytedanceSeedreamV4EditImageSize::Auto => "auto",
-        EnqueueBytedanceSeedreamV4EditImageSize::Auto2k => "auto_2K",
-        EnqueueBytedanceSeedreamV4EditImageSize::Auto4k => "auto_4K",
-      })
-      .map(|resolution| resolution.to_string());
-
-  let request = BytedanceSeedreamV4EditImageInput {
-    prompt: args.prompt.to_string(),
-    image_urls: args.image_urls,
-    // Optionals
-    num_images,
-    max_images,
-    image_size,
-    // Constants
-    enhance_prompt_mode: Some("standard".to_string()),
-    enable_safety_checker: Some(false),
-  };
-
-  let result = bytedance_seedream_v4_edit_image(request)
-      .with_api_key(&args.api_key.0)
-      .queue_webhook(args.webhook_url)
-      .await;
-
-  result.map_err(|err| classify_fal_error(err))
-}
-
-#[cfg(test)]
-mod tests {
-  use crate::creds::fal_api_key::FalApiKey;
-  use crate::requests::webhook::image::edit::enqueue_bytedance_seedream_v4_edit_image_webhook::{enqueue_bytedance_seedream_v4_edit_image_webhook, EnqueueBytedanceSeedreamV4EditImageArgs, EnqueueBytedanceSeedreamV4EditImageMaxImages, EnqueueBytedanceSeedreamV4EditImageNumImages, EnqueueBytedanceSeedreamV4EditImageSize};
-  use errors::AnyhowResult;
-  use std::fs::read_to_string;
-  use test_data::web::image_urls::{GHOST_IMAGE_URL, TREX_SKELETON_IMAGE_URL};
-
-  #[tokio::test]
-  #[ignore]
-  async fn test() -> AnyhowResult<()> {
-    // XXX: Don't commit secrets!
-    let secret = read_to_string("/Users/bt/Artcraft/credentials/fal_api_key.txt")?;
-
-    let api_key = FalApiKey::from_str(&secret);
-
-    let args = EnqueueBytedanceSeedreamV4EditImageArgs {
-      image_urls: vec![
-        GHOST_IMAGE_URL.to_string(),
-        TREX_SKELETON_IMAGE_URL.to_string(),
-      ],
-      prompt: "add the ghost to the image of the t-rex skeleton, make it look spooky but friendly",
-      num_images: Some(EnqueueBytedanceSeedreamV4EditImageNumImages::Two),
-      max_images: Some(EnqueueBytedanceSeedreamV4EditImageMaxImages::Two),
-      image_size: Some(EnqueueBytedanceSeedreamV4EditImageSize::Auto2k),
-      api_key: &api_key,
-      webhook_url: "https://example.com/webhook",
-    };
-
-    let result = enqueue_bytedance_seedream_v4_edit_image_webhook(args).await?;
-
-    Ok(())
-  }
-}
@@ -1,142 +0,0 @@
-use crate::creds::fal_api_key::FalApiKey;
-use crate::error::classify_fal_error::classify_fal_error;
-use crate::error::fal_error_plus::FalErrorPlus;
-use fal::endpoints::fal_ai::bytedance::seedream::bytedance_seedream_v4p5_edit_image::{bytedance_seedream_v4p5_edit_image, BytedanceSeedreamV4p5EditImageInput};
-use fal::webhook::WebhookResponse;
-use reqwest::IntoUrl;
-
-pub struct EnqueueBytedanceSeedreamV4p5EditImageArgs<'a, R: IntoUrl> {
-  // Request required
-  pub prompt: &'a str,
-  pub image_urls: Vec<String>,
-
-  // Optional args
-  pub num_images: Option<EnqueueBytedanceSeedreamV4p5EditImageNumImages>,
-  pub max_images: Option<EnqueueBytedanceSeedreamV4p5EditImageMaxImages>,
-  pub image_size: Option<EnqueueBytedanceSeedreamV4p5EditImageSize>,
-
-  // Fulfillment
-  pub webhook_url: R,
-  pub api_key: &'a FalApiKey,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueBytedanceSeedreamV4p5EditImageNumImages {
-  One,
-  Two,
-  Three,
-  Four,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueBytedanceSeedreamV4p5EditImageMaxImages {
-  One,
-  Two,
-  Three,
-  Four,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueBytedanceSeedreamV4p5EditImageSize {
-  // Square
-  Square,
-  SquareHd,
-  // Tall
-  PortraitFourThree,
-  PortraitSixteenNine,
-  // Wide
-  LandscapeFourThree,
-  LandscapeSixteenNine,
-  // Auto
-  Auto2k,
-  Auto4k,
-}
-
-pub async fn enqueue_bytedance_seedream_v4p5_edit_image_webhook<R: IntoUrl>(
-  args: EnqueueBytedanceSeedreamV4p5EditImageArgs<'_, R>
-) -> Result<WebhookResponse, FalErrorPlus> {
-
-  let num_images = args.num_images
-      .map(|num_images| match num_images {
-        EnqueueBytedanceSeedreamV4p5EditImageNumImages::One => 1,
-        EnqueueBytedanceSeedreamV4p5EditImageNumImages::Two => 2,
-        EnqueueBytedanceSeedreamV4p5EditImageNumImages::Three => 3,
-        EnqueueBytedanceSeedreamV4p5EditImageNumImages::Four => 4,
-      });
-
-  let max_images = args.max_images
-      .map(|num_images| match num_images {
-        EnqueueBytedanceSeedreamV4p5EditImageMaxImages::One => 1,
-        EnqueueBytedanceSeedreamV4p5EditImageMaxImages::Two => 2,
-        EnqueueBytedanceSeedreamV4p5EditImageMaxImages::Three => 3,
-        EnqueueBytedanceSeedreamV4p5EditImageMaxImages::Four => 4,
-      });
-
-  let image_size = args.image_size
-      .map(|image_size| match image_size {
-        EnqueueBytedanceSeedreamV4p5EditImageSize::Square => "square",
-        EnqueueBytedanceSeedreamV4p5EditImageSize::SquareHd => "square_hd",
-        EnqueueBytedanceSeedreamV4p5EditImageSize::PortraitFourThree => "portrait_4_3",
-        EnqueueBytedanceSeedreamV4p5EditImageSize::PortraitSixteenNine => "portrait_16_9",
-        EnqueueBytedanceSeedreamV4p5EditImageSize::LandscapeFourThree => "landscape_4_3",
-        EnqueueBytedanceSeedreamV4p5EditImageSize::LandscapeSixteenNine => "landscape_16_9",
-        EnqueueBytedanceSeedreamV4p5EditImageSize::Auto2k => "auto_2K",
-        EnqueueBytedanceSeedreamV4p5EditImageSize::Auto4k => "auto_4K",
-      })
-      .map(|resolution| resolution.to_string());
-
-  let request = BytedanceSeedreamV4p5EditImageInput {
-    prompt: args.prompt.to_string(),
-    image_urls: args.image_urls,
-    // Optionals
-    num_images,
-    max_images,
-    image_size,
-    // Constants
-    enable_safety_checker: Some(false),
-    seed: None,
-  };
-
-  let result = bytedance_seedream_v4p5_edit_image(request)
-      .with_api_key(&args.api_key.0)
-      .queue_webhook(args.webhook_url)
-      .await;
-
-  result.map_err(|err| classify_fal_error(err))
-}
-
-#[cfg(test)]
-mod tests {
-  use crate::creds::fal_api_key::FalApiKey;
-  use crate::requests::webhook::image::edit::enqueue_bytedance_seedream_v4p5_edit_image_webhook::{enqueue_bytedance_seedream_v4p5_edit_image_webhook, EnqueueBytedanceSeedreamV4p5EditImageArgs, EnqueueBytedanceSeedreamV4p5EditImageMaxImages, EnqueueBytedanceSeedreamV4p5EditImageNumImages, EnqueueBytedanceSeedreamV4p5EditImageSize};
-  use errors::AnyhowResult;
-  use std::fs::read_to_string;
-  use test_data::web::image_urls::{GHOST_IMAGE_URL, TREX_SKELETON_IMAGE_URL};
-
-  #[tokio::test]
-  #[ignore]
-  async fn test() -> AnyhowResult<()> {
-    // XXX: Don't commit secrets!
-    //let secret = read_to_string("/Users/bt/Artcraft/credentials/fal_api_key.txt")?;
-    let secret = read_to_string("/home/bt/Artcraft/credentials/fal_api_key.txt")?;
-
-    let api_key = FalApiKey::from_str(&secret);
-
-    let args = EnqueueBytedanceSeedreamV4p5EditImageArgs {
-      image_urls: vec![
-        GHOST_IMAGE_URL.to_string(),
-        TREX_SKELETON_IMAGE_URL.to_string(),
-      ],
-      prompt: "add the ghost to the image of the t-rex skeleton, make it look spooky but friendly",
-      num_images: Some(EnqueueBytedanceSeedreamV4p5EditImageNumImages::Two),
-      max_images: Some(EnqueueBytedanceSeedreamV4p5EditImageMaxImages::Two),
-      image_size: Some(EnqueueBytedanceSeedreamV4p5EditImageSize::Auto2k),
-      api_key: &api_key,
-      webhook_url: "https://example.com/webhook",
-    };
-
-    let result = enqueue_bytedance_seedream_v4p5_edit_image_webhook(args).await?;
-
-    Ok(())
-  }
-}
@@ -1,147 +0,0 @@
-use crate::creds::fal_api_key::FalApiKey;
-use crate::error::classify_fal_error::classify_fal_error;
-use crate::error::fal_error_plus::FalErrorPlus;
-use fal::endpoints::fal_ai::nano_banana_pro::nano_banana_pro_image_edit::{nano_banana_pro_image_edit, NanoBananaProImageEditInput};
-use fal::webhook::WebhookResponse;
-use reqwest::IntoUrl;
-
-pub struct EnqueueNanoBananaProEditImageArgs<'a, R: IntoUrl> {
-  // Request required
-  pub prompt: &'a str,
-  pub image_urls: Vec<String>,
-  pub num_images: EnqueueNanoBananaProEditImageNumImages,
-
-  // Optional args
-  pub resolution: Option<EnqueueNanoBananaProEditImageResolution>,
-  pub aspect_ratio: Option<EnqueueNanoBananaProEditImageAspectRatio>,
-
-  // Fulfillment
-  pub webhook_url: R,
-  pub api_key: &'a FalApiKey,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueNanoBananaProEditImageNumImages {
-  One,
-  Two,
-  Three,
-  Four,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueNanoBananaProEditImageResolution {
-  OneK,
-  TwoK,
-  FourK,
-}
-
-/// 21:9, 16:9, 3:2, 4:3, 5:4, 1:1, 4:5, 3:4, 2:3, 9:16
-/// Default is "1:1"
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueNanoBananaProEditImageAspectRatio {
-  // Square
-  OneByOne,
-  // Wide
-  FiveByFour,
-  FourByThree,
-  ThreeByTwo,
-  SixteenByNine,
-  TwentyOneByNine,
-  // Tall
-  FourByFive,
-  ThreeByFour,
-  TwoByThree,
-  NineBySixteen, // NB: No NineByTwentyOne ?
-}
-
-pub async fn enqueue_nano_banana_pro_image_edit_webhook<R: IntoUrl>(
-  args: EnqueueNanoBananaProEditImageArgs<'_, R>
-) -> Result<WebhookResponse, FalErrorPlus> {
-
-  let num_images = match args.num_images {
-    EnqueueNanoBananaProEditImageNumImages::One => 1,
-    EnqueueNanoBananaProEditImageNumImages::Two => 2,
-    EnqueueNanoBananaProEditImageNumImages::Three => 3,
-    EnqueueNanoBananaProEditImageNumImages::Four => 4,
-  };
-
-  let resolution = args.resolution
-      .map(|resolution| match resolution {
-        EnqueueNanoBananaProEditImageResolution::OneK => "1K",
-        EnqueueNanoBananaProEditImageResolution::TwoK => "2K",
-        EnqueueNanoBananaProEditImageResolution::FourK => "4K",
-      })
-      .map(|resolution| resolution.to_string());
-
-  let aspect_ratio = args.aspect_ratio
-      .map(|aspect_ratio| match aspect_ratio {
-        // Square
-        EnqueueNanoBananaProEditImageAspectRatio::OneByOne => "1:1",
-        // Wide
-        EnqueueNanoBananaProEditImageAspectRatio::FiveByFour => "5:4",
-        EnqueueNanoBananaProEditImageAspectRatio::FourByThree => "4:3",
-        EnqueueNanoBananaProEditImageAspectRatio::ThreeByTwo => "3:2",
-        EnqueueNanoBananaProEditImageAspectRatio::SixteenByNine => "16:9",
-        EnqueueNanoBananaProEditImageAspectRatio::TwentyOneByNine => "21:9",
-        // Tall
-        EnqueueNanoBananaProEditImageAspectRatio::FourByFive => "4:5",
-        EnqueueNanoBananaProEditImageAspectRatio::ThreeByFour => "3:4",
-        EnqueueNanoBananaProEditImageAspectRatio::TwoByThree => "2:3",
-        EnqueueNanoBananaProEditImageAspectRatio::NineBySixteen => "9:16",
-      })
-      .map(|aspect_ratio| aspect_ratio.to_string());
-
-  let request = NanoBananaProImageEditInput {
-    prompt: args.prompt.to_string(),
-    image_urls: args.image_urls,
-    num_images: Some(num_images),
-    // Optionals
-    aspect_ratio,
-    resolution,
-    // Constants
-    output_format: Some("png".to_string()),
-  };
-
-  let result = nano_banana_pro_image_edit(request)
-      .with_api_key(&args.api_key.0)
-      .queue_webhook(args.webhook_url)
-      .await;
-
-  result.map_err(|err| classify_fal_error(err))
-}
-
-#[cfg(test)]
-mod tests {
-  use crate::creds::fal_api_key::FalApiKey;
-  use crate::requests::webhook::image::edit::enqueue_nano_banana_pro_edit_image_webhook::{enqueue_nano_banana_pro_image_edit_webhook, EnqueueNanoBananaProEditImageArgs, EnqueueNanoBananaProEditImageAspectRatio, EnqueueNanoBananaProEditImageNumImages, EnqueueNanoBananaProEditImageResolution};
-  use errors::AnyhowResult;
-  use std::fs::read_to_string;
-  use test_data::web::image_urls::{ERNEST_SCARED_STUPID_IMAGE_URL, GHOST_IMAGE_URL, TREX_SKELETON_IMAGE_URL};
-
-  #[tokio::test]
-  #[ignore]
-  async fn test() -> AnyhowResult<()> {
-    // XXX: Don't commit secrets!
-    let secret = read_to_string("/Users/bt/Artcraft/credentials/fal_api_key.txt")?;
-
-    let api_key = FalApiKey::from_str(&secret);
-
-    let args = EnqueueNanoBananaProEditImageArgs {
-      image_urls: vec![
-        GHOST_IMAGE_URL.to_string(),
-        TREX_SKELETON_IMAGE_URL.to_string(),
-        ERNEST_SCARED_STUPID_IMAGE_URL.to_string(),
-      ],
-      prompt: "add the ghost and scared man to the image of the t-rex skeleton, make it look spooky but friendly",
-      num_images: EnqueueNanoBananaProEditImageNumImages::Two,
-      aspect_ratio: Some(EnqueueNanoBananaProEditImageAspectRatio::SixteenByNine),
-      resolution: Some(EnqueueNanoBananaProEditImageResolution::TwoK),
-      api_key: &api_key,
-      webhook_url: "https://example.com/webhook",
-    };
-
-    let result = enqueue_nano_banana_pro_image_edit_webhook(args).await?;
-
-    Ok(())
-  }
-}
@@ -1,8 +1,5 @@
-pub mod enqueue_bytedance_seedream_v4_edit_image_webhook;
-pub mod enqueue_bytedance_seedream_v4p5_edit_image_webhook;
 pub mod enqueue_flux_pro_kontext_max_edit_webhook;
 pub mod enqueue_gemini_25_flash_edit_webhook;
 pub mod enqueue_gpt_image_1_edit_image_webhook;
-pub mod enqueue_nano_banana_pro_edit_image_webhook;
 pub mod enqueue_qwen_image_edit_webhook;
 pub mod enqueue_seededit_v3_edit_webhook;
@@ -6,4 +6,3 @@ pub mod enqueue_flux_pro_11_ultra_text_to_image_webhook;
 pub mod enqueue_gpt_image_1_text_to_image_webhook;
 pub mod infill;
 pub mod remove_background_rembg_webhook;
-pub mod text;
@@ -1,137 +0,0 @@
-use crate::creds::fal_api_key::FalApiKey;
-use crate::error::classify_fal_error::classify_fal_error;
-use crate::error::fal_error_plus::FalErrorPlus;
-use fal::endpoints::fal_ai::bytedance::seedream::bytedance_seedream_v4_text_to_image::BytedanceSeedreamV4TextToImageInput;
-use fal::prelude::fal_ai::bytedance::seedream::bytedance_seedream_v4_text_to_image::bytedance_seedream_v4_text_to_image;
-use fal::webhook::WebhookResponse;
-use reqwest::IntoUrl;
-
-pub struct EnqueueBytedanceSeedreamV4TextToImageArgs<'a, R: IntoUrl> {
-  // Request required
-  pub prompt: &'a str,
-
-  // Optional args
-  pub num_images: Option<EnqueueBytedanceSeedreamV4TextToImageNumImages>,
-  pub max_images: Option<EnqueueBytedanceSeedreamV4TextToImageMaxImages>,
-  pub image_size: Option<EnqueueBytedanceSeedreamV4TextToImageSize>,
-
-  // Fulfillment
-  pub webhook_url: R,
-  pub api_key: &'a FalApiKey,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueBytedanceSeedreamV4TextToImageNumImages {
-  One,
-  Two,
-  Three,
-  Four,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueBytedanceSeedreamV4TextToImageMaxImages {
-  One,
-  Two,
-  Three,
-  Four,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueBytedanceSeedreamV4TextToImageSize {
-  // Square
-  Square,
-  SquareHd,
-  // Tall
-  PortraitFourThree,
-  PortraitSixteenNine,
-  // Wide
-  LandscapeFourThree,
-  LandscapeSixteenNine,
-  // Auto
-  Auto,
-  Auto2k,
-  Auto4k,
-}
-
-pub async fn enqueue_bytedance_seedream_v4_text_to_image_webhook<R: IntoUrl>(
-  args: EnqueueBytedanceSeedreamV4TextToImageArgs<'_, R>
-) -> Result<WebhookResponse, FalErrorPlus> {
-
-  let num_images = args.num_images
-      .map(|num_images| match num_images {
-        EnqueueBytedanceSeedreamV4TextToImageNumImages::One => 1,
-        EnqueueBytedanceSeedreamV4TextToImageNumImages::Two => 2,
-        EnqueueBytedanceSeedreamV4TextToImageNumImages::Three => 3,
-        EnqueueBytedanceSeedreamV4TextToImageNumImages::Four => 4,
-      });
-
-  let max_images = args.max_images
-      .map(|num_images| match num_images {
-        EnqueueBytedanceSeedreamV4TextToImageMaxImages::One => 1,
-        EnqueueBytedanceSeedreamV4TextToImageMaxImages::Two => 2,
-        EnqueueBytedanceSeedreamV4TextToImageMaxImages::Three => 3,
-        EnqueueBytedanceSeedreamV4TextToImageMaxImages::Four => 4,
-      });
-
-  let image_size = args.image_size
-      .map(|image_size| match image_size {
-        EnqueueBytedanceSeedreamV4TextToImageSize::Square => "square",
-        EnqueueBytedanceSeedreamV4TextToImageSize::SquareHd => "square_hd",
-        EnqueueBytedanceSeedreamV4TextToImageSize::PortraitFourThree => "portrait_4_3",
-        EnqueueBytedanceSeedreamV4TextToImageSize::PortraitSixteenNine => "portrait_16_9",
-        EnqueueBytedanceSeedreamV4TextToImageSize::LandscapeFourThree => "landscape_4_3",
-        EnqueueBytedanceSeedreamV4TextToImageSize::LandscapeSixteenNine => "landscape_16_9",
-        EnqueueBytedanceSeedreamV4TextToImageSize::Auto => "auto",
-        EnqueueBytedanceSeedreamV4TextToImageSize::Auto2k => "auto_2K",
-        EnqueueBytedanceSeedreamV4TextToImageSize::Auto4k => "auto_4K",
-      })
-      .map(|resolution| resolution.to_string());
-
-  let request = BytedanceSeedreamV4TextToImageInput {
-    prompt: args.prompt.to_string(),
-    // Optionals
-    num_images,
-    max_images,
-    image_size,
-    // Constants
-    enhance_prompt_mode: Some("standard".to_string()),
-    enable_safety_checker: Some(false),
-  };
-
-  let result = bytedance_seedream_v4_text_to_image(request)
-      .with_api_key(&args.api_key.0)
-      .queue_webhook(args.webhook_url)
-      .await;
-
-  result.map_err(|err| classify_fal_error(err))
-}
-
-#[cfg(test)]
-mod tests {
-  use crate::creds::fal_api_key::FalApiKey;
-  use crate::requests::webhook::image::text::enqueue_bytedance_seedream_v4_text_to_image_webhook::{enqueue_bytedance_seedream_v4_text_to_image_webhook, EnqueueBytedanceSeedreamV4TextToImageArgs, EnqueueBytedanceSeedreamV4TextToImageMaxImages, EnqueueBytedanceSeedreamV4TextToImageNumImages, EnqueueBytedanceSeedreamV4TextToImageSize};
-  use errors::AnyhowResult;
-  use std::fs::read_to_string;
-
-  #[tokio::test]
-  #[ignore]
-  async fn test() -> AnyhowResult<()> {
-    // XXX: Don't commit secrets!
-    let secret = read_to_string("/Users/bt/Artcraft/credentials/fal_api_key.txt")?;
-
-    let api_key = FalApiKey::from_str(&secret);
-
-    let args = EnqueueBytedanceSeedreamV4TextToImageArgs {
-      prompt: "an anime girl is riding a t-rex in the forest",
-      num_images: Some(EnqueueBytedanceSeedreamV4TextToImageNumImages::Two),
-      max_images: Some(EnqueueBytedanceSeedreamV4TextToImageMaxImages::Two),
-      image_size: Some(EnqueueBytedanceSeedreamV4TextToImageSize::LandscapeSixteenNine),
-      api_key: &api_key,
-      webhook_url: "https://example.com/webhook",
-    };
-
-    let result = enqueue_bytedance_seedream_v4_text_to_image_webhook(args).await?;
-
-    Ok(())
-  }
-}
@@ -1,134 +0,0 @@
-use crate::creds::fal_api_key::FalApiKey;
-use crate::error::classify_fal_error::classify_fal_error;
-use crate::error::fal_error_plus::FalErrorPlus;
-use fal::endpoints::fal_ai::bytedance::seedream::bytedance_seedream_v4p5_text_to_image::{bytedance_seedream_v4p5_text_to_image, BytedanceSeedreamV4p5TextToImageInput};
-use fal::webhook::WebhookResponse;
-use reqwest::IntoUrl;
-
-pub struct EnqueueBytedanceSeedreamV4p5TextToImageArgs<'a, R: IntoUrl> {
-  // Request required
-  pub prompt: &'a str,
-
-  // Optional args
-  pub num_images: Option<EnqueueBytedanceSeedreamV4p5TextToImageNumImages>,
-  pub max_images: Option<EnqueueBytedanceSeedreamV4p5TextToImageMaxImages>,
-  pub image_size: Option<EnqueueBytedanceSeedreamV4p5TextToImageSize>,
-
-  // Fulfillment
-  pub webhook_url: R,
-  pub api_key: &'a FalApiKey,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueBytedanceSeedreamV4p5TextToImageNumImages {
-  One,
-  Two,
-  Three,
-  Four,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueBytedanceSeedreamV4p5TextToImageMaxImages {
-  One,
-  Two,
-  Three,
-  Four,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueBytedanceSeedreamV4p5TextToImageSize {
-  // Square
-  Square,
-  SquareHd,
-  // Tall
-  PortraitFourThree,
-  PortraitSixteenNine,
-  // Wide
-  LandscapeFourThree,
-  LandscapeSixteenNine,
-  // Auto
-  Auto2k,
-  Auto4k,
-}
-
-pub async fn enqueue_bytedance_seedream_v4p5_text_to_image_webhook<R: IntoUrl>(
-  args: EnqueueBytedanceSeedreamV4p5TextToImageArgs<'_, R>
-) -> Result<WebhookResponse, FalErrorPlus> {
-
-  let num_images = args.num_images
-      .map(|num_images| match num_images {
-        EnqueueBytedanceSeedreamV4p5TextToImageNumImages::One => 1,
-        EnqueueBytedanceSeedreamV4p5TextToImageNumImages::Two => 2,
-        EnqueueBytedanceSeedreamV4p5TextToImageNumImages::Three => 3,
-        EnqueueBytedanceSeedreamV4p5TextToImageNumImages::Four => 4,
-      });
-
-  let max_images = args.max_images
-      .map(|num_images| match num_images {
-        EnqueueBytedanceSeedreamV4p5TextToImageMaxImages::One => 1,
-        EnqueueBytedanceSeedreamV4p5TextToImageMaxImages::Two => 2,
-        EnqueueBytedanceSeedreamV4p5TextToImageMaxImages::Three => 3,
-        EnqueueBytedanceSeedreamV4p5TextToImageMaxImages::Four => 4,
-      });
-
-  let image_size = args.image_size
-      .map(|image_size| match image_size {
-        EnqueueBytedanceSeedreamV4p5TextToImageSize::Square => "square",
-        EnqueueBytedanceSeedreamV4p5TextToImageSize::SquareHd => "square_hd",
-        EnqueueBytedanceSeedreamV4p5TextToImageSize::PortraitFourThree => "portrait_4_3",
-        EnqueueBytedanceSeedreamV4p5TextToImageSize::PortraitSixteenNine => "portrait_16_9",
-        EnqueueBytedanceSeedreamV4p5TextToImageSize::LandscapeFourThree => "landscape_4_3",
-        EnqueueBytedanceSeedreamV4p5TextToImageSize::LandscapeSixteenNine => "landscape_16_9",
-        EnqueueBytedanceSeedreamV4p5TextToImageSize::Auto2k => "auto_2K",
-        EnqueueBytedanceSeedreamV4p5TextToImageSize::Auto4k => "auto_4K",
-      })
-      .map(|resolution| resolution.to_string());
-
-  let request = BytedanceSeedreamV4p5TextToImageInput {
-    prompt: args.prompt.to_string(),
-    // Optionals
-    num_images,
-    max_images,
-    image_size,
-    // Constants
-    enable_safety_checker: Some(false),
-    seed: None,
-  };
-
-  let result = bytedance_seedream_v4p5_text_to_image(request)
-      .with_api_key(&args.api_key.0)
-      .queue_webhook(args.webhook_url)
-      .await;
-
-  result.map_err(|err| classify_fal_error(err))
-}
-
-#[cfg(test)]
-mod tests {
-  use crate::creds::fal_api_key::FalApiKey;
-  use crate::requests::webhook::image::text::enqueue_bytedance_seedream_v4p5_text_to_image_webhook::{enqueue_bytedance_seedream_v4p5_text_to_image_webhook, EnqueueBytedanceSeedreamV4p5TextToImageArgs, EnqueueBytedanceSeedreamV4p5TextToImageMaxImages, EnqueueBytedanceSeedreamV4p5TextToImageNumImages, EnqueueBytedanceSeedreamV4p5TextToImageSize};
-  use errors::AnyhowResult;
-  use std::fs::read_to_string;
-
-  #[tokio::test]
-  #[ignore]
-  async fn test() -> AnyhowResult<()> {
-    // XXX: Don't commit secrets!
-    let secret = read_to_string("/home/bt/Artcraft/credentials/fal_api_key.txt")?;
-
-    let api_key = FalApiKey::from_str(&secret);
-
-    let args = EnqueueBytedanceSeedreamV4p5TextToImageArgs {
-      prompt: "an anime girl is riding a t-rex in the forest",
-      num_images: Some(EnqueueBytedanceSeedreamV4p5TextToImageNumImages::Two),
-      max_images: Some(EnqueueBytedanceSeedreamV4p5TextToImageMaxImages::Two),
-      image_size: Some(EnqueueBytedanceSeedreamV4p5TextToImageSize::LandscapeSixteenNine),
-      api_key: &api_key,
-      webhook_url: "https://example.com/webhook",
-    };
-
-    let result = enqueue_bytedance_seedream_v4p5_text_to_image_webhook(args).await?;
-
-    Ok(())
-  }
-}
@@ -1,139 +0,0 @@
-use crate::creds::fal_api_key::FalApiKey;
-use crate::error::classify_fal_error::classify_fal_error;
-use crate::error::fal_error_plus::FalErrorPlus;
-use fal::endpoints::fal_ai::nano_banana_pro::nano_banana_pro_text_to_image::{nano_banana_pro_text_to_image, NanoBananaProTextToImageInput};
-use fal::webhook::WebhookResponse;
-use reqwest::IntoUrl;
-
-pub struct EnqueueNanoBananaProTextToImageArgs<'a, R: IntoUrl> {
-  // Request required
-  pub prompt: &'a str,
-  pub num_images: EnqueueNanoBananaProTextToImageNumImages,
-
-  // Optional args
-  pub resolution: Option<EnqueueNanoBananaProTextToImageResolution>,
-  pub aspect_ratio: Option<EnqueueNanoBananaProTextToImageAspectRatio>,
-
-  // Fulfillment
-  pub webhook_url: R,
-  pub api_key: &'a FalApiKey,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueNanoBananaProTextToImageNumImages {
-  One,
-  Two,
-  Three,
-  Four,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueNanoBananaProTextToImageResolution {
-  OneK,
-  TwoK,
-  FourK,
-}
-
-/// 21:9, 16:9, 3:2, 4:3, 5:4, 1:1, 4:5, 3:4, 2:3, 9:16
-/// Default is "1:1"
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueNanoBananaProTextToImageAspectRatio {
-  // Square
-  OneByOne,
-  // Wide
-  FiveByFour,
-  FourByThree,
-  ThreeByTwo,
-  SixteenByNine,
-  TwentyOneByNine,
-  // Tall
-  FourByFive,
-  ThreeByFour,
-  TwoByThree,
-  NineBySixteen, // NB: No NineByTwentyOne ?
-}
-
-pub async fn enqueue_nano_banana_pro_text_to_image_webhook<R: IntoUrl>(
-  args: EnqueueNanoBananaProTextToImageArgs<'_, R>
-) -> Result<WebhookResponse, FalErrorPlus> {
-
-  let num_images = match args.num_images {
-    EnqueueNanoBananaProTextToImageNumImages::One => 1,
-    EnqueueNanoBananaProTextToImageNumImages::Two => 2,
-    EnqueueNanoBananaProTextToImageNumImages::Three => 3,
-    EnqueueNanoBananaProTextToImageNumImages::Four => 4,
-  };
-
-  let resolution = args.resolution
-      .map(|resolution| match resolution {
-        EnqueueNanoBananaProTextToImageResolution::OneK => "1K",
-        EnqueueNanoBananaProTextToImageResolution::TwoK => "2K",
-        EnqueueNanoBananaProTextToImageResolution::FourK => "4K",
-      })
-      .map(|resolution| resolution.to_string());
-
-  let aspect_ratio = args.aspect_ratio
-      .map(|aspect_ratio| match aspect_ratio {
-        // Square
-        EnqueueNanoBananaProTextToImageAspectRatio::OneByOne => "1:1",
-        // Wide
-        EnqueueNanoBananaProTextToImageAspectRatio::FiveByFour => "5:4",
-        EnqueueNanoBananaProTextToImageAspectRatio::FourByThree => "4:3",
-        EnqueueNanoBananaProTextToImageAspectRatio::ThreeByTwo => "3:2",
-        EnqueueNanoBananaProTextToImageAspectRatio::SixteenByNine => "16:9",
-        EnqueueNanoBananaProTextToImageAspectRatio::TwentyOneByNine => "21:9",
-        // Tall
-        EnqueueNanoBananaProTextToImageAspectRatio::FourByFive => "4:5",
-        EnqueueNanoBananaProTextToImageAspectRatio::ThreeByFour => "3:4",
-        EnqueueNanoBananaProTextToImageAspectRatio::TwoByThree => "2:3",
-        EnqueueNanoBananaProTextToImageAspectRatio::NineBySixteen => "9:16",
-      })
-      .map(|aspect_ratio| aspect_ratio.to_string());
-
-  let request = NanoBananaProTextToImageInput {
-    prompt: args.prompt.to_string(),
-    num_images: Some(num_images),
-    // Optionals
-    aspect_ratio,
-    resolution,
-    // Constants
-    output_format: Some("png".to_string()),
-  };
-
-  let result = nano_banana_pro_text_to_image(request)
-      .with_api_key(&args.api_key.0)
-      .queue_webhook(args.webhook_url)
-      .await;
-
-  result.map_err(|err| classify_fal_error(err))
-}
-
-#[cfg(test)]
-mod tests {
-  use crate::creds::fal_api_key::FalApiKey;
-  use crate::requests::webhook::image::text::enqueue_nano_banana_pro_text_to_image_webhook::{enqueue_nano_banana_pro_text_to_image_webhook, EnqueueNanoBananaProTextToImageArgs, EnqueueNanoBananaProTextToImageAspectRatio, EnqueueNanoBananaProTextToImageNumImages, EnqueueNanoBananaProTextToImageResolution};
-  use errors::AnyhowResult;
-  use std::fs::read_to_string;
-
-  #[tokio::test]
-  #[ignore]
-  async fn test() -> AnyhowResult<()> {
-    // XXX: Don't commit secrets!
-    let secret = read_to_string("/Users/bt/Artcraft/credentials/fal_api_key.txt")?;
-
-    let api_key = FalApiKey::from_str(&secret);
-
-    let args = EnqueueNanoBananaProTextToImageArgs {
-      prompt: "an anime girl riding on the back of a t-rex",
-      num_images: EnqueueNanoBananaProTextToImageNumImages::One,
-      aspect_ratio: Some(EnqueueNanoBananaProTextToImageAspectRatio::SixteenByNine),
-      resolution: Some(EnqueueNanoBananaProTextToImageResolution::TwoK),
-      api_key: &api_key,
-      webhook_url: "https://example.com/webhook",
-    };
-
-    let result = enqueue_nano_banana_pro_text_to_image_webhook(args).await?;
-
-    Ok(())
-  }
-}
@@ -1,3 +0,0 @@
-pub mod enqueue_bytedance_seedream_v4_text_to_image_webhook;
-pub mod enqueue_bytedance_seedream_v4p5_text_to_image_webhook;
-pub mod enqueue_nano_banana_pro_text_to_image_webhook;
@@ -1,70 +0,0 @@
-use crate::creds::fal_api_key::FalApiKey;
-use crate::error::classify_fal_error::classify_fal_error;
-use crate::error::fal_error_plus::FalErrorPlus;
-use fal::endpoints::fal_ai::minimax::hailuo::hailuo_v2p3_fast_pro_image_to_video::{hailuo_v2p3_fast_pro_image_to_video, HailuoV2p3FastProImageToVideoInput};
-use fal::webhook::WebhookResponse;
-use reqwest::IntoUrl;
-
-pub struct EnqueueHailuoV2p3FastProImageToVideoArgs<'a, R: IntoUrl> {
-  // Request required
-  pub prompt: String,
-  pub image_url: String,
-
-  // Optional args
-  pub prompt_optimizer: Option<bool>,
-
-  // Fulfillment
-  pub webhook_url: R,
-  pub api_key: &'a FalApiKey,
-}
-
-pub async fn enqueue_hailuo_v2p3_fast_pro_image_to_video_webhook<R: IntoUrl>(
-  args: EnqueueHailuoV2p3FastProImageToVideoArgs<'_, R>
-) -> Result<WebhookResponse, FalErrorPlus> {
-
-  let prompt_optimizer = args.prompt_optimizer.unwrap_or(true);
-
-  let request = HailuoV2p3FastProImageToVideoInput {
-    prompt: args.prompt,
-    image_url: args.image_url,
-    // Optionals
-    prompt_optimizer: Some(prompt_optimizer),
-  };
-
-  let result = hailuo_v2p3_fast_pro_image_to_video(request)
-      .with_api_key(&args.api_key.0)
-      .queue_webhook(args.webhook_url)
-      .await;
-
-  result.map_err(|err| classify_fal_error(err))
-}
-
-#[cfg(test)]
-mod tests {
-  use crate::creds::fal_api_key::FalApiKey;
-  use crate::requests::webhook::video::image::enqueue_hailuo_v2p3_fast_pro_image_to_video_webhook::{enqueue_hailuo_v2p3_fast_pro_image_to_video_webhook, EnqueueHailuoV2p3FastProImageToVideoArgs};
-  use errors::AnyhowResult;
-  use std::fs::read_to_string;
-  use test_data::web::image_urls::TREX_SKELETON_IMAGE_URL;
-
-  #[tokio::test]
-  #[ignore]
-  async fn test() -> AnyhowResult<()> {
-    // XXX: Don't commit secrets!
-    let secret = read_to_string("/home/bt/Artcraft/credentials/fal_api_key.txt")?;
-
-    let api_key = FalApiKey::from_str(&secret);
-
-    let args = EnqueueHailuoV2p3FastProImageToVideoArgs {
-      image_url: TREX_SKELETON_IMAGE_URL.to_string(),
-      prompt: "the t-rex skeleton gets off the podium and begins walking to the camera. the camera orbits slightly. The t-rex gets close and then bites.".to_string(),
-      prompt_optimizer: Some(true),
-      api_key: &api_key,
-      webhook_url: "https://example.com/webhook",
-    };
-
-    let result = enqueue_hailuo_v2p3_fast_pro_image_to_video_webhook(args).await?;
-
-    Ok(())
-  }
-}
@@ -1,70 +0,0 @@
-use crate::creds::fal_api_key::FalApiKey;
-use crate::error::classify_fal_error::classify_fal_error;
-use crate::error::fal_error_plus::FalErrorPlus;
-use fal::endpoints::fal_ai::minimax::hailuo::hailuo_v2p3_pro_image_to_video::{hailuo_v2p3_pro_image_to_video, HailuoV2p3ProImageToVideoInput};
-use fal::webhook::WebhookResponse;
-use reqwest::IntoUrl;
-
-pub struct EnqueueHailuoV2p3ProImageToVideoArgs<'a, R: IntoUrl> {
-  // Request required
-  pub prompt: String,
-  pub image_url: String,
-
-  // Optional args
-  pub prompt_optimizer: Option<bool>,
-
-  // Fulfillment
-  pub webhook_url: R,
-  pub api_key: &'a FalApiKey,
-}
-
-pub async fn enqueue_hailuo_v2p3_pro_image_to_video_webhook<R: IntoUrl>(
-  args: EnqueueHailuoV2p3ProImageToVideoArgs<'_, R>
-) -> Result<WebhookResponse, FalErrorPlus> {
-
-  let prompt_optimizer = args.prompt_optimizer.unwrap_or(true);
-
-  let request = HailuoV2p3ProImageToVideoInput {
-    prompt: args.prompt,
-    image_url: args.image_url,
-    // Optionals
-    prompt_optimizer: Some(prompt_optimizer),
-  };
-
-  let result = hailuo_v2p3_pro_image_to_video(request)
-      .with_api_key(&args.api_key.0)
-      .queue_webhook(args.webhook_url)
-      .await;
-
-  result.map_err(|err| classify_fal_error(err))
-}
-
-#[cfg(test)]
-mod tests {
-  use crate::creds::fal_api_key::FalApiKey;
-  use crate::requests::webhook::video::image::enqueue_hailuo_v2p3_pro_image_to_video_webhook::{enqueue_hailuo_v2p3_pro_image_to_video_webhook, EnqueueHailuoV2p3ProImageToVideoArgs};
-  use errors::AnyhowResult;
-  use std::fs::read_to_string;
-  use test_data::web::image_urls::TREX_SKELETON_IMAGE_URL;
-
-  #[tokio::test]
-  #[ignore]
-  async fn test() -> AnyhowResult<()> {
-    // XXX: Don't commit secrets!
-    let secret = read_to_string("/home/bt/Artcraft/credentials/fal_api_key.txt")?;
-
-    let api_key = FalApiKey::from_str(&secret);
-
-    let args = EnqueueHailuoV2p3ProImageToVideoArgs {
-      image_url: TREX_SKELETON_IMAGE_URL.to_string(),
-      prompt: "the t-rex skeleton gets off the podium and begins walking to the camera. the camera orbits slightly. The t-rex gets close and then bites.".to_string(),
-      prompt_optimizer: Some(true),
-      api_key: &api_key,
-      webhook_url: "https://example.com/webhook",
-    };
-
-    let result = enqueue_hailuo_v2p3_pro_image_to_video_webhook(args).await?;
-
-    Ok(())
-  }
-}
@@ -1,90 +0,0 @@
-use crate::creds::fal_api_key::FalApiKey;
-use crate::error::classify_fal_error::classify_fal_error;
-use crate::error::fal_error_plus::FalErrorPlus;
-use fal::endpoints::fal_ai::kling_video::v2_5::kling_v2p5_turbo_pro_image_to_video::{kling_v2p5_turbo_pro_image_to_video, KlingV2p5TurboProImageToVideoInput};
-use fal::webhook::WebhookResponse;
-use reqwest::IntoUrl;
-
-pub struct EnqueueKlingV2p5TurboProImageToVideoArgs<'a, R: IntoUrl> {
-  // Request required
-  pub prompt: String,
-  pub image_url: String,
-
-  // Optional args
-  pub tail_image_url: Option<String>,
-  pub negative_prompt: Option<String>,
-
-  pub duration: Option<EnqueueKlingV2p5TurboProImageToVideoDurationSeconds>,
-
-  // Fulfillment
-  pub webhook_url: R,
-  pub api_key: &'a FalApiKey,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueKlingV2p5TurboProImageToVideoDurationSeconds {
-  Five,
-  Ten,
-}
-
-pub async fn enqueue_kling_v2p5_turbo_pro_image_to_video_webhook<R: IntoUrl>(
-  args: EnqueueKlingV2p5TurboProImageToVideoArgs<'_, R>
-) -> Result<WebhookResponse, FalErrorPlus> {
-
-  let duration = args.duration
-      .map(|resolution| match resolution {
-        EnqueueKlingV2p5TurboProImageToVideoDurationSeconds::Five => "5",
-        EnqueueKlingV2p5TurboProImageToVideoDurationSeconds::Ten => "10",
-      })
-      .map(|resolution| resolution.to_string());
-
-  let request = KlingV2p5TurboProImageToVideoInput {
-    prompt: args.prompt,
-    image_url: args.image_url,
-    // Optionals
-    duration,
-    tail_image_url: args.tail_image_url,
-    negative_prompt: args.negative_prompt,
-    // Constants
-    cfg_scale: None,
-  };
-
-  let result = kling_v2p5_turbo_pro_image_to_video(request)
-      .with_api_key(&args.api_key.0)
-      .queue_webhook(args.webhook_url)
-      .await;
-
-  result.map_err(|err| classify_fal_error(err))
-}
-
-#[cfg(test)]
-mod tests {
-  use crate::creds::fal_api_key::FalApiKey;
-  use crate::requests::webhook::video::image::enqueue_kling_v2p5_turbo_pro_image_to_video_webhook::{enqueue_kling_v2p5_turbo_pro_image_to_video_webhook, EnqueueKlingV2p5TurboProImageToVideoArgs, EnqueueKlingV2p5TurboProImageToVideoDurationSeconds};
-  use errors::AnyhowResult;
-  use std::fs::read_to_string;
-  use test_data::web::image_urls::TREX_SKELETON_IMAGE_URL;
-
-  #[tokio::test]
-  #[ignore]
-  async fn test() -> AnyhowResult<()> {
-    // XXX: Don't commit secrets!
-    let secret = read_to_string("/home/bt/Artcraft/credentials/fal_api_key.txt")?;
-
-    let api_key = FalApiKey::from_str(&secret);
-
-    let args = EnqueueKlingV2p5TurboProImageToVideoArgs {
-      image_url: TREX_SKELETON_IMAGE_URL.to_string(),
-      prompt: "the t-rex skeleton gets off the podium and begins walking to the camera. the camera orbits slightly. The t-rex gets close and then bites.".to_string(),
-      negative_prompt: None,
-      tail_image_url: None,
-      duration: Some(EnqueueKlingV2p5TurboProImageToVideoDurationSeconds::Five),
-      api_key: &api_key,
-      webhook_url: "https://example.com/webhook",
-    };
-
-    let result = enqueue_kling_v2p5_turbo_pro_image_to_video_webhook(args).await?;
-
-    Ok(())
-  }
-}
@@ -1,86 +0,0 @@
-use crate::creds::fal_api_key::FalApiKey;
-use crate::error::classify_fal_error::classify_fal_error;
-use crate::error::fal_error_plus::FalErrorPlus;
-use fal::webhook::WebhookResponse;
-use reqwest::IntoUrl;
-use fal::endpoints::fal_ai::kling_video::v2_5::kling_v2p5_turbo_standard_image_to_video::{kling_v2p5_turbo_standard_image_to_video, KlingV2p5TurboStandardImageToVideoInput};
-
-pub struct EnqueueKlingV2p5TurboStandardImageToVideoArgs<'a, R: IntoUrl> {
-  // Request required
-  pub prompt: String,
-  pub image_url: String,
-
-  // Optional args
-  pub negative_prompt: Option<String>,
-  pub duration: Option<EnqueueKlingV2p5TurboStandardImageToVideoDurationSeconds>,
-
-  // Fulfillment
-  pub webhook_url: R,
-  pub api_key: &'a FalApiKey,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueKlingV2p5TurboStandardImageToVideoDurationSeconds {
-  Five,
-  Ten,
-}
-
-pub async fn enqueue_kling_v2p5_turbo_standard_image_to_video_webhook<R: IntoUrl>(
-  args: EnqueueKlingV2p5TurboStandardImageToVideoArgs<'_, R>
-) -> Result<WebhookResponse, FalErrorPlus> {
-
-  let duration = args.duration
-      .map(|resolution| match resolution {
-        EnqueueKlingV2p5TurboStandardImageToVideoDurationSeconds::Five => "5",
-        EnqueueKlingV2p5TurboStandardImageToVideoDurationSeconds::Ten => "10",
-      })
-      .map(|resolution| resolution.to_string());
-
-  let request = KlingV2p5TurboStandardImageToVideoInput {
-    prompt: args.prompt,
-    image_url: args.image_url,
-    // Optionals
-    duration,
-    negative_prompt: args.negative_prompt,
-    // Constants
-    cfg_scale: None,
-  };
-
-  let result = kling_v2p5_turbo_standard_image_to_video(request)
-      .with_api_key(&args.api_key.0)
-      .queue_webhook(args.webhook_url)
-      .await;
-
-  result.map_err(|err| classify_fal_error(err))
-}
-
-#[cfg(test)]
-mod tests {
-  use crate::creds::fal_api_key::FalApiKey;
-  use errors::AnyhowResult;
-  use std::fs::read_to_string;
-  use test_data::web::image_urls::TREX_SKELETON_IMAGE_URL;
-  use crate::requests::webhook::video::image::enqueue_kling_v2p5_turbo_standard_image_to_video_webhook::{enqueue_kling_v2p5_turbo_standard_image_to_video_webhook, EnqueueKlingV2p5TurboStandardImageToVideoArgs, EnqueueKlingV2p5TurboStandardImageToVideoDurationSeconds};
-
-  #[tokio::test]
-  #[ignore]
-  async fn test() -> AnyhowResult<()> {
-    // XXX: Don't commit secrets!
-    let secret = read_to_string("/home/bt/Artcraft/credentials/fal_api_key.txt")?;
-
-    let api_key = FalApiKey::from_str(&secret);
-
-    let args = EnqueueKlingV2p5TurboStandardImageToVideoArgs {
-      image_url: TREX_SKELETON_IMAGE_URL.to_string(),
-      prompt: "the t-rex skeleton gets off the podium and begins walking to the camera. the camera orbits slightly. The t-rex gets close and then bites.".to_string(),
-      negative_prompt: None,
-      duration: Some(EnqueueKlingV2p5TurboStandardImageToVideoDurationSeconds::Five),
-      api_key: &api_key,
-      webhook_url: "https://example.com/webhook",
-    };
-
-    let result = enqueue_kling_v2p5_turbo_standard_image_to_video_webhook(args).await?;
-
-    Ok(())
-  }
-}
@@ -1,87 +0,0 @@
-use crate::creds::fal_api_key::FalApiKey;
-use crate::error::classify_fal_error::classify_fal_error;
-use crate::error::fal_error_plus::FalErrorPlus;
-use fal::endpoints::fal_ai::kling_video::v2_6::kling_v2p6_pro_image_to_video::{kling_v2p6_pro_image_to_video, KlingV2p6ProImageToVideoInput};
-use fal::webhook::WebhookResponse;
-use reqwest::IntoUrl;
-
-pub struct EnqueueKlingV2p6ProImageToVideoArgs<'a, R: IntoUrl> {
-  // Request required
-  pub prompt: String,
-  pub image_url: String,
-
-  // Optional args
-  pub generate_audio: Option<bool>,
-  pub negative_prompt: Option<String>,
-  pub duration: Option<EnqueueKlingV2p6ProImageToVideoDurationSeconds>,
-
-  // Fulfillment
-  pub webhook_url: R,
-  pub api_key: &'a FalApiKey,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueKlingV2p6ProImageToVideoDurationSeconds {
-  Five,
-  Ten,
-}
-
-pub async fn enqueue_kling_v2p6_pro_image_to_video_webhook<R: IntoUrl>(
-  args: EnqueueKlingV2p6ProImageToVideoArgs<'_, R>
-) -> Result<WebhookResponse, FalErrorPlus> {
-
-  let duration = args.duration
-      .map(|resolution| match resolution {
-        EnqueueKlingV2p6ProImageToVideoDurationSeconds::Five => "5",
-        EnqueueKlingV2p6ProImageToVideoDurationSeconds::Ten => "10",
-      })
-      .map(|resolution| resolution.to_string());
-
-  let request = KlingV2p6ProImageToVideoInput {
-    prompt: args.prompt,
-    image_url: args.image_url,
-    // Optionals
-    duration,
-    negative_prompt: args.negative_prompt,
-    generate_audio: args.generate_audio,
-  };
-
-  let result = kling_v2p6_pro_image_to_video(request)
-      .with_api_key(&args.api_key.0)
-      .queue_webhook(args.webhook_url)
-      .await;
-
-  result.map_err(|err| classify_fal_error(err))
-}
-
-#[cfg(test)]
-mod tests {
-  use crate::creds::fal_api_key::FalApiKey;
-  use crate::requests::webhook::video::image::enqueue_kling_v2p6_pro_image_to_video_webhook::{enqueue_kling_v2p6_pro_image_to_video_webhook, EnqueueKlingV2p6ProImageToVideoArgs, EnqueueKlingV2p6ProImageToVideoDurationSeconds};
-  use errors::AnyhowResult;
-  use std::fs::read_to_string;
-  use test_data::web::image_urls::ERNEST_SCARED_STUPID_IMAGE_URL;
-
-  #[tokio::test]
-  #[ignore]
-  async fn test() -> AnyhowResult<()> {
-    // XXX: Don't commit secrets!
-    let secret = read_to_string("/home/bt/Artcraft/credentials/fal_api_key.txt")?;
-
-    let api_key = FalApiKey::from_str(&secret);
-
-    let args = EnqueueKlingV2p6ProImageToVideoArgs {
-      image_url: ERNEST_SCARED_STUPID_IMAGE_URL.to_string(),
-      prompt: "the man says, 'these ghosts sure are scary!' and then runs. behind him, a group of ghosts appear from the trees and chase him. the camera tracks the action. finally, the man yells, 'go away ghosts'.".to_string(),
-      negative_prompt: None,
-      generate_audio: Some(true),
-      duration: Some(EnqueueKlingV2p6ProImageToVideoDurationSeconds::Ten),
-      api_key: &api_key,
-      webhook_url: "https://example.com/webhook",
-    };
-
-    let result = enqueue_kling_v2p6_pro_image_to_video_webhook(args).await?;
-
-    Ok(())
-  }
-}
@@ -1,152 +0,0 @@
-use crate::creds::fal_api_key::FalApiKey;
-use crate::error::classify_fal_error::classify_fal_error;
-use crate::error::fal_error_plus::FalErrorPlus;
-use fal::endpoints::fal_ai::pixverse::v5::pixverse_v5_image_to_video::{pixverse_v5_image_to_video, PixverseV5ImageToVideoInput};
-use fal::webhook::WebhookResponse;
-use reqwest::IntoUrl;
-
-pub struct EnqueuePixverseV5ImageToVideoArgs<'a, R: IntoUrl> {
-  // Request required
-  pub prompt: String,
-  pub image_url: String,
-
-  // Optional args
-  pub negative_prompt: Option<String>,
-  
-  // NB: eight-second videos do not work with 1080P
-  pub duration: Option<EnqueuePixverseV5ImageToVideoDurationSeconds>,
-  pub aspect_ratio: Option<EnqueuePixverseV5ImageToVideoAspectRatio>,
-  pub resolution: Option<EnqueuePixverseV5ImageToVideoResolution>,
-  pub style: Option<EnqueuePixverseV5ImageToVideoStyle>,
-
-  // Fulfillment
-  pub webhook_url: R,
-  pub api_key: &'a FalApiKey,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueuePixverseV5ImageToVideoDurationSeconds {
-  Five,
-  Eight,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueuePixverseV5ImageToVideoResolution {
-  ThreeSixtyP,
-  FiveFortyP,
-  SevenTwentyP,
-  TenEightyP,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueuePixverseV5ImageToVideoAspectRatio {
-  Square,
-  SixteenByNine,
-  FourByThree,
-  NineBySixteen,
-  ThreeByFour,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueuePixverseV5ImageToVideoStyle {
-  Anime,
-  Animation3d,
-  Clay,
-  Comic,
-  Cyberpunk,
-}
-
-pub async fn enqueue_pixverse_v5_image_to_video_webhook<R: IntoUrl>(
-  args: EnqueuePixverseV5ImageToVideoArgs<'_, R>
-) -> Result<WebhookResponse, FalErrorPlus> {
-
-  let duration = args.duration
-      .map(|resolution| match resolution {
-        EnqueuePixverseV5ImageToVideoDurationSeconds::Five => "5",
-        EnqueuePixverseV5ImageToVideoDurationSeconds::Eight=> "8",
-      })
-      .map(|s| s.to_string());
-
-  let aspect_ratio = args.aspect_ratio
-      .map(|aspect_ratio| match aspect_ratio {
-        EnqueuePixverseV5ImageToVideoAspectRatio::Square => "1:1",
-        EnqueuePixverseV5ImageToVideoAspectRatio::SixteenByNine => "16:9",
-        EnqueuePixverseV5ImageToVideoAspectRatio::FourByThree => "4:3",
-        EnqueuePixverseV5ImageToVideoAspectRatio::NineBySixteen => "9:16",
-        EnqueuePixverseV5ImageToVideoAspectRatio::ThreeByFour => "3:4",
-      })
-      .map(|s| s.to_string());
-
-  let resolution = args.resolution
-      .map(|resolution| match resolution {
-        EnqueuePixverseV5ImageToVideoResolution::ThreeSixtyP => "360p",
-        EnqueuePixverseV5ImageToVideoResolution::FiveFortyP => "540p",
-        EnqueuePixverseV5ImageToVideoResolution::SevenTwentyP => "720p",
-        EnqueuePixverseV5ImageToVideoResolution::TenEightyP => "1080p",
-      })
-      .map(|s| s.to_string());
-
-  let style = args.style
-      .map(|style| match style {
-        EnqueuePixverseV5ImageToVideoStyle::Anime => "anime",
-        EnqueuePixverseV5ImageToVideoStyle::Animation3d => "3d_animation",
-        EnqueuePixverseV5ImageToVideoStyle::Clay => "clay",
-        EnqueuePixverseV5ImageToVideoStyle::Comic => "comic",
-        EnqueuePixverseV5ImageToVideoStyle::Cyberpunk => "cyberpunk",
-      })
-      .map(|s| s.to_string());
-
-  let request = PixverseV5ImageToVideoInput {
-    prompt: args.prompt,
-    image_url: args.image_url,
-    // Optionals
-    duration,
-    negative_prompt: args.negative_prompt,
-    aspect_ratio,
-    resolution,
-    style,
-    // Constant
-    seed: None,
-  };
-
-  let result = pixverse_v5_image_to_video(request)
-      .with_api_key(&args.api_key.0)
-      .queue_webhook(args.webhook_url)
-      .await;
-
-  result.map_err(|err| classify_fal_error(err))
-}
-
-#[cfg(test)]
-mod tests {
-  use crate::creds::fal_api_key::FalApiKey;
-  use crate::requests::webhook::video::image::enqueue_pixverse_v5_image_to_video_webhook::{enqueue_pixverse_v5_image_to_video_webhook, EnqueuePixverseV5ImageToVideoArgs, EnqueuePixverseV5ImageToVideoAspectRatio, EnqueuePixverseV5ImageToVideoDurationSeconds, EnqueuePixverseV5ImageToVideoResolution, EnqueuePixverseV5ImageToVideoStyle};
-  use errors::AnyhowResult;
-  use std::fs::read_to_string;
-  use test_data::web::image_urls::TREX_SKELETON_IMAGE_URL;
-
-  #[tokio::test]
-  #[ignore]
-  async fn test() -> AnyhowResult<()> {
-    // XXX: Don't commit secrets!
-    let secret = read_to_string("/home/bt/Artcraft/credentials/fal_api_key.txt")?;
-
-    let api_key = FalApiKey::from_str(&secret);
-
-    let args = EnqueuePixverseV5ImageToVideoArgs {
-      image_url: TREX_SKELETON_IMAGE_URL.to_string(),
-      prompt: "the t-rex skeleton gets off the podium and begins walking to the camera. the camera orbits slightly. The t-rex gets close and then bites.".to_string(),
-      negative_prompt: None,
-      duration: Some(EnqueuePixverseV5ImageToVideoDurationSeconds::Five),
-      style: Some(EnqueuePixverseV5ImageToVideoStyle::Cyberpunk),
-      aspect_ratio: Some(EnqueuePixverseV5ImageToVideoAspectRatio::FourByThree),
-      resolution: Some(EnqueuePixverseV5ImageToVideoResolution::TenEightyP),
-      api_key: &api_key,
-      webhook_url: "https://example.com/webhook",
-    };
-
-    let result = enqueue_pixverse_v5_image_to_video_webhook(args).await?;
-
-    Ok(())
-  }
-}
@@ -1,118 +0,0 @@
-use crate::creds::fal_api_key::FalApiKey;
-use crate::error::classify_fal_error::classify_fal_error;
-use crate::error::fal_error_plus::FalErrorPlus;
-use fal::endpoints::fal_ai::sora::sora2::sora_2_image_to_video::{sora_2_image_to_video, Sora2ImageToVideoInput};
-use fal::webhook::WebhookResponse;
-use reqwest::IntoUrl;
-
-pub struct EnqueueSora2ImageToVideoArgs<'a, R: IntoUrl> {
-  // Request required
-  pub prompt: String,
-  pub image_url: String,
-
-  // Optional args
-  pub resolution: Option<EnqueueSora2ImageToVideoResolution>,
-  pub duration: Option<EnqueueSora2ImageToVideoDurationSeconds>,
-  pub aspect_ratio: Option<EnqueueSora2ImageToVideoAspectRatio>,
-
-  // Fulfillment
-  pub webhook_url: R,
-  pub api_key: &'a FalApiKey,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueSora2ImageToVideoDurationSeconds {
-  Four,
-  Eight,
-  Twelve,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueSora2ImageToVideoResolution {
-  Auto,
-  SevenTwentyP,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueSora2ImageToVideoAspectRatio {
-  Auto,
-  NineBySixteen,
-  SixteenByNine,
-}
-
-pub async fn enqueue_sora_2_image_to_video_webhook<R: IntoUrl>(
-  args: EnqueueSora2ImageToVideoArgs<'_, R>
-) -> Result<WebhookResponse, FalErrorPlus> {
-
-  let duration = args.duration
-      .map(|resolution| match resolution {
-        EnqueueSora2ImageToVideoDurationSeconds::Four => 4,
-        EnqueueSora2ImageToVideoDurationSeconds::Eight => 8,
-        EnqueueSora2ImageToVideoDurationSeconds::Twelve => 12,
-      });
-
-  let resolution = args.resolution
-      .map(|resolution| match resolution {
-        EnqueueSora2ImageToVideoResolution::Auto => "auto",
-        EnqueueSora2ImageToVideoResolution::SevenTwentyP => "720p",
-      })
-      .map(|resolution| resolution.to_string());
-
-  let aspect_ratio = args.aspect_ratio
-      .map(|aspect_ratio| match aspect_ratio {
-        EnqueueSora2ImageToVideoAspectRatio::Auto => "auto",
-        EnqueueSora2ImageToVideoAspectRatio::NineBySixteen => "9:16",
-        EnqueueSora2ImageToVideoAspectRatio::SixteenByNine => "16:9",
-      })
-      .map(|resolution| resolution.to_string());
-
-  let request = Sora2ImageToVideoInput {
-    prompt: args.prompt,
-    image_url: args.image_url,
-    // Optionals
-    duration,
-    resolution,
-    aspect_ratio,
-    // Constants
-    delete_video: Some(false),
-  };
-
-  let result = sora_2_image_to_video(request)
-      .with_api_key(&args.api_key.0)
-      .queue_webhook(args.webhook_url)
-      .await;
-
-  result.map_err(|err| classify_fal_error(err))
-}
-
-#[cfg(test)]
-mod tests {
-  use crate::creds::fal_api_key::FalApiKey;
-  use crate::requests::webhook::video::image::enqueue_sora_2_image_to_video_webhook::{enqueue_sora_2_image_to_video_webhook, EnqueueSora2ImageToVideoArgs, EnqueueSora2ImageToVideoAspectRatio, EnqueueSora2ImageToVideoDurationSeconds, EnqueueSora2ImageToVideoResolution};
-  use errors::AnyhowResult;
-  use std::fs::read_to_string;
-  use test_data::web::image_urls::TREX_SKELETON_IMAGE_URL;
-
-  #[tokio::test]
-  #[ignore]
-  async fn test() -> AnyhowResult<()> {
-    // XXX: Don't commit secrets!
-    let secret = read_to_string("/home/bt/Artcraft/credentials/fal_api_key.txt")?;
-
-    let api_key = FalApiKey::from_str(&secret);
-
-    let args = EnqueueSora2ImageToVideoArgs {
-      image_url: TREX_SKELETON_IMAGE_URL.to_string(),
-      prompt: "the t-rex skeleton gets off the podium and begins walking to the camera. the camera orbits slightly. The t-rex gets close and then bites.".to_string(),
-      duration: Some(EnqueueSora2ImageToVideoDurationSeconds::Twelve),
-      aspect_ratio: Some(EnqueueSora2ImageToVideoAspectRatio::SixteenByNine),
-      resolution: Some(EnqueueSora2ImageToVideoResolution::SevenTwentyP),
-      api_key: &api_key,
-      webhook_url: "https://example.com/webhook",
-    };
-
-    let result = enqueue_sora_2_image_to_video_webhook(args).await?;
-
-    Ok(())
-  }
-}
@@ -1,120 +0,0 @@
-use crate::creds::fal_api_key::FalApiKey;
-use crate::error::classify_fal_error::classify_fal_error;
-use crate::error::fal_error_plus::FalErrorPlus;
-use fal::endpoints::fal_ai::sora::sora2::sora_2_pro_image_to_video::{sora_2_pro_image_to_video, Sora2ProImageToVideoInput};
-use fal::webhook::WebhookResponse;
-use reqwest::IntoUrl;
-
-pub struct EnqueueSora2ProImageToVideoArgs<'a, R: IntoUrl> {
-  // Request required
-  pub prompt: String,
-  pub image_url: String,
-
-  // Optional args
-  pub resolution: Option<EnqueueSora2ProImageToVideoResolution>,
-  pub duration: Option<EnqueueSora2ProImageToVideoDurationSeconds>,
-  pub aspect_ratio: Option<EnqueueSora2ProImageToVideoAspectRatio>,
-
-  // Fulfillment
-  pub webhook_url: R,
-  pub api_key: &'a FalApiKey,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueSora2ProImageToVideoDurationSeconds {
-  Four,
-  Eight,
-  Twelve,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueSora2ProImageToVideoResolution {
-  Auto,
-  SevenTwentyP,
-  TenEightyP,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueSora2ProImageToVideoAspectRatio {
-  Auto,
-  NineBySixteen,
-  SixteenByNine,
-}
-
-pub async fn enqueue_sora_2_pro_image_to_video_webhook<R: IntoUrl>(
-  args: EnqueueSora2ProImageToVideoArgs<'_, R>
-) -> Result<WebhookResponse, FalErrorPlus> {
-
-  let duration = args.duration
-      .map(|resolution| match resolution {
-        EnqueueSora2ProImageToVideoDurationSeconds::Four => 4,
-        EnqueueSora2ProImageToVideoDurationSeconds::Eight => 8,
-        EnqueueSora2ProImageToVideoDurationSeconds::Twelve => 12,
-      });
-
-  let resolution = args.resolution
-      .map(|resolution| match resolution {
-        EnqueueSora2ProImageToVideoResolution::Auto => "auto",
-        EnqueueSora2ProImageToVideoResolution::SevenTwentyP => "720p",
-        EnqueueSora2ProImageToVideoResolution::TenEightyP => "1080p",
-      })
-      .map(|resolution| resolution.to_string());
-
-  let aspect_ratio = args.aspect_ratio
-      .map(|aspect_ratio| match aspect_ratio {
-        EnqueueSora2ProImageToVideoAspectRatio::Auto => "auto",
-        EnqueueSora2ProImageToVideoAspectRatio::NineBySixteen => "9:16",
-        EnqueueSora2ProImageToVideoAspectRatio::SixteenByNine => "16:9",
-      })
-      .map(|resolution| resolution.to_string());
-
-  let request = Sora2ProImageToVideoInput {
-    prompt: args.prompt,
-    image_url: args.image_url,
-    // Optionals
-    duration,
-    resolution,
-    aspect_ratio,
-    // Constants
-    delete_video: Some(false),
-  };
-
-  let result = sora_2_pro_image_to_video(request)
-      .with_api_key(&args.api_key.0)
-      .queue_webhook(args.webhook_url)
-      .await;
-
-  result.map_err(|err| classify_fal_error(err))
-}
-
-#[cfg(test)]
-mod tests {
-  use crate::creds::fal_api_key::FalApiKey;
-  use crate::requests::webhook::video::image::enqueue_sora_2_pro_image_to_video_webhook::{enqueue_sora_2_pro_image_to_video_webhook, EnqueueSora2ProImageToVideoArgs, EnqueueSora2ProImageToVideoAspectRatio, EnqueueSora2ProImageToVideoDurationSeconds, EnqueueSora2ProImageToVideoResolution};
-  use errors::AnyhowResult;
-  use std::fs::read_to_string;
-  use test_data::web::image_urls::TREX_SKELETON_IMAGE_URL;
-
-  #[tokio::test]
-  #[ignore]
-  async fn test() -> AnyhowResult<()> {
-    // XXX: Don't commit secrets!
-    let secret = read_to_string("/home/bt/Artcraft/credentials/fal_api_key.txt")?;
-
-    let api_key = FalApiKey::from_str(&secret);
-
-    let args = EnqueueSora2ProImageToVideoArgs {
-      image_url: TREX_SKELETON_IMAGE_URL.to_string(),
-      prompt: "the t-rex skeleton gets off the podium and begins walking to the camera. the camera orbits slightly. The t-rex gets close and then bites.".to_string(),
-      duration: Some(EnqueueSora2ProImageToVideoDurationSeconds::Twelve),
-      aspect_ratio: Some(EnqueueSora2ProImageToVideoAspectRatio::SixteenByNine),
-      resolution: Some(EnqueueSora2ProImageToVideoResolution::TenEightyP),
-      api_key: &api_key,
-      webhook_url: "https://example.com/webhook",
-    };
-
-    let result = enqueue_sora_2_pro_image_to_video_webhook(args).await?;
-
-    Ok(())
-  }
-}
@@ -1,129 +0,0 @@
-use crate::creds::fal_api_key::FalApiKey;
-use crate::error::classify_fal_error::classify_fal_error;
-use crate::error::fal_error_plus::FalErrorPlus;
-use fal::endpoints::fal_ai::veo::veo3_1::veo_3p1_fast_first_last_frame_image_to_video::{veo_3p1_fast_first_last_frame_image_to_video, Veo3p1FastFirstLastFrameImageToVideoInput};
-use fal::webhook::WebhookResponse;
-use reqwest::IntoUrl;
-
-pub struct EnqueueVeo3p1FastFirstLastFrameImageToVideoArgs<'a, R: IntoUrl> {
-  // Request required
-  pub prompt: String,
-
-  // Starting frame
-  pub first_frame_url: String,
-
-  // Ending frame
-  pub last_frame_url: String,
-
-  // Optional args
-  pub duration: Option<EnqueueVeo3p1FastFirstLastFrameImageToVideoDurationSeconds>,
-  pub aspect_ratio: Option<EnqueueVeo3p1FastFirstLastFrameImageToVideoAspectRatio>,
-  pub resolution: Option<EnqueueVeo3p1FastFirstLastFrameImageToVideoResolution>,
-  pub generate_audio: Option<bool>,
-
-  // Fulfillment
-  pub webhook_url: R,
-  pub api_key: &'a FalApiKey,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueVeo3p1FastFirstLastFrameImageToVideoDurationSeconds {
-  Four,
-  Six,
-  Eight,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueVeo3p1FastFirstLastFrameImageToVideoAspectRatio {
-  Auto,
-  Square,
-  SixteenByNine,
-  NineBySixteen,
-}
-
-#[derive(Copy, Clone, Debug)]
-pub enum EnqueueVeo3p1FastFirstLastFrameImageToVideoResolution {
-  SevenTwentyP,
-  TenEightyP,
-}
-
-pub async fn enqueue_veo_3p1_fast_first_last_frame_image_to_video_webhook<R: IntoUrl>(
-  args: EnqueueVeo3p1FastFirstLastFrameImageToVideoArgs<'_, R>
-) -> Result<WebhookResponse, FalErrorPlus> {
-
-  let duration = args.duration
-      .map(|resolution| match resolution {
-        EnqueueVeo3p1FastFirstLastFrameImageToVideoDurationSeconds::Four => "4s",
-        EnqueueVeo3p1FastFirstLastFrameImageToVideoDurationSeconds::Six => "6s",
-        EnqueueVeo3p1FastFirstLastFrameImageToVideoDurationSeconds::Eight=> "8s",
-      })
-      .map(|s| s.to_string());
-
-  let aspect_ratio = args.aspect_ratio
-      .map(|aspect_ratio| match aspect_ratio {
-        EnqueueVeo3p1FastFirstLastFrameImageToVideoAspectRatio::Auto => "auto",
-        EnqueueVeo3p1FastFirstLastFrameImageToVideoAspectRatio::Square => "1:1",
-        EnqueueVeo3p1FastFirstLastFrameImageToVideoAspectRatio::SixteenByNine => "16:9",
-        EnqueueVeo3p1FastFirstLastFrameImageToVideoAspectRatio::NineBySixteen => "9:16",
-      })
-      .map(|s| s.to_string());
-
-  let resolution = args.resolution
-      .map(|resolution| match resolution {
-        EnqueueVeo3p1FastFirstLastFrameImageToVideoResolution::SevenTwentyP => "720p",
-        EnqueueVeo3p1FastFirstLastFrameImageToVideoResolution::TenEightyP => "1080p",
-      })
-      .map(|s| s.to_string());
-
-  let request = Veo3p1FastFirstLastFrameImageToVideoInput {
-    prompt: args.prompt,
-    first_frame_url: args.first_frame_url,
-    last_frame_url: args.last_frame_url,
-    generate_audio: args.generate_audio,
-    // Optionals
-    duration,
-    aspect_ratio,
-    resolution,
-  };
-
-  let result = veo_3p1_fast_first_last_frame_image_to_video(request)
-      .with_api_key(&args.api_key.0)
-      .queue_webhook(args.webhook_url)
-      .await;
-
-  result.map_err(|err| classify_fal_error(err))
-}
-
-#[cfg(test)]
-mod tests {
-  use crate::creds::fal_api_key::FalApiKey;
-  use crate::requests::webhook::video::image::enqueue_veo_3p1_fast_first_last_frame_image_to_video_webhook::{enqueue_veo_3p1_fast_first_last_frame_image_to_video_webhook, EnqueueVeo3p1FastFirstLastFrameImageToVideoArgs, EnqueueVeo3p1FastFirstLastFrameImageToVideoAspectRatio, EnqueueVeo3p1FastFirstLastFrameImageToVideoDurationSeconds, EnqueueVeo3p1FastFirstLastFrameImageToVideoResolution};
-  use errors::AnyhowResult;
-  use std::fs::read_to_string;
-  use test_data::web::image_urls::{TALL_CORGI_SHIBA_TREASURE_OCEAN_URL, TALL_CORGI_SHIBA_TREASURE_SKY_URL};
-
-  #[tokio::test]
-  #[ignore]
-  async fn test() -> AnyhowResult<()> {
-    // XXX: Don't commit secrets!
-    let secret = read_to_string("/home/bt/Artcraft/credentials/fal_api_key.txt")?;
-
-    let api_key = FalApiKey::from_str(&secret);
-
-    let args = EnqueueVeo3p1FastFirstLastFrameImageToVideoArgs {
-      first_frame_url: TALL_CORGI_SHIBA_TREASURE_OCEAN_URL.to_string(),
-      last_frame_url: TALL_CORGI_SHIBA_TREASURE_SKY_URL.to_string(),
-      prompt: "There is a tiny ocean island with a corgi and shiba and treasure chest on it. The corgi and shiba are barking at the chest, when suddenly the island launches itself into the air. The camera tracks the island and follows it up high in the sky. The sun beams over the horizon. The dogs are happy and bark. The gold coins gleam in the sun.".to_string(),
-      duration: Some(EnqueueVeo3p1FastFirstLastFrameImageToVideoDurationSeconds::Six),
-      aspect_ratio: Some(EnqueueVeo3p1FastFirstLastFrameImageToVideoAspectRatio::NineBySixteen),
-      resolution: Some(EnqueueVeo3p1FastFirstLastFrameImageToVideoResolution::SevenTwentyP),
-      generate_audio: Some(true),
-      api_key: &api_key,
-      webhook_url: "https://example.com/webhook",
-    };
-
-    let result = enqueue_veo_3p1_fast_first_last_frame_image_to_video_webhook(args).await?;
-
-    Ok(())
-  }
-}
--- a/Show More
+++ b/Show More
				`@@ -1 +0,0 @@`
				`pub mod nano_banana_pro_multi_function_image_gen;`