rrelayer_core 0.7.0

Core types and functionality for rrelayer - a powerful blockchain transaction relay service
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

use std::sync::Arc;

use super::{
    cache::{get_transaction_cache, set_transaction_cache},
    types::{Transaction, TransactionId},
};
use crate::{
    postgres::{PostgresClient, PostgresError},
    shared::cache::Cache,
};

pub async fn get_transaction_by_id(
    cache: &Arc<Cache>,
    db: &PostgresClient,
    id: TransactionId,
) -> Result<Option<Transaction>, PostgresError> {
    if let Some(cached_transaction) = get_transaction_cache(cache, &id).await {
        return Ok(Some(cached_transaction));
    }

    let transaction = db.get_transaction(&id).await?;

    set_transaction_cache(cache, &id, &transaction).await;

    Ok(transaction)
}