derust 0.1.1

Easy way to start your Rust asynchronous application server using Tokio and Axum frameworks.
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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

mod http;
mod runner;
mod sns;
mod sqs;

pub use http::*;
pub use outbox_pattern_processor::outbox_resources::OutboxProcessorResources;
pub use runner::*;

use crate::httpx::{AppContext, HttpError, HttpTags};
use axum::http::StatusCode;
use outbox_pattern_processor::outbox::Outbox;
use outbox_pattern_processor::outbox_repository::OutboxRepository;
use sqlx::PgConnection;

#[cfg(feature = "aws")]
pub use sqs::*;

#[cfg(feature = "aws")]
pub use sns::*;

#[cfg(any(feature = "statsd", feature = "prometheus"))]
use crate::metricx::{timer, MetricTags};

pub async fn insert_outbox<S>(
    context: &AppContext<S>,
    db_conn: &mut PgConnection,
    outbox: Outbox,
    tags: &HttpTags,
) -> Result<Outbox, HttpError>
where
    S: Clone,
{
    #[cfg(any(feature = "statsd", feature = "prometheus"))]
    let stopwatch = timer::start_stopwatch(
        context,
        "repository_outbox_insert_seconds",
        MetricTags::from(tags.clone()),
    );

    let result = OutboxRepository::insert(db_conn, outbox)
        .await
        .map_err(|error| {
            HttpError::without_body(
                StatusCode::INTERNAL_SERVER_ERROR,
                format!("Failed to insert outbox: {error}"),
                tags.clone(),
            )
        });

    #[cfg(any(feature = "statsd", feature = "prometheus"))]
    {
        let success = match result {
            Ok(_) => "true",
            Err(_) => "false",
        };

        let mut result_metric_tags = MetricTags::from(tags);
        result_metric_tags = result_metric_tags.push("success".to_string(), success.to_string());
        stopwatch.record(result_metric_tags);
    }

    result
}