create visitor log

Author: indpurvesh

src/api/cms_api.rs

@@ -36,19 +36,12 @@ impl Cms for CmsApi {
         // let headers = request.g
         let remote_addr: Option<SocketAddr> = request.remote_addr();
 
-        // Log or use the remote address as needed
-        if let Some(addr) = remote_addr {
-            println!("Request from: {}", addr);
-        } else {
-            println!("Could not determine remote address.");
-        }
-
         let req = request.into_inner();
 
         match self
             .state
             .cms_service
-            .get_cms_content(req, &self.state.db)
+            .get_cms_content(req, remote_addr, &self.state.db)
             .await
         {
             Ok(reply) => Ok(Response::new(reply)),

src/api/proto/setting.rs

@@ -1,48 +1,69 @@
 // This file is @generated by prost-build.
 #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
+/// setting model
 pub struct SettingModel {
     #[prost(string, tag = "1")]
+    /// id
     pub id: ::prost::alloc::string::String,
     #[prost(string, tag = "2")]
+    /// identifier
     pub identifier: ::prost::alloc::string::String,
     #[prost(string, tag = "3")]
+    /// value
     pub value: ::prost::alloc::string::String,
     #[prost(message, optional, tag = "4")]
+    /// created at
     pub created_at: ::core::option::Option<::prost_types::Timestamp>,
     #[prost(message, optional, tag = "5")]
+    /// updated at
     pub updated_at: ::core::option::Option<::prost_types::Timestamp>,
+    
     #[prost(string, tag = "6")]
+    /// created by
     pub created_by: ::prost::alloc::string::String,
     #[prost(string, tag = "7")]
+    /// updated by
     pub updated_by: ::prost::alloc::string::String,
 }
 #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
+/// setting save model
 pub struct SettingSaveModel {
     #[prost(string, tag = "1")]
+    /// id
     pub id: ::prost::alloc::string::String,
     #[prost(string, tag = "2")]
+    /// identifier
     pub identifier: ::prost::alloc::string::String,
     #[prost(string, tag = "3")]
+    /// value
     pub value: ::prost::alloc::string::String,
 }
 /// Setting services
 #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
+/// get setting request
 pub struct GetSettingRequest {}
 #[derive(Clone, PartialEq, ::prost::Message)]
+/// get setting response
 pub struct GetSettingResponse {
     #[prost(bool, tag = "1")]
+    /// status
     pub status: bool,
     #[prost(message, repeated, tag = "2")]
+    /// data
     pub data: ::prost::alloc::vec::Vec<SettingModel>,
 }
 #[derive(Clone, PartialEq, ::prost::Message)]
+/// store setting request
 pub struct StoreSettingRequest {
     #[prost(message, repeated, tag = "1")]
+    /// data
     pub data: ::prost::alloc::vec::Vec<SettingSaveModel>,
 }
 #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
+/// store setting request
 pub struct StoreSettingResponse {
     #[prost(bool, tag = "1")]
+    /// status
     pub status: bool,
 }
 /// Generated client implementations.
@@ -75,8 +96,8 @@ pub mod setting_client {
     where
         T: tonic::client::GrpcService<tonic::body::Body>,
         T::Error: Into<StdError>,
-        T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
-        <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
+        T::ResponseBody: Body<Data = Bytes> + Send + 'static,
+        <T::ResponseBody as Body>::Error: Into<StdError> + Send,
     {
         pub fn new(inner: T) -> Self {
             let inner = tonic::client::Grpc::new(inner);
@@ -93,15 +114,15 @@ pub mod setting_client {
         where
             F: tonic::service::Interceptor,
             T::ResponseBody: Default,
-            T: tonic::codegen::Service<
+            T: Service<
                 http::Request<tonic::body::Body>,
                 Response = http::Response<
                     <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
                 >,
             >,
-            <T as tonic::codegen::Service<
+            <T as Service<
                 http::Request<tonic::body::Body>,
-            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
+            >>::Error: Into<StdError> + Send + Sync,
         {
             SettingClient::new(InterceptedService::new(inner, interceptor))
         }
@@ -139,7 +160,7 @@ pub mod setting_client {
         pub async fn get_setting(
             &mut self,
             request: impl tonic::IntoRequest<super::GetSettingRequest>,
-        ) -> std::result::Result<
+        ) -> Result<
             tonic::Response<super::GetSettingResponse>,
             tonic::Status,
         > {
@@ -163,7 +184,7 @@ pub mod setting_client {
         pub async fn store_setting(
             &mut self,
             request: impl tonic::IntoRequest<super::StoreSettingRequest>,
-        ) -> std::result::Result<
+        ) -> Result<
             tonic::Response<super::StoreSettingResponse>,
             tonic::Status,
         > {
@@ -198,18 +219,18 @@ pub mod setting_server {
     use tonic::codegen::*;
     /// Generated trait containing gRPC methods that should be implemented for use with SettingServer.
     #[async_trait]
-    pub trait Setting: std::marker::Send + std::marker::Sync + 'static {
+    pub trait Setting: Send + Sync + 'static {
         async fn get_setting(
             &self,
             request: tonic::Request<super::GetSettingRequest>,
-        ) -> std::result::Result<
+        ) -> Result<
             tonic::Response<super::GetSettingResponse>,
             tonic::Status,
         >;
         async fn store_setting(
             &self,
             request: tonic::Request<super::StoreSettingRequest>,
-        ) -> std::result::Result<
+        ) -> Result<
             tonic::Response<super::StoreSettingResponse>,
             tonic::Status,
         >;
@@ -273,19 +294,19 @@ pub mod setting_server {
             self
         }
     }
-    impl<T, B> tonic::codegen::Service<http::Request<B>> for SettingServer<T>
+    impl<T, B> Service<http::Request<B>> for SettingServer<T>
     where
         T: Setting,
-        B: Body + std::marker::Send + 'static,
-        B::Error: Into<StdError> + std::marker::Send + 'static,
+        B: Body + Send + 'static,
+        B::Error: Into<StdError> + Send + 'static,
     {
         type Response = http::Response<tonic::body::Body>;
         type Error = std::convert::Infallible;
         type Future = BoxFuture<Self::Response, Self::Error>;
         fn poll_ready(
             &mut self,
             _cx: &mut Context<'_>,
-        ) -> Poll<std::result::Result<(), Self::Error>> {
+        ) -> Poll<Result<(), Self::Error>> {
             Poll::Ready(Ok(()))
         }
         fn call(&mut self, req: http::Request<B>) -> Self::Future {

src/avored_state.rs

@@ -11,6 +11,7 @@ use crate::repositories::role_repository::RoleRepository;
 use crate::repositories::security_alert_repository::SecurityAlertRepository;
 // use crate::repositories::security_audit_repository::SecurityAuditRepository;
 use crate::repositories::setting_repository::SettingRepository;
+use crate::repositories::visitor_log_repository::VisitorLogRepository;
 use crate::services::admin_user_service::AdminUserService;
 use crate::services::asset_service::AssetService;
 use crate::services::auth_service::AuthService;
@@ -83,6 +84,7 @@ impl AvoRedState {
         let setting_repository = SettingRepository::new();
         // let security_audit_repository = SecurityAuditRepository::new();
         let security_alert_repository = SecurityAlertRepository::new();
+        let visitor_log_repository = VisitorLogRepository::new();
 
         let misc_service = MiscService::new().await?;
         let auth_service =
@@ -92,7 +94,7 @@ impl AvoRedState {
             ContentService::new(content_repository.clone(), collection_repository)?;
         let asset_service = AssetService::new(asset_repository)?;
         let setting_service = SettingService::new(setting_repository)?;
-        let cms_service = CmsService::new(content_repository)?;
+        let cms_service = CmsService::new(content_repository, visitor_log_repository)?;
         let general_service = GeneralService::new()?;
         // let security_audit_service = SecurityAuditService::new(security_audit_repository);
         // let security_alert_service = SecurityAlertService::new(security_alert_repository);

src/models/mod.rs

@@ -40,6 +40,8 @@ pub mod token_claim_model;
 /// validation module
 pub mod validation_error;
 
+/// visitor log module
+pub mod visitor_log_model;
 
 // /// Pagination struct
 // #[derive(Serialize, Debug, Deserialize, Clone, Default)]

src/models/visitor_log_model.rs

@@ -0,0 +1,70 @@
+use serde::{Deserialize, Serialize};
+use surrealdb::sql::{Datetime, Object};
+use crate::error::{Error, Result};
+use super::BaseModel;
+
+
+// region: Struct initialze
+
+/// Represents an visitor log model in the system.
+#[derive(Serialize, Debug, Deserialize, Clone, Default)]
+pub struct VistitorLogModel {
+
+    /// The unique identifier for the visitor log.
+    pub id: String,
+
+    /// The content tpye of the visitor log.
+    pub content_type: String,
+
+    /// The content id of the visitor log.
+    pub content_id: String,
+
+    /// The IP address of the visitor log
+    pub ip_address: Option<String>,
+  
+    /// The date and time when the visitor log was created.
+    pub created_at: Datetime
+}
+
+/// Represents a model for creating an visitor log.
+#[derive(Serialize, Debug, Deserialize, Clone)]
+pub struct CreatableVisitorLogModel {
+    /// The content type of the visitor log.
+    pub content_type: String,
+
+    /// The content identifier of the visitor log.
+    pub content_id: String,
+
+    /// The password of the visitor log.
+    pub ip_address: Option<String>,
+}
+
+// endregion: Struct initialize
+
+
+
+
+
+// region: impl
+
+impl TryFrom<Object> for VistitorLogModel {
+    type Error = Error;
+    fn try_from(val: Object) -> Result<Self> {
+        let id: String = val.get("id").get_id()?;
+        let content_id = val.get("content_id").get_string()?;
+        let content_type = val.get("content_type").get_string()?;
+        let ip_address = val.get("ip_address").get_string()?;
+        let created_at = val.get("created_at").get_datetime()?;
+
+        Ok(Self {
+            id,
+            content_id,
+            content_type,
+            ip_address: Some(ip_address),
+            created_at,
+        })
+    }
+}
+
+
+// endregion: impl

src/repositories/mod.rs

@@ -33,6 +33,9 @@ pub mod security_audit_repository;
 /// setting repository
 pub mod setting_repository;
 
+/// visitor log repository module
+pub mod visitor_log_repository;
+
 
 /// into iter object
 pub fn into_iter_objects(responses: Vec<Response>) -> Result<impl Iterator<Item = Result<Object>>> {

src/repositories/visitor_log_repository.rs

@@ -0,0 +1,66 @@
+use crate::error::{Error, Result};
+use crate::models::visitor_log_model::{CreatableVisitorLogModel, VistitorLogModel};
+use crate::repositories::into_iter_objects;
+use surrealdb::dbs::Session;
+use surrealdb::kvs::Datastore;
+use surrealdb::sql::Datetime;
+use std::collections::BTreeMap;
+use surrealdb::sql::Value;
+
+/// visitor log repository
+#[derive(Clone)]
+pub struct VisitorLogRepository {}
+
+impl Default for VisitorLogRepository {
+    fn default() -> Self {
+        Self::new()
+    }
+}
+
+impl VisitorLogRepository {
+    /// new instance password repository
+    #[must_use] pub const fn new() -> Self {
+        Self {}
+    }
+
+    /// create visitor log record in table
+    pub async fn create(
+        &self,
+        datastore: &Datastore,
+        database_session: &Session,
+        creatable_visitor_log: CreatableVisitorLogModel
+    ) -> Result<VistitorLogModel> {
+
+        let sql = "CREATE visitor_log CONTENT $data";
+
+        let data: BTreeMap<String, Value> = [
+            (
+                "content_type".into(),
+                creatable_visitor_log.content_type.into(),
+            ),
+            (
+                "content_id".into(),
+                creatable_visitor_log.content_id.into(),
+            ),
+            (
+                "ip_address".into(),
+                creatable_visitor_log.ip_address.into(),
+            ),
+            ("created_at".into(), Datetime::default().into()),
+        ]
+        .into();
+        let vars: BTreeMap<String, Value> = [("data".into(), data.into())].into();
+
+        let ress = datastore.execute(sql, database_session, Some(vars)).await?;
+
+        let result_object_option = into_iter_objects(ress)?.next();
+        let result_object = match result_object_option {
+            Some(object) => object,
+            None => Err(Error::Generic("no record found".to_string())),
+        };
+        let visitor_log_model: Result<VistitorLogModel> = result_object?.try_into();
+
+        visitor_log_model
+
+    }
+}