axum-webtools 0.1.47

General purpose tools for axum web framework.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use scoped_futures::ScopedBoxFuture;
use sqlx::{Database, Pool, Transaction};

pub async fn with_tx<'p, F, R, E, DB>(pool: &Pool<DB>, callback: F) -> Result<R, E>
where
    F: for<'r> FnOnce(&'r mut Transaction<DB>) -> ScopedBoxFuture<'p, 'r, Result<R, E>> + Send + 'p,
    E: From<sqlx::Error> + Send + 'p,
    R: Send + 'p,
    DB: Database,
{
    let mut tx = pool.begin().await?;
    let res = callback(&mut tx).await;
    match res {
        Ok(response) => {
            tx.commit().await?;
            Ok(response)
        }
        Err(e) => {
            tx.rollback().await?;
            Err(e)
        }
    }
}