update and update identifier

Author: indpurvesh

proto/entity.proto

@@ -58,9 +58,39 @@ message GetEntityResponse {
   EntityModel data = 2;
 }
 
+message UpdateEntityRequest {
+  string entity_id = 1;
+  string name = 2;
+}
+
+message UpdateEntityResponse {
+  bool status = 1;
+  EntityModel data = 2;
+}
+
+message PutEntityIdentifierRequest {
+  string entity_id = 1;
+  string identifier = 2;
+}
+
+message PutEntityIdentifierResponse {
+  bool status = 1;
+  EntityModel data = 2;
+}
+
+message DeleteEntityRequest {
+  string entity_id = 1;
+}
+
+message DeleteEntityResponse {
+  bool status = 1;
+}
 
 service EnttyService {
     rpc Paginate(EntityPaginateRequest) returns (EntityPaginateResponse);
     rpc StoreEntity(StoreEntityRequest) returns (StoreEntityResponse);
     rpc GetEntity(GetEntityRequest) returns(GetEntityResponse);
+    rpc UpdateEntity(UpdateEntityRequest) returns(UpdateEntityResponse);
+    rpc PutEntityIdentifier(PutEntityIdentifierRequest) returns (PutEntityIdentifierResponse);
+    rpc DeleteEntity(DeleteEntityRequest) returns (DeleteEntityResponse);
 }

src/api/entity_api.rs

@@ -1,8 +1,7 @@
 use crate::api::proto::entity::entity_paginate_response::{EntityPaginateData, EntityPagination};
 use crate::api::proto::entity::entty_service_server::EnttyService;
 use crate::api::proto::entity::{
-    EntityPaginateRequest, EntityPaginateResponse, GetEntityRequest, GetEntityResponse,
-    StoreEntityRequest, StoreEntityResponse,
+    DeleteEntityRequest, DeleteEntityResponse, EntityPaginateRequest, EntityPaginateResponse, GetEntityRequest, GetEntityResponse, PutEntityIdentifierRequest, PutEntityIdentifierResponse, StoreEntityRequest, StoreEntityResponse, UpdateEntityRequest, UpdateEntityResponse
 };
 use crate::avored_state::AvoRedState;
 use crate::error::Error::Tonic;
@@ -115,11 +114,11 @@ impl EnttyService for EntityApi {
             .await
         {
             Ok(entity_model) => {
-                let get_admin_user_response = GetEntityResponse {
+                let get_entity_response = GetEntityResponse {
                     status: true,
                     data: Some(entity_model),
                 };
-                let res = Response::new(get_admin_user_response);
+                let res = Response::new(get_entity_response);
                 Ok(res)
             }
             Err(e) => match e {
@@ -128,4 +127,116 @@ impl EnttyService for EntityApi {
             },
         }
     }
+
+    async fn update_entity(
+        &self,
+        request: Request<UpdateEntityRequest>,
+    ) -> Result<Response<UpdateEntityResponse>, Status> {
+        println!("->> {:<12} - update_entity", "gRPC_Entity_Service");
+
+        let claims = request.get_token_claim()?;
+
+        let logged_in_user = claims.admin_user_model;
+        logged_in_user
+            .check_user_has_resouce_access(
+                &self.state.admin_user_service,
+                String::from("update_entity"),
+            )
+            .await?;
+
+        let req = request.into_inner();
+
+        match self
+            .state
+            .entity_service
+            .update_entity(req, logged_in_user.email, &self.state.db)
+            .await
+        {
+            Ok(entity_response) => {
+                Ok(Response::new(entity_response))
+            }
+            Err(e) => match e {
+                Tonic(status) => Err(*status),
+                _ => Err(Status::internal(e.to_string())),
+            },
+        }
+    }
+
+    async fn put_entity_identifier(
+        &self,
+        request: Request<PutEntityIdentifierRequest>,
+    ) -> Result<Response<PutEntityIdentifierResponse>, Status> {
+        println!(
+            "->> {:<12} - put_entity_identifier",
+            "gRPC_Entity_Service"
+        );
+
+        let claims = request.get_token_claim()?;
+        let logged_in_user = claims.admin_user_model;
+        logged_in_user
+            .check_user_has_resouce_access(
+                &self.state.admin_user_service,
+                String::from("put_entiy_identifier"),
+            )
+            .await?;
+
+        let user_locale = logged_in_user.locale.clone();
+        let req = request.into_inner();
+        req.validate(&self.state, user_locale).await?;
+
+        match self
+            .state
+            .entity_service
+            .put_entity_identifier(req, claims.email, &self.state.db)
+            .await
+        {
+            Ok(reply) => {
+                let res = Response::new(reply);
+
+                Ok(res)
+            }
+            Err(e) => match e {
+                Tonic(status) => Err(*status),
+                _ => Err(Status::internal(e.to_string())),
+            },
+        }
+    }    
+
+    async fn delete_entity(
+        &self,
+        request: Request<DeleteEntityRequest>,
+    ) -> Result<Response<DeleteEntityResponse>, Status> {
+        println!("->> {:<12} - delete_entity", "gRPC_entity_Service");
+
+        let claims = request.get_token_claim()?;
+        let logged_in_user = claims.admin_user_model;
+        logged_in_user
+            .check_user_has_resouce_access(
+                &self.state.admin_user_service,
+                String::from("delete_entity"),
+            )
+            .await?;
+
+        let user_locale = logged_in_user.locale.clone();
+        let req = request.into_inner();
+        req.validate(user_locale)?;
+
+        match self
+            .state
+            .entity_service
+            .delete_entity(req, &self.state.db)
+            .await
+        {
+            Ok(reply) => {
+                let res = Response::new(reply);
+
+                Ok(res)
+            }
+            Err(e) => match e {
+                Tonic(status) => Err(*status),
+                _ => Err(Status::internal(e.to_string())),
+            },
+        }
+    }
+
 }