cleanup (let's test if it works...)

src/common_queries/list_tts_inference_results.rs

@@ -1,15 +1,19 @@
 use anyhow::anyhow;
 use chrono::{DateTime, Utc};
+use crate::shared_constants::DEFAULT_MYSQL_QUERY_RESULT_PAGE_SIZE;
 use crate::util::anyhow_result::AnyhowResult;
 use log::{warn, info};
 use sqlx::MySqlPool;
-use crate::shared_constants::DEFAULT_MYSQL_QUERY_RESULT_PAGE_SIZE;
 
 #[derive(Serialize)]
 pub struct TtsInferenceListPage {
   pub inference_records: Vec<TtsInferenceRecordForList>,
   pub sort_ascending: bool,
+
+  /// ID of the first record in `inference_records`.
   pub first_id: Option<i64>,
+
+  /// ID of the last record in `inference_records`.
   pub last_id: Option<i64>,
 }
 
@@ -34,438 +38,10 @@ pub struct TtsInferenceRecordForList {
   pub updated_at: DateTime<Utc>,
 }
 
-struct RawTtsInferenceRecordForList {
-  pub tts_result_token: String, // from field `tts_results.token`
-
-  pub tts_model_token: String,
-  pub raw_inference_text: String,
-
-  pub maybe_creator_user_token: Option<String>,
-  pub maybe_creator_username: Option<String>,
-  pub maybe_creator_display_name: Option<String>,
-
-  pub file_size_bytes: i32,
-  pub duration_millis: i32,
-
-  //pub model_is_mod_approved: i8, // needs convert
-  //pub maybe_mod_user_token: Option<String>,
-
-  pub created_at: DateTime<Utc>,
-  pub updated_at: DateTime<Utc>,
-}
-
-pub async fn list_tts_inference_results(
-  mysql_pool: &MySqlPool,
-  scope_creator_username: Option<&str>,
-  block_mod_disabled_models: bool
-) -> AnyhowResult<Vec<TtsInferenceRecordForList>> {
-
-  let maybe_results = match scope_creator_username {
-    Some(username) => {
-      list_tts_inference_results_creator_scoped(mysql_pool, username, block_mod_disabled_models)
-        .await
-    },
-    None => {
-      list_tts_inference_results_for_all_creators(mysql_pool, block_mod_disabled_models)
-        .await
-    },
-  };
-
-  let results : Vec<RawTtsInferenceRecordForList> = match maybe_results {
-    Ok(results) => {
-      info!("Results length: {}", results.len());
-      results
-    },
-    Err(err) => {
-      warn!("Error: {:?}", err);
-
-      match err {
-        RowNotFound => {
-          return Ok(Vec::new());
-        },
-        _ => {
-          warn!("tts inference result list query error: {:?}", err);
-          return Err(anyhow!("tts inference result list query error"));
-        }
-      }
-    }
-  };
-
-  Ok(results.into_iter()
-    .map(|ir| {
-      TtsInferenceRecordForList {
-        tts_result_token: ir.tts_result_token.clone(),
-
-        tts_model_token: ir.tts_model_token.clone(),
-        raw_inference_text: ir.raw_inference_text.clone(),
-
-        maybe_creator_user_token: ir.maybe_creator_user_token.clone(),
-        maybe_creator_username: ir.maybe_creator_username.clone(),
-        maybe_creator_display_name: ir.maybe_creator_display_name.clone(),
-        //model_is_mod_approved: if ir.model_is_mod_approved == 0 { false } else { true },
-
-        file_size_bytes: if ir.file_size_bytes > 0 { ir.file_size_bytes as u32 } else { 0 },
-        duration_millis: if ir.duration_millis > 0 { ir.duration_millis as u32 } else { 0 },
-
-        created_at: ir.created_at.clone(),
-        updated_at: ir.updated_at.clone(),
-      }
-    })
-    .collect::<Vec<TtsInferenceRecordForList>>())
-}
-
-async fn list_tts_inference_results_for_all_creators(
-  mysql_pool: &MySqlPool,
-  block_mod_disabled_models : bool
-) -> AnyhowResult<Vec<RawTtsInferenceRecordForList>> {
-  // TODO: There has to be a better way.
-  //  Sqlx doesn't like anything except string literals.
-  let maybe_results = if block_mod_disabled_models {
-    info!("listing tts inference results for everyone; mod-approved only");
-    sqlx::query_as!(
-      RawTtsInferenceRecordForList,
-        r#"
-SELECT
-    tts_results.token as tts_result_token,
-
-    tts_results.model_token as tts_model_token,
-    tts_results.raw_inference_text as raw_inference_text,
-
-    users.token as maybe_creator_user_token,
-    users.username as maybe_creator_username,
-    users.display_name as maybe_creator_display_name,
-
-    tts_results.file_size_bytes,
-    tts_results.duration_millis,
-    tts_results.created_at,
-    tts_results.updated_at
-
-FROM tts_results
-LEFT OUTER JOIN tts_models
-    ON tts_results.model_token = tts_models.token
-LEFT OUTER JOIN users
-    ON tts_results.maybe_creator_user_token = users.token
-WHERE
-    tts_models.is_locked_from_use IS FALSE
-    AND tts_results.user_deleted_at IS NULL
-    AND tts_results.mod_deleted_at IS NULL
-        "#)
-      .fetch_all(mysql_pool)
-      .await?
-  } else {
-    info!("listing tts inference results for everyone; all");
-    sqlx::query_as!(
-      RawTtsInferenceRecordForList,
-        r#"
-SELECT
-    tts_results.token as tts_result_token,
-
-    tts_results.model_token as tts_model_token,
-    tts_results.raw_inference_text as raw_inference_text,
-
-    users.token as maybe_creator_user_token,
-    users.username as maybe_creator_username,
-    users.display_name as maybe_creator_display_name,
-
-    tts_results.file_size_bytes,
-    tts_results.duration_millis,
-    tts_results.created_at,
-    tts_results.updated_at
-
-FROM tts_results
-LEFT OUTER JOIN tts_models
-    ON tts_results.model_token = tts_models.token
-LEFT OUTER JOIN users
-    ON tts_results.maybe_creator_user_token = users.token
-WHERE
-    tts_results.user_deleted_at IS NULL
-    AND tts_results.mod_deleted_at IS NULL
-        "#)
-      .fetch_all(mysql_pool)
-      .await?
-  };
-
-  Ok(maybe_results)
-}
-
-async fn list_tts_inference_results_creator_scoped(
-  mysql_pool: &MySqlPool,
-  scope_creator_username: &str,
-  block_mod_disabled : bool
-) -> AnyhowResult<Vec<RawTtsInferenceRecordForList>> {
-  // TODO: There has to be a better way.
-  //  Sqlx doesn't like anything except string literals.
-  let maybe_results = if block_mod_disabled {
-    info!("listing tts inference results for user `{}`; mod-approved only", scope_creator_username);
-    sqlx::query_as!(
-      RawTtsInferenceRecordForList,
-        r#"
-SELECT
-    tts_results.token as tts_result_token,
-
-    tts_results.model_token as tts_model_token,
-    tts_results.raw_inference_text as raw_inference_text,
-
-    users.token as maybe_creator_user_token,
-    users.username as maybe_creator_username,
-    users.display_name as maybe_creator_display_name,
-
-    tts_results.file_size_bytes,
-    tts_results.duration_millis,
-    tts_results.created_at,
-    tts_results.updated_at
-
-FROM tts_results
-LEFT OUTER JOIN tts_models
-    ON tts_results.model_token = tts_models.token
-LEFT OUTER JOIN users
-    ON tts_results.maybe_creator_user_token = users.token
-WHERE
-    users.username = ?
-    AND tts_models.is_locked_from_use IS FALSE
-    AND tts_results.user_deleted_at IS NULL
-    AND tts_results.mod_deleted_at IS NULL
-        "#,
-    scope_creator_username)
-      .fetch_all(mysql_pool)
-      .await?
-  } else {
-    info!("listing tts inference results for user `{}`; all", scope_creator_username);
-    sqlx::query_as!(
-      RawTtsInferenceRecordForList,
-        r#"
-SELECT
-    tts_results.token as tts_result_token,
-
-    tts_results.model_token as tts_model_token,
-    tts_results.raw_inference_text as raw_inference_text,
-
-    users.token as maybe_creator_user_token,
-    users.username as maybe_creator_username,
-    users.display_name as maybe_creator_display_name,
-
-    tts_results.file_size_bytes,
-    tts_results.duration_millis,
-    tts_results.created_at,
-    tts_results.updated_at
-
-FROM tts_results
-LEFT OUTER JOIN tts_models
-    ON tts_results.model_token = tts_models.token
-LEFT OUTER JOIN users
-    ON tts_results.maybe_creator_user_token = users.token
-WHERE
-    users.username = ?
-    AND tts_results.user_deleted_at IS NULL
-    AND tts_results.mod_deleted_at IS NULL
-        "#,
-    scope_creator_username)
-      .fetch_all(mysql_pool)
-      .await?
-  };
-
-  Ok(maybe_results)
-}
-
-#[derive(sqlx::FromRow)]
-pub struct RawInternalTtsRecord {
-  pub tts_result_id: i64,
-  pub tts_result_token: String,
-
-  pub tts_model_token: String,
-  pub raw_inference_text: String,
-
-  pub maybe_creator_user_token : Option<String>,
-  pub maybe_creator_username: Option<String>,
-  pub maybe_creator_display_name: Option<String>,
-
-  pub file_size_bytes : i64,
-  pub duration_millis : i64,
-  pub created_at: DateTime<Utc>,
-  pub updated_at: DateTime<Utc>,
-}
-
-/// Paginated queries.
-pub async fn list_tts_inference_page(
-  mysql_pool: &MySqlPool,
-  scope_creator_username: Option<&str>,
-  sort_ascending: bool,
-  cursor_is_previous: bool,
-  block_mod_disabled : bool,
-  limit: u16,
-  offset: Option<u64>,
-) -> AnyhowResult<TtsInferenceListPage> {
-
-  let inference_results = list_tts_inference_results_query(
-    mysql_pool,
-    scope_creator_username,
-    sort_ascending,
-    cursor_is_previous,
-    block_mod_disabled,
-    limit,
-    offset
-  ).await?;
-
-  let mut first_id = inference_results.first()
-      .map(|raw_result| raw_result.tts_result_id);
-
-  let mut last_id = inference_results.last()
-      .map(|raw_result| raw_result.tts_result_id);
-
-  let inference_results = inference_results
-      .iter()
-      .map(|r| {
-        TtsInferenceRecordForList {
-          tts_result_token: r.tts_result_token.clone(),
-          tts_model_token: r.tts_model_token.clone(),
-          raw_inference_text: r.raw_inference_text.clone(),
-          maybe_creator_user_token: r.maybe_creator_user_token.clone(),
-          maybe_creator_username: r.maybe_creator_username.clone(),
-          maybe_creator_display_name: r.maybe_creator_display_name.clone(),
-          file_size_bytes: if r.file_size_bytes > 0 { r.file_size_bytes as u32 } else { 0 },
-          duration_millis: if r.duration_millis > 0 { r.duration_millis as u32 } else { 0 },
-          created_at: r.created_at,
-          updated_at: r.updated_at,
-        }
-      })
-      .collect::<Vec<TtsInferenceRecordForList>>();
-
-  Ok(TtsInferenceListPage {
-    inference_records: inference_results,
-    sort_ascending,
-    first_id,
-    last_id,
-  })
-}
-
-async fn list_tts_inference_results_query (
-  mysql_pool: &MySqlPool,
-  scope_creator_username: Option<&str>,
-  sort_ascending: bool,
-  cursor_is_previous: bool,
-  block_mod_disabled : bool,
-  limit: u16,
-  offset: Option<u64>,
-) -> AnyhowResult<Vec<RawInternalTtsRecord>> {
-  info!("listing tts inference results");
-
-  // TODO/NB: Unfortunately SQLx can't statically typecheck this query
-  let mut query = r#"
-SELECT
-    tts_results.id as tts_result_id,
-    tts_results.token as tts_result_token,
-
-    tts_results.model_token as tts_model_token,
-    tts_results.raw_inference_text as raw_inference_text,
-
-    users.token as maybe_creator_user_token,
-    users.username as maybe_creator_username,
-    users.display_name as maybe_creator_display_name,
-
-    tts_results.file_size_bytes,
-    tts_results.duration_millis,
-    tts_results.created_at,
-    tts_results.updated_at
-
-FROM tts_results
-LEFT OUTER JOIN tts_models
-    ON tts_results.model_token = tts_models.token
-LEFT OUTER JOIN users
-    ON tts_results.maybe_creator_user_token = users.token
-  "#.to_string();
-
-  let mut sort_ascending = sort_ascending; // NB: We may need to change the direction.
-  let mut reverse_results = false;
-
-  let mut first_predicate_added = false;
-
-  if let Some(offset) = offset {
-    if !first_predicate_added {
-      query.push_str(" WHERE ");
-      first_predicate_added = true;
-    } else {
-      query.push_str(" AND ");
-    }
-
-    // TODO: Cleanup, builder class, tests.
-
-    if sort_ascending {
-      if cursor_is_previous {
-        // NB: We're searching backwards.
-        query.push_str(" tts_results.id < ? ");
-        sort_ascending = !sort_ascending;
-        reverse_results = true;
-      } else {
-        query.push_str(" tts_results.id > ? ");
-      }
-    } else {
-      if cursor_is_previous {
-        // NB: We're searching backwards.
-        query.push_str(" tts_results.id > ? ");
-        sort_ascending = !sort_ascending;
-        reverse_results = true;
-      } else {
-        query.push_str(" tts_results.id < ? ");
-      }
-    }
-  }
-
-  if let Some(username) = scope_creator_username {
-    if !first_predicate_added {
-      query.push_str(r#" WHERE users.username = ? "#);
-      first_predicate_added = true;
-    } else {
-      query.push_str(r#" AND users.username = ? "#);
-    }
-  }
-
-  if block_mod_disabled {
-    if !first_predicate_added {
-      query.push_str(r#"
-        WHERE tts_results.user_deleted_at IS NULL
-        AND tts_results.mod_deleted_at IS NULL
-      "#);
-      first_predicate_added = true;
-    } else {
-      query.push_str(r#"
-        AND tts_results.user_deleted_at IS NULL
-        AND tts_results.mod_deleted_at IS NULL
-      "#);
-    }
-  }
-
-  if sort_ascending {
-    query.push_str(" ORDER BY tts_results.id ASC ");
-  } else {
-    query.push_str(" ORDER BY tts_results.id DESC ");
-  }
-
-  query.push_str(" LIMIT ? ");
-
-  let mut query = sqlx::query_as::<_, RawInternalTtsRecord>(&query);
-
-  if let Some(offset) = offset {
-    query = query.bind(offset);
-  }
-
-  if let Some(username) = scope_creator_username {
-    query = query.bind(username);
-  }
-
-  query = query.bind(limit);
-
-  let mut results = query.fetch_all(mysql_pool)
-      .await?;
-
-  if reverse_results {
-    results.reverse()
-  }
-
-  Ok(results)
-}
-
-/// These are very difficult queries, so this helps.
-pub struct QueryBuilder {
+/// Query Builder for listing TTS results.
+/// These are very difficult queries, so the builder helps for
+/// testability, construction, and correctness.
+pub struct ListTtsResultsQueryBuilder {
   scope_creator_username: Option<String>,
   include_mod_disabled_results: bool,
   sort_ascending: bool,
@@ -474,7 +50,7 @@ pub struct QueryBuilder {
   cursor_is_reversed: bool,
 }
 
-impl QueryBuilder {
+impl ListTtsResultsQueryBuilder {
   pub fn new() -> Self {
     Self {
       scope_creator_username: None,
@@ -517,7 +93,50 @@ impl QueryBuilder {
   }
 
   /// Perform the query based on the set predicates.
-  pub async fn perform_query(
+  /// Wrap the results in a "Page" we can return to the frontend.
+  /// This will remove any IDs from the records, but the ids themselves also need scrubbing.
+  pub async fn perform_query_for_page(
+    &self,
+    mysql_pool: &MySqlPool
+  ) -> AnyhowResult<TtsInferenceListPage> {
+
+    let internal_results = self.perform_internal_query(mysql_pool).await?;
+
+    let mut first_id = internal_results.first()
+        .map(|raw_result| raw_result.tts_result_id);
+
+    let mut last_id = internal_results.last()
+        .map(|raw_result| raw_result.tts_result_id);
+
+    let inference_results = internal_results
+        .iter()
+        .map(|r| {
+          TtsInferenceRecordForList {
+            tts_result_token: r.tts_result_token.clone(),
+            tts_model_token: r.tts_model_token.clone(),
+            raw_inference_text: r.raw_inference_text.clone(),
+            maybe_creator_user_token: r.maybe_creator_user_token.clone(),
+            maybe_creator_username: r.maybe_creator_username.clone(),
+            maybe_creator_display_name: r.maybe_creator_display_name.clone(),
+            file_size_bytes: if r.file_size_bytes > 0 { r.file_size_bytes as u32 } else { 0 },
+            duration_millis: if r.duration_millis > 0 { r.duration_millis as u32 } else { 0 },
+            created_at: r.created_at,
+            updated_at: r.updated_at,
+          }
+        })
+        .collect::<Vec<TtsInferenceRecordForList>>();
+
+    Ok(TtsInferenceListPage {
+      inference_records: inference_results,
+      sort_ascending: self.sort_ascending,
+      first_id,
+      last_id,
+    })
+  }
+
+  /// Perform the query based on the set predicates.
+  /// The records contain IDs, which we should not expose to the frontend.
+  pub async fn perform_internal_query(
     &self,
     mysql_pool: &MySqlPool
   ) -> AnyhowResult<Vec<RawInternalTtsRecord>> {
@@ -644,13 +263,31 @@ LEFT OUTER JOIN users
   }
 }
 
+#[derive(sqlx::FromRow)]
+pub struct RawInternalTtsRecord {
+  pub tts_result_id: i64,
+  pub tts_result_token: String,
+
+  pub tts_model_token: String,
+  pub raw_inference_text: String,
+
+  pub maybe_creator_user_token : Option<String>,
+  pub maybe_creator_username: Option<String>,
+  pub maybe_creator_display_name: Option<String>,
+
+  pub file_size_bytes : i64,
+  pub duration_millis : i64,
+  pub created_at: DateTime<Utc>,
+  pub updated_at: DateTime<Utc>,
+}
+
 #[cfg(test)]
 mod tests {
-  use crate::common_queries::list_tts_inference_results::QueryBuilder;
+  use crate::common_queries::list_tts_inference_results::ListTtsResultsQueryBuilder;
 
   #[test]
   fn predicates_without_scoping() {
-    let query_builder = QueryBuilder::new();
+    let query_builder = ListTtsResultsQueryBuilder::new();
 
     assert_eq!(&query_builder.build_predicates(),
       " WHERE tts_results.user_deleted_at IS NULL \
@@ -661,7 +298,7 @@ mod tests {
 
   #[test]
   fn predicates_scoped_to_user() {
-    let query_builder = QueryBuilder::new()
+    let query_builder = ListTtsResultsQueryBuilder::new()
         .scope_creator_username(Some("echelon"));
 
     assert_eq!(&query_builder.build_predicates(),
@@ -674,7 +311,7 @@ mod tests {
 
   #[test]
   fn predicates_including_deleted() {
-    let query_builder = QueryBuilder::new()
+    let query_builder = ListTtsResultsQueryBuilder::new()
         .include_mod_disabled_results(true);
 
     assert_eq!(&query_builder.build_predicates(),
@@ -684,7 +321,7 @@ mod tests {
 
   #[test]
   fn predicates_sort_ascending() {
-    let query_builder = QueryBuilder::new()
+    let query_builder = ListTtsResultsQueryBuilder::new()
         .sort_ascending(true);
 
     assert_eq!(&query_builder.build_predicates(),
@@ -696,7 +333,7 @@ mod tests {
 
   #[test]
   fn predicates_offset() {
-    let query_builder = QueryBuilder::new()
+    let query_builder = ListTtsResultsQueryBuilder::new()
         .offset(Some(100));
 
     assert_eq!(&query_builder.build_predicates(),
@@ -709,7 +346,7 @@ mod tests {
 
   #[test]
   fn predicates_offset_and_sort_ascending() {
-    let query_builder = QueryBuilder::new()
+    let query_builder = ListTtsResultsQueryBuilder::new()
         .sort_ascending(true)
         .offset(Some(100));
 
@@ -723,7 +360,7 @@ mod tests {
 
   #[test]
   fn predicates_limit() {
-    let query_builder = QueryBuilder::new()
+    let query_builder = ListTtsResultsQueryBuilder::new()
         .limit(15);
 
     // NB: Does not change the query itself! Just the downstream binding.
@@ -736,7 +373,7 @@ mod tests {
 
   #[test]
   fn predicates_cursor_is_reversed_without_cursor() {
-    let query_builder = QueryBuilder::new()
+    let query_builder = ListTtsResultsQueryBuilder::new()
         .cursor_is_reversed(true);
 
     // NB: Without a cursor, nothing happens.
@@ -749,7 +386,7 @@ mod tests {
 
   #[test]
   fn predicates_offset_cursor_is_reversed() {
-    let query_builder = QueryBuilder::new()
+    let query_builder = ListTtsResultsQueryBuilder::new()
         .offset(Some(100))
         .cursor_is_reversed(true);
 
@@ -764,7 +401,7 @@ mod tests {
 
   #[test]
   fn predicates_offset_cursor_is_reversed_sort_ascending() {
-    let query_builder = QueryBuilder::new()
+    let query_builder = ListTtsResultsQueryBuilder::new()
         .offset(Some(100))
         .cursor_is_reversed(true)
         .sort_ascending(true);
@@ -780,7 +417,7 @@ mod tests {
 
   #[test]
   fn predicates_limit_scope_user_offset_cursor_is_reversed_sort_ascending() {
-    let query_builder = QueryBuilder::new()
+    let query_builder = ListTtsResultsQueryBuilder::new()
         .limit(1000)
         .scope_creator_username(Some("pikachu"))
         .offset(Some(100))

src/http_server/endpoints/users/list_user_tts_inference_results.rs

@@ -8,12 +8,13 @@ use actix_web::web::{Path, Query};
 use actix_web::{Responder, web, HttpResponse, error, HttpRequest, HttpMessage};
 use chrono::{DateTime, Utc};
 use crate::AnyhowResult;
+use crate::common_queries::list_tts_inference_results::ListTtsResultsQueryBuilder;
 use crate::common_queries::list_tts_inference_results::TtsInferenceRecordForList;
-use crate::common_queries::list_tts_inference_results::list_tts_inference_page;
 use crate::common_queries::sessions::create_session_for_user;
 use crate::http_server::endpoints::users::create_account::CreateAccountError::{BadInput, ServerError, UsernameTaken, EmailTaken};
 use crate::http_server::endpoints::users::login::LoginSuccessResponse;
 use crate::http_server::web_utils::ip_address::get_request_ip;
+use crate::http_server::web_utils::response_error_helpers::to_simple_json_error;
 use crate::http_server::web_utils::session_checker::SessionRecord;
 use crate::server_state::ServerState;
 use crate::util::random_crockford_token::random_crockford_token;
@@ -27,7 +28,6 @@ use sqlx::error::DatabaseError;
 use sqlx::error::Error::Database;
 use sqlx::mysql::MySqlDatabaseError;
 use std::sync::Arc;
-use crate::http_server::web_utils::response_error_helpers::to_simple_json_error;
 
 /// For the URL PathInfo
 #[derive(Deserialize)]
@@ -40,7 +40,7 @@ pub struct ListTtsInferenceResultsForUserQuery {
   pub sort_ascending: Option<bool>,
   pub limit: Option<u16>,
   pub cursor: Option<String>,
-  pub cursor_is_previous: Option<bool>,
+  pub cursor_is_reversed: Option<bool>,
 }
 
 #[derive(Serialize)]
@@ -81,14 +81,11 @@ pub async fn list_user_tts_inference_results_handler(
 {
   info!("Fetching inference results for user: {}", &path.username);
 
-  let mod_disabled = false;
-
   let limit = query.limit.unwrap_or(25);
   //let limit = std::cmp::max(limit, 100);
 
   let sort_ascending = query.sort_ascending.unwrap_or(false);
-
-  let cursor_is_previous = query.cursor_is_previous.unwrap_or(false);
+  let cursor_is_reversed = query.cursor_is_reversed.unwrap_or(false);
 
   let cursor = if let Some(cursor) = query.cursor.as_deref() {
     let cursor = server_state.sort_key_crypto.decrypt_id(cursor)
@@ -101,15 +98,18 @@ pub async fn list_user_tts_inference_results_handler(
     None
   };
 
-  let query_results = list_tts_inference_page(
-    &server_state.mysql_pool,
-    Some(path.username.as_ref()),
-    sort_ascending,
-    cursor_is_previous,
-    mod_disabled,
-    limit,
-    cursor,
-  ).await;
+  let include_mod_disabled = false; // TODO: Permission check
+
+  let mut query_builder = ListTtsResultsQueryBuilder::new()
+      .sort_ascending(sort_ascending)
+      .scope_creator_username(Some(path.username.as_ref()))
+      .include_mod_disabled_results(include_mod_disabled)
+      .limit(limit)
+      .cursor_is_reversed(cursor_is_reversed)
+      .offset(cursor);
+
+  let query_results = query_builder.perform_query_for_page(&server_state.mysql_pool)
+      .await;
 
   let results_page = match query_results {
     Ok(results) => results,