codegen db

.sqlx/query-2ed95dcd9f68ddfc3c4fe4885a06827151ee92cc17034dd4683544c34a7d320b.json

@@ -0,0 +1,179 @@
+{
+  "db_name": "MySQL",
+  "query": "\nSELECT\n    users.token as `user_token: tokens::tokens::users::UserToken`,\n    username,\n    display_name,\n    username_is_generated as `username_is_generated: bool`,\n    is_temporary as `is_temporary: bool`,\n    username_is_not_customized as `username_is_not_customized: bool`,\n    email_address,\n    email_confirmed as `email_confirmed: bool`,\n    email_is_synthetic as `email_is_synthetic: bool`,\n    is_without_password as `is_without_password: bool`,\n    ip_address_creation,\n    ip_address_last_login,\n    maybe_avatar_media_file_token,\n    email_gravatar_hash,\n    created_at\nFROM users\nWHERE\n    users.token = ?\n    AND users.user_deleted_at IS NULL\n    AND users.mod_deleted_at IS NULL\nLIMIT 1\n    ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "user_token: tokens::tokens::users::UserToken",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | UNIQUE_KEY | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 128
+        }
+      },
+      {
+        "ordinal": 1,
+        "name": "username",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | UNIQUE_KEY | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 80
+        }
+      },
+      {
+        "ordinal": 2,
+        "name": "display_name",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 80
+        }
+      },
+      {
+        "ordinal": 3,
+        "name": "username_is_generated: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 4,
+        "name": "is_temporary: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 5,
+        "name": "username_is_not_customized: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 6,
+        "name": "email_address",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | UNIQUE_KEY | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 1020
+        }
+      },
+      {
+        "ordinal": 7,
+        "name": "email_confirmed: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 8,
+        "name": "email_is_synthetic: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 9,
+        "name": "is_without_password: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 10,
+        "name": "ip_address_creation",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 160
+        }
+      },
+      {
+        "ordinal": 11,
+        "name": "ip_address_last_login",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 160
+        }
+      },
+      {
+        "ordinal": 12,
+        "name": "maybe_avatar_media_file_token",
+        "type_info": {
+          "type": "VarString",
+          "flags": "MULTIPLE_KEY | BINARY",
+          "char_set": 224,
+          "max_size": 128
+        }
+      },
+      {
+        "ordinal": 13,
+        "name": "email_gravatar_hash",
+        "type_info": {
+          "type": "String",
+          "flags": "NOT_NULL | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 128
+        }
+      },
+      {
+        "ordinal": 14,
+        "name": "created_at",
+        "type_info": {
+          "type": "Timestamp",
+          "flags": "NOT_NULL | BINARY | TIMESTAMP",
+          "char_set": 63,
+          "max_size": 19
+        }
+      }
+    ],
+    "parameters": {
+      "Right": 1
+    },
+    "nullable": [
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      true,
+      false,
+      false
+    ]
+  },
+  "hash": "2ed95dcd9f68ddfc3c4fe4885a06827151ee92cc17034dd4683544c34a7d320b"
+}

.sqlx/query-34455ac40b35a73439f2158ff6e9e14cae5d025508cfa9f76546ee9b48b7fbd4.json

