endpoint to look up users by stripe customer_id

crates/api_clients/artcraft/artcraft_api_defs/src/moderation/user/mod.rs

@@ -1 +1,2 @@
 pub mod user_lookup;
+pub mod user_lookup_by_stripe_customer_id;

crates/api_clients/artcraft/artcraft_api_defs/src/moderation/user/user_lookup.rs

@@ -1,4 +1,5 @@
 use serde_derive::{Deserialize, Serialize};
+use tokens::tokens::media_files::MediaFileToken;
 use utoipa::ToSchema;
 
 pub const MODERATOR_USER_LOOKUP_PATH: &str = "/v1/moderation/user_lookup";
@@ -28,6 +29,6 @@ pub struct ModeratorUserLookupUserDetails {
   pub is_without_password: bool,
   pub ip_address_creation: String,
   pub ip_address_last_login: String,
-  pub maybe_avatar_media_file_token: Option<String>,
+  pub maybe_avatar_media_file_token: Option<MediaFileToken>,
   pub email_gravatar_hash: String,
 }

crates/api_clients/artcraft/artcraft_api_defs/src/moderation/user/user_lookup_by_stripe_customer_id.rs

@@ -0,0 +1,26 @@
+use serde_derive::{Deserialize, Serialize};
+use tokens::tokens::users::UserToken;
+use utoipa::ToSchema;
+
+pub const MODERATOR_USER_LOOKUP_BY_STRIPE_CUSTOMER_ID_PATH: &str = "/v1/moderation/user_lookup_by_stripe_customer_id";
+
+#[derive(Deserialize, ToSchema)]
+pub struct ModeratorUserLookupByStripeCustomerIdRequest {
+  pub stripe_customer_id: String,
+}
+
+#[derive(Serialize, ToSchema)]
+pub struct ModeratorUserLookupByStripeCustomerIdResponse {
+  pub success: bool,
+  pub users: Vec<ModeratorUserLookupByStripeCustomerIdEntry>,
+}
+
+#[derive(Serialize, ToSchema)]
+pub struct ModeratorUserLookupByStripeCustomerIdEntry {
+  pub subscription_namespace: String,
+  pub maybe_stripe_subscription_id: Option<String>,
+  pub token: UserToken,
+  pub email_address: String,
+  pub username: String,
+  pub display_name: String,
+}

crates/schema/database/mysql_queries/src/queries/users/user/get/lookup_user_for_moderation.rs

@@ -4,6 +4,7 @@ use log::warn;
 use sqlx::MySqlPool;
 
 use errors::AnyhowResult;
