fplus_database/core/common.rs
1use actix_web::web;
2use anyhow::Result;
3use mongodb::{Client, Collection};
4use std::sync::Mutex;
5
6pub const DATABASE: &str = "fplus-db";
7
8pub async fn get_collection<T>(
9 state: web::Data<Mutex<Client>>,
10 collection_name: &str,
11) -> Result<Collection<T>> {
12 let col: Collection<T> = state
13 .lock()
14 .unwrap()
15 .database(DATABASE)
16 .collection(collection_name);
17 Ok(col)
18}