Graphql query and mutation for crystal library

backend/crystal_library/Cargo.toml

@@ -7,6 +7,7 @@ edition = "2021"
 async-graphql = { workspace = true }
 axum = { workspace = true }
 clap = { workspace = true }
+chrono ={ workspace = true }
 dotenvy = { workspace = true }
 graphql_endpoints = { path = "../graphql_endpoints" }
 opa_client = { path = "../opa_client", features = ["graphql"] }

backend/crystal_library/src/entities/crystal_wells.rs

@@ -1,6 +1,5 @@
-//src/entities/compound_instances.rs
-
 use async_graphql::SimpleObject;
+use chrono::{DateTime, Utc};
 use sea_orm::{
     ActiveModelBehavior, DeriveEntityModel, DerivePrimaryKey, DeriveRelation, EntityTrait,
     EnumIter, PrimaryKeyTrait,
@@ -14,7 +13,9 @@ pub struct Model {
     #[sea_orm(primary_key, auto_increment = false)]
     pub id: Uuid,
     pub plate_id: Uuid,
-    pub well_num: i16,
+    pub well_number: i16,
+    pub operator_id: String,
+    pub timestamp: DateTime<Utc>,
 }
 
 #[derive(Clone, Copy, Debug, EnumIter, DeriveRelation)]

backend/crystal_library/src/resolvers/crystal_wells_res.rs → backend/crystal_library/src/graphql/crystal_wells_res.rs

@@ -1,7 +1,6 @@
-// src/resolvers/crystal_wells_res.rs
-
 use crate::entities::crystal_wells;
 use async_graphql::{Context, Object};
+use chrono::Utc;
 use opa_client::subject_authorization;
 use sea_orm::{ActiveValue, DatabaseConnection, EntityTrait};
 use the_paginator::graphql::{CursorInput, ModelConnection};
@@ -46,14 +45,17 @@ impl CrystalMutation {
         &self,
         ctx: &Context<'_>,
         plate_id: Uuid,
-        well_num: i16,
+        well_number: i16,
     ) -> async_graphql::Result<crystal_wells::Model> {
-        subject_authorization!("xchemlab.crystal_library.write_crystal", ctx).await?;
+        let operator_id =
+            subject_authorization!("xchemlab.crystal_library.write_crystal", ctx).await?;
         let db = ctx.data::<DatabaseConnection>()?;
         let crystal = crystal_wells::ActiveModel {
             id: ActiveValue::Set(Uuid::now_v7()),
             plate_id: ActiveValue::Set(plate_id),
-            well_num: ActiveValue::Set(well_num),
+            well_number: ActiveValue::Set(well_number),
+            operator_id: ActiveValue::Set(operator_id),
+            timestamp: ActiveValue::Set(Utc::now()),
         };
         Ok(crystal_wells::Entity::insert(crystal)
             .exec_with_returning(db)

backend/crystal_library/src/graphql.rs → backend/crystal_library/src/graphql/mod.rs

@@ -1,7 +1,7 @@
-// src/graphql.rs
+pub mod crystal_wells_res;
 
-use crate::resolvers::crystal_wells_res::{CrystalMutation, CrystalQuery};
 use async_graphql::{EmptySubscription, MergedObject, Schema, SchemaBuilder};
+use crystal_wells_res::{CrystalMutation, CrystalQuery};
 
 #[derive(Debug, Clone, MergedObject, Default)]
 pub struct Query(CrystalQuery);

backend/crystal_library/src/main.rs

@@ -1,9 +1,6 @@
-// main.rs
-
 mod entities;
 mod graphql;
 mod migrator;
-mod resolvers;
 
 use async_graphql::extensions::Tracing;
 use axum::{routing::get, Router, Server};

backend/crystal_library/src/migrator.rs

@@ -1,5 +1,3 @@
-// src/migrator.rs
-
 use crate::entities::crystal_wells;
 use axum::async_trait;
 use sea_orm::{DbErr, DeriveMigrationName, Schema};