Function test_transaction_rollback

tests/database.rs:56–77

()

    #[tokio::test]
    async fn test_transaction_rollback() {
        run_test(async {
            let pool = connection_pool().await;
            let executor = Arc::new(RwLock::new(Executor::new(pool)));

            executor.write().await.begin().await.unwrap();
            // let trx: Transactions = connection.begin().await.unwrap();
            let mut board_repo: Repository<BoardAggregate> =
                board_repository_helper(executor.clone());

            let mut board_aggregate = board_create_helper(BoardState::Unpublished);
            let id = board_repo.add(&mut board_aggregate).await.unwrap();

            executor.write().await.rollback().await.unwrap();

            //TODO Shouldn't exist
            if board_repo.get(&id).await.is_ok() {
                panic!("Shouldn't exist!")
            }
        })
        .await;
    }
}