brokerage-db 0.2.7

Database management for trader brokerage data with a MongoDB backend.
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

use anyhow::Result;
use mongodb::{ClientSession, Database};
use serde::Serialize;
use std::{any::type_name, fmt::Debug, sync::Arc};
use tokio::sync::Mutex;

pub async fn insert<T>(
    t: &T,
    db: &Database,
    collection_name: &str,
    session: Option<Arc<Mutex<ClientSession>>>,
) -> Result<()>
where
    T: Serialize + Send + Sync + Debug,
{
    let collection = db.collection::<T>(collection_name);

    let result = if session.is_some() {
        let session_am = session.unwrap();
        collection
            .insert_one(t)
            .session(&mut *session_am.lock().await)
            .await?
    } else {
        collection.insert_one(t).await?
    };

    tracing::info!(
        "inserted {} {:?}, _id: {}",
        type_name::<T>(),
        t,
        result.inserted_id
    );
    Ok(())
}