@@ -0,0 +1,179 @@
+{
+  "db_name": "MySQL",
+  "query": "\nSELECT\n    users.token as `user_token: tokens::tokens::users::UserToken`,\n    username,\n    display_name,\n    username_is_generated as `username_is_generated: bool`,\n    is_temporary as `is_temporary: bool`,\n    username_is_not_customized as `username_is_not_customized: bool`,\n    email_address,\n    email_confirmed as `email_confirmed: bool`,\n    email_is_synthetic as `email_is_synthetic: bool`,\n    is_without_password as `is_without_password: bool`,\n    ip_address_creation,\n    ip_address_last_login,\n    maybe_avatar_media_file_token,\n    email_gravatar_hash,\n    created_at\nFROM users\nWHERE\n    users.email_address = ?\n    AND users.user_deleted_at IS NULL\n    AND users.mod_deleted_at IS NULL\nLIMIT 1\n    ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "user_token: tokens::tokens::users::UserToken",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | UNIQUE_KEY | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 128
+        }
+      },
+      {
+        "ordinal": 1,
+        "name": "username",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | UNIQUE_KEY | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 80
+        }
+      },
+      {
+        "ordinal": 2,
+        "name": "display_name",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 80
+        }
+      },
+      {
+        "ordinal": 3,
+        "name": "username_is_generated: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 4,
+        "name": "is_temporary: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 5,
+        "name": "username_is_not_customized: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 6,
+        "name": "email_address",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | UNIQUE_KEY | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 1020
+        }
+      },
+      {
+        "ordinal": 7,
+        "name": "email_confirmed: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 8,
+        "name": "email_is_synthetic: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 9,
+        "name": "is_without_password: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 10,
+        "name": "ip_address_creation",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 160
+        }
+      },
+      {
+        "ordinal": 11,
+        "name": "ip_address_last_login",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 160
+        }
+      },
+      {
+        "ordinal": 12,
+        "name": "maybe_avatar_media_file_token",
+        "type_info": {
+          "type": "VarString",
+          "flags": "MULTIPLE_KEY | BINARY",
+          "char_set": 224,
+          "max_size": 128
+        }
+      },
+      {
+        "ordinal": 13,
+        "name": "email_gravatar_hash",
+        "type_info": {
+          "type": "String",
+          "flags": "NOT_NULL | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 128
+        }
+      },
+      {
+        "ordinal": 14,
+        "name": "created_at",
+        "type_info": {
+          "type": "Timestamp",
+          "flags": "NOT_NULL | BINARY | TIMESTAMP",
+          "char_set": 63,
+          "max_size": 19
+        }
+      }
+    ],
+    "parameters": {
+      "Right": 1
+    },
+    "nullable": [
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      true,
+      false,
+      false
+    ]
+  },
+  "hash": "34455ac40b35a73439f2158ff6e9e14cae5d025508cfa9f76546ee9b48b7fbd4"
+}

.sqlx/query-b983acd5a1f5446f6edfbfe21a0c3d50b0fe0b471d22877e86b690dc0d7e24c8.json

@@ -0,0 +1,179 @@
+{
+  "db_name": "MySQL",
+  "query": "\nSELECT\n    users.token as `user_token: tokens::tokens::users::UserToken`,\n    username,\n    display_name,\n    username_is_generated as `username_is_generated: bool`,\n    is_temporary as `is_temporary: bool`,\n    username_is_not_customized as `username_is_not_customized: bool`,\n    email_address,\n    email_confirmed as `email_confirmed: bool`,\n    email_is_synthetic as `email_is_synthetic: bool`,\n    is_without_password as `is_without_password: bool`,\n    ip_address_creation,\n    ip_address_last_login,\n    maybe_avatar_media_file_token,\n    email_gravatar_hash,\n    created_at\nFROM users\nWHERE\n    users.username = ?\n    AND users.user_deleted_at IS NULL\n    AND users.mod_deleted_at IS NULL\nLIMIT 1\n    ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "user_token: tokens::tokens::users::UserToken",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | UNIQUE_KEY | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 128
+        }
+      },
+      {
+        "ordinal": 1,
+        "name": "username",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | UNIQUE_KEY | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 80
+        }
+      },
+      {
+        "ordinal": 2,
+        "name": "display_name",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 80
+        }
+      },
+      {
+        "ordinal": 3,
+        "name": "username_is_generated: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 4,
+        "name": "is_temporary: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 5,
+        "name": "username_is_not_customized: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 6,
+        "name": "email_address",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | UNIQUE_KEY | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 1020
+        }
+      },
+      {
+        "ordinal": 7,
+        "name": "email_confirmed: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 8,
+        "name": "email_is_synthetic: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 9,
+        "name": "is_without_password: bool",
+        "type_info": {
+          "type": "Tiny",
+          "flags": "NOT_NULL",
+          "char_set": 63,
+          "max_size": 1
+        }
+      },
+      {
+        "ordinal": 10,
+        "name": "ip_address_creation",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 160
+        }
+      },
+      {
+        "ordinal": 11,
+        "name": "ip_address_last_login",
+        "type_info": {
+          "type": "VarString",
+          "flags": "NOT_NULL | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 160
+        }
+      },
+      {
+        "ordinal": 12,
+        "name": "maybe_avatar_media_file_token",
+        "type_info": {
+          "type": "VarString",
+          "flags": "MULTIPLE_KEY | BINARY",
+          "char_set": 224,
+          "max_size": 128
+        }
+      },
+      {
+        "ordinal": 13,
+        "name": "email_gravatar_hash",
+        "type_info": {
+          "type": "String",
+          "flags": "NOT_NULL | BINARY | NO_DEFAULT_VALUE",
+          "char_set": 224,
+          "max_size": 128
+        }
+      },
+      {
+        "ordinal": 14,
+        "name": "created_at",
+        "type_info": {
+          "type": "Timestamp",
+          "flags": "NOT_NULL | BINARY | TIMESTAMP",
+          "char_set": 63,
+          "max_size": 19
+        }
+      }
+    ],
+    "parameters": {
+      "Right": 1
+    },
+    "nullable": [
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      false,
+      true,
+      false,
+      false
+    ]
+  },
+  "hash": "b983acd5a1f5446f6edfbfe21a0c3d50b0fe0b471d22877e86b690dc0d7e24c8"
+}