+use tokens::tokens::media_files::MediaFileToken;
 use tokens::tokens::users::UserToken;
 
 pub struct LookupUserForModerationResult {
@@ -19,7 +20,7 @@ pub struct LookupUserForModerationResult {
   pub is_without_password: bool,
   pub ip_address_creation: String,
   pub ip_address_last_login: String,
-  pub maybe_avatar_media_file_token: Option<String>,
+  pub maybe_avatar_media_file_token: Option<MediaFileToken>,
   pub email_gravatar_hash: String,
   pub created_at: DateTime<Utc>,
 }
@@ -44,7 +45,7 @@ SELECT
     is_without_password as `is_without_password: bool`,
     ip_address_creation,
     ip_address_last_login,
-    maybe_avatar_media_file_token,
+    maybe_avatar_media_file_token as `maybe_avatar_media_file_token: tokens::tokens::media_files::MediaFileToken`,
     email_gravatar_hash,
     created_at
 FROM users
@@ -91,7 +92,7 @@ SELECT
     is_without_password as `is_without_password: bool`,
     ip_address_creation,
     ip_address_last_login,
-    maybe_avatar_media_file_token,
+    maybe_avatar_media_file_token as `maybe_avatar_media_file_token: tokens::tokens::media_files::MediaFileToken`,
     email_gravatar_hash,
     created_at
 FROM users
@@ -138,7 +139,7 @@ SELECT
     is_without_password as `is_without_password: bool`,
     ip_address_creation,
     ip_address_last_login,
-    maybe_avatar_media_file_token,
+    maybe_avatar_media_file_token as `maybe_avatar_media_file_token: tokens::tokens::media_files::MediaFileToken`,
     email_gravatar_hash,
     created_at
 FROM users

crates/schema/database/mysql_queries/src/queries/users/user_subscriptions/lookup_users_by_stripe_customer_id.rs

@@ -0,0 +1,52 @@
+use anyhow::anyhow;
+use log::warn;
+use sqlx::MySqlPool;
+
+use errors::AnyhowResult;
+use tokens::tokens::users::UserToken;
+
+pub struct UserByStripeCustomerIdResult {
+  pub subscription_namespace: String,
+  pub maybe_stripe_subscription_id: Option<String>,
+  pub user_token: UserToken,
+  pub email_address: String,
+  pub username: String,
+  pub display_name: String,
+}
+
+pub async fn lookup_users_by_stripe_customer_id(
+  stripe_customer_id: &str,
+  mysql_pool: &MySqlPool,
+) -> AnyhowResult<Vec<UserByStripeCustomerIdResult>> {
+  let results = sqlx::query_as!(
+    UserByStripeCustomerIdResult,
+    r#"
+SELECT
+    user_subscriptions.subscription_namespace,
+    user_subscriptions.maybe_stripe_subscription_id,
+    users.token as `user_token: tokens::tokens::users::UserToken`,
+    users.email_address,
+    users.username,
+    users.display_name
+FROM user_subscriptions
+INNER JOIN users ON users.token = user_subscriptions.user_token
+WHERE
+    user_subscriptions.maybe_stripe_customer_id = ?
+    AND user_subscriptions.deleted_at IS NULL
+    AND users.user_deleted_at IS NULL
+    AND users.mod_deleted_at IS NULL
+ORDER BY user_subscriptions.created_at DESC
+    "#,
+    stripe_customer_id,
+  )
+    .fetch_all(mysql_pool)
+    .await;
+
+  match results {
+    Ok(records) => Ok(records),
+    Err(err) => {
+      warn!("lookup_users_by_stripe_customer_id query error: {:?}", err);
+      Err(anyhow!("query error"))
+    }
+  }
+}

crates/schema/database/mysql_queries/src/queries/users/user_subscriptions/mod.rs

@@ -1,4 +1,5 @@
 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;

crates/service/web/storyteller_web/src/docs/api_doc.rs

@@ -266,6 +266,7 @@ use artcraft_api_defs::media_file::list_batch_generated_media_files::*;
 // Handler modules with locally-defined types
 use crate::http_server::endpoints::moderation::info::moderator_token_info_handler::*;
 use artcraft_api_defs::moderation::user::user_lookup::*;
+use artcraft_api_defs::moderation::user::user_lookup_by_stripe_customer_id::*;
 use crate::http_server::endpoints::webhooks::fal_webhook_handler::*;
 use crate::http_server::endpoints::image_studio::update_gpt_image_job_status_handler::*;
 use crate::http_server::endpoints::voice_conversion::enqueue_seed_vc_inference_handler::*;
@@ -436,6 +437,7 @@ use crate::http_server::endpoints::media_files::list::list_batch_generated_redux
     // Moderation
     crate::http_server::endpoints::moderation::info::moderator_token_info_handler::moderator_get_token_info_handler,
     crate::http_server::endpoints::moderation::user::moderator_user_lookup_handler::moderator_user_lookup_handler,
+    crate::http_server::endpoints::moderation::user::moderator_user_lookup_by_stripe_customer_id_handler::moderator_user_lookup_by_stripe_customer_id_handler,
     // Credits
     crate::http_server::endpoints::credits::get_session_credits_handler::get_session_credits_handler,
     // Subscriptions
@@ -616,6 +618,9 @@ use crate::http_server::endpoints::media_files::list::list_batch_generated_redux
     ModeratorUserLookupRequest,
     ModeratorUserLookupSuccessResponse,
     ModeratorUserLookupUserDetails,
+    ModeratorUserLookupByStripeCustomerIdRequest,
+    ModeratorUserLookupByStripeCustomerIdResponse,
+    ModeratorUserLookupByStripeCustomerIdEntry,
     GptImage1EditImageRequest,
     GptImage1EditImageImageSize,
     GptImage1EditImageNumImages,

crates/service/web/storyteller_web/src/http_server/endpoints/moderation/user/mod.rs

@@ -1 +1,2 @@
+pub mod moderator_user_lookup_by_stripe_customer_id_handler;
 pub mod moderator_user_lookup_handler;

crates/service/web/storyteller_web/src/http_server/endpoints/moderation/user/moderator_user_lookup_by_stripe_customer_id_handler.rs

@@ -0,0 +1,69 @@
+use std::sync::Arc;
+
+use actix_web::web::Json;
+use actix_web::{web, HttpRequest};
+use log::warn;
+
+use artcraft_api_defs::moderation::user::user_lookup_by_stripe_customer_id::{
+  ModeratorUserLookupByStripeCustomerIdEntry,
+  ModeratorUserLookupByStripeCustomerIdRequest,
+  ModeratorUserLookupByStripeCustomerIdResponse,
+};
+use mysql_queries::queries::users::user_subscriptions::lookup_users_by_stripe_customer_id::lookup_users_by_stripe_customer_id;
+
+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;
+
+/// Moderator User Lookup by Stripe Customer ID
+#[utoipa::path(
+  post,
+  tag = "Moderation",
+  path = "/v1/moderation/user_lookup_by_stripe_customer_id",
+  request_body = ModeratorUserLookupByStripeCustomerIdRequest,
+  responses(
+    (status = 200, description = "Success", body = ModeratorUserLookupByStripeCustomerIdResponse),
+    (status = 401, description = "Unauthorized"),
+    (status = 500, description = "Server error"),
+  ),
+)]
+pub async fn moderator_user_lookup_by_stripe_customer_id_handler(
+  http_request: HttpRequest,
+  request: Json<ModeratorUserLookupByStripeCustomerIdRequest>,
+  server_state: web::Data<Arc<ServerState>>,
+) -> Result<Json<ModeratorUserLookupByStripeCustomerIdResponse>, CommonWebError> {
+
+  let _user_session = require_moderator(&http_request, &server_state, UseDatabase::Implicit)
+    .await
+    .map_err(|_| CommonWebError::NotAuthorized)?;
+
+  let stripe_customer_id = request.stripe_customer_id.trim();
+
+  if stripe_customer_id.is_empty() {
+    return Ok(Json(ModeratorUserLookupByStripeCustomerIdResponse {
+      success: true,
+      users: vec![],
+    }));
+  }
+
+  let results = lookup_users_by_stripe_customer_id(stripe_customer_id, &server_state.mysql_pool)
+    .await
+    .map_err(|err| {
+      warn!("moderator_user_lookup_by_stripe_customer_id error: {:?}", err);
+      CommonWebError::ServerError
+    })?;
+
+  let users = results.into_iter().map(|row| ModeratorUserLookupByStripeCustomerIdEntry {
+    subscription_namespace: row.subscription_namespace,
+    maybe_stripe_subscription_id: row.maybe_stripe_subscription_id,
+    token: row.user_token,
+    email_address: row.email_address,
+    username: row.username,
+    display_name: row.display_name,
+  }).collect();
+
+  Ok(Json(ModeratorUserLookupByStripeCustomerIdResponse {
+    success: true,
+    users,
+  }))
+}

