Merge pull request #14 from lexara-prime-ai/dev

Dev

Author: irfanghat

rust/src/main.rs

@@ -8,14 +8,82 @@ use tokio::main;
 #[main]
 async fn main() {
     /// List all Services.
-    // let services = ServiceManager::list_all_services("20").await;
+    let services = ServiceManager::list_all_services("20").await;
 
     // List all Services by Name and Type.
-    // let services = ServiceManager::find_service_by_name_and_type("whoami", "web_service").await;
+    let services = ServiceManager::find_service_by_name_and_type("whoami", "web_service").await;
 
     // List all Services by Region.
-    // let services = ServiceManager::find_service_by_region("oregon", "10").await;
+    let services = ServiceManager::find_service_by_region("oregon", "10").await;
 
     // List all Services by Environment.
     let services = ServiceManager::find_service_by_environment("image", "10").await;
 }
+
+/// Checks for regression of service management functions
+///
+/// These checks are there to validate that it is functioning properly
+/// and returning the right results, after which we shall describe each test case.
+/// List all Services.
+///
+/// This test confirms if the function list_all_services returns all services available.
+///
+/// #[tokio::test]
+/// async fn test_list_all_services() {
+/// let result = ServiceManager::list_all_services("10").await;
+///     // The result should be Ok().
+///     assert!(result.is_ok());
+///
+///    // Validate content.
+///    let services = result.unwrap();
+///     assert!(!services.is_empty());
+/// }
+///
+///  #[tokio::test]
+/// async fn test_find_service_by_name_and_type() {
+///     let result = ServiceManager::find_service_by_name_and_type("whoami", "web_service").await;
+///     // The result should be Ok().
+///     assert!(result.is_ok());
+///    // Validate content.
+///     let services = result.unwrap();
+///     assert!(!services.is_empty());
+/// }
+/// More tests...
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[tokio::test]
+    async fn test_list_all_services() {
+        let result = ServiceManager::list_all_services("10").await;
+        // The result should be Ok().
+        assert!(result.is_ok());
+
+        // Validate content.
+        let services = result.unwrap();
+        assert!(!services.is_empty());
+    }
+
+    #[tokio::test]
+    async fn test_find_service_by_name_and_type() {
+        let result = ServiceManager::find_service_by_name_and_type("whoami", "web_service").await;
+        // The result should be Ok().
+        assert!(result.is_ok());
+
+        // Validate content.
+        let services = result.unwrap();
+        assert!(!services.is_empty());
+    }
+
+    #[tokio::test]
+    async fn test_find_service_by_region() {
+        let result = ServiceManager::find_service_by_region("oregon", "10").await;
+        // The result should be Ok().
+        assert!(result.is_ok());
+
+        // Validate content.
+        let services = result.unwrap();
+        assert!(!services.is_empty());
+    }
+}

rust/src/resource_management/services/service_manager.rs

@@ -10,9 +10,18 @@ const BASE_URL: &str = "https://api.render.com/v1";
 #[derive(Debug)]
 pub struct ServiceManager;
 
-impl ServiceManager {
+
+pub trait ServiceManagerOperations {
+    fn list_all_services(limit: &str) -> impl std::future::Future<Output = Result<String, Error>> + Send;
+    fn find_service_by_name_and_type(service_name: &str, service_type: &str) -> impl std::future::Future<Output = Result<String, Error>> + Send;
+    fn find_service_by_region(service_region: &str, limit: &str) -> impl std::future::Future<Output = Result<String, Error>> + Send;
+    fn find_service_by_environment(service_env: &str, limit: &str) -> impl std::future::Future<Output = Result<String, Error>> + Send;
+}
+
+
+impl ServiceManagerOperations for ServiceManager {
     /// List all resources.
-    pub async fn list_all_services(limit: &str) -> Result<String, Error> {
+    async fn list_all_services(limit: &str) -> Result<String, Error> {
         /*****************************************************
          *
             curl --request GET \
@@ -57,7 +66,7 @@ impl ServiceManager {
 
     /// Finding services by type.
     /// Reqquired arguments: <service_type>
-    pub async fn find_service_by_name_and_type(
+    async fn find_service_by_name_and_type(
         service_name: &str,
         service_type: &str,
     ) -> Result<String, Error> {
@@ -107,7 +116,7 @@ impl ServiceManager {
     }
 
     /// Finding services by region.
-    pub async fn find_service_by_region(
+    async fn find_service_by_region(
         service_region: &str,
         limit: &str,
     ) -> Result<String, Error> {
@@ -157,7 +166,7 @@ impl ServiceManager {
     }
 
     /// Filtering for environments.
-    pub async fn find_service_by_environment(
+    async fn find_service_by_environment(
         service_env: &str,
         limit: &str,
     ) -> Result<String, Error> {
@@ -181,8 +190,8 @@ impl ServiceManager {
         //////////////////////////////
         ////// [DEBUG] logs. /////////
         //////////////////////////////
-        println!("[REQUEST] -> {}", api_url);
-        println!("[REQUEST] -> {}", api_key.clone());
+        // println!("[REQUEST] -> {}", api_url);
+        // println!("[REQUEST] -> {}", api_key.clone());
         //////////////////////////////
         let response = client
             .get(api_url)

rust/src/state/state.rs

@@ -2,13 +2,14 @@
 use anyhow::{Context, Error, Ok, Result};
 use reqwest::header::{ACCEPT, AUTHORIZATION, CONTENT_TYPE};
 use reqwest::{self};
+use std::sync::Arc;
 
 use crate::environment_management::prelude::*;
 
 #[allow(non_snake_case)]
 #[derive(Debug)]
 pub struct State {
-    pub CLIENT: reqwest::Client,
+    pub CLIENT: Arc<reqwest::Client>,
     pub API_KEY: String,
 }
 
@@ -19,7 +20,7 @@ impl State {
 
         /// This method returns an instance of the applications current [State].
         Self {
-            CLIENT: client,
+            CLIENT: client.into(),
             API_KEY: api_key.trim().to_string(),
         }
     }