Uuidv7 update

Author: iamvigneshwars

backend/Cargo.lock

@@ -45,4 +45,4 @@ tokio = { version = "1.35.1", features = ["macros", "rt-multi-thread"] }
 tracing = { version = "0.1.40" }
 tracing-subscriber = { version = "0.3.18", features = ["env-filter"] }
 url = { version = "2.5.0" }
-uuid = { version = "1.7.0", features = ["v4"] }
+uuid = { version = "1.7.0", features = ["v7"] }

backend/Cargo.toml

@@ -30,14 +30,14 @@ pub async fn setup_rabbitmq_client(address: Url) -> Result<Connection, anyhow::E
 }
 
 /// Joins a RabbitMQ channel, creating a [`Consumer`] with [`Default`] [`BasicConsumeOptions`] and [`FieldTable`].
-/// The consumer tag is generated following the format `chimp_chomp_${`[`Uuid::new_v4`]`}`.
+/// The consumer tag is generated following the format `chimp_chomp_${`[`Uuid::now_v7`]`}`.
 ///
 /// Returns a [`lapin::Error`] if the requested channel is not available.
 pub async fn setup_job_consumer(
     rabbitmq_channel: Channel,
     channel: impl AsRef<str>,
 ) -> Result<Consumer, lapin::Error> {
-    let worker_id = Uuid::new_v4();
+    let worker_id = Uuid::now_v7();
     let worker_tag = format!("chimp_chomp_{worker_id}");
     rabbitmq_channel
         .queue_declare(

backend/chimp_chomp/src/jobs.rs

@@ -20,7 +20,7 @@ pub async fn setup_chimp_client(
 
     let channel = connection.create_channel().await?;
 
-    let reply_queue_id = Uuid::new_v4();
+    let reply_queue_id = Uuid::now_v7();
     channel
         .queue_declare(
             &reply_queue_id.to_string(),

backend/chimp_controller/src/chimp_messages.rs

@@ -74,7 +74,7 @@ impl CaneMountMutation {
         }?;
 
         let cane = cane_mount::ActiveModel {
-            id: ActiveValue::Set(Uuid::new_v4()),
+            id: ActiveValue::Set(Uuid::now_v7()),
             barcode: ActiveValue::Set(barcode),
             operator_id: ActiveValue::Set(operator_id),
             timestamp: ActiveValue::Set(Utc::now()),

backend/pin_packing/src/resolvers/cane_mount.rs

@@ -53,7 +53,7 @@ impl CrystalMutation {
         let operator_id = subject_authorization!("xchemlab.pin_packing.write_crystal", ctx).await?;
         let database = ctx.data::<DatabaseConnection>()?;
         let crystal = crystal::ActiveModel {
-            id: ActiveValue::Set(Uuid::new_v4()),
+            id: ActiveValue::Set(Uuid::now_v7()),
             plate: ActiveValue::Set(well.plate),
             well: ActiveValue::Set(well.well),
             crystal_state: ActiveValue::Set(crystal_state),

backend/pin_packing/src/resolvers/crystal.rs

@@ -77,7 +77,7 @@ impl PinMountMutation {
         }?;
 
         let pin_mount = pin_mount::ActiveModel {
-            id: ActiveValue::Set(Uuid::new_v4()),
+            id: ActiveValue::Set(Uuid::now_v7()),
             crystal_id: ActiveValue::Set(crystal_id),
             puck_mount_id: ActiveValue::Set(puck_mount_id),
             puck_location: ActiveValue::Set(puck_location),

backend/pin_packing/src/resolvers/pin_mount.rs

@@ -66,7 +66,7 @@ impl PuckMountMutation {
         }?;
 
         let puck = puck_mount::ActiveModel {
-            id: ActiveValue::Set(Uuid::new_v4()),
+            id: ActiveValue::Set(Uuid::now_v7()),
             cane_mount_id: ActiveValue::Set(None),
             cane_location: ActiveValue::Set(None),
             barcode: ActiveValue::Set(barcode),

backend/pin_packing/src/resolvers/puck_mount.rs

@@ -46,7 +46,7 @@ struct CrystalInput {
 impl prediction_crystal::ActiveModel {
     fn from_crystal_input_and_drop_id(crystal_input: &CrystalInput, drop_id: Uuid) -> Self {
         Self {
-            id: ActiveValue::Set(Uuid::new_v4()),
+            id: ActiveValue::Set(Uuid::now_v7()),
             drop_id: ActiveValue::Set(drop_id),
             left: ActiveValue::Set(crystal_input.bounding_box.left),
             right: ActiveValue::Set(crystal_input.bounding_box.right),
@@ -96,7 +96,7 @@ struct DropInput {
 impl prediction_drop::ActiveModel {
     fn from_drop_input_and_prediction_id(drop_input: &DropInput, prediction_id: Uuid) -> Self {
         Self {
-            id: ActiveValue::Set(Uuid::new_v4()),
+            id: ActiveValue::Set(Uuid::now_v7()),
             prediction_id: ActiveValue::Set(prediction_id),
             insertion_point_x: ActiveValue::Set(drop_input.insertion_point.x),
             insertion_point_y: ActiveValue::Set(drop_input.insertion_point.y),
@@ -185,7 +185,7 @@ impl PredicitonMutation {
             .transaction::<_, _, DbErr>(|transaction| {
                 Box::pin(async move {
                     let prediction = prediction::Entity::insert(prediction::ActiveModel {
-                        id: ActiveValue::Set(Uuid::new_v4()),
+                        id: ActiveValue::Set(Uuid::now_v7()),
                         plate: ActiveValue::Set(plate.plate),
                         well: ActiveValue::Set(plate.well),
                         well_centroid_x: ActiveValue::Set(well_centroid.x),