crates/api_clients/artcraft/artcraft_api_defs/src/lib.rs

@@ -4,6 +4,7 @@ pub mod credits;
 pub mod generate;
 pub mod jobs;
 pub mod media_file;
+pub mod moderation;
 pub mod prompts;
 pub mod stripe_artcraft;
 pub mod subscriptions;

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

@@ -0,0 +1 @@
+pub mod user;

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

@@ -0,0 +1 @@
+pub mod user_lookup;

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

@@ -0,0 +1,33 @@
+use serde_derive::{Deserialize, Serialize};
+use utoipa::ToSchema;
+
+pub const MODERATOR_USER_LOOKUP_PATH: &str = "/v1/moderation/user_lookup";
+
+#[derive(Deserialize, ToSchema)]
+pub struct ModeratorUserLookupRequest {
+  pub search: String,
+}
+
+#[derive(Serialize, ToSchema)]
+pub struct ModeratorUserLookupSuccessResponse {
+  pub success: bool,
+  pub maybe_user: Option<ModeratorUserLookupUserDetails>,
+}
+
+#[derive(Serialize, ToSchema)]
+pub struct ModeratorUserLookupUserDetails {
+  pub token: String,
+  pub username: String,
+  pub display_name: String,
+  pub username_is_generated: bool,
+  pub is_temporary: bool,
+  pub username_is_not_customized: bool,
+  pub email_address: String,
+  pub email_confirmed: bool,
+  pub email_is_synthetic: bool,
+  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 email_gravatar_hash: String,
+}

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

