feat: implemented created_at/updated_at fields

Cargo.toml

@@ -9,7 +9,7 @@ dmtri = { version = "0.1.0", git = "https://github.com/demeter-run/specs.git" }
 
 anyhow = "1.0.86"
 async-trait = "0.1.80"
-sqlx = { version = "0.7.4", features = ["runtime-tokio-rustls", "sqlite"] }
+sqlx = { version = "0.7.4", features = ["runtime-tokio-rustls", "sqlite", "chrono"] }
 tokio = { version = "1.38.0", features = ["macros", "rt-multi-thread", "time"] }
 tonic = "0.11.0"
 serde = { version = "1.0.203", features = ["derive"] }
@@ -33,6 +33,7 @@ bech32 = "0.11.0"
 argon2 = "0.5.3"
 tower = "0.4.13"
 hyper = "1.4.1"
+chrono = "0.4.38"
 
 [dev-dependencies]
 mockall = "0.12.1"

src/domain/event.rs

@@ -1,4 +1,5 @@
 use anyhow::{bail, Result};
+use chrono::{DateTime, Utc};
 use serde::{Deserialize, Serialize};
 
 macro_rules! into_event {
@@ -17,6 +18,8 @@ pub struct ProjectCreated {
     pub name: String,
     pub namespace: String,
     pub owner: String,
+    pub created_at: DateTime<Utc>,
+    pub updated_at: DateTime<Utc>,
 }
 into_event!(ProjectCreated);
 
@@ -27,6 +30,8 @@ pub struct ResourceCreated {
     pub project_namespace: String,
     pub kind: String,
     pub data: String,
+    pub created_at: DateTime<Utc>,
+    pub updated_at: DateTime<Utc>,
 }
 into_event!(ResourceCreated);
 
@@ -37,6 +42,7 @@ pub struct ProjectSecretCreated {
     pub name: String,
     pub phc: String,
     pub secret: Vec<u8>,
+    pub created_at: DateTime<Utc>,
 }
 into_event!(ProjectSecretCreated);
 

src/domain/project.rs

@@ -1,6 +1,7 @@
 use anyhow::{bail, Error, Result};
 use argon2::{password_hash::SaltString, Argon2, PasswordHash, PasswordHasher, PasswordVerifier};
 use bech32::{Bech32m, Hrp};
+use chrono::{DateTime, Utc};
 use k8s_openapi::api::core::v1::Namespace;
 use kube::{api::ObjectMeta, ResourceExt};
 use rand::{
@@ -34,6 +35,8 @@ pub async fn create(
         namespace: cmd.namespace.clone(),
         name: cmd.name,
         owner: user_id,
+        created_at: Utc::now(),
+        updated_at: Utc::now(),
     };
 
     event.dispatch(evt.into()).await?;
@@ -113,6 +116,7 @@ pub async fn create_secret(
         name: cmd.name,
         phc: password_hash.to_string(),
         secret: secret.to_vec(),
+        created_at: Utc::now(),
     };
 
     event.dispatch(evt.into()).await?;
@@ -211,6 +215,8 @@ pub struct ProjectCache {
     pub name: String,
     pub namespace: String,
     pub owner: String,
+    pub created_at: DateTime<Utc>,
+    pub updated_at: DateTime<Utc>,
 }
 impl From<ProjectCreated> for ProjectCache {
     fn from(value: ProjectCreated) -> Self {
@@ -219,6 +225,8 @@ impl From<ProjectCreated> for ProjectCache {
             namespace: value.namespace,
             name: value.name,
             owner: value.owner,
+            created_at: value.created_at,
+            updated_at: value.updated_at,
         }
     }
 }
@@ -252,6 +260,7 @@ pub struct ProjectSecretCache {
     pub name: String,
     pub phc: String,
     pub secret: Vec<u8>,
+    pub created_at: DateTime<Utc>,
 }
 impl From<ProjectSecretCreated> for ProjectSecretCache {
     fn from(value: ProjectSecretCreated) -> Self {
@@ -261,6 +270,7 @@ impl From<ProjectSecretCreated> for ProjectSecretCache {
             name: value.name,
             phc: value.phc,
             secret: value.secret,
+            created_at: value.created_at,
         }
     }
 }
@@ -269,6 +279,7 @@ impl From<ProjectSecretCreated> for ProjectSecretCache {
 pub struct ProjectUserCache {
     pub user_id: String,
     pub project_id: String,
+    pub created_at: DateTime<Utc>,
 }
 
 #[async_trait::async_trait]
@@ -350,6 +361,8 @@ mod tests {
                 name: "New Project".into(),
                 namespace: "sonic-vegas".into(),
                 owner: "user id".into(),
+                created_at: Utc::now(),
+                updated_at: Utc::now(),
             }
         }
     }
@@ -360,6 +373,8 @@ mod tests {
                 name: "New Project".into(),
                 namespace: "sonic-vegas".into(),
                 owner: "user id".into(),
+                created_at: Utc::now(),
+                updated_at: Utc::now(),
             }
         }
     }
@@ -389,6 +404,7 @@ mod tests {
                 name: "Key 1".into(),
                 phc: PHC.into(),
                 secret: SECRET.to_bytes().to_vec(),
+                created_at: Utc::now(),
             }
         }
     }
@@ -400,6 +416,7 @@ mod tests {
                 name: "Key 1".into(),
                 phc: PHC.into(),
                 secret: SECRET.to_bytes().to_vec(),
+                created_at: Utc::now(),
             }
         }
     }
@@ -409,6 +426,7 @@ mod tests {
             Self {
                 user_id: Uuid::new_v4().to_string(),
                 project_id: Uuid::new_v4().to_string(),
+                created_at: Utc::now(),
             }
         }
     }