beeble endpoint

const def
add a few more clients for testing
2026-10-24 10:39:28 -04:00 · 2026-06-09 20:12:17 -04:00 · 2026-06-09 20:08:16 -04:00 · 2026-06-09 20:04:53 -04:00 · 2026-06-09 19:10:10 -04:00
72 changed files with 217 additions and 1440 deletions
@@ -1,36 +0,0 @@
-{
-  "db_name": "MySQL",
-  "query": "\nSELECT DISTINCT\n  subscription_namespace as `subscription_namespace: enums::common::payments_namespace::PaymentsNamespace`,\n  maybe_stripe_customer_id as `stripe_customer_id!`\n\nFROM user_subscriptions\n\nWHERE\n  user_token = ?\n  AND maybe_stripe_customer_id IS NOT NULL\n  AND deleted_at IS NULL\nORDER BY subscription_namespace ASC, maybe_stripe_customer_id ASC\n    ",
-  "describe": {
-    "columns": [
-      {
-        "ordinal": 0,
-        "name": "subscription_namespace: enums::common::payments_namespace::PaymentsNamespace",
-        "type_info": {
-          "type": "VarString",
-          "flags": "NOT_NULL | MULTIPLE_KEY | BINARY | NO_DEFAULT_VALUE",
-          "char_set": 224,
-          "max_size": 128
-        }
-      },
-      {
-        "ordinal": 1,
-        "name": "stripe_customer_id!",
-        "type_info": {
-          "type": "VarString",
-          "flags": "MULTIPLE_KEY | BINARY",
-          "char_set": 224,
-          "max_size": 1020
-        }
-      }
-    ],
-    "parameters": {
-      "Right": 1
-    },
-    "nullable": [
-      false,
-      true
-    ]
-  },
-  "hash": "516db34b6a642a2f7d7107f186905a79ad694c3c86f3078efc77bcaae7f39f3d"
-}
@@ -1,47 +0,0 @@
-{
-  "db_name": "MySQL",
-  "query": "\nSELECT\n  user_token as `user_token: tokens::tokens::users::UserToken`,\n  payments_namespace as `payments_namespace: enums::common::payments_namespace::PaymentsNamespace`,\n  stripe_customer_id\n\nFROM user_stripe_customer_links\n\nWHERE user_token = ?\nORDER BY id ASC\n    ",
-  "describe": {
-    "columns": [
-      {
-        "ordinal": 0,
-        "name": "user_token: tokens::tokens::users::UserToken",
-        "type_info": {
-          "type": "VarString",
-          "flags": "NOT_NULL | MULTIPLE_KEY | BINARY | NO_DEFAULT_VALUE",
-          "char_set": 224,
-          "max_size": 128
-        }
-      },
-      {
-        "ordinal": 1,
-        "name": "payments_namespace: enums::common::payments_namespace::PaymentsNamespace",
-        "type_info": {
-          "type": "VarString",
-          "flags": "NOT_NULL | BINARY | NO_DEFAULT_VALUE",
-          "char_set": 224,
-          "max_size": 128
-        }
-      },
-      {
-        "ordinal": 2,
-        "name": "stripe_customer_id",
-        "type_info": {
-          "type": "VarString",
-          "flags": "NOT_NULL | UNIQUE_KEY | BINARY | NO_DEFAULT_VALUE",
-          "char_set": 224,
-          "max_size": 1020
-        }
-      }
-    ],
-    "parameters": {
-      "Right": 1
-    },
-    "nullable": [
-      false,
-      false,
-      false
-    ]
-  },
-  "hash": "ffb5717340f21f21693bfcade201bc055fb3fb8a26da8d0574e3de44b033586c"
-}
@@ -2,6 +2,5 @@ pub mod alerts;
 pub mod jobs;
 pub mod user;
 pub mod user_referrals;
-pub mod user_stripe_data;
 pub mod wallet_ledger_entries;
 pub mod wallets;
@@ -1 +0,0 @@
-pub mod moderator_get_user_stripe_customer_ids;
@@ -1,43 +0,0 @@
-use enums::common::payments_namespace::PaymentsNamespace;
-use serde_derive::{Deserialize, Serialize};
-use tokens::tokens::users::UserToken;
-use utoipa::ToSchema;
-
-pub const MODERATOR_GET_USER_STRIPE_CUSTOMER_IDS_PATH: &str =
-    "/v1/moderation/user_stripe_data/{user_token}/customer_ids";
-
-#[derive(Deserialize, ToSchema)]
-pub struct ModeratorGetUserStripeCustomerIdsPathInfo {
-  pub user_token: UserToken,
-}
-
-#[derive(Serialize, ToSchema)]
-pub struct ModeratorGetUserStripeCustomerIdsResponse {
-  pub success: bool,
-
-  /// All stripe customer ids we have on file for the user, across payments
-  /// namespaces. A user may have zero or several: a customer link and/or
-  /// subscriptions per namespace (eg. artcraft), plus legacy fakeyou
-  /// subscriptions. The same customer id can appear once per source.
-  pub customer_ids: Vec<ModeratorUserStripeCustomerIdEntry>,
-}
-
-#[derive(Serialize, ToSchema)]
-pub struct ModeratorUserStripeCustomerIdEntry {
-  pub stripe_customer_id: String,
-  pub payments_namespace: PaymentsNamespace,
-  pub source: ModeratorStripeCustomerIdSource,
-
-  /// Link to the customer in the Stripe dashboard for the namespace's account.
-  pub stripe_dashboard_url: String,
-}
-
-/// Which table the customer id was found in.
-#[derive(Serialize, ToSchema)]
-#[serde(rename_all = "snake_case")]
-pub enum ModeratorStripeCustomerIdSource {
-  /// From the `user_stripe_customer_links` table (1:1 per namespace).
-  CustomerLink,
-  /// From the user's rows in the `user_subscriptions` table.
-  Subscription,
-}
@@ -87,8 +87,7 @@ mod tests {
  use crate::requests::image_websocket::messages::websocket_server_message::WebsocketServerMessage;

  fn json_path(file_name: &str) -> String {
-    // NB: Cargo runs tests with the crate root as the working directory.
-    format!("test_data/websocket_messages/{}", file_name)
+    format!("/Users/bt/dev/storyteller/storyteller-rust/crates/api_clients/grok_consumer_client/test_data/websocket_messages/{}", file_name)
  }

  #[test]
@@ -1,25 +0,0 @@
-{
-  "type": "json",
-  "current_status": "completed",
-  "percentage_complete": 100,
-  "job_id": "c1bed796-3f05-4716-8ef0-a4d4900dfc6e",
-  "elapsed": null,
-  "prompt": "a dog typing on a keyboard",
-  "confirmation": "Drew a dog typing",
-  "full_prompt": "a dog typing on a keyboard",
-  "flags": null,
-  "is_alteration": false,
-  "section_id": 0,
-  "input_type": "text",
-  "request_id": "fc39cefd-fcf9-4775-b490-7e17ce670060",
-  "asr_transcript": null,
-  "asr_accepted": null,
-  "seed": null,
-  "image_reference": null,
-  "is_image_edit": null,
-  "moderated": false,
-  "r_rated": false,
-  "order": 1,
-  "model_name": "imagine_h_1",
-  "image_id": "78b3e6ef-defc-41a6-a9ac-b7a370d26ce5"
-}
@@ -1,25 +0,0 @@
-{
-  "type": "json",
-  "current_status": "start_stage",
-  "percentage_complete": 0,
-  "job_id": "57baeffe-d5cf-483b-a5bb-7794899f905c",
-  "elapsed": null,
-  "prompt": "a dog typing on a keyboard",
-  "confirmation": "Drew a dog typing",
-  "full_prompt": "a dog typing on a keyboard",
-  "flags": null,
-  "is_alteration": true,
-  "section_id": 0,
-  "input_type": "text",
-  "request_id": "fc39cefd-fcf9-4775-b490-7e17ce670060",
-  "asr_transcript": null,
-  "asr_accepted": null,
-  "seed": null,
-  "image_reference": null,
-  "is_image_edit": null,
-  "moderated": false,
-  "r_rated": null,
-  "order": 7,
-  "model_name": "imagine_h_1",
-  "image_id": null
-}
@@ -1,21 +0,0 @@
-{
-  "type": "conversation.item.create",
-  "timestamp": 1761010203630,
-  "item": {
-    "type": "message",
-    "content": [
-      {
-        "requestId": "fc39cefd-fcf9-4775-b490-7e17ce670060",
-        "text": "a dog typing on a keyboard",
-        "type": "input_text",
-        "properties": {
-          "section_count": 0,
-          "is_kids_mode": false,
-          "enable_nsfw": true,
-          "skip_upsampler": false,
-          "is_initial": false
-        }
-      }
-    ]
-  }
-}
@@ -1 +0,0 @@
-{}
@@ -1,4 +0,0 @@
-{
-  "type": "other_type",
-  "foo": "bar"
-}
@@ -1 +0,0 @@
-{"type":"json","current_status":"start_stage","percentage_complete":0.0,"job_id":"0080eaac-f7f7-4369-90a2-346491939c1b","elapsed":null,"prompt":"a dog riding a motorcycle","confirmation":"Drew a dog riding a motorcycle","full_prompt":"a dog riding a motorcycle","flags":null,"is_alteration":false,"section_id":0,"input_type":"text","request_id":"bbc15402-3257-4415-922e-b156c151f3c2","asr_transcript":null,"asr_accepted":null,"seed":null,"image_reference":null,"is_image_edit":null,"moderated":false,"r_rated":null,"order":0,"model_name":"imagine_h_1","image_id":null}
@@ -1,25 +0,0 @@
-{
-  "type": "json",
-  "current_status": "start_stage",
-  "percentage_complete": 0,
-  "job_id": "0080eaac-f7f7-4369-90a2-346491939c1b",
-  "elapsed": null,
-  "prompt": "a dog riding a motorcycle",
-  "confirmation": "Drew a dog riding a motorcycle",
-  "full_prompt": "a dog riding a motorcycle",
-  "flags": null,
-  "is_alteration": false,
-  "section_id": 0,
-  "input_type": "text",
-  "request_id": "bbc15402-3257-4415-922e-b156c151f3c2",
-  "asr_transcript": null,
-  "asr_accepted": null,
-  "seed": null,
-  "image_reference": null,
-  "is_image_edit": null,
-  "moderated": false,
-  "r_rated": null,
-  "order": 0,
-  "model_name": "imagine_h_1",
-  "image_id": null
-}
@@ -89,15 +89,7 @@ mod tests {
    let cookies = format!("cookie={}", "a".repeat(10000));
    assert_eq!(has_session_cookie(&cookies).unwrap(), SessionCookiePresence::MaybePresent);

-    // Synthetic fixture (the original real session token was redacted); the session
-    // cookie name is what matters for detection.
-    let cookies = "__Host-authjs.csrf-token=abc123; \
-      __Secure-authjs.callback-url=https%3A%2F%2Fsora.com%2F; \
-      __Secure-authjs.session-token=fake-session-token-value";
-
-    assert_eq!(has_session_cookie(cookies).unwrap(), SessionCookiePresence::Present);
-
-    let cookies = "__Secure-next-auth.session-token=fake-session-token-value";
+    let cookies = "";

    assert_eq!(has_session_cookie(cookies).unwrap(), SessionCookiePresence::Present);
  }
@@ -1,4 +1,3 @@
-pub mod seedance2pro_bad_request_api_error;
 pub mod seedance2pro_client_error;
 pub mod seedance2pro_error;
 pub mod seedance2pro_generic_api_error;
@@ -1,29 +0,0 @@
-use std::error::Error;
-use std::fmt::{Display, Formatter};
-
-/// These represent known "400s" that are the fault of the client sending a bad request.
-#[derive(Debug)]
-pub enum Seedance2ProBadRequestApiError {
-  /// The video generation request was flagged as a content violation.
-  VideoGenerationViolation { raw_body: String },
-
-  /// The prompt exceeded Kinovi's maximum length (10,000 characters at the
-  /// time of writing).
-  PromptIsTooLong { raw_body: String },
-
-  /// Too many media URLs were attached to the request (`uploadedUrls` is
-  /// capped at 9 elements at the time of writing).
-  TooManyUrls { raw_body: String },
-}
-
-impl Error for Seedance2ProBadRequestApiError {}
-
-impl Display for Seedance2ProBadRequestApiError {
-  fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
-    match self {
-      Self::VideoGenerationViolation { raw_body } => write!(f, "Video generation violation: {}", raw_body),
-      Self::PromptIsTooLong { raw_body } => write!(f, "Prompt is too long: {}", raw_body),
-      Self::TooManyUrls { raw_body } => write!(f, "Too many urls: {}", raw_body),
-    }
-  }
-}
@@ -1,4 +1,3 @@
-use crate::error::seedance2pro_bad_request_api_error::Seedance2ProBadRequestApiError;
 use crate::error::seedance2pro_client_error::Seedance2ProClientError;
 use crate::error::seedance2pro_generic_api_error::Seedance2ProGenericApiError;
 use crate::error::seedance2pro_specific_api_error::Seedance2ProSpecificApiError;
@@ -10,7 +9,6 @@ pub enum Seedance2ProError {
  Client(Seedance2ProClientError),
  ApiSpecific(Seedance2ProSpecificApiError),
  ApiGeneric(Seedance2ProGenericApiError),
-  ApiBadRequest(Seedance2ProBadRequestApiError),
 }

 impl Seedance2ProError {
@@ -40,7 +38,6 @@ impl std::fmt::Display for Seedance2ProError {
      Self::Client(e) => write!(f, "Seedance2ProClientError: {:?}", e),
      Self::ApiSpecific(e) => write!(f, "Seedance2ProSpecificApiError: {:?}", e),
      Self::ApiGeneric(e) => write!(f, "Seedance2ProGenericApiError: {:?}", e),
-      Self::ApiBadRequest(e) => write!(f, "Seedance2ProBadRequestApiError: {:?}", e),
    }
  }
 }