@@ -0,0 +1,164 @@
+use anyhow::anyhow;
+use chrono::{DateTime, Utc};
+use log::warn;
+use sqlx::MySqlPool;
+
+use errors::AnyhowResult;
+use tokens::tokens::users::UserToken;
+
+pub struct LookupUserForModerationResult {
+  pub user_token: UserToken,
+  pub username: String,
+  pub display_name: String,
+  pub username_is_generated: bool,
+  pub is_temporary: bool,
+  pub username_is_not_customized: bool,
+  pub email_address: String,
+  pub email_confirmed: bool,
+  pub email_is_synthetic: bool,
+  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 email_gravatar_hash: String,
+  pub created_at: DateTime<Utc>,
+}
+
+pub async fn lookup_user_for_moderation_by_token(
+  token: &str,
+  mysql_pool: &MySqlPool,
+) -> AnyhowResult<Option<LookupUserForModerationResult>> {
+  let result = sqlx::query_as!(
+    LookupUserForModerationResult,
+    r#"
+SELECT
+    users.token as `user_token: tokens::tokens::users::UserToken`,
+    username,
+    display_name,
+    username_is_generated as `username_is_generated: bool`,
+    is_temporary as `is_temporary: bool`,
+    username_is_not_customized as `username_is_not_customized: bool`,
+    email_address,
+    email_confirmed as `email_confirmed: bool`,
+    email_is_synthetic as `email_is_synthetic: bool`,
+    is_without_password as `is_without_password: bool`,
+    ip_address_creation,
+    ip_address_last_login,
+    maybe_avatar_media_file_token,
+    email_gravatar_hash,
+    created_at
+FROM users
+WHERE
+    users.token = ?
+    AND users.user_deleted_at IS NULL
+    AND users.mod_deleted_at IS NULL
+LIMIT 1
+    "#,
+    token,
+  )
+    .fetch_one(mysql_pool)
+    .await;
+
+  match result {
+    Ok(record) => Ok(Some(record)),
+    Err(sqlx::Error::RowNotFound) => Ok(None),
+    Err(err) => {
+      warn!("lookup_user_for_moderation_by_token query error: {:?}", err);
+      Err(anyhow!("query error"))
+    }
+  }
+}
+
+pub async fn lookup_user_for_moderation_by_email(
+  email: &str,
+  mysql_pool: &MySqlPool,
+) -> AnyhowResult<Option<LookupUserForModerationResult>> {
+  let email = email.trim().to_lowercase();
+
+  let result = sqlx::query_as!(
+    LookupUserForModerationResult,
+    r#"
+SELECT
+    users.token as `user_token: tokens::tokens::users::UserToken`,
+    username,
+    display_name,
+    username_is_generated as `username_is_generated: bool`,
+    is_temporary as `is_temporary: bool`,
+    username_is_not_customized as `username_is_not_customized: bool`,
+    email_address,
+    email_confirmed as `email_confirmed: bool`,
+    email_is_synthetic as `email_is_synthetic: bool`,
+    is_without_password as `is_without_password: bool`,
+    ip_address_creation,
+    ip_address_last_login,
+    maybe_avatar_media_file_token,
+    email_gravatar_hash,
+    created_at
+FROM users
+WHERE
+    users.email_address = ?
+    AND users.user_deleted_at IS NULL
+    AND users.mod_deleted_at IS NULL
+LIMIT 1
+    "#,
+    email,
+  )
+    .fetch_one(mysql_pool)
+    .await;
+
+  match result {
+    Ok(record) => Ok(Some(record)),
+    Err(sqlx::Error::RowNotFound) => Ok(None),
+    Err(err) => {
+      warn!("lookup_user_for_moderation_by_email query error: {:?}", err);
+      Err(anyhow!("query error"))
+    }
+  }
+}
+
+pub async fn lookup_user_for_moderation_by_username(
+  username: &str,
+  mysql_pool: &MySqlPool,
+) -> AnyhowResult<Option<LookupUserForModerationResult>> {
+  let username = username.trim().to_lowercase();
+
+  let result = sqlx::query_as!(
+    LookupUserForModerationResult,
+    r#"
+SELECT
+    users.token as `user_token: tokens::tokens::users::UserToken`,
+    username,
+    display_name,
+    username_is_generated as `username_is_generated: bool`,
+    is_temporary as `is_temporary: bool`,
+    username_is_not_customized as `username_is_not_customized: bool`,
+    email_address,
+    email_confirmed as `email_confirmed: bool`,
+    email_is_synthetic as `email_is_synthetic: bool`,
+    is_without_password as `is_without_password: bool`,
+    ip_address_creation,
+    ip_address_last_login,
+    maybe_avatar_media_file_token,
+    email_gravatar_hash,
+    created_at
+FROM users
+WHERE
+    users.username = ?
+    AND users.user_deleted_at IS NULL
+    AND users.mod_deleted_at IS NULL
+LIMIT 1
+    "#,
+    username,
+  )
+    .fetch_one(mysql_pool)
+    .await;
+
+  match result {
+    Ok(record) => Ok(Some(record)),
+    Err(sqlx::Error::RowNotFound) => Ok(None),
+    Err(err) => {
+      warn!("lookup_user_for_moderation_by_username query error: {:?}", err);
+      Err(anyhow!("query error"))
+    }
+  }
+}

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

@@ -3,3 +3,4 @@ pub mod lookup_user_for_login_by_email;
 pub mod lookup_user_for_login_by_email_with_transactor;
 pub mod lookup_user_for_login_by_username;
 pub mod lookup_user_for_login_result;
+pub mod lookup_user_for_moderation;

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

@@ -1,4 +1,4 @@
 pub mod edit_user_profile_as_account_holder;
 pub mod edit_user_profile_as_mod;
 pub mod get_user_profile_by_token;
-pub mod get_user_profile_by_username;
+pub mod get_user_profile_by_username;

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

@@ -265,6 +265,7 @@ use artcraft_api_defs::subscriptions::get_session_subscription::*;
 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 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::*;
@@ -434,6 +435,7 @@ use crate::http_server::endpoints::media_files::list::list_batch_generated_redux
     crate::http_server::endpoints::tts::enqueue_infer_f5_tts_handler::enqueue_infer_f5_tts_handler::enqueue_infer_f5_tts_handler,
     // 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,
     // Credits
     crate::http_server::endpoints::credits::get_session_credits_handler::get_session_credits_handler,
     // Subscriptions
@@ -611,6 +613,9 @@ use crate::http_server::endpoints::media_files::list::list_batch_generated_redux
     EditUserFeatureFlagsError,
     EditUserFeatureFlagsOption,
     EditUserFeatureFlagsRequest,
