Merge pull request #122 from amfoss/develop

Update member mutation and add track column

Author: hrideshmg

docs/member.md

@@ -17,6 +17,7 @@ struct Member {
     mac_address: String,
     discord_id: String,
     group_id: i32,
+    track: String,
 }
 ```
 
@@ -53,6 +54,7 @@ mutation {
             macAddress: "XX:XX:XX:XX:XX:XX"
             discordId: "123456789"
             groupId: 1
+            track: "web"
         }
     ) {
         memberId

migrations/20250602174736_add_track_feild_to_members.sql

@@ -0,0 +1,3 @@
+-- Add migration script here
+ALTER TABLE Member
+ADD COLUMN track VARCHAR(255);

src/graphql/mutations/member_mutations.rs

@@ -1,11 +1,9 @@
-use std::sync::Arc;
-
+use crate::models::member::{CreateMemberInput, Member, UpdateMemberInput};
 use async_graphql::{Context, Object, Result};
 use chrono::Local;
 use chrono_tz::Asia::Kolkata;
 use sqlx::PgPool;
-
-use crate::models::member::{CreateMemberInput, Member};
+use std::sync::Arc;
 
 #[derive(Default)]
 pub struct MemberMutations;
@@ -15,11 +13,11 @@ impl MemberMutations {
     #[graphql(name = "createMember")]
     async fn create_member(&self, ctx: &Context<'_>, input: CreateMemberInput) -> Result<Member> {
         let pool = ctx.data::<Arc<PgPool>>().expect("Pool must be in context.");
-
         let now = Local::now().with_timezone(&Kolkata).date_naive();
+
         let member = sqlx::query_as::<_, Member>(
-            "INSERT INTO Member (roll_no, name, email, sex, year, hostel, mac_address, discord_id, group_id, created_at)
-            VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10) RETURNING *"
+            "INSERT INTO Member (roll_no, name, email, sex, year, hostel, mac_address, discord_id, group_id, track, created_at)
+            VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11) RETURNING *"
         )
         .bind(&input.roll_no)
         .bind(&input.name)
@@ -30,10 +28,47 @@ impl MemberMutations {
         .bind(&input.mac_address)
         .bind(&input.discord_id)
         .bind(input.group_id)
+        .bind(&input.track)
         .bind(now)
         .fetch_one(pool.as_ref())
         .await?;
 
         Ok(member)
     }
+
+    #[graphql(name = "updateMember")]
+    async fn update_member(&self, ctx: &Context<'_>, input: UpdateMemberInput) -> Result<Member> {
+        let pool = ctx.data::<Arc<PgPool>>().expect("Pool must be in context.");
+
+        let member = sqlx::query_as::<_, Member>(
+            "UPDATE Member SET
+                roll_no = COALESCE($1, roll_no),
+                name = COALESCE($2, name),
+                email = COALESCE($3, email),
+                sex = COALESCE($4, sex),
+                year = COALESCE($5, year),
+                hostel = COALESCE($6, hostel),
+                mac_address = COALESCE($7, mac_address),
+                discord_id = COALESCE($8, discord_id),
+                group_id = COALESCE($9, group_id),
+                track = COALESCE($10, track)
+            WHERE member_id = $11
+            RETURNING *",
+        )
+        .bind(&input.roll_no)
+        .bind(&input.name)
+        .bind(&input.email)
+        .bind(input.sex)
+        .bind(input.year)
+        .bind(&input.hostel)
+        .bind(&input.mac_address)
+        .bind(&input.discord_id)
+        .bind(input.group_id)
+        .bind(&input.track)
+        .bind(input.member_id)
+        .fetch_one(pool.as_ref())
+        .await?;
+
+        Ok(member)
+    }
 }

src/models/member.rs

@@ -23,6 +23,7 @@ pub struct Member {
     pub mac_address: String,
     pub discord_id: String,
     pub group_id: i32,
+    pub track: Option<String>,
     #[graphql(skip)] // Don't expose internal fields/meta-data
     pub created_at: NaiveDateTime,
 }
@@ -38,4 +39,20 @@ pub struct CreateMemberInput {
     pub mac_address: String,
     pub discord_id: String,
     pub group_id: i32,
+    pub track: Option<String>,
+}
+
+#[derive(InputObject)]
+pub struct UpdateMemberInput {
+    pub member_id: i32,
+    pub roll_no: Option<String>,
+    pub name: Option<String>,
+    pub email: Option<String>,
+    pub sex: Option<Sex>,
+    pub year: Option<i32>,
+    pub hostel: Option<String>,
+    pub mac_address: Option<String>,
+    pub discord_id: Option<String>,
+    pub group_id: Option<i32>,
+    pub track: Option<String>,
 }