headless_lms_models/
exercise_reset_logs.rs

use crate::prelude::*;
use sqlx::PgConnection;

#[derive(Debug, Serialize, Deserialize, PartialEq, Clone)]
#[cfg_attr(feature = "ts_rs", derive(TS))]
pub struct ExerciseResetLog {
    pub id: Uuid,
    pub reset_by: Uuid,
    pub reset_by_first_name: Option<String>,
    pub reset_by_last_name: Option<String>,
    pub reset_for: Uuid,
    pub exercise_id: Uuid,
    pub exercise_name: String,
    pub course_id: Uuid,
    pub reset_at: DateTime<Utc>,
    pub created_at: DateTime<Utc>,
    pub updated_at: DateTime<Utc>,
    pub deleted_at: Option<DateTime<Utc>>,
}

/// Adds a log entry for reset exercises for a user
pub async fn log_exercise_reset(
    tx: &mut PgConnection,
    reset_by: Uuid,
    user_id: Uuid,
    exercise_ids: &[Uuid],
    course_id: Uuid,
) -> Result<(), sqlx::Error> {
    sqlx::query!(
        r#"
INSERT INTO exercise_reset_logs (
    reset_by,
    reset_for,
    exercise_id,
    course_id,
    reset_at
  )
SELECT $1,
  $2,
  unnest($3::uuid []),
  $4,
  NOW()
      "#,
        reset_by,
        user_id,
        &exercise_ids,
        course_id
    )
    .execute(&mut *tx)
    .await?;

    Ok(())
}

pub async fn get_exercise_reset_logs_for_user(
    conn: &mut PgConnection,
    user_id: Uuid,
) -> ModelResult<Vec<ExerciseResetLog>> {
    let result = sqlx::query_as!(
        ExerciseResetLog,
        r#"
SELECT erl.id,
  erl.reset_by,
  ud.first_name AS reset_by_first_name,
  ud.last_name AS reset_by_last_name,
  erl.reset_for,
  erl.exercise_id,
  e.name AS exercise_name,
  erl.course_id,
  erl.reset_at,
  erl.created_at,
  erl.updated_at,
  erl.deleted_at
FROM exercise_reset_logs erl
  JOIN exercises e ON erl.exercise_id = e.id
  JOIN user_details ud ON erl.reset_by = ud.user_id
WHERE erl.reset_for = $1
ORDER BY erl.reset_at DESC"#,
        user_id
    )
    .fetch_all(&mut *conn)
    .await?;

    Ok(result)
}
headless_lms_models/exercise_reset_logs.rs

headless_lms_models/
exercise_reset_logs.rs