+    ModeratorUserLookupRequest,
+    ModeratorUserLookupSuccessResponse,
+    ModeratorUserLookupUserDetails,
     GptImage1EditImageRequest,
     GptImage1EditImageImageSize,
     GptImage1EditImageNumImages,

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

@@ -1,5 +1,6 @@
 pub mod info;
 pub mod ip_bans;
 pub mod jobs;
+pub mod user;
 pub mod user_bans;
 pub mod user_feature_flags;

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

@@ -0,0 +1 @@
+pub mod moderator_user_lookup_handler;

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

@@ -0,0 +1,91 @@
+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::{
+  ModeratorUserLookupRequest,
+  ModeratorUserLookupSuccessResponse,
+  ModeratorUserLookupUserDetails,
+};
+use mysql_queries::queries::users::user::get::lookup_user_for_moderation::{
+  lookup_user_for_moderation_by_email,
+  lookup_user_for_moderation_by_token,
+  lookup_user_for_moderation_by_username,
+};
+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;
+
+const LEGACY_USER_TOKEN_PREFIX: &str = "U:";
+
+/// Moderator User Lookup
+#[utoipa::path(
+  post,
+  tag = "Moderation",
+  path = "/v1/moderation/user_lookup",
+  request_body = ModeratorUserLookupRequest,
+  responses(
+    (status = 200, description = "Success", body = ModeratorUserLookupSuccessResponse),
+    (status = 401, description = "Unauthorized"),
+    (status = 500, description = "Server error"),
+  ),
+)]
+pub async fn moderator_user_lookup_handler(
+  http_request: HttpRequest,
+  request: Json<ModeratorUserLookupRequest>,
+  server_state: web::Data<Arc<ServerState>>,
+) -> Result<Json<ModeratorUserLookupSuccessResponse>, CommonWebError> {
+
+  let _user_session = require_moderator(&http_request, &server_state, UseDatabase::Implicit)
+    .await
+    .map_err(|_| CommonWebError::NotAuthorized)?;
+
+  let search = request.search.trim();
+
+  if search.is_empty() {
+    return Ok(Json(ModeratorUserLookupSuccessResponse {
+      success: true,
+      maybe_user: None,
+    }));
+  }
+
+  let maybe_result = if search.starts_with(UserToken::token_prefix()) || search.starts_with(LEGACY_USER_TOKEN_PREFIX) {
+    lookup_user_for_moderation_by_token(search, &server_state.mysql_pool).await
+  } else if search.contains('@') {
+    lookup_user_for_moderation_by_email(search, &server_state.mysql_pool).await
+  } else {
+    lookup_user_for_moderation_by_username(search, &server_state.mysql_pool).await
+  };
+
+  let maybe_user = maybe_result
+    .map_err(|err| {
+      warn!("moderator_user_lookup error: {:?}", err);
+      CommonWebError::ServerError
+    })?;
+
+  let maybe_user_details = maybe_user.map(|user| ModeratorUserLookupUserDetails {
+    token: user.user_token.to_string(),
+    username: user.username,
+    display_name: user.display_name,
+    username_is_generated: user.username_is_generated,
+    is_temporary: user.is_temporary,
+    username_is_not_customized: user.username_is_not_customized,
+    email_address: user.email_address,
+    email_confirmed: user.email_confirmed,
+    email_is_synthetic: user.email_is_synthetic,
+    is_without_password: user.is_without_password,
+    ip_address_creation: user.ip_address_creation,
+    ip_address_last_login: user.ip_address_last_login,
+    maybe_avatar_media_file_token: user.maybe_avatar_media_file_token,
+    email_gravatar_hash: user.email_gravatar_hash,
+  });
+
+  Ok(Json(ModeratorUserLookupSuccessResponse {
+    success: true,
+    maybe_user: maybe_user_details,
+  }))
+}

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_handler::moderator_user_lookup_handler;
 use crate::http_server::endpoints::moderation::user_feature_flags::edit_user_feature_flags_handler::edit_user_feature_flags_handler;
 
 pub fn add_moderator_routes<T, B> (app: App<T>) -> App<T>
@@ -42,6 +43,10 @@ pub fn add_moderator_routes<T, B> (app: App<T>) -> App<T>
             .route(web::post().to(edit_user_feature_flags_handler))
             .route(web::head().to(|| HttpResponse::Ok()))
         )
+        .service(web::resource("/user_lookup")
+            .route(web::post().to(moderator_user_lookup_handler))
+            .route(web::head().to(|| HttpResponse::Ok()))
+        )
       )
       .service(web::scope("/moderation")
         .service(web::resource("/staff")