[FEATURE] Find all method for Mongo repository implemented.

Author: Rafael24595

Cargo.lock

@@ -9,6 +9,7 @@ edition = "2021"
 tokio = { version = "1", features = ["full"] }
 async-trait = "0.1.80"
 serde_json = "1.0.115"
+futures-util = "0.3.30"
 mongodb = "2.8.2"
 
 crossterm = "0.27.0"

Cargo.toml

@@ -10,7 +10,7 @@ pub trait IDBRepository: Clone + Send + Sync {
     async fn list_collections(&self, query: DataBaseQuery) -> Result<Vec<String>, ConnectException>;
     fn info(&self) -> Vec<u8>;
     async fn find(&self, query: DataBaseQuery) -> Result<Vec<u8>, ConnectException>;
-    fn find_all(&self, query: DataBaseQuery) -> Vec<String>;
+    async fn find_all(&self, query: DataBaseQuery) -> Result<Vec<String>, ConnectException>;
     fn insert(&self, query: DataBaseQuery, value: String) -> Vec<u8>;
     fn update(&self, query: DataBaseQuery, value: String) -> Vec<u8>;
     fn delete(&self, query: DataBaseQuery) -> Vec<u8>;

src/infrastructure/repository/i_db_repository.rs

@@ -1,6 +1,8 @@
 use async_trait::async_trait;
 use mongodb::{bson::Document, options::{AggregateOptions, ClientOptions}, Client, Collection, Database};
 
+use futures_util::stream::StreamExt;
+
 use crate::{
     commons::exception::connect_exception::ConnectException, 
     domain::{
@@ -104,8 +106,35 @@ impl IDBRepository for MongoDbRepository {
         todo!()
     }
 
-    fn find_all(&self, query: DataBaseQuery) -> Vec<String> {
-        todo!()
+    async fn find_all(&self, query: DataBaseQuery) -> Result<Vec<String>, ConnectException> {
+        let collection = self.collection(&query);
+
+        let r_cursor = collection.find(None, None).await;
+        if r_cursor.is_err() {
+            let exception = ConnectException::new(r_cursor.err().unwrap().to_string());
+            return Err(exception);
+        }
+
+        let mut elements = Vec::<String>::new();
+        
+        let mut cursor = r_cursor.ok().unwrap();
+        while let Some(result) = cursor.next().await {
+            if result.is_err() {
+                let exception = ConnectException::new(result.err().unwrap().to_string());
+                return Err(exception);
+            }
+
+            let document = result.ok().unwrap();
+
+            let json = serde_json::to_string(&document);
+            if json.is_err() {
+                let exception = ConnectException::new(json.err().unwrap().to_string());
+                return Err(exception);
+            }
+            elements.push(json.ok().unwrap());
+        }
+
+        Ok(elements)
     }
 
     fn insert(&self, query: DataBaseQuery, value: String) -> Vec<u8> {