rewrite graphql interface

This commit changes a lot more things than just the graphql interface.
Also likely introduces a few extra regressions. ¯\_(ツ)_/¯

Author: ivinjabraham

Cargo.lock

@@ -21,5 +21,5 @@ serde_json = "1.0"
 reqwest = { version = "0.11.27", features = ["json"] }
 config = "0.13"
 tracing = "0.1.41"
-tracing-subscriber = "0.3.19"
+tracing-subscriber = { version = "0.3.19", features = ["env-filter"] }
 dotenv = "0.15.0"

Cargo.toml

@@ -32,7 +32,7 @@ CREATE TABLE Attendance (
                 (is_present = FALSE AND time_in IS NULL AND time_out IS NULL)
         ),
         CHECK (is_present = FALSE OR date <= CURRENT_DATE),
-        CHECK (time_out IS NULL OR time_out > time_in),
+        CHECK (time_out IS NULL OR time_out >= time_in),
         UNIQUE (member_id, date)
 );
 
@@ -58,7 +58,7 @@ CREATE TABLE AttendanceSummary (
         primary key (member_id, year, month)
 );
 
-CREATE TABLE StatusUpdateStreaks (
+CREATE TABLE StatusUpdateStreak (
         member_id INT REFERENCES Member(member_id) ON DELETE CASCADE,
         current_streak int NOT NULL DEFAULT 0,
         max_streak INT NOT NULL,

migrations/20250114180047_create_tables.sql

@@ -2,7 +2,7 @@ use chrono::{Datelike, Local, NaiveDate, NaiveTime};
 use chrono_tz::Asia::Kolkata;
 use sqlx::PgPool;
 use std::sync::Arc;
-use tracing::{debug, error, info, trace};
+use tracing::{debug, error};
 
 use crate::models::member::Member;
 
@@ -26,7 +26,7 @@ pub async fn execute_daily_task(pool: Arc<PgPool>) {
 // We need to add a record for every member because otherwise [`Presense`](https://www.github.com/presense) will only add present members to the DB, and we will have to JOIN Members and Attendance records for the day to get the absent members. In exchange for increased storage use, we get simpler queries for Home which needs the data for every member for every day so far. But as of Jan 2025, there are less than 50 members in the club and thus storage really shouldn't be an issue.
 /// Inserts new attendance records everyday for [`presense`](https://www.github.com/amfoss/presense) to update them later in the day and updates the AttendanceSummary table to keep track of monthly streaks.
 async fn update_attendance(members: Vec<Member>, pool: &PgPool) {
-    info!("Updating attendance...");
+    debug!("Updating attendance...");
     let today = Local::now().with_timezone(&Kolkata).date_naive();
 
     for member in members {
@@ -66,7 +66,7 @@ async fn update_attendance(members: Vec<Member>, pool: &PgPool) {
 
 /// Checks if the member was present yesterday, and if so, increments the `days_attended` value. Otherwise, do nothing.
 async fn update_attendance_summary(member_id: i32, pool: &PgPool) {
-    trace!("Updating summary for member #{}", member_id);
+    debug!("Updating summary for member #{}", member_id);
     let today = chrono::Local::now().with_timezone(&Kolkata).date_naive();
     let yesterday = today.checked_sub_signed(chrono::Duration::days(1)).unwrap(); // Get yesterday's date
 

src/attendance/daily_task.rs renamed to src/daily_task/daily_task.rs

@@ -1,2 +1,2 @@
 pub mod mutations;
-pub mod query;
+pub mod queries;