monoxide 0.0.2

A mongodb helper
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

use mongodb::{bson::document::Document, options::FindOptions, Collection};

use futures::stream::StreamExt;

impl super::Database {
    pub async fn find<R>(
        &self,
        collection: &str,
        filter: Option<Document>,
        find_options: Option<FindOptions>,
    ) -> Result<Vec<R>, String>
    where
        for<'r> R: serde::Deserialize<'r>,
    {
        let collection: Collection = self.db.collection(&String::from(collection));

        match collection.find(filter, find_options).await {
            Ok(mut cursor) => {
                let mut result = vec![];
                while let Some(doc) = cursor.next().await {
                    let parsed_document =
                        match bson::de::from_bson::<R>(bson::Bson::Document(match doc {
                            Ok(doc) => doc,
                            Err(e) => return Err(e.to_string()),
                        })) {
                            Ok(document) => document,
                            Err(e) => return Err(e.to_string()),
                        };
                    result.push(parsed_document);
                }
                Ok(result)
            }
            Err(e) => Err(e.to_string()),
        }
    }
}