Struct MongoRepository 

pub struct MongoRepository<T: BaseDocument + Debug + Serialize + for<'de> Deserialize<'de> + Sync + Send> {
    pub collection: Collection<T>,
}

Default base_repository implementation which should work out of the box for any struct which implements the BaseDocument trait

use bson::oid::ObjectId;
use serde::{Deserialize, Serialize};
use mongo_data::document::document::BaseDocument;
#[derive(Deserialize, Serialize, Debug, Clone)]
 pub struct TestEntity {
    #[serde(rename = "_id", skip_serializing_if = "Option::is_none")]
    pub id: Option<ObjectId>,
   pub pid: String,
}

// Implement the BaseDocument trait
impl BaseDocument for TestEntity {
    fn set_id(&mut self, id: Option<ObjectId>) {
        self.id = id
    }

    fn get_id(&self) -> Option<ObjectId> {
       self.id
    }
}

Fields

collection: Collection<T>

Trait Implementations

impl<T: BaseDocument + Debug + Serialize + for<'de> Deserialize<'de> + Sync + Unpin + Send> Repository<T> for MongoRepository<T>

fn save<'life0, 'life1, 'async_trait>( &'life0 self, entity: T, ctx: Option<&'life1 Context>, ) -> Pin<Box<dyn Future<Output = Result<ObjectId, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Save a new document

fn save_many<'life0, 'life1, 'async_trait>( &'life0 self, entities: Vec<T>, ctx: Option<&'life1 Context>, options: Option<InsertManyOptions>, ) -> Pin<Box<dyn Future<Output = Result<Vec<ObjectId>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Save many documents

fn get_all_pageable<'life0, 'life1, 'async_trait>( &'life0 self, request: PageableRequest, ctx: Option<&'life1 Context>, ) -> Pin<Box<dyn Future<Output = Result<PageableResponse<T>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get all documents from a collection (pageable)

fn count_documents_in_collection<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: Option<&'life1 Context>, ) -> Pin<Box<dyn Future<Output = Result<u64, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get the number of documents in a collection

fn find_by_id<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 str, ctx: Option<&'life2 Context>, ) -> Pin<Box<dyn Future<Output = Result<T, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

find a document by ObjectId hex(string)

fn find_by_raw_id<'life0, 'life1, 'async_trait>( &'life0 self, id: ObjectId, ctx: Option<&'life1 Context>, ) -> Pin<Box<dyn Future<Output = Result<T, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

find a document by ObjectId

fn find_by_ids<'life0, 'life1, 'async_trait>( &'life0 self, ids: Vec<String>, ctx: Option<&'life1 Context>, ) -> Pin<Box<dyn Future<Output = Result<Vec<T>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Find documents by a list of ObjectId hex(string)

fn find_by_raw_ids<'life0, 'life1, 'async_trait>( &'life0 self, ids: Vec<ObjectId>, ctx: Option<&'life1 Context>, ) -> Pin<Box<dyn Future<Output = Result<Vec<T>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Find documents by a list of ObjectIds

fn find_by_filter_and_options<'life0, 'life1, 'async_trait>( &'life0 self, filter: Document, options: Option<FindOneOptions>, ctx: Option<&'life1 Context>, ) -> Pin<Box<dyn Future<Output = Result<T, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Find 1 document by a user defined filter

fn find_all_by_filter_and_options<'life0, 'life1, 'async_trait>( &'life0 self, filter: Document, options: Option<FindOptions>, ctx: Option<&'life1 Context>, ) -> Pin<Box<dyn Future<Output = Result<Vec<T>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Find a list of documents by a user defined filter

fn update<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, entity: &'life1 T, ctx: Option<&'life2 Context>, ) -> Pin<Box<dyn Future<Output = Result<ObjectId, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Update an existing document

fn delete_by_id<'life0, 'life1, 'async_trait>( &'life0 self, id: ObjectId, ctx: Option<&'life1 Context>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete an existing document by ObjectID

fn delete_by_ids<'life0, 'life1, 'async_trait>( &'life0 self, ids: Vec<ObjectId>, ctx: Option<&'life1 Context>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete a list existing documents by ObjectIDs

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, filter: Document, ctx: Option<&'life1 Context>, options: Option<FindOneAndDeleteOptions>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete an existing document by a user filter

fn delete_many<'life0, 'life1, 'async_trait>( &'life0 self, filter: Document, ctx: Option<&'life1 Context>, options: Option<DeleteOptions>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete existing documents by a user defined filter