diff options
author | rtkay123 <dev@kanjala.com> | 2025-08-10 18:07:13 +0200 |
---|---|---|
committer | rtkay123 <dev@kanjala.com> | 2025-08-10 18:07:13 +0200 |
commit | a9aef1863ff0fe0422eee403f85644fc76952e80 (patch) | |
tree | a233ca1ca7fb38d06592fa7296382b5e9b478d62 /crates/pseudonyms/src | |
parent | 8b4f27d2c39d1e1f5f1cc455c58800e806ee98d0 (diff) | |
download | warden-a9aef1863ff0fe0422eee403f85644fc76952e80.tar.bz2 warden-a9aef1863ff0fe0422eee403f85644fc76952e80.zip |
feat(warden): save history
Diffstat (limited to 'crates/pseudonyms/src')
-rw-r--r-- | crates/pseudonyms/src/main.rs | 9 | ||||
-rw-r--r-- | crates/pseudonyms/src/server/interceptor.rs | 4 | ||||
-rw-r--r-- | crates/pseudonyms/src/state.rs | 6 | ||||
-rw-r--r-- | crates/pseudonyms/src/state/mutate.rs | 6 |
4 files changed, 13 insertions, 12 deletions
diff --git a/crates/pseudonyms/src/main.rs b/crates/pseudonyms/src/main.rs index 7b67557..127cb2a 100644 --- a/crates/pseudonyms/src/main.rs +++ b/crates/pseudonyms/src/main.rs @@ -1,8 +1,8 @@ use clap::Parser; -use warden_stack::{Configuration, Services, tracing::Tracing}; use std::sync::Arc; use tracing::error; use warden_pseudonyms::state::{AppHandle, AppState}; +use warden_stack::{Configuration, Services, tracing::Tracing}; /// warden-pseudonyms #[derive(Parser, Debug)] @@ -47,18 +47,17 @@ async fn main() -> anyhow::Result<()> { .inspect_err(|e| error!("cache: {e}"))? .build(); - let postgres = services + let postgres = services .postgres .take() .ok_or_else(|| anyhow::anyhow!("database is not ready"))?; - let cache = services + let cache = services .cache .take() .ok_or_else(|| anyhow::anyhow!("cache is not ready"))?; - let services = warden_pseudonyms::state::Services { postgres , cache}; - + let services = warden_pseudonyms::state::Services { postgres, cache }; let state = AppState::new(services, config, Some(provider))?; diff --git a/crates/pseudonyms/src/server/interceptor.rs b/crates/pseudonyms/src/server/interceptor.rs index f30f140..eeb36c2 100644 --- a/crates/pseudonyms/src/server/interceptor.rs +++ b/crates/pseudonyms/src/server/interceptor.rs @@ -1,9 +1,9 @@ +use tonic::{Status, service::Interceptor}; +use tracing::Span; use warden_stack::{ opentelemetry::global, tracing::telemetry::tonic::extractor, tracing_opentelemetry::OpenTelemetrySpanExt, }; -use tonic::{Status, service::Interceptor}; -use tracing::Span; #[derive(Clone, Copy)] pub struct MyInterceptor; diff --git a/crates/pseudonyms/src/state.rs b/crates/pseudonyms/src/state.rs index 349c324..82f025f 100644 --- a/crates/pseudonyms/src/state.rs +++ b/crates/pseudonyms/src/state.rs @@ -1,11 +1,13 @@ mod mutate; use std::{ - net::{Ipv6Addr, SocketAddr}, ops::Deref, sync::Arc + net::{Ipv6Addr, SocketAddr}, + ops::Deref, + sync::Arc, }; use sqlx::PgPool; -use warden_stack::{cache::RedisManager, tracing::SdkTracerProvider, Configuration}; +use warden_stack::{Configuration, cache::RedisManager, tracing::SdkTracerProvider}; use crate::AppConfig; diff --git a/crates/pseudonyms/src/state/mutate.rs b/crates/pseudonyms/src/state/mutate.rs index b0d2f7a..6a737b5 100644 --- a/crates/pseudonyms/src/state/mutate.rs +++ b/crates/pseudonyms/src/state/mutate.rs @@ -1,6 +1,3 @@ -use warden_stack::{ - opentelemetry_semantic_conventions::attribute, tracing_opentelemetry::OpenTelemetrySpanExt, -}; use time::OffsetDateTime; use tonic::{Request, Response, Status}; use tracing::{Instrument, info_span, instrument}; @@ -10,6 +7,9 @@ use warden_core::{ CreatePseudonymRequest, mutate_pseudonym_server::MutatePseudonym, }, }; +use warden_stack::{ + opentelemetry_semantic_conventions::attribute, tracing_opentelemetry::OpenTelemetrySpanExt, +}; use crate::state::AppHandle; |