create admin users

Author: indpurvesh

migrations/1753999476__create_settings_table.surql

@@ -0,0 +1,9 @@
+REMOVE TABLE settings;
+DEFINE TABLE settings;
+
+DEFINE FIELD identifier     ON TABLE settings TYPE string;
+DEFINE FIELD setting_value  ON TABLE settings TYPE string;
+DEFINE FIELD created_at     ON TABLE settings TYPE datetime;
+DEFINE FIELD updated_at     ON TABLE settings TYPE datetime;
+DEFINE FIELD created_by     ON TABLE settings TYPE string;
+DEFINE FIELD updated_by     ON TABLE settings TYPE string;

migrations/1753999477__create_admin_users_table.surql

@@ -0,0 +1,13 @@
+REMOVE TABLE admin_users;
+DEFINE TABLE admin_users;
+
+DEFINE FIELD full_name ON TABLE admin_users TYPE string;
+DEFINE FIELD email ON TABLE admin_users TYPE string;
+DEFINE FIELD password_hash ON TABLE admin_users TYPE string;
+DEFINE FIELD profile_image ON TABLE admin_users TYPE string;
+DEFINE FIELD is_super_admin ON TABLE admin_users TYPE bool;
+DEFINE FIELD created_by ON TABLE admin_users TYPE string;
+DEFINE FIELD updated_by ON TABLE admin_users TYPE string;
+DEFINE FIELD created_at ON TABLE admin_users TYPE datetime;
+DEFINE FIELD updated_at ON TABLE admin_users TYPE datetime;
+DEFINE INDEX admin_users_email_index ON TABLE admin_users COLUMNS email UNIQUE;

proto/misc.proto

@@ -11,6 +11,9 @@ message HealthCheckResponse {
 }
 
 message SetupRequest {
+    string full_name = 1;
+    string email = 2;
+    string password = 3;
 }
 
 message SetupResponse {

src/adapters/grpc_api/misc_api.rs

@@ -2,10 +2,9 @@
 use tonic::{Request, Response, Status};
 
 use crate::{
-    application::use_cases::misc_use_case::MiscUseCase,
-    infra::grpc::misc::{
-        misc_server::Misc, HealthCheckRequest, HealthCheckResponse, SetupRequest, SetupResponse,
-    },
+    application::use_cases::misc_use_case::MiscUseCase, domain::models::admin_user::StorableAdminUser, infra::grpc::misc::{
+        HealthCheckRequest, HealthCheckResponse, SetupRequest, SetupResponse, misc_server::Misc
+    }
 };
 
 
@@ -32,19 +31,33 @@ impl Misc for MiscGrpcApi {
     ) -> Result<Response<HealthCheckResponse>, Status> {
         println!("Got a request: {:?}", request);
 
-        let request = HealthCheckResponse { status: true };
+        let response = HealthCheckResponse { status: true };
 
-        Ok(Response::new(request))
+        Ok(Response::new(response))
     }
 
     async fn setup(
         &self,
         request: Request<SetupRequest>,
     ) -> Result<Response<SetupResponse>, Status> {
-        println!("Got a setup request: {:?}", request);
+        let request = request.into_inner();
+
+        // validate the request and convert it to a storable admin user
+
+        let mut storable_admin_user: StorableAdminUser = match request.try_into() {
+            Ok(req) => req,
+            Err(e) => return Err(Status::invalid_argument(e.to_string())),
+        };
+
+        storable_admin_user.logged_in_user = "ApplicationSetupProcess".to_string();
+        storable_admin_user.is_super_admin = true;
+
+        // @todo hash the password
+        
+        println!("Got a setup request: {:?}", storable_admin_user);
 
         // Think of implementing a generic result handler
-        let setup_result = match  self.misc_use_case.setup().await {
+        let setup_result = match  self.misc_use_case.setup(storable_admin_user).await {
             Ok(result) => result,
             Err(e) => return Err(Status::internal(e.to_string())),
         };

src/adapters/mod.rs

@@ -1 +1,2 @@
 pub mod grpc_api;
+pub mod requests;

src/adapters/requests/misc/misc_request.rs

@@ -0,0 +1,17 @@
+use crate::{domain::models::admin_user::StorableAdminUser, infra::grpc::misc::SetupRequest};
+use crate::error::Error;
+use crate::error::Result;
+
+impl TryFrom<SetupRequest> for StorableAdminUser {
+    type Error = Error;
+    fn try_from(val: SetupRequest) -> Result<StorableAdminUser> {
+        Ok(StorableAdminUser {
+            full_name: val.full_name,
+            email: val.email,
+            password_hash: val.password,
+            logged_in_user: String::from(""),
+            profile_image: String::from(""),
+            is_super_admin: false,
+        })
+    }
+}

src/adapters/requests/misc/mod.rs

@@ -0,0 +1 @@
+pub mod misc_request;

src/adapters/requests/mod.rs

@@ -0,0 +1 @@
+pub mod misc;

src/application/use_cases/misc_use_case.rs

@@ -1,4 +1,5 @@
 use std::sync::Arc;
+use crate::domain::models::admin_user::StorableAdminUser;
 use crate::error::Result;
 use crate::infra::repositories::misc_repository::MiscRepository;
 
@@ -12,7 +13,7 @@ impl MiscUseCase {
         Self { misc_repository }
     }
 
-    pub async fn setup(&self) -> Result<bool> {
-        self.misc_repository.setup().await
+    pub async fn setup(&self, storable_admin_user: StorableAdminUser) -> Result<bool> {
+        self.misc_repository.setup(storable_admin_user).await
     }
 }

src/domain/models/admin_user.rs

@@ -0,0 +1,16 @@
+use serde::{Deserialize, Serialize};
+
+
+
+// id
+
+
+#[derive(Debug, Serialize, Deserialize)]
+pub struct StorableAdminUser {
+    pub full_name: String,
+    pub profile_image: String,
+    pub is_super_admin: bool,
+    pub email: String,
+    pub password_hash: String,
+    pub logged_in_user: String,
+}