crates/service/web/storyteller_web/src/http_server/routes/application_routes/moderation_routes.rs

@@ -24,6 +24,7 @@ use crate::http_server::endpoints::moderation::jobs::get_w2l_inference_queue_cou
 use crate::http_server::endpoints::moderation::jobs::kill_tts_inference_jobs::kill_tts_inference_jobs_handler;
 use crate::http_server::endpoints::moderation::user_bans::ban_user::ban_user_handler;
 use crate::http_server::endpoints::moderation::user_bans::list_banned_users::list_banned_users_handler;
+use crate::http_server::endpoints::moderation::user::moderator_user_lookup_by_stripe_customer_id_handler::moderator_user_lookup_by_stripe_customer_id_handler;
 use crate::http_server::endpoints::moderation::user::moderator_user_lookup_handler::moderator_user_lookup_handler;
 use crate::http_server::endpoints::moderation::user_feature_flags::edit_user_feature_flags_handler::edit_user_feature_flags_handler;
 
@@ -47,6 +48,10 @@ pub fn add_moderator_routes<T, B> (app: App<T>) -> App<T>
             .route(web::post().to(moderator_user_lookup_handler))
             .route(web::head().to(|| HttpResponse::Ok()))
         )
+        .service(web::resource("/user_lookup_by_stripe_customer_id")
+            .route(web::post().to(moderator_user_lookup_by_stripe_customer_id_handler))
+            .route(web::head().to(|| HttpResponse::Ok()))
+        )
       )
       .service(web::scope("/moderation")
         .service(web::resource("/staff")