@@ -62,9 +59,3 @@ impl From<Seedance2ProGenericApiError> for Seedance2ProError {
    Self::ApiGeneric(error)
  }
 }
-
-impl From<Seedance2ProBadRequestApiError> for Seedance2ProError {
-  fn from(error: Seedance2ProBadRequestApiError) -> Self {
-    Self::ApiBadRequest(error)
-  }
-}
@@ -16,12 +16,8 @@ pub enum Seedance2ProGenericApiError {
  /// Includes the original body.
  SerdeParseErrorWithBodyOnNon200(serde_json::Error, String),

-  /// A response that parsed, but didn't have the shape we expected
-  /// (eg. an empty batch response array).
-  UnexpectedResponseShape {
-    explanation: String,
-    raw_body: String,
-  },
+  /// An uncategorized bad HTTP response.
+  UncategorizedBadResponse(String),

  /// An uncategorized bad HTTP response with status code and body.
  UncategorizedBadResponseWithStatusAndBody {
@@ -41,7 +37,7 @@ impl Display for Seedance2ProGenericApiError {
      Self::CloudflareError(err) => write!(f, "Cloudflare error: {}", err),
      Self::SerdeResponseParseErrorWithBody(err, body) => write!(f, "Failed to parse response body: {:?}. Body: {}", err, body),
      Self::SerdeParseErrorWithBodyOnNon200(err, body) => write!(f, "Failed to parse non-200 response body: {:?}. Body: {}", err, body),
-      Self::UnexpectedResponseShape { explanation, raw_body } => write!(f, "Unexpected response shape: {}. Body: {}", explanation, raw_body),
+      Self::UncategorizedBadResponse(msg) => write!(f, "Uncategorized bad response: {}", msg),
      Self::UncategorizedBadResponseWithStatusAndBody { status_code, body } => write!(f, "Uncategorized bad response: status code {}, body: {}", status_code, body),
      Self::WreqError(err) => write!(f, "Wreq client error: {}", err),
    }
@@ -8,6 +8,9 @@ pub enum Seedance2ProSpecificApiError {
  /// The session cookies are expired or invalid.
  UnauthorizedSessionExpired,

+  /// The video generation request was flagged as a content violation.
+  VideoGenerationViolation(String),
+
  /// The account does not have enough credits to perform the operation.
  BillingError {
    status_code: StatusCode,
@@ -21,6 +24,7 @@ impl Display for Seedance2ProSpecificApiError {
  fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
    match self {
      Self::UnauthorizedSessionExpired => write!(f, "Unauthorized: session cookies expired or invalid."),
+      Self::VideoGenerationViolation(body) => write!(f, "Video generation violation: {}", body),
      Self::BillingError { status_code, body } => write!(f, "Billing error (status {}): {}", status_code, body),
    }
  }
@@ -119,10 +119,9 @@ pub async fn generate_character(args: GenerateCharacterArgs<'_>) -> Result<Gener
  let data = batch_response
    .into_iter()
    .next()
-    .ok_or_else(|| Seedance2ProGenericApiError::UnexpectedResponseShape {
-      explanation: "Empty batch response array".to_string(),
-      raw_body: response_body.clone(),
-    })?
+    .ok_or_else(|| Seedance2ProGenericApiError::UncategorizedBadResponse(
+      "Empty batch response array".to_string()
+    ))?
    .result
    .data
    .json;
@@ -1,8 +1,8 @@
 use crate::creds::seedance2pro_session::Seedance2ProSession;
-use crate::error::seedance2pro_bad_request_api_error::Seedance2ProBadRequestApiError;
 use crate::error::seedance2pro_client_error::Seedance2ProClientError;
 use crate::error::seedance2pro_error::Seedance2ProError;
 use crate::error::seedance2pro_generic_api_error::Seedance2ProGenericApiError;
+use crate::error::seedance2pro_specific_api_error::Seedance2ProSpecificApiError;
 use crate::requests::generate_image::request_types::*;
 use crate::requests::kinovi_host::{KinoviHost, resolve_host};
 use crate::utils::categorize_seedance2pro_error::categorize_seedance2pro_error;
@@ -285,16 +285,15 @@ pub async fn generate_image(args: GenerateImageArgs<'_>) -> Result<GenerateImage
  let task_data = batch_response
    .into_iter()
    .next()
-    .ok_or_else(|| Seedance2ProGenericApiError::UnexpectedResponseShape {
-      explanation: "Empty batch response array".to_string(),
-      raw_body: response_body.clone(),
-    })?
+    .ok_or_else(|| Seedance2ProGenericApiError::UncategorizedBadResponse(
+      "Empty batch response array".to_string()
+    ))?
    .result
    .data
    .json;

  if task_data.violation_warning {
-    return Err(Seedance2ProBadRequestApiError::VideoGenerationViolation { raw_body: response_body }.into());
+    return Err(Seedance2ProSpecificApiError::VideoGenerationViolation(response_body).into());
  }

  Ok(GenerateImageResponse {
@@ -1,8 +1,8 @@
 use crate::creds::seedance2pro_session::Seedance2ProSession;
-use crate::error::seedance2pro_bad_request_api_error::Seedance2ProBadRequestApiError;
 use crate::error::seedance2pro_client_error::Seedance2ProClientError;
 use crate::error::seedance2pro_error::Seedance2ProError;
 use crate::error::seedance2pro_generic_api_error::Seedance2ProGenericApiError;
+use crate::error::seedance2pro_specific_api_error::Seedance2ProSpecificApiError;
 use crate::requests::generate_video::request_types::*;
 use crate::requests::kinovi_host::{KinoviHost, resolve_host};
 use crate::utils::categorize_seedance2pro_error::categorize_seedance2pro_error;
@@ -403,16 +403,15 @@ pub async fn generate_video(args: GenerateVideoArgs<'_>) -> Result<GenerateVideo
  let task_data = batch_response
    .into_iter()
    .next()
-    .ok_or_else(|| Seedance2ProGenericApiError::UnexpectedResponseShape {
-      explanation: "Empty batch response array".to_string(),
-      raw_body: response_body.clone(),
-    })?
+    .ok_or_else(|| Seedance2ProGenericApiError::UncategorizedBadResponse(
+      "Empty batch response array".to_string()
+    ))?
    .result
    .data
    .json;

  if task_data.violation_warning {
-    return Err(Seedance2ProBadRequestApiError::VideoGenerationViolation { raw_body: response_body }.into());
+    return Err(Seedance2ProSpecificApiError::VideoGenerationViolation(response_body).into());
  }

  Ok(GenerateVideoResponse {
@@ -94,10 +94,9 @@ pub async fn get_user_auth_details(
  let json = batch_response
    .into_iter()
    .next()
-    .ok_or_else(|| Seedance2ProGenericApiError::UnexpectedResponseShape {
-      explanation: "Empty batch response array".to_string(),
-      raw_body: response_body.clone(),
-    })?
+    .ok_or_else(|| Seedance2ProGenericApiError::UncategorizedBadResponse(
+      "Empty batch response array".to_string()
+    ))?
    .result
    .data
    .json;
@@ -181,10 +181,9 @@ pub async fn poll_characters(args: PollCharactersArgs<'_>) -> Result<PollCharact
  let data = batch_response
    .into_iter()
    .next()
-    .ok_or_else(|| Seedance2ProGenericApiError::UnexpectedResponseShape {
-      explanation: "Empty batch response array".to_string(),
-      raw_body: response_body.clone(),
-    })?
+    .ok_or_else(|| Seedance2ProGenericApiError::UncategorizedBadResponse(
+      "Empty batch response array".to_string()
+    ))?
    .result
    .data
    .json;
@@ -201,10 +201,9 @@ pub async fn poll_orders(args: PollOrdersArgs<'_>) -> Result<PollOrdersResponse,
  let json = batch_response
    .into_iter()
    .next()
-    .ok_or_else(|| Seedance2ProGenericApiError::UnexpectedResponseShape {
-      explanation: "Empty batch response array".to_string(),
-      raw_body: response_body.clone(),
-    })?
+    .ok_or_else(|| Seedance2ProGenericApiError::UncategorizedBadResponse(
+      "Empty batch response array".to_string()
+    ))?
    .result
    .data
    .json;
@@ -106,10 +106,9 @@ pub async fn prepare_file_upload(args: PrepareFileUploadArgs<'_>) -> Result<Prep
  let upload_url = batch_response
    .into_iter()
    .next()
-    .ok_or_else(|| Seedance2ProGenericApiError::UnexpectedResponseShape {
-      explanation: "Empty batch response array".to_string(),
-      raw_body: response_body.clone(),
-    })?
+    .ok_or_else(|| Seedance2ProGenericApiError::UncategorizedBadResponse(
+      "Empty batch response array".to_string()
+    ))?
    .result
    .data
    .json;
@@ -102,10 +102,9 @@ pub async fn update_character(args: UpdateCharacterArgs<'_>) -> Result<UpdateCha
  let data = batch_response
    .into_iter()
    .next()
-    .ok_or_else(|| Seedance2ProGenericApiError::UnexpectedResponseShape {
-      explanation: "Empty batch response array".to_string(),
-      raw_body: response_body.clone(),
-    })?
+    .ok_or_else(|| Seedance2ProGenericApiError::UncategorizedBadResponse(
+      "Empty batch response array".to_string()
+    ))?
    .result
    .data
    .json;
@@ -1,8 +1,8 @@
 use crate::creds::seedance2pro_session::Seedance2ProSession;
-use crate::error::seedance2pro_bad_request_api_error::Seedance2ProBadRequestApiError;
 use crate::error::seedance2pro_client_error::Seedance2ProClientError;
 use crate::error::seedance2pro_error::Seedance2ProError;
 use crate::error::seedance2pro_generic_api_error::Seedance2ProGenericApiError;
+use crate::error::seedance2pro_specific_api_error::Seedance2ProSpecificApiError;
 use crate::requests::workflow_run_task::request_types::*;
 use crate::requests::kinovi_host::{KinoviHost, resolve_host};
 use crate::utils::categorize_seedance2pro_error::categorize_seedance2pro_error;
@@ -415,16 +415,15 @@ pub async fn workflow_run_task(args: WorkflowRunTaskArgs<'_>) -> Result<Workflow
  let task_data = batch_response
    .into_iter()
    .next()
-    .ok_or_else(|| Seedance2ProGenericApiError::UnexpectedResponseShape {
-      explanation: "Empty batch response array".to_string(),
-      raw_body: response_body.clone(),
-    })?
+    .ok_or_else(|| Seedance2ProGenericApiError::UncategorizedBadResponse(
+      "Empty batch response array".to_string()
+    ))?
    .result
    .data
    .json;

  if task_data.violation_warning {
-    return Err(Seedance2ProBadRequestApiError::VideoGenerationViolation { raw_body: response_body }.into());
+    return Err(Seedance2ProSpecificApiError::VideoGenerationViolation(response_body).into());
  }

  Ok(WorkflowRunTaskResponse {
@@ -1,6 +1,5 @@
 use wreq::StatusCode;

-use crate::error::seedance2pro_bad_request_api_error::Seedance2ProBadRequestApiError;
 use crate::error::seedance2pro_error::Seedance2ProError;
 use crate::error::seedance2pro_generic_api_error::Seedance2ProGenericApiError;
 use crate::error::seedance2pro_specific_api_error::Seedance2ProSpecificApiError;
@@ -10,25 +9,11 @@ const BILLING_ERROR_MARKERS: &[&str] = &[
  "credits not enough",
 ];

-/// Zod validation message for a string field exceeding its maximum length,
-/// eg. "参数验证失败 - String must contain at most 10000 character(s)".
-const STRING_TOO_LONG_MARKER: &str = "String must contain at most";
-
-/// Zod validation message for an array field exceeding its maximum size,
-/// eg. "参数验证失败 - Array must contain at most 9 element(s)".
-const ARRAY_TOO_LARGE_MARKER: &str = "Array must contain at most";
-
-/// Zod `fieldErrors` path entry for the prompt field.
-const PROMPT_FIELD_MARKER: &str = "\"prompt\"";
-
-/// Zod `fieldErrors` path entry for the uploaded media urls field.
-const UPLOADED_URLS_FIELD_MARKER: &str = "\"uploadedUrls\"";
-
 /// Categorize a non-success HTTP response into a specific or generic error.
 ///
-/// Checks the response body for known patterns (e.g. billing errors, request
-/// validation failures) and returns a specific error variant when possible,
-/// falling back to `UncategorizedBadResponseWithStatusAndBody` otherwise.
+/// Checks the response body for known patterns (e.g. billing errors) and returns
+/// a specific error variant when possible, falling back to
+/// `UncategorizedBadResponseWithStatusAndBody` otherwise.
 pub fn categorize_seedance2pro_error(
  status_code: StatusCode,
  body: String,
@@ -40,15 +25,6 @@ pub fn categorize_seedance2pro_error(
    }.into();
  }

-  if status_code == StatusCode::BAD_REQUEST {
-    if is_prompt_too_long_error(&body) {
-      return Seedance2ProBadRequestApiError::PromptIsTooLong { raw_body: body }.into();
-    }
-    if is_too_many_urls_error(&body) {
-      return Seedance2ProBadRequestApiError::TooManyUrls { raw_body: body }.into();
-    }
-  }
-
  Seedance2ProGenericApiError::UncategorizedBadResponseWithStatusAndBody {
    status_code,
    body,
@@ -61,164 +37,75 @@ fn is_billing_error(body: &str) -> bool {
  BILLING_ERROR_MARKERS.iter().any(|marker| body_lower.contains(marker))
 }

-/// Check if the response body is a zod validation failure for an over-long prompt.
-fn is_prompt_too_long_error(body: &str) -> bool {
-  body.contains(STRING_TOO_LONG_MARKER) && body.contains(PROMPT_FIELD_MARKER)
-}
-
-/// Check if the response body is a zod validation failure for too many uploaded urls.
-fn is_too_many_urls_error(body: &str) -> bool {
-  body.contains(ARRAY_TOO_LARGE_MARKER) && body.contains(UPLOADED_URLS_FIELD_MARKER)
-}
-
 #[cfg(test)]
 mod tests {
  use super::*;
  use crate::error::seedance2pro_error::Seedance2ProError;

-  mod billing_tests {
-    use super::*;
+  #[test]
+  fn real_not_enough_credits_response() {
+    let body = std::fs::read_to_string("test_data/responses/not_enough_credits.json")
+        .expect("Failed to read test data file");

-    #[test]
-    fn real_not_enough_credits_response() {
-      let body = read_response_body("not_enough_credits.json");
+    let error = categorize_seedance2pro_error(StatusCode::BAD_REQUEST, body);

-      let error = categorize_seedance2pro_error(StatusCode::BAD_REQUEST, body);
-
-      match error {
-        Seedance2ProError::ApiSpecific(
-          Seedance2ProSpecificApiError::BillingError { status_code, body }
-        ) => {
-          assert_eq!(status_code, StatusCode::BAD_REQUEST);
-          assert!(body.contains("credits not enough"));
-        }
-        other => panic!("Expected BillingError, got: {:?}", other),
-      }
-    }
-
-    #[test]
-    fn billing_error_case_insensitive() {
-      let body = r#"{"error":"Credits Not Enough"}"#.to_string();
-
-      let error = categorize_seedance2pro_error(StatusCode::BAD_REQUEST, body);
-
-      match error {
-        Seedance2ProError::ApiSpecific(
-          Seedance2ProSpecificApiError::BillingError { .. }
-        ) => {}
-        other => panic!("Expected BillingError, got: {:?}", other),
+    match error {
+      Seedance2ProError::ApiSpecific(
+        Seedance2ProSpecificApiError::BillingError { status_code, body }
+      ) => {
+        assert_eq!(status_code, StatusCode::BAD_REQUEST);
+        assert!(body.contains("credits not enough"));
      }
+      other => panic!("Expected BillingError, got: {:?}", other),
    }
  }

-  mod bad_request_tests {
-    use super::*;
+  #[test]
+  fn billing_error_case_insensitive() {
+    let body = r#"{"error":"Credits Not Enough"}"#.to_string();

-    #[test]
-    fn real_prompt_too_long_response() {
-      let body = read_response_body("prompt_too_long.json");
+    let error = categorize_seedance2pro_error(StatusCode::BAD_REQUEST, body);

-      let error = categorize_seedance2pro_error(StatusCode::BAD_REQUEST, body);
-
-      match error {
-        Seedance2ProError::ApiBadRequest(
-          Seedance2ProBadRequestApiError::PromptIsTooLong { raw_body }
-        ) => {
-          assert!(raw_body.contains("String must contain at most 10000 character(s)"));
-          assert!(raw_body.contains("\"prompt\""));
-        }
-        other => panic!("Expected PromptIsTooLong, got: {:?}", other),
-      }
-    }
-
-    #[test]
-    fn real_too_many_urls_response() {
-      let body = read_response_body("too_many_urls.json");
-
-      let error = categorize_seedance2pro_error(StatusCode::BAD_REQUEST, body);
-
-      match error {
-        Seedance2ProError::ApiBadRequest(
-          Seedance2ProBadRequestApiError::TooManyUrls { raw_body }
-        ) => {
-          assert!(raw_body.contains("Array must contain at most 9 element(s)"));
-          assert!(raw_body.contains("\"uploadedUrls\""));
-        }
-        other => panic!("Expected TooManyUrls, got: {:?}", other),
-      }
-    }
-
-    #[test]
-    fn bad_request_markers_require_400_status() {
-      let body = read_response_body("prompt_too_long.json");
-
-      let error = categorize_seedance2pro_error(StatusCode::INTERNAL_SERVER_ERROR, body);
-
-      match error {
-        Seedance2ProError::ApiGeneric(
-          Seedance2ProGenericApiError::UncategorizedBadResponseWithStatusAndBody { .. }
-        ) => {}
-        other => panic!("Expected UncategorizedBadResponseWithStatusAndBody, got: {:?}", other),
-      }
-    }
-
-    #[test]
-    fn validation_failure_for_other_field_is_not_categorized() {
-      // Same zod shape, but for a field we don't have a variant for.
-      let body = r#"[{"error":{"json":{"message":"validation failed - String must contain at most 100 character(s)","code":-32600,"data":{"code":"BAD_REQUEST","httpStatus":400,"zodError":{"formErrors":[],"fieldErrors":{"apiParams":[{"code":"custom","message":"String must contain at most 100 character(s)","path":["apiParams","negativePrompt"],"fatal":true}]}}}}}]"#.to_string();
-
-      let error = categorize_seedance2pro_error(StatusCode::BAD_REQUEST, body);
-
-      match error {
-        Seedance2ProError::ApiGeneric(
-          Seedance2ProGenericApiError::UncategorizedBadResponseWithStatusAndBody { .. }
-        ) => {}
-        other => panic!("Expected UncategorizedBadResponseWithStatusAndBody, got: {:?}", other),
-      }
+    match error {
+      Seedance2ProError::ApiSpecific(
+        Seedance2ProSpecificApiError::BillingError { .. }
+      ) => {}
+      other => panic!("Expected BillingError, got: {:?}", other),
    }
  }

-  mod fallback_tests {
-    use super::*;
+  #[test]
+  fn unknown_error_falls_back_to_uncategorized() {
+    let body = r#"{"error":"something else went wrong"}"#.to_string();

-    #[test]
-    fn unknown_error_falls_back_to_uncategorized() {
-      let body = r#"{"error":"something else went wrong"}"#.to_string();
+    let error = categorize_seedance2pro_error(
+      StatusCode::INTERNAL_SERVER_ERROR,
+      body.clone(),
+    );

-      let error = categorize_seedance2pro_error(
-        StatusCode::INTERNAL_SERVER_ERROR,
-        body.clone(),
-      );
-
-      match error {
-        Seedance2ProError::ApiGeneric(
-          Seedance2ProGenericApiError::UncategorizedBadResponseWithStatusAndBody { status_code, body: b }
-        ) => {
-          assert_eq!(status_code, StatusCode::INTERNAL_SERVER_ERROR);
-          assert_eq!(b, body);
-        }
-        other => panic!("Expected UncategorizedBadResponseWithStatusAndBody, got: {:?}", other),
-      }
-    }
-
-    #[test]
-    fn empty_body_falls_back_to_uncategorized() {
-      let error = categorize_seedance2pro_error(
-        StatusCode::BAD_REQUEST,
-        String::new(),
-      );
-
-      match error {
-        Seedance2ProError::ApiGeneric(
-          Seedance2ProGenericApiError::UncategorizedBadResponseWithStatusAndBody { .. }
-        ) => {}
-        other => panic!("Expected UncategorizedBadResponseWithStatusAndBody, got: {:?}", other),
+    match error {
+      Seedance2ProError::ApiGeneric(
+        Seedance2ProGenericApiError::UncategorizedBadResponseWithStatusAndBody { status_code, body: b }
+      ) => {
+        assert_eq!(status_code, StatusCode::INTERNAL_SERVER_ERROR);
+        assert_eq!(b, body);
      }
+      other => panic!("Expected UncategorizedBadResponseWithStatusAndBody, got: {:?}", other),
    }
  }

-  fn read_response_body(filename: &str) -> String {
-    std::fs::read_to_string(format!("test_data/responses/{}", filename))
-        .expect("Failed to read test data file")
+  #[test]
+  fn empty_body_falls_back_to_uncategorized() {
+    let error = categorize_seedance2pro_error(
+      StatusCode::BAD_REQUEST,
+      String::new(),
+    );
+
+    match error {
+      Seedance2ProError::ApiGeneric(
+        Seedance2ProGenericApiError::UncategorizedBadResponseWithStatusAndBody { .. }
+      ) => {}
+      other => panic!("Expected UncategorizedBadResponseWithStatusAndBody, got: {:?}", other),
+    }
  }
 }
@@ -1,40 +0,0 @@
-[
-  {
-    "error": {
-      "json": {
-        "message": "[{\"code\": \"custom\",\"message\": \"参数验证失败 - String must contain at most 10000 character(s)\",\"path\": [\"apiParams\",\"prompt\"],\"fatal\": true}]",
-        "code": -32600,
-        "data": {
-          "code": "BAD_REQUEST",
-          "httpStatus": 400,
-          "path": "workflow.runTask",
-          "zodError": {
-            "formErrors": [],
-            "fieldErrors": {
-              "apiParams": [
-                {
-                  "code": "custom",
-                  "message": "参数验证失败 - String must contain at most 10000 character(s)",
-                  "path": [
-                    "apiParams",
-                    "prompt"
-                  ],
-                  "fatal": true
-                }
-              ]
-            }
-          }
-        },
-        "stack": null
-      },
-      "meta": {
-        "values": {
-          "stack": [
-            "undefined"
-          ]
-        },
-        "v": 1
-      }
-    }
-  }
-]
@@ -1,40 +0,0 @@
-[
-  {
-    "error": {
-      "json": {
-        "message": "[{\"code\": \"custom\",\"message\": \"参数验证失败 - Array must contain at most 9 element(s)\",\"path\": [\"apiParams\",\"uploadedUrls\"],\"fatal\": true}]",
-        "code": -32600,
-        "data": {
-          "code": "BAD_REQUEST",
-          "httpStatus": 400,
-          "path": "workflow.runTask",
-          "zodError": {
-            "formErrors": [],
-            "fieldErrors": {
-              "apiParams": [
-                {
-                  "code": "custom",
-                  "message": "参数验证失败 - Array must contain at most 9 element(s)",
-                  "path": [
-                    "apiParams",
-                    "uploadedUrls"
-                  ],
-                  "fatal": true
-                }
-              ]
-            }
-          }
-        },
-        "stack": null
-      },
-      "meta": {
-        "values": {
-          "stack": [
-            "undefined"
-          ]
-        },
-        "v": 1
-      }
-    }
-  }
-]
@@ -136,12 +136,12 @@ struct RawResponse {
 #[cfg(test)]
 mod tests {
  use crate::api::api_types::upload_object_id::UploadObjectId;
-  use crate::api::requests::objects::begin_object_image_upload::{get_url, BASE_URL};
+  use crate::api::requests::objects::begin_object_image_upload::get_url;

  #[test]
  fn test_get_url() {
    let upload_id = UploadObjectId("foo-bar-baz-bin".to_string());
-    let expected = format!("{}/foo-bar-baz-bin:upload", BASE_URL);
+    let expected = "https://marble2-kgw-prod-iac1.wlt-ai.art/api/v1/objects/foo-bar-baz-bin:upload";
    assert_eq!(get_url(&upload_id), expected);
  }
 }
@@ -147,9 +147,6 @@ mod tests {
  #[test]
  fn test_request() {
    let request = RawRequest::for_mime_type(UploadMimeType::ImageJpeg);
-    // The display name embeds a random uuid, eg. "uploaded_image_{uuid}.jpeg"
-    assert!(request.display_name.starts_with("uploaded_image_"));
-    assert!(request.display_name.ends_with(".jpeg"));
-    assert_eq!(request.mime_type, "image/jpeg");
+    assert_eq!(request.display_name, "uploaded_image_jpeg");
  }
 }
@@ -135,7 +135,7 @@ struct RawResponse {
 #[cfg(test)]
 mod tests {
  use crate::api::api_types::upload_object_id::UploadObjectId;
-  use crate::api::requests::objects::finalize_object_image_upload::{finalize_object_image_upload, get_url, FinalizeObjectImageUploadArgs, BASE_URL};
+  use crate::api::requests::objects::finalize_object_image_upload::{finalize_object_image_upload, get_url, FinalizeObjectImageUploadArgs};
  use crate::test_utils::get_test_bearer_token::get_test_bearer_token;
  use crate::test_utils::get_test_cookies::get_typed_test_cookies;
  use crate::test_utils::setup_test_logging::setup_test_logging;
@@ -144,7 +144,7 @@ mod tests {
  #[test]
  fn test_get_url() {
    let upload_id = UploadObjectId("foo-bar-baz-bin".to_string());
-    let expected = format!("{}/foo-bar-baz-bin:complete", BASE_URL);
+    let expected = "https://marble2-kgw-prod-iac1.wlt-ai.art/api/v1/objects/foo-bar-baz-bin:complete";
    assert_eq!(get_url(&upload_id), expected);
  }

@@ -405,10 +405,6 @@ mod tests {
  use crate::api::api_types::pano_object_id::PanoObjectId;
  use crate::api::api_types::run_object_id::RunObjectId;
  use crate::api::requests::objects::update_run_object_with_upload::{RawRequest, UpdateRunObjectWithUploadPayloadArgs};
-  use serde_json::{json, Value};
-
-  /// Any timestamp from `Utc::now()` should exceed this (2023-11-14 in epoch millis).
-  const MIN_PLAUSIBLE_EPOCH_MILLIS: u64 = 1_700_000_000_000;

  #[test]
  fn request_default() {
@@ -436,88 +432,9 @@ mod tests {

    let request = RawRequest::from_args(&args);

-    // The `createdAt` / `updatedAt` timestamps come from `Utc::now()` at build time,
-    // so they're nondeterministic. Sanity-check them, then zero them out before
-    // comparing the rest of the document.
-    assert!(request.object.metadata.created_at > MIN_PLAUSIBLE_EPOCH_MILLIS);
-    assert!(request.object.metadata.updated_at >= request.object.metadata.created_at);
+    let json = serde_json::to_string_pretty(&request).unwrap();
+    println!("{}", json);

-    let mut actual = serde_json::to_value(&request).unwrap();
-    zero_out_timestamps(&mut actual);
-
-    let expected = json!({
-      "object": {
-        "metadata": {
-          "version": "0.0.1",
-          "createdAt": 0,
-          "updatedAt": 0,
-          "usesAdvancedEditing": false,
-          "draftMode": false,
-          "nodes": {
-            "bc17252b-811e-49d7-be3e-b7c538df9d30": {
-              "id": "bc17252b-811e-49d7-be3e-b7c538df9d30",
-              "type": "input",
-              "parentId": null,
-              "source": {
-                "type": "image",
-                "image_url": "https://todo.com"
-              },
-              "createdAt": 0
-            },
-            "82f6b488-8afe-4311-9022-80ad5789ad92": {
-              "id": "82f6b488-8afe-4311-9022-80ad5789ad92",
-              "type": "pano",
-              "parentId": "bc17252b-811e-49d7-be3e-b7c538df9d30",
-              "source": {
-                "type": "generate_world",
-                "world_id": "pending",
-                "status": "pending"
-              },
-              "createdAt": 0
-            },
-            "f08ec501-601c-47c6-a104-402d1820b8f0": {
-              "id": "f08ec501-601c-47c6-a104-402d1820b8f0",
-              "type": "world",
-              "parentId": "82f6b488-8afe-4311-9022-80ad5789ad92",
-              "source": {
-                "type": "generate_world",
-                "world_id": "pending",
-                "posed_cubemaps_url": "",
-                "minimap_url": "",
-                "minimap_metadata": "",
-                "status": "pending"
-              },
-              "createdAt": 0
-            }
-          }
-        }
-      },
-      "update_mask": [
-        "metadata"
-      ]
-    });
-
-    assert_eq!(actual, expected);
-  }
-
-  /// Recursively replaces nondeterministic `createdAt` / `updatedAt` values with 0.
-  fn zero_out_timestamps(value: &mut Value) {
-    match value {
-      Value::Object(map) => {
-        for (key, child) in map.iter_mut() {
-          if key == "createdAt" || key == "updatedAt" {
-            *child = json!(0);
-          } else {
-            zero_out_timestamps(child);
-          }
-        }
-      },
-      Value::Array(items) => {
-        for item in items.iter_mut() {
-          zero_out_timestamps(item);
-        }
-      },
-      _ => {},
-    }
+    assert_eq!(json, r#"{"type":"abcxyz_image_input_id","value":"image_input_id"}"#);
  }
 }
@@ -411,10 +411,6 @@ mod tests {
  use crate::api::api_types::meta_world_object_id::MetaWorldObjectId;
  use crate::api::api_types::world_id::WorldObjectId;
  use crate::api::requests::objects::update_run_object_with_world::{RawRequest, UpdateRunObjectWithWorldPayloadArgs};
-  use serde_json::{json, Value};
-
-  /// Any timestamp from `Utc::now()` should exceed this (2023-11-14 in epoch millis).
-  const MIN_PLAUSIBLE_EPOCH_MILLIS: u64 = 1_700_000_000_000;

  #[test]
  fn request_default() {
@@ -450,91 +446,9 @@ mod tests {

    let request = RawRequest::from_args(&args);

-    // The `createdAt` / `updatedAt` timestamps come from `Utc::now()` at build time,
-    // so they're nondeterministic. Sanity-check them, then zero them out before
-    // comparing the rest of the document.
-    assert!(request.object.metadata.created_at > MIN_PLAUSIBLE_EPOCH_MILLIS);
-    assert!(request.object.metadata.updated_at >= request.object.metadata.created_at);
+    let json = serde_json::to_string_pretty(&request).unwrap();
+    println!("{}", json);

-    let mut actual = serde_json::to_value(&request).unwrap();
-    zero_out_timestamps(&mut actual);
-
-    let expected = json!({
-      "object": {
-        "metadata": {
-          "version": "0.0.1",
-          "name": title,
-          "createdAt": 0,
-          "updatedAt": 0,
-          "usesAdvancedEditing": false,
-          "draftMode": false,
-          "nodes": {
-            "bc17252b-811e-49d7-be3e-b7c538df9d30": {
-              "id": "bc17252b-811e-49d7-be3e-b7c538df9d30",
-              "type": "input",
-              "parentId": null,
-              "source": {
-                "type": "image",
-                "image_url": "https://cdn.marble.worldlabs.ai/object/13ca760c-8ef9-4bf5-acc3-5a507fad3abf/asset.jpg"
-              },
-              "createdAt": 0,
-              "title": title,
-              "caption": caption
-            },
-            "82f6b488-8afe-4311-9022-80ad5789ad92": {
-              "id": "82f6b488-8afe-4311-9022-80ad5789ad92",
-              "type": "pano",
-              "parentId": "bc17252b-811e-49d7-be3e-b7c538df9d30",
-              "source": {
-                "type": "generate_world",
-                "world_id": "d60cfa21-5506-43de-9a9c-0707fc17a5ec",
-                "status": "pending"
-              },
-              "createdAt": 0
-            },
-            "f08ec501-601c-47c6-a104-402d1820b8f0": {
-              "id": "f08ec501-601c-47c6-a104-402d1820b8f0",
-              "type": "world",
-              "parentId": "82f6b488-8afe-4311-9022-80ad5789ad92",
-              "source": {
-                "type": "generate_world",
-                "world_id": "d60cfa21-5506-43de-9a9c-0707fc17a5ec",
-                "posed_cubemaps_url": "",
-                "minimap_url": "",
-                "minimap_metadata": "",
-                "status": "pending"
-              },
-              "createdAt": 0
-            }
-          }
-        }
-      },
-      "update_mask": [
-        "metadata"
-      ]
-    });
-
-    assert_eq!(actual, expected);
-  }
-
-  /// Recursively replaces nondeterministic `createdAt` / `updatedAt` values with 0.
-  fn zero_out_timestamps(value: &mut Value) {
-    match value {
-      Value::Object(map) => {
-        for (key, child) in map.iter_mut() {
-          if key == "createdAt" || key == "updatedAt" {
-            *child = json!(0);
-          } else {
-            zero_out_timestamps(child);
-          }
-        }
-      },
-      Value::Array(items) => {
-        for item in items.iter_mut() {
-          zero_out_timestamps(item);
-        }
-      },
-      _ => {},
-    }
+    assert_eq!(json, r#"{"type":"abcxyz_image_input_id","value":"image_input_id"}"#);
  }
 }
@@ -151,7 +151,7 @@ struct SpzUrls {
 #[cfg(test)]
 mod tests {
  use crate::api::api_types::world_id::WorldObjectId;
-  use crate::api::requests::worlds::poll_world_status::{get_url, poll_world_status, PollWorldStatusArgs, BASE_URL};
+  use crate::api::requests::worlds::poll_world_status::{get_url, poll_world_status, PollWorldStatusArgs};
  use crate::test_utils::get_test_bearer_token::get_test_bearer_token;
  use crate::test_utils::get_test_cookies::get_typed_test_cookies;
  use crate::test_utils::setup_test_logging::setup_test_logging;
@@ -160,7 +160,7 @@ mod tests {
  #[test]
  fn test_get_url() {
    let world_id = WorldObjectId("d60cfa21-5506-43de-9a9c-0707fc17a5ec".to_string());
-    let expected = format!("{}/d60cfa21-5506-43de-9a9c-0707fc17a5ec", BASE_URL);
+    let expected = "https://marble2-kgw-prod-iac1.wlt-ai.art/api/v1/worlds/d60cfa21-5506-43de-9a9c-0707fc17a5ec";
    assert_eq!(get_url(&world_id), expected);
  }

@@ -407,7 +407,6 @@ mod tests {
  }

  #[test]
-  #[ignore] // Transliteration for the time-bombed characters (α, đ, ß) was never implemented.
  pub fn most_frequent_failures_2p5k_usages() {
    assert_converted("～", "~"); // b'\\uff5e' 2507
    time_bomb_ignore(|| assert_converted("â", "a")); // b'\xe2' 2607
@@ -430,7 +429,6 @@ mod tests {
  }

  #[test]
-  #[ignore] // Transliteration for the time-bombed characters (ę, ě, ᴾ, ł) was never implemented.
  pub fn most_frequent_failures_2k_usages() {
    assert_converted("、", ","); // b'\\u3001' 2001
    assert_converted("ć", "c"); // b'\\u0107' 2017
@@ -444,7 +442,6 @@ mod tests {
  }

  #[test]
-  #[ignore] // Transliteration for the time-bombed characters (ū, ι, ε) was never implemented.
  pub fn most_frequent_failures_1p5k_usages() {
    assert_converted("·", " "); // b'\xb7' 1514
    assert_converted("š", "s"); // b'\\u0161' 1514
@@ -1,50 +0,0 @@
-use sqlx::pool::PoolConnection;
-use sqlx::MySql;
-
-use enums::common::payments_namespace::PaymentsNamespace;
-use tokens::tokens::users::UserToken;
-
-use crate::queries::users::user_stripe_customer_links::find_user_stripe_customer_link::UserStripeCustomerLink;
-
-/// List every stripe customer link for a user, across all payments namespaces.
-/// Users have at most one link per namespace.
-pub async fn list_user_stripe_customer_links_for_user(
-  user_token: &UserToken,
-  connection: &mut PoolConnection<MySql>,
-) -> Result<Vec<UserStripeCustomerLink>, sqlx::Error> {
-  let records = sqlx::query_as!(
-    RawUserStripeCustomerLink,
-    r#"
-SELECT
-  user_token as `user_token: tokens::tokens::users::UserToken`,
-  payments_namespace as `payments_namespace: enums::common::payments_namespace::PaymentsNamespace`,
-  stripe_customer_id
-
-FROM user_stripe_customer_links
-
-WHERE user_token = ?
-ORDER BY id ASC
-    "#,
-    user_token.as_str(),
-  )
-      .fetch_all(&mut **connection)
-      .await?;
-
-  let links = records
-      .into_iter()
-      .map(|record| UserStripeCustomerLink {
-        user_token: record.user_token,
-        payments_namespace: record.payments_namespace,
-        stripe_customer_id: record.stripe_customer_id,
-      })
-      .collect();
-
-  Ok(links)
-}
-
-#[derive(sqlx::FromRow)]
-struct RawUserStripeCustomerLink {
-  user_token: UserToken,
-  payments_namespace: PaymentsNamespace,
-  stripe_customer_id: String,
-}
@@ -1,3 +1,2 @@
 pub mod find_user_stripe_customer_link;
-pub mod list_user_stripe_customer_links_for_user;
-pub mod upsert_user_stripe_customer_link;
+pub mod upsert_user_stripe_customer_link;
@@ -1,40 +0,0 @@
-use sqlx::pool::PoolConnection;
-use sqlx::MySql;
-
-use enums::common::payments_namespace::PaymentsNamespace;
-use tokens::tokens::users::UserToken;
-
-/// A distinct stripe customer id attached to one of the user's subscriptions.
-pub struct UserSubscriptionStripeCustomerId {
-  pub subscription_namespace: PaymentsNamespace,
-  pub stripe_customer_id: String,
-}
-
-/// List the distinct stripe customer ids across all of a user's subscriptions
-/// (current and historical), across all payments namespaces.
-pub async fn list_stripe_customer_ids_for_user_subscriptions(
-  user_token: &UserToken,
-  connection: &mut PoolConnection<MySql>,
-) -> Result<Vec<UserSubscriptionStripeCustomerId>, sqlx::Error> {
-  let records = sqlx::query_as!(
-    UserSubscriptionStripeCustomerId,
-    r#"
-SELECT DISTINCT
-  subscription_namespace as `subscription_namespace: enums::common::payments_namespace::PaymentsNamespace`,
-  maybe_stripe_customer_id as `stripe_customer_id!`
-
-FROM user_subscriptions
-
-WHERE
-  user_token = ?
-  AND maybe_stripe_customer_id IS NOT NULL
-  AND deleted_at IS NULL
-ORDER BY subscription_namespace ASC, maybe_stripe_customer_id ASC
-    "#,
-    user_token.as_str(),
-  )
-      .fetch_all(&mut **connection)
-      .await?;
-
-  Ok(records)
-}
@@ -1,8 +1,7 @@
 pub mod find_possibly_inactive_first_subscription_for_owner_user;
+pub mod lookup_users_by_stripe_customer_id;
 pub mod find_subscription_for_owner_user;
 pub mod get_user_subscription_by_stripe_subscription_id;
 pub mod list_active_user_subscriptions;
-pub mod list_stripe_customer_ids_for_user_subscriptions;
-pub mod lookup_users_by_stripe_customer_id;
 pub mod upsert_user_subscription_by_stripe_id;
 pub mod upsert_user_subscription_with_invoice_paid_status_by_stripe_id;
@@ -222,15 +222,14 @@ mod tests {
      assert_eq!(variants.pop_first(), Some(MediaFileOriginModelType::LivePortrait));
      assert_eq!(variants.pop_first(), Some(MediaFileOriginModelType::RvcV2));
      assert_eq!(variants.pop_first(), Some(MediaFileOriginModelType::SadTalker));
+      assert_eq!(variants.pop_first(), Some(MediaFileOriginModelType::SeedVc));
      assert_eq!(variants.pop_first(), Some(MediaFileOriginModelType::SoVitsSvc));
      assert_eq!(variants.pop_first(), Some(MediaFileOriginModelType::Tacotron2));
      assert_eq!(variants.pop_first(), Some(MediaFileOriginModelType::MocapNet));
-      assert_eq!(variants.pop_first(), Some(MediaFileOriginModelType::SeedVc));
      assert_eq!(variants.pop_first(), Some(MediaFileOriginModelType::StyleTTS2));
      assert_eq!(variants.pop_first(), Some(MediaFileOriginModelType::StableDiffusion15));
      assert_eq!(variants.pop_first(), Some(MediaFileOriginModelType::GptSovits));
      assert_eq!(variants.pop_first(), Some(MediaFileOriginModelType::StorytellerStudio));
-      assert_eq!(variants.pop_first(), Some(MediaFileOriginModelType::StorytellerStudioImageGen));
      assert_eq!(variants.pop_first(), Some(MediaFileOriginModelType::VideoStyleTransfer));
      assert_eq!(variants.pop_first(), Some(MediaFileOriginModelType::ComfyUi));
      assert_eq!(variants.pop_first(), Some(MediaFileOriginModelType::VallEX));
@@ -117,9 +117,7 @@ mod tests {
    fn test_serialization() {
      assert_serialization(PromptContextSemanticType::VidStartFrame, "vid_start_frame");
      assert_serialization(PromptContextSemanticType::VidEndFrame, "vid_end_frame");
-      // NB: serde serialization ("vid_ref") intentionally differs from to_str()/the DB value
-      // ("vidref"); see the "Current DB values" comment at the top of this file.
-      assert_serialization(PromptContextSemanticType::VidRef, "vid_ref");
+      assert_serialization(PromptContextSemanticType::VidRef, "vidref");
      assert_serialization(PromptContextSemanticType::Imgsrc, "imgsrc");
      assert_serialization(PromptContextSemanticType::Imgmask, "imgmask");
      assert_serialization(PromptContextSemanticType::Imgref, "imgref");
@@ -127,7 +127,7 @@ mod tests {
      {"id":"sub_1LhA3MEU5se17MekeWvmTNyk","automatic_tax":{"enabled":false},
      "billing_cycle_anchor":1662979188,"cancel_at_period_end":false,
      "collection_method":"charge_automatically","created":1662979188,"current_period_end":1665571188,
-      "current_period_start":1662979188,"customer":"cus_MQ03py0gWUh0Ox","currency":"usd","default_tax_rates":[],
+      "current_period_start":1662979188,"customer":"cus_MQ03py0gWUh0Ox","default_tax_rates":[],
      "items":{"data":[{"id":"si_MQ03hadVNfRnaS","created":1662979188,"deleted":false,"metadata":{},
      "price":{"id":"price_1LeDnKEU5se17MekVr1iYYNf","active":true,"billing_scheme":"per_unit",
      "created":1662278586,"currency":"usd","deleted":false,"livemode":false,"metadata":{},
@@ -172,7 +172,7 @@ mod tests {
      "cancel_at_period_end":false,"collection_method":"charge_automatically","created":1662948037,
      "current_period_end":1665540037,"current_period_start":1662948037,
      "customer":"cus_MPrgIen5Wh6QKG",
-      "default_payment_method":"pm_1Lh1wtEU5se17MekpirKtMJm","currency":"usd","default_tax_rates":[],
+      "default_payment_method":"pm_1Lh1wtEU5se17MekpirKtMJm","default_tax_rates":[],
      "items":{"data":[{"id":"si_MPrgTAV333Nq7c","created":1662948037,"deleted":false,"metadata":{},
      "price":{"id":"price_1LeDnKEU5se17MekVr1iYYNf","active":true,"billing_scheme":"per_unit",
      "created":1662278586,"currency":"usd","deleted":false,"livemode":false,"metadata":{},
@@ -216,7 +216,7 @@ mod tests {
      "billing_cycle_anchor":1662979188,"cancel_at_period_end":false,"canceled_at":1662979740,
      "collection_method":"charge_automatically","created":1662979188,"current_period_end":1665571188,
      "current_period_start":1662979188,"customer":"cus_MQ03py0gWUh0Ox",
-      "default_payment_method":"pm_1LhA3LEU5se17MekViNvoYAx","currency":"usd","default_tax_rates":[],
+      "default_payment_method":"pm_1LhA3LEU5se17MekViNvoYAx","default_tax_rates":[],
      "ended_at":1662979740,"items":{"data":[{"id":"si_MQ03hadVNfRnaS","created":1662979188,
      "deleted":false,"metadata":{},"price":{"id":"price_1LeDnKEU5se17MekVr1iYYNf","active":true,
      "billing_scheme":"per_unit","created":1662278586,"currency":"usd","deleted":false,
@@ -127,11 +127,8 @@ mod tests {
      {"id":"sub_1LhA3MEU5se17MekeWvmTNyk","automatic_tax":{"enabled":false},
      "billing_cycle_anchor":1662979188,"cancel_at_period_end":false,
      "collection_method":"charge_automatically","created":1662979188,"current_period_end":1665571188,
-      "current_period_start":1662979188,"customer":"cus_MQ03py0gWUh0Ox","currency":"usd","default_tax_rates":[],"discounts":[],
-      "invoice_settings":{"issuer":{"type":"self"}},
-      "items":{"data":[{"id":"si_MQ03hadVNfRnaS","created":1662979188,"current_period_end":1665571188,
-      "current_period_start":1662979188,"deleted":false,"discounts":[],
-      "plan":{"id":"price_1LeDnKEU5se17MekVr1iYYNf","object":"plan","active":true,"amount":700,"amount_decimal":"700","billing_scheme":"per_unit","created":1662278586,"currency":"usd","interval":"month","interval_count":1,"livemode":false,"metadata":{},"product":"prod_MMxi2J5y69VPbO","usage_type":"licensed"},"metadata":{},
+      "current_period_start":1662979188,"customer":"cus_MQ03py0gWUh0Ox","default_tax_rates":[],
+      "items":{"data":[{"id":"si_MQ03hadVNfRnaS","created":1662979188,"deleted":false,"metadata":{},
      "price":{"id":"price_1LeDnKEU5se17MekVr1iYYNf","active":true,"billing_scheme":"per_unit",
      "created":1662278586,"currency":"usd","deleted":false,"livemode":false,"metadata":{},
      "product":"prod_MMxi2J5y69VPbO","recurring":{"interval":"month","interval_count":1,
@@ -175,11 +172,8 @@ mod tests {
      "cancel_at_period_end":false,"collection_method":"charge_automatically","created":1662948037,
      "current_period_end":1665540037,"current_period_start":1662948037,
      "customer":"cus_MPrgIen5Wh6QKG",
-      "default_payment_method":"pm_1Lh1wtEU5se17MekpirKtMJm","currency":"usd","default_tax_rates":[],"discounts":[],
-      "invoice_settings":{"issuer":{"type":"self"}},
-      "items":{"data":[{"id":"si_MPrgTAV333Nq7c","created":1662948037,"current_period_end":1665540037,
-      "current_period_start":1662948037,"deleted":false,"discounts":[],
-      "plan":{"id":"price_1LeDnKEU5se17MekVr1iYYNf","object":"plan","active":true,"amount":700,"amount_decimal":"700","billing_scheme":"per_unit","created":1662278586,"currency":"usd","interval":"month","interval_count":1,"livemode":false,"metadata":{},"product":"prod_MMxi2J5y69VPbO","usage_type":"licensed"},"metadata":{},
+      "default_payment_method":"pm_1Lh1wtEU5se17MekpirKtMJm","default_tax_rates":[],
+      "items":{"data":[{"id":"si_MPrgTAV333Nq7c","created":1662948037,"deleted":false,"metadata":{},
      "price":{"id":"price_1LeDnKEU5se17MekVr1iYYNf","active":true,"billing_scheme":"per_unit",
      "created":1662278586,"currency":"usd","deleted":false,"livemode":false,"metadata":{},
      "product":"prod_MMxi2J5y69VPbO","recurring":{"interval":"month","interval_count":1,
@@ -222,12 +216,9 @@ mod tests {
      "billing_cycle_anchor":1662979188,"cancel_at_period_end":false,"canceled_at":1662979740,
      "collection_method":"charge_automatically","created":1662979188,"current_period_end":1665571188,
      "current_period_start":1662979188,"customer":"cus_MQ03py0gWUh0Ox",
-      "default_payment_method":"pm_1LhA3LEU5se17MekViNvoYAx","currency":"usd","default_tax_rates":[],"discounts":[],
-      "invoice_settings":{"issuer":{"type":"self"}},
+      "default_payment_method":"pm_1LhA3LEU5se17MekViNvoYAx","default_tax_rates":[],
      "ended_at":1662979740,"items":{"data":[{"id":"si_MQ03hadVNfRnaS","created":1662979188,
-      "current_period_end":1665571188,"current_period_start":1662979188,
-      "deleted":false,"discounts":[],
-      "plan":{"id":"price_1LeDnKEU5se17MekVr1iYYNf","object":"plan","active":true,"amount":700,"amount_decimal":"700","billing_scheme":"per_unit","created":1662278586,"currency":"usd","interval":"month","interval_count":1,"livemode":false,"metadata":{},"product":"prod_MMxi2J5y69VPbO","usage_type":"licensed"},"metadata":{},"price":{"id":"price_1LeDnKEU5se17MekVr1iYYNf","active":true,
+      "deleted":false,"metadata":{},"price":{"id":"price_1LeDnKEU5se17MekVr1iYYNf","active":true,
      "billing_scheme":"per_unit","created":1662278586,"currency":"usd","deleted":false,
      "livemode":false,"metadata":{},"product":"prod_MMxi2J5y69VPbO",
      "recurring":{"interval":"month","interval_count":1,"usage_type":"licensed"},
@@ -292,14 +283,7 @@ mod tests {
        ],
        "description": null,
        "discount": null,
-        "discounts": [
-        ],
        "ended_at": null,
-        "invoice_settings": {
-          "issuer": {
-            "type": "self"
-          }
-        },
        "items": {
          "object": "list",
          "data": [
@@ -308,9 +292,6 @@ mod tests {
              "object": "subscription_item",
              "billing_thresholds": null,
              "created": 1663430298,
-              "current_period_end": 1666022298,
-              "current_period_start": 1663430298,
-              "discounts": [],
              "metadata": {
              },
              "plan": {
@@ -2,8 +2,6 @@ use stripe::Client;

 #[derive(Clone)]
 pub struct ArtcraftStripeConfig {
-  /// The Stripe account id (eg. "acct_..."), used to build dashboard links.
-  pub stripe_account_id: String,
  pub secret_key: String,
  pub secret_webhook_signing_key: String,
  pub checkout_success_url: String,
@@ -13,8 +11,6 @@ pub struct ArtcraftStripeConfig {

 #[derive(Clone)]
 pub struct ArtcraftStripeConfigWithClient {
-  /// The Stripe account id (eg. "acct_..."), used to build dashboard links.
-  pub stripe_account_id: String,
  pub secret_key: String,
  pub secret_webhook_signing_key: String,
  pub checkout_success_url: String,
@@ -26,7 +22,6 @@ pub struct ArtcraftStripeConfigWithClient {
 impl ArtcraftStripeConfig {
  pub fn to_config_with_client(&self) -> ArtcraftStripeConfigWithClient {
    ArtcraftStripeConfigWithClient {
-      stripe_account_id: self.stripe_account_id.clone(),
      secret_key: self.secret_key.clone(),
      secret_webhook_signing_key: self.secret_webhook_signing_key.clone(),
      checkout_success_url: self.checkout_success_url.clone(),
@@ -117,7 +117,6 @@ use artcraft_api_defs::folders::media_files::*;
 use artcraft_api_defs::folders::subfolder::*;
 use artcraft_api_defs::moderation::user_referrals::list_global_user_referrals::*;
 use artcraft_api_defs::moderation::user_referrals::list_user_referrals_for_user::*;
-use artcraft_api_defs::moderation::user_stripe_data::moderator_get_user_stripe_customer_ids::*;
 use crate::http_server::endpoints::moderation::user_sessions::moderator_list_user_session_impersonation_requests_for_user_handler::*;
 use crate::http_server::endpoints::moderation::user_sessions::moderator_list_user_session_impersonation_requests_handler::*;
 use crate::http_server::endpoints::moderation::user_sessions::moderator_user_session_impersonation_request_handler::*;
@@ -559,7 +558,6 @@ use crate::http_server::endpoints::media_files::list::list_batch_generated_redux
    crate::http_server::endpoints::moderation::user_bans::moderation_ban_user_handler::moderation_ban_user_handler,
    crate::http_server::endpoints::moderation::user_emails::moderator_change_user_email_handler::moderator_change_user_email_handler,
    crate::http_server::endpoints::moderation::user_emails::moderator_list_email_address_changes_for_user_handler::moderator_list_email_address_changes_for_user_handler,
-    crate::http_server::endpoints::moderation::user_stripe_data::moderator_get_user_stripe_customer_ids_handler::moderator_get_user_stripe_customer_ids_handler,

    // Folders
    crate::http_server::endpoints::folders::folder::create_folder_handler::create_folder_handler,
@@ -818,10 +816,6 @@ use crate::http_server::endpoints::media_files::list::list_batch_generated_redux
    ModeratorGetWalletLedgerEntryPathInfo,
    ModeratorGetWalletLedgerEntryResponse,
    ModeratorGetWalletLedgerEntryDetails,
-    ModeratorGetUserStripeCustomerIdsPathInfo,
-    ModeratorGetUserStripeCustomerIdsResponse,
-    ModeratorUserStripeCustomerIdEntry,
-    ModeratorStripeCustomerIdSource,
    GptImage1EditImageRequest,
    GptImage1EditImageImageSize,
    GptImage1EditImageNumImages,
@@ -123,14 +123,14 @@ mod tests {

    assert_eq!(cover_image.maybe_cover_image_public_bucket_path, Some("/media/b/u/c/k/e/bucket_hash/image_bucket_hash.png".to_string()));
    assert_eq!(cover_image.maybe_cover_image_public_bucket_url,
-               Some(Url::parse("https://cdn-2.fakeyou.com/media/b/u/c/k/e/bucket_hash/image_bucket_hash.png").unwrap()));
+               Some(Url::parse("https://storage.googleapis.com/vocodes-public/media/b/u/c/k/e/bucket_hash/image_bucket_hash.png").unwrap()));
    assert_eq!(cover_image.default_cover.image_index, 18);

    let links = cover_image.maybe_links.unwrap();

    assert_eq!(links.cdn_url, Url::parse(
-      "https://cdn-2.fakeyou.com/media/b/u/c/k/e/bucket_hash/image_bucket_hash.png").unwrap());
+      "https://cdn.storyteller.ai/media/b/u/c/k/e/bucket_hash/image_bucket_hash.png").unwrap());
    assert_eq!(links.thumbnail_template,
-               "https://cdn-2.fakeyou.com/cdn-cgi/image/width={WIDTH},quality=95/media/b/u/c/k/e/bucket_hash/image_bucket_hash.png");
+               "https://cdn.storyteller.ai/cdn-cgi/image/width={WIDTH},quality=95/media/b/u/c/k/e/bucket_hash/image_bucket_hash.png");
  }
 }
@@ -41,11 +41,6 @@ pub fn is_job_failure_test(prompt: &str) -> bool {
 mod tests {
  use super::*;

-  const EXPECTED_FAILURE_MESSAGE: &str =
-      "This was a simulated failure. This message comes from the backend and \
-      database to simulate a dynamic failure message. This message could in \
-      theory be anything.";
-
  #[test]
  fn no_trigger_returns_none() {
    assert!(test_synthetic_failure_reason("a normal prompt").is_none());
@@ -55,14 +50,14 @@ mod tests {
  fn trigger_simulate_with_no_category_defaults_to_generation_failed() {
    let result = test_synthetic_failure_reason("simulate_artcraft_failure").unwrap();
    assert_eq!(result.frontend_failure_category, FrontendFailureCategory::GenerationFailed);
-    assert_eq!(result.frontend_failure_message.as_deref(), Some(EXPECTED_FAILURE_MESSAGE));
+    assert_eq!(result.frontend_failure_message.as_deref(), Some("This was a simulated failure"));
  }

  #[test]
  fn trigger_test_with_no_category_defaults_to_generation_failed() {
    let result = test_synthetic_failure_reason("test_artcraft_failure").unwrap();
    assert_eq!(result.frontend_failure_category, FrontendFailureCategory::GenerationFailed);
-    assert_eq!(result.frontend_failure_message.as_deref(), Some(EXPECTED_FAILURE_MESSAGE));
+    assert_eq!(result.frontend_failure_message.as_deref(), Some("This was a simulated failure"));
  }

  #[test]
@@ -1,85 +0,0 @@
-//! Maps Kinovi (Seedance2Pro) client errors to web errors.
-//!
-//! Known bad requests (content violations, over-long prompts, too many urls)
-//! become 400s with a user-facing message. Everything else is unanticipated
-//! and stays a 500.
-
-use seedance2pro_client::error::seedance2pro_bad_request_api_error::Seedance2ProBadRequestApiError;
-use seedance2pro_client::error::seedance2pro_error::Seedance2ProError;
-
-use crate::http_server::common_responses::common_web_error::CommonWebError;
-
-/// Map a raw Kinovi client error to a web error.
-pub fn map_seedance2pro_error_to_web_error(error: Seedance2ProError) -> CommonWebError {
-  match error {
-    Seedance2ProError::ApiBadRequest(bad_request) => {
-      CommonWebError::BadInputWithSimpleMessage(user_facing_bad_request_message(&bad_request))
-    }
-    other => CommonWebError::from_error(other),
-  }
-}
-
-fn user_facing_bad_request_message(error: &Seedance2ProBadRequestApiError) -> String {
-  match error {
-    Seedance2ProBadRequestApiError::VideoGenerationViolation { .. } => {
-      "The generation request was flagged as a content violation. \
-       Please adjust your prompt or input media and try again.".to_string()
-    }
-    Seedance2ProBadRequestApiError::PromptIsTooLong { .. } => {
-      "The prompt is too long. Please shorten it below 10,000 characters and try again.".to_string()
-    }
-    Seedance2ProBadRequestApiError::TooManyUrls { .. } => {
-      "Too many input files were attached. \
-       Please remove some and try again.".to_string()
-    }
-  }
-}
-
-#[cfg(test)]
-mod tests {
-  use actix_web::ResponseError;
-  use seedance2pro_client::error::seedance2pro_specific_api_error::Seedance2ProSpecificApiError;
-
-  use super::*;
-
-  #[test]
-  fn bad_requests_become_400s_with_user_facing_messages() {
-    let cases = [
-      (
-        Seedance2ProBadRequestApiError::VideoGenerationViolation { raw_body: "{}".to_string() },
-        "content violation",
-      ),
-      (
-        Seedance2ProBadRequestApiError::PromptIsTooLong { raw_body: "{}".to_string() },
-        "prompt is too long",
-      ),
-      (
-        Seedance2ProBadRequestApiError::TooManyUrls { raw_body: "{}".to_string() },
-        "Too many input files",
-      ),
-    ];
-
-    for (bad_request, expected_message_fragment) in cases {
-      let error = map_seedance2pro_error_to_web_error(
-        Seedance2ProError::ApiBadRequest(bad_request));
-
-      assert_eq!(error.status_code().as_u16(), 400);
-      match error {
-        CommonWebError::BadInputWithSimpleMessage(message) => {
-          assert!(
-            message.contains(expected_message_fragment),
-            "message {:?} should contain {:?}", message, expected_message_fragment);
-        }
-        other => panic!("Expected BadInputWithSimpleMessage, got: {:?}", other),
-      }
-    }
-  }
-
-  #[test]
-  fn unanticipated_errors_stay_500s() {
-    let error = map_seedance2pro_error_to_web_error(
-      Seedance2ProError::ApiSpecific(Seedance2ProSpecificApiError::UnauthorizedSessionExpired));
-
-    assert_eq!(error.status_code().as_u16(), 500);
-  }
-}
@@ -1,4 +1,3 @@
 pub mod job_failure_test;
-pub mod map_seedance2pro_web_errors;
 pub mod payments_error_test;
 mod test_synthetic_failure_reason;
@@ -1,10 +1,9 @@
 use std::collections::HashMap;
 use std::sync::Arc;
-use actix_http::StatusCode;
+
 use crate::billing::wallets::attempt_wallet_deduction::attempt_wallet_deduction_else_common_web_error;
 use crate::http_server::common_responses::common_web_error::CommonWebError;
 use crate::http_server::endpoint_helpers::refund_wallet_after_api_failure::refund_wallet_after_api_failure;
-use crate::http_server::endpoints::generate::common::map_seedance2pro_web_errors::map_seedance2pro_error_to_web_error;
 use crate::http_server::endpoints::generate::common::payments_error_test::payments_error_test;
 use crate::http_server::session::lookup::user_session_feature_flags::UserSessionFeatureFlags;
 use crate::http_server::validations::validate_idempotency_token_format::validate_idempotency_token_format;
@@ -13,7 +12,7 @@ use crate::state::server_state::ServerState;
 use crate::util::http_download_url_to_bytes::http_download_url_to_bytes;
 use crate::util::lookup::lookup_media_file_urls_as_map::lookup_media_file_urls_as_map;
 use actix_web::web::Json;
-use actix_web::{web, HttpRequest, ResponseError};
+use actix_web::{web, HttpRequest};
 use artcraft_api_defs::generate::video::multi_function::seedance_2p0_multi_function_video_gen::{
  Seedance2p0AspectRatio, Seedance2p0BatchCount, Seedance2p0MultiFunctionVideoGenRequest,
  Seedance2p0MultiFunctionVideoGenResponse, Seedance2p0OutputResolution,
@@ -235,19 +234,13 @@ pub async fn seedance_2p0_multi_function_video_gen_handler(
          }
          Err(err) => {
            warn!("Regular session fallback also failed for user {:?}: {:?}", user_token, err);
-
-            // Client-fault errors (eg. content violations, over-long prompts)
-            // surface to the user as 400s and shouldn't page.
-            if err.status_code() != StatusCode::BAD_REQUEST {
-              let notification = NotificationDetailsBuilder::from_boxed_error(err.clone().into())
-                  .set_title("Seedance 2.0 generation failed (whitelist + fallback)".to_string())
-                  .set_urgency(Some(NotificationUrgency::High))
-                  .build();
-              if let Err(page_err) = server_state.pager.enqueue_page(notification) {
-                warn!("Failed to enqueue pager alert: {:?}", page_err);
-              }
+            let notification = NotificationDetailsBuilder::from_boxed_error(err.clone().into())
+                .set_title("Seedance 2.0 generation failed (whitelist + fallback)".to_string())
+                .set_urgency(Some(NotificationUrgency::High))
+                .build();
+            if let Err(page_err) = server_state.pager.enqueue_page(notification) {
+              warn!("Failed to enqueue pager alert: {:?}", page_err);
            }
-
            refund_wallet_after_api_failure(&deduction_result.ledger_entry_token, &mut mysql_connection).await?;
            return Err(err);
          }
@@ -276,19 +269,13 @@ pub async fn seedance_2p0_multi_function_video_gen_handler(
      Ok(result) => result,
      Err(err) => {
        warn!("Error calling seedance2pro generate_video: {:?}", err);
-
-        // Client-fault errors (eg. content violations, over-long prompts)
-        // surface to the user as 400s and shouldn't page.
-        if err.status_code() != StatusCode::BAD_REQUEST {
-          let notification = NotificationDetailsBuilder::from_boxed_error(err.clone().into())
-              .set_title("Seedance 2.0 generation failed".to_string())
-              .set_urgency(Some(NotificationUrgency::High))
-              .build();
-          if let Err(page_err) = server_state.pager.enqueue_page(notification) {
-            warn!("Failed to enqueue pager alert: {:?}", page_err);
-          }
+        let notification = NotificationDetailsBuilder::from_boxed_error(err.clone().into())
+            .set_title("Seedance 2.0 generation failed".to_string())
+            .set_urgency(Some(NotificationUrgency::High))
+            .build();
+        if let Err(page_err) = server_state.pager.enqueue_page(notification) {
+          warn!("Failed to enqueue pager alert: {:?}", page_err);
        }
-
        refund_wallet_after_api_failure(&deduction_result.ledger_entry_token, &mut mysql_connection).await?;
        return Err(err);
      }
@@ -626,7 +613,7 @@ async fn upload_and_generate(
  let gen_response = generate_video(video_gen_args).await
    .map_err(|err| {
      warn!("Error calling seedance2pro generate_video: {:?}", err);
-      map_seedance2pro_error_to_web_error(err)
+      CommonWebError::from_error(err)
    })?;

  Ok(SeedanceGenerationResult {
@@ -394,7 +394,7 @@ mod tests {
    let result = payload.maybe_result.expect("should have result");

    assert_eq!(
-      Url::parse("https://cdn-2.fakeyou.com/media/t/p/k/8/4/tpk848b5s5zwhnwrph75jhyfyja3j42v/fakeyou_tpk848b5s5zwhnwrph75jhyfyja3j42v.wav").unwrap(),
+      Url::parse("https://cdn.storyteller.ai/media/t/p/k/8/4/tpk848b5s5zwhnwrph75jhyfyja3j42v/fakeyou_tpk848b5s5zwhnwrph75jhyfyja3j42v.wav").unwrap(),
      result.media_links.cdn_url
    );

@@ -433,7 +433,7 @@ mod tests {
    let result = payload.maybe_result.expect("should have result");

    assert_eq!(
-      Url::parse("https://cdn-2.fakeyou.com/tts_inference_output/9/9/7/vocodes_997e710c-d733-406c-9b6e-5e1d0c471816.wav").unwrap(),
+      Url::parse("https://cdn.fakeyou.com/tts_inference_output/9/9/7/vocodes_997e710c-d733-406c-9b6e-5e1d0c471816.wav").unwrap(),
      result.media_links.cdn_url
    );

@@ -10,6 +10,5 @@ pub mod user_emails;
 pub mod user_feature_flags;
 pub mod user_referrals;
 pub mod user_sessions;
-pub mod user_stripe_data;
 pub mod wallet_ledger_entries;
 pub mod wallets;
@@ -1 +0,0 @@
-pub mod moderator_get_user_stripe_customer_ids_handler;
@@ -1,101 +0,0 @@
-use std::sync::Arc;
-
-use actix_web::web::{Json, Path};
-use actix_web::{web, HttpRequest};
-use log::warn;
-
-use artcraft_api_defs::moderation::user_stripe_data::moderator_get_user_stripe_customer_ids::{
-  ModeratorGetUserStripeCustomerIdsPathInfo,
-  ModeratorGetUserStripeCustomerIdsResponse,
-  ModeratorStripeCustomerIdSource,
-  ModeratorUserStripeCustomerIdEntry,
-};
-use mysql_queries::queries::users::user_stripe_customer_links::list_user_stripe_customer_links_for_user::list_user_stripe_customer_links_for_user;
-use enums::common::payments_namespace::PaymentsNamespace;
-use mysql_queries::queries::users::user_subscriptions::list_stripe_customer_ids_for_user_subscriptions::list_stripe_customer_ids_for_user_subscriptions;
-use tokens::tokens::users::UserToken;
-
-use crate::http_server::common_responses::common_web_error::CommonWebError;
-use crate::http_server::web_utils::user_session::require_moderator::{require_moderator, UseDatabase};
-use crate::state::server_state::ServerState;
-
-/// Get all stripe customer ids on file for a user (moderation)
-#[utoipa::path(
-  get,
-  tag = "Moderation",
-  path = "/v1/moderation/user_stripe_data/{user_token}/customer_ids",
-  responses(
-    (status = 200, description = "Success", body = ModeratorGetUserStripeCustomerIdsResponse),
-    (status = 401, description = "Unauthorized"),
-    (status = 500, description = "Server error"),
-  ),
-  params(
-    ("user_token" = UserToken, Path, description = "User token to look up"),
-  )
-)]
-pub async fn moderator_get_user_stripe_customer_ids_handler(
-  http_request: HttpRequest,
-  path: Path<ModeratorGetUserStripeCustomerIdsPathInfo>,
-  server_state: web::Data<Arc<ServerState>>,
-) -> Result<Json<ModeratorGetUserStripeCustomerIdsResponse>, CommonWebError> {
-
-  let mut mysql_connection = server_state.mysql_pool
-      .acquire()
-      .await?;
-
-  let _moderator_session = require_moderator(
-    &http_request,
-    &server_state,
-    UseDatabase::FromPool(&mut mysql_connection),
-  )
-      .await
-      .map_err(|_| CommonWebError::NotAuthorized)?;
-
-  let customer_links = list_user_stripe_customer_links_for_user(&path.user_token, &mut mysql_connection)
-      .await
-      .map_err(|err| {
-        warn!("moderator_get_user_stripe_customer_ids customer link query error: {:?}", err);
-        CommonWebError::from_error(err)
-      })?;
-
-  let subscription_customer_ids = list_stripe_customer_ids_for_user_subscriptions(&path.user_token, &mut mysql_connection)
-      .await
-      .map_err(|err| {
-        warn!("moderator_get_user_stripe_customer_ids subscription query error: {:?}", err);
-        CommonWebError::from_error(err)
-      })?;
-
-  let mut customer_ids = Vec::with_capacity(customer_links.len() + subscription_customer_ids.len());
-
-  customer_ids.extend(customer_links.into_iter().map(|link| ModeratorUserStripeCustomerIdEntry {
-    stripe_dashboard_url: stripe_dashboard_customer_url(&server_state, link.payments_namespace, &link.stripe_customer_id),
-    stripe_customer_id: link.stripe_customer_id,
-    payments_namespace: link.payments_namespace,
-    source: ModeratorStripeCustomerIdSource::CustomerLink,
-  }));
-
-  customer_ids.extend(subscription_customer_ids.into_iter().map(|subscription| ModeratorUserStripeCustomerIdEntry {
-    stripe_dashboard_url: stripe_dashboard_customer_url(&server_state, subscription.subscription_namespace, &subscription.stripe_customer_id),
-    stripe_customer_id: subscription.stripe_customer_id,
-    payments_namespace: subscription.subscription_namespace,
-    source: ModeratorStripeCustomerIdSource::Subscription,
-  }));
-
-  Ok(Json(ModeratorGetUserStripeCustomerIdsResponse {
-    success: true,
-    customer_ids,
-  }))
-}
-
-/// Each payments namespace bills through a different Stripe account.
-fn stripe_dashboard_customer_url(
-  server_state: &ServerState,
-  payments_namespace: PaymentsNamespace,
-  stripe_customer_id: &str,
-) -> String {
-  let stripe_account_id = match payments_namespace {
-    PaymentsNamespace::Artcraft => &server_state.stripe_artcraft.stripe_account_id,
-    PaymentsNamespace::FakeYou => &server_state.stripe.stripe_account_id,
-  };
-  format!("https://dashboard.stripe.com/{}/customers/{}", stripe_account_id, stripe_customer_id)
-}
@@ -18,7 +18,6 @@ use tokens::tokens::users::UserToken;
 use crate::billing::wallets::attempt_wallet_deduction::attempt_wallet_deduction_else_common_web_error;
 use crate::http_server::common_responses::common_web_error::CommonWebError;
 use crate::http_server::endpoints::omni_gen::generate::image::pipeline_result::ImagePipelineResult;
-use crate::http_server::endpoints::omni_gen::shared_utils::map_seedance2pro_router_error::map_router_error_to_web_error;
 use crate::state::server_state::ServerState;
 use crate::util::lookup::lookup_media_files_as_cdn_url_list_and_map::MediaFilesAsCdnUrlListAndMap;

@@ -156,7 +155,7 @@ async fn finalize_and_generate(
        .await
        .map_err(|err| {
          warn!("Failed to finalize image v2 draft: {:?}", err);
-          map_router_error_to_web_error(err)
+          CommonWebError::from_error(err)
        })?
    }
  };
@@ -165,7 +164,7 @@ async fn finalize_and_generate(
    .await
    .map_err(|err| {
      warn!("v2 image generation failed: {:?}", err);
-      map_router_error_to_web_error(err)
+      CommonWebError::from_error(err)
    })
 }

@@ -19,7 +19,6 @@ use crate::http_server::endpoints::omni_gen::generate::video::helpers::build_rou
 use crate::http_server::endpoints::omni_gen::generate::video::helpers::pipeline_result::PipelineResult;
 use crate::http_server::endpoints::omni_gen::generate::video::helpers::resolve_media_tokens_to_urls::resolve_media_tokens_to_urls;
 use crate::http_server::endpoints::omni_gen::generate::video::kinovi_account::KinoviAccount;
-use crate::http_server::endpoints::omni_gen::shared_utils::map_seedance2pro_router_error::map_router_error_to_web_error;
 use crate::state::server_state::ServerState;

 pub struct RunPipelineV2Args<'a> {
@@ -171,7 +170,7 @@ async fn upload_and_generate(
          .await
          .map_err(|err| {
            warn!("Failed to finalize v2 draft: {:?}", err);
-            map_router_error_to_web_error(err)
+            CommonWebError::from_error(err)
          })?
    }
  };
@@ -180,6 +179,6 @@ async fn upload_and_generate(
      .await
      .map_err(|err| {
        warn!("v2 video generation failed: {:?}", err);
-        map_router_error_to_web_error(err)
+        CommonWebError::from_error(err)
      })
 }
@@ -1,90 +0,0 @@
-//! Maps artcraft router errors to web errors for the omni_gen pipelines.
-//!
-//! Known Kinovi (Seedance2Pro) bad requests (content violations, over-long
-//! prompts, too many urls) become 400s with a user-facing message. Everything
-//! else is unanticipated and stays a 500.
-
-use artcraft_router::errors::artcraft_router_error::ArtcraftRouterError;
-use artcraft_router::errors::provider_error::ProviderError;
-use seedance2pro_client::error::seedance2pro_bad_request_api_error::Seedance2ProBadRequestApiError;
-use seedance2pro_client::error::seedance2pro_error::Seedance2ProError;
-
-use crate::http_server::common_responses::common_web_error::CommonWebError;
-
-/// Map an artcraft router error to a web error, unwrapping Kinovi bad requests.
-pub fn map_router_error_to_web_error(error: ArtcraftRouterError) -> CommonWebError {
-  match error {
-    ArtcraftRouterError::Provider(
-      ProviderError::Seedance2Pro(Seedance2ProError::ApiBadRequest(bad_request))
-    ) => {
-      CommonWebError::BadInputWithSimpleMessage(user_facing_bad_request_message(&bad_request))
-    }
-    other => CommonWebError::from_error(other),
-  }
-}
-
-fn user_facing_bad_request_message(error: &Seedance2ProBadRequestApiError) -> String {
-  match error {
-    Seedance2ProBadRequestApiError::VideoGenerationViolation { .. } => {
-      "The generation request was flagged as a content violation. \
-       Please adjust your prompt or input media and try again.".to_string()
-    }
-    Seedance2ProBadRequestApiError::PromptIsTooLong { .. } => {
-      "The prompt is too long. Please shorten it below 10,000 characters and try again.".to_string()
-    }
-    Seedance2ProBadRequestApiError::TooManyUrls { .. } => {
-      "Too many input files were attached. \
-       Please remove some and try again.".to_string()
-    }
-  }
-}
-
-#[cfg(test)]
-mod tests {
-  use actix_web::ResponseError;
-
-  use super::*;
-
-  #[test]
-  fn kinovi_bad_requests_become_400s_with_user_facing_messages() {
-    let cases = [
-      (
-        Seedance2ProBadRequestApiError::VideoGenerationViolation { raw_body: "{}".to_string() },
-        "content violation",
-      ),
-      (
-        Seedance2ProBadRequestApiError::PromptIsTooLong { raw_body: "{}".to_string() },
-        "prompt is too long",
-      ),
-      (
-        Seedance2ProBadRequestApiError::TooManyUrls { raw_body: "{}".to_string() },
-        "Too many input files",
-      ),
-    ];
-
-    for (bad_request, expected_message_fragment) in cases {
-      let error = map_router_error_to_web_error(
-        ArtcraftRouterError::Provider(
-          ProviderError::Seedance2Pro(
-            Seedance2ProError::ApiBadRequest(bad_request))));
-
-      assert_eq!(error.status_code().as_u16(), 400);
-      match error {
-        CommonWebError::BadInputWithSimpleMessage(message) => {
-          assert!(
-            message.contains(expected_message_fragment),
-            "message {:?} should contain {:?}", message, expected_message_fragment);
-        }
-        other => panic!("Expected BadInputWithSimpleMessage, got: {:?}", other),
-      }
-    }
-  }
-
-  #[test]
-  fn other_router_errors_stay_500s() {
-    let error = map_router_error_to_web_error(
-      ArtcraftRouterError::UnsupportedModel("some_model".to_string()));
-
-    assert_eq!(error.status_code().as_u16(), 500);
-  }
-}
@@ -1,2 +1 @@
-pub mod map_seedance2pro_router_error;
-pub mod video;
+pub mod video;
@@ -46,7 +46,6 @@ use crate::http_server::endpoints::moderation::user_referrals::moderator_list_gl
 use crate::http_server::endpoints::moderation::user_referrals::moderator_list_user_referrals_for_user_handler::moderator_list_user_referrals_for_user_handler;
 use crate::http_server::endpoints::moderation::user_sessions::moderator_list_user_session_impersonation_requests_handler::moderator_list_user_session_impersonation_requests_handler;
 use crate::http_server::endpoints::moderation::user_sessions::moderator_user_session_impersonation_request_handler::moderator_user_session_impersonation_request_handler;
-use crate::http_server::endpoints::moderation::user_stripe_data::moderator_get_user_stripe_customer_ids_handler::moderator_get_user_stripe_customer_ids_handler;

 pub fn add_moderator_routes<T, B> (app: App<T>) -> App<T>
  where
@@ -172,12 +171,6 @@ pub fn add_moderator_routes<T, B> (app: App<T>) -> App<T>
                .route(web::head().to(|| HttpResponse::Ok()))
            )
        )
-        .service(web::scope("/user_stripe_data")
-            .service(web::resource("/{user_token}/customer_ids")
-                .route(web::get().to(moderator_get_user_stripe_customer_ids_handler))
-                .route(web::head().to(|| HttpResponse::Ok()))
-            )
-        )
        .service(web::resource("/wallet_ledger_entry/{wallet_ledger_entry_token}")
            .route(web::get().to(moderator_get_wallet_ledger_entry_handler))
            .route(web::head().to(|| HttpResponse::Ok()))
@@ -5,7 +5,6 @@ use errors::AnyhowResult;

 pub fn setup_stripe_artcraft() -> AnyhowResult<ArtcraftStripeConfigWithClient> {
  Ok(ArtcraftStripeConfig {
-    stripe_account_id: easyenv::get_env_string_required("STRIPE_ARTCRAFT_ACCOUNT_ID")?,
    secret_key: easyenv::get_env_string_required("STRIPE_ARTCRAFT_SECRET_KEY")?,
    secret_webhook_signing_key: easyenv::get_env_string_required("STRIPE_ARTCRAFT_SECRET_WEBHOOK_KEY")?,
    checkout_success_url: easyenv::get_env_string_required("STRIPE_ARTCRAFT_CHECKOUT_SUCCESS_URL")?,
@@ -31,6 +31,5 @@ pub fn setup_stripe_fakeyou() -> AnyhowResult<StripeSettings> {
  Ok(StripeSettings {
    config: stripe_configs,
    client: stripe_client,
-    stripe_account_id: easyenv::get_env_string_required("STRIPE_FAKEYOU_ACCOUNT_ID")?,
  })
 }
@@ -219,9 +219,6 @@ pub struct EphemeralInMemoryCaches {
 pub struct StripeSettings {
  pub config: StripeConfig,
  pub client: stripe::Client,
-
-  /// The Stripe account id (eg. "acct_..."), used to build dashboard links.
-  pub stripe_account_id: String,
 }

 /// Flags set at service startup
@@ -2,21 +2,7 @@

 This is an `nx` monorepo that can contain multiple apps and shared libraries.

-All commands to run these projects are performed from _this_ directory
-(except the repo-root launcher scripts noted below).
-
-## Requirements
-
- **Node.js 20+** (Nx 21 / Vite 6 requirement). Install via [nvm](https://github.com/nvm-sh/nvm),
-  [nodejs.org](https://nodejs.org), or `brew install node`.
- **npm** (ships with Node).
-
-> **We use npm, not pnpm.** pnpm was briefly adopted ("add pnpm to solve build
-> issues") and later removed ("fix(frontend): consume video-editor libs via nx
-> path aliases, drop pnpm"). If you have leftovers from that era — a
-> `pnpm-lock.yaml`, `pnpm-workspace.yaml`, or a `node_modules/.pnpm` directory —
-> npm installs will fail (typically with `ENOTEMPTY` rename errors). See
-> Troubleshooting below.
+All commands to run these projects are performed from _this_ directory.

 ## Install dependencies

@@ -24,95 +10,58 @@ All commands to run these projects are performed from _this_ directory
 npm install
 ```

-## Running the apps in dev mode
+## Editor2d

-From the **repository root**, the launcher scripts (these preflight your
-environment, install dependencies, and free the dev port first):
+Run dev server:

 ```bash
-./script/website/unix_frontend_dev.sh           # artcraft-website (marketing site), port 4200
-./script/website/unix_frontend_webapp_dev.sh    # artcraft-webapp (user dashboard), port 4201
-./script/artcraft/unix_frontend_dev.sh          # artcraft (Tauri app frontend), port 5173
-```
-
-Or directly from this directory:
-
-```bash
-nx dev artcraft-website
-nx dev artcraft-webapp
-nx dev artcraft        # NB: the Tauri app also needs the Rust dev server running
 nx dev editor2d
 ```

-## Building
+## artcraft
+
+Run dev server:

 ```bash
-npx nx build artcraft-website
-npx nx build artcraft-webapp
-npx nx build artcraft
-npx nx build editor2d
+nx dev artcraft
 ```

-Netlify deploys run `apps/<app>/script/netlify_build.sh` (see each app's
-`netlify.toml`).
-
-## Troubleshooting
-
-### `npm install` fails with `ENOTEMPTY: directory not empty, rename ...`
-
-Your `node_modules` tree is corrupted — usually an interrupted install, or a
-tree written by pnpm back when the repo briefly used it. Fix:
-
-```bash
-./clean_modules.sh
-npm install
 ```
+call when starting on main or a new branch:
+./clean_modules

-Or the manual minimum:
-
-```bash
-rm -rf node_modules .nx pnpm-lock.yaml pnpm-workspace.yaml
-npm install
-```
-
-### Stale build state after switching branches
-
-Call this when starting on main or a new branch:
-
-```bash
-./clean_modules.sh
-```
-
-It removes all `dist/` outputs, resets the nx cache, and removes
-`node_modules`.
-
-## Import aliases
-
-The names for `@frontend` and `@storyteller` come from the `package.json` file
-in the libs folder:
-
-```ts
+The names for @frontend and @storyteller come from the package.json file in the libs folder.
 import { Login } from "@frontend/login";
 import { api } from "@storyteller/api";
-```

-For shared UI components, import from `@storyteller/ui-[componentname]`:
-
-```ts
+For shared UI components, import from @storyteller/ui-[componentname].
 import { Button } from "@storyteller/ui-button";
 import { Modal } from "@storyteller/ui-modal";
-```

-## Generating a new component library
+building:
+npx nx build artcraft
+npx nx build editor2d

-```bash
-# 1. Generate the library
+dev:
+npx nx dev artcraft
+npx nx dev editor2d
+
+
+
+# component build
+1.
 npx nx g @nx/react:library libs/components/toaster --import-path=@storyteller/ui-toaster --bundler=vite
 npm install
+2.import it first in code
+3.nx sync
+4.nx build

-# 2. Import it somewhere in code
+or

-# 3. Sync and build
-nx sync
-nx build
+# frontend build
+in frontend folder
+
+% nx build -project type
+% nx build artcraft
+% nx dev artcraft
 ```
@@ -3066,7 +3066,6 @@
      "resolved": "https://registry.npmjs.org/@emnapi/core/-/core-1.11.0.tgz",
      "integrity": "sha512-l9Oo58x0HOP5znGzVhYW9U3e5wVuA4LAZU2AGezTmkhO1CgQRFDhDg4nneHsu/t3WniXg9QrG2nIXL/ZS8ln8Q==",
      "license": "MIT",
-      "peer": true,
      "dependencies": {
        "@emnapi/wasi-threads": "1.2.2",
        "tslib": "^2.4.0"
@@ -3077,7 +3076,6 @@
      "resolved": "https://registry.npmjs.org/@emnapi/runtime/-/runtime-1.11.0.tgz",
      "integrity": "sha512-55coeOFKHv1ywEcUXJtWU5f+Jr/W5tZDvZig8DLKSwUN1JpROQ4rk/SNOQiFWmaR/VKF4zuFyW1B8JduOSv6Pg==",
      "license": "MIT",
-      "peer": true,
      "dependencies": {
        "tslib": "^2.4.0"
      }
@@ -13372,6 +13370,42 @@
        "node": ">=14.0.0"
      }
    },
+    "node_modules/@unrs/resolver-binding-wasm32-wasi/node_modules/@emnapi/core": {
+      "version": "1.10.0",
+      "resolved": "https://registry.npmjs.org/@emnapi/core/-/core-1.10.0.tgz",
+      "integrity": "sha512-yq6OkJ4p82CAfPl0u9mQebQHKPJkY7WrIuk205cTYnYe+k2Z8YBh11FrbRG/H6ihirqcacOgl2BIO8oyMQLeXw==",
+      "dev": true,
+      "license": "MIT",
+      "optional": true,
+      "peer": true,
+      "dependencies": {
+        "@emnapi/wasi-threads": "1.2.1",
+        "tslib": "^2.4.0"
+      }
+    },
+    "node_modules/@unrs/resolver-binding-wasm32-wasi/node_modules/@emnapi/runtime": {
+      "version": "1.10.0",
+      "resolved": "https://registry.npmjs.org/@emnapi/runtime/-/runtime-1.10.0.tgz",
+      "integrity": "sha512-ewvYlk86xUoGI0zQRNq/mC+16R1QeDlKQy21Ki3oSYXNgLb45GV1P6A0M+/s6nyCuNDqe5VpaY84BzXGwVbwFA==",
+      "dev": true,
+      "license": "MIT",
+      "optional": true,
+      "peer": true,
+      "dependencies": {
+        "tslib": "^2.4.0"
+      }
+    },
+    "node_modules/@unrs/resolver-binding-wasm32-wasi/node_modules/@emnapi/wasi-threads": {
+      "version": "1.2.1",
+      "resolved": "https://registry.npmjs.org/@emnapi/wasi-threads/-/wasi-threads-1.2.1.tgz",
+      "integrity": "sha512-uTII7OYF+/Mes/MrcIOYp5yOtSMLBWSIoLPpcgwipoiKbli6k322tcoFsxoIIxPDqW01SQGAgko4EzZi2BNv2w==",
+      "dev": true,
+      "license": "MIT",
+      "optional": true,
+      "dependencies": {
+        "tslib": "^2.4.0"
+      }
+    },
    "node_modules/@unrs/resolver-binding-wasm32-wasi/node_modules/@napi-rs/wasm-runtime": {
      "version": "1.1.4",
      "resolved": "https://registry.npmjs.org/@napi-rs/wasm-runtime/-/wasm-runtime-1.1.4.tgz",
@@ -27256,7 +27290,6 @@
      "integrity": "sha512-c4FRfUm/dbcWZ7U+1Wq0AwCyFL+3nt2bEw05wfxSz+DWpWsitgmSgYmy2dQdWyKC1694ELPqMs/YzUSNozLt8A==",
      "dev": true,
      "license": "MIT",
-      "peer": true,
      "dependencies": {
        "whatwg-url": "^5.0.0"
      },
@@ -4,9 +4,6 @@
 root_dir=$(pwd)
 frontend_path="${root_dir}/frontend"

-source "${root_dir}/script/common/frontend_preflight.sh"
-frontend_preflight "${frontend_path}"
-
 echo "Running Artcraft Frontend in Dev Mode..."
 echo ""

@@ -23,7 +20,7 @@ fi

 pushd "${frontend_path}" || exit

-frontend_npm_install
+npm install --verbose

 export VITE_ENVIRONMENT_TYPE="production"

@@ -1,86 +0,0 @@
-#!/usr/bin/env bash
-# Shared preflight checks for the frontend dev/build scripts.
-#
-# Usage (from a script that has set ${frontend_path}):
-#
-#   source "${root_dir}/script/common/frontend_preflight.sh"
-#   frontend_preflight "${frontend_path}"
-#   ...
-#   pushd "${frontend_path}"
-#   frontend_npm_install
-#
-
-# Node 20+ is required by Nx 21 and comfortably covers Vite 6.
-FRONTEND_MINIMUM_NODE_MAJOR=20
-
-frontend_preflight() {
-  local frontend_path="$1"
-
-  if [ ! -d "${frontend_path}" ]; then
-    echo "ERROR: frontend directory not found at: ${frontend_path}"
-    echo "Run this script from the repository root."
-    exit 1
-  fi
-
-  # --- Node and npm must be installed ---
-  if ! command -v node &>/dev/null; then
-    echo "ERROR: node is not installed (or not on PATH)."
-    echo "Install Node.js ${FRONTEND_MINIMUM_NODE_MAJOR}+ via nvm (https://github.com/nvm-sh/nvm),"
-    echo "https://nodejs.org, or:"
-    echo "  brew install node"
-    exit 1
-  fi
-
-  if ! command -v npm &>/dev/null; then
-    echo "ERROR: npm is not installed (or not on PATH). It normally ships with Node.js."
-    echo "Reinstall Node.js to get it back."
-    exit 1
-  fi
-
-  # --- Node must be recent enough for Nx 21 / Vite 6 ---
-  local node_major
-  node_major=$(node --version | sed -E 's/^v([0-9]+).*/\1/')
-  if [ "${node_major}" -lt "${FRONTEND_MINIMUM_NODE_MAJOR}" ]; then
-    echo "ERROR: Node.js ${FRONTEND_MINIMUM_NODE_MAJOR}+ is required (found $(node --version))."
-    echo "Upgrade via nvm ('nvm install --lts') or https://nodejs.org."
-    exit 1
-  fi
-
-  # --- The frontend uses npm; stale pnpm state breaks installs ---
-  # pnpm was briefly adopted ("add pnpm to solve build issues") and then dropped
-  # ("fix(frontend): consume video-editor libs via nx path aliases, drop pnpm").
-  # A node_modules tree written by pnpm makes npm fail with ENOTEMPTY errors.
-  if [ -e "${frontend_path}/pnpm-lock.yaml" ] \
-      || [ -e "${frontend_path}/pnpm-workspace.yaml" ] \
-      || [ -d "${frontend_path}/node_modules/.pnpm" ]; then
-    echo "ERROR: Stale pnpm artifacts detected in ${frontend_path}."
-    echo "The frontend uses npm (pnpm was dropped; see frontend/README.md)."
-    echo "Clean up with:"
-    echo "  cd ${frontend_path} && rm -rf node_modules pnpm-lock.yaml pnpm-workspace.yaml && npm install"
-    exit 1
-  fi
-}
-
-# Run `npm install` in the current directory. If it fails (typically from a
-# corrupted node_modules tree, eg. an interrupted install or a leftover pnpm
-# layout causing ENOTEMPTY rename errors), wipe node_modules and the nx cache
-# and retry once before giving up.
-frontend_npm_install() {
-  if npm install; then
-    return 0
-  fi
-
-  echo ""
-  echo "WARNING: npm install failed. node_modules may be corrupted (eg. an"
-  echo "interrupted install or a mixed npm/pnpm tree). Wiping and retrying..."
-  echo ""
-
-  rm -rf node_modules .nx
-
-  if ! npm install; then
-    echo ""
-    echo "ERROR: npm install failed again. See the npm output above and the"
-    echo "troubleshooting section in frontend/README.md."
-    exit 1
-  fi
-}
@@ -4,9 +4,6 @@
 root_dir=$(pwd)
 frontend_path="${root_dir}/frontend"

-source "${root_dir}/script/common/frontend_preflight.sh"
-frontend_preflight "${frontend_path}"
-
 echo "Running Artcraft Website in Dev Mode..."
 echo ""

@@ -20,7 +17,7 @@ fi

 pushd "${frontend_path}" || exit

-frontend_npm_install
+npm install --verbose

 export VITE_ENVIRONMENT_TYPE="production"

@@ -4,9 +4,6 @@
 root_dir=$(pwd)
 frontend_path="${root_dir}/frontend"

-source "${root_dir}/script/common/frontend_preflight.sh"
-frontend_preflight "${frontend_path}"
-
 echo "Running Artcraft Webapp in Dev Mode..."
 echo ""

@@ -20,7 +17,7 @@ fi

 pushd "${frontend_path}" || exit

-frontend_npm_install
+npm install --verbose

 export VITE_ENVIRONMENT_TYPE="production"
Author	SHA1	Message	Date
Brandon Thomas	67dd65c636	beeble endpoint	2026-06-09 20:12:17 -04:00
Brandon Thomas	cc4203ff3e	const def	2026-06-09 20:08:16 -04:00
Brandon Thomas	6c053aba7c	add a few more clients for testing	2026-06-09 20:04:53 -04:00
Brandon Thomas	671fe5892b	add generation platform type (web, desktop, etc.)	2026-06-09 19:10:10 -04:00
				`@@ -1 +0,0 @@`
				`pub mod moderator_get_user_stripe_customer_ids;`
				`@@ -1 +0,0 @@`
				{"type":"json","current_status":"start_stage","percentage_complete":0.0,"job_id":"0080eaac-f7f7-4369-90a2-346491939c1b","elapsed":null,"prompt":"a dog riding a motorcycle","confirmation":"Drew a dog riding a motorcycle","full_prompt":"a dog riding a motorcycle","flags":null,"is_alteration":false,"section_id":0,"input_type":"text","request_id":"bbc15402-3257-4415-922e-b156c151f3c2","asr_transcript":null,"asr_accepted":null,"seed":null,"image_reference":null,"is_image_edit":null,"moderated":false,"r_rated":null,"order":0,"model_name":"imagine_h_1","image_id":null}