From a9aef1863ff0fe0422eee403f85644fc76952e80 Mon Sep 17 00:00:00 2001 From: rtkay123 Date: Sun, 10 Aug 2025 18:07:13 +0200 Subject: feat(warden): save history --- crates/pseudonyms/Cargo.toml | 5 ----- crates/pseudonyms/src/main.rs | 9 ++++----- crates/pseudonyms/src/server/interceptor.rs | 4 ++-- crates/pseudonyms/src/state.rs | 6 ++++-- crates/pseudonyms/src/state/mutate.rs | 6 +++--- crates/pseudonyms/tests/helpers.rs | 4 ++-- 6 files changed, 15 insertions(+), 19 deletions(-) (limited to 'crates/pseudonyms') diff --git a/crates/pseudonyms/Cargo.toml b/crates/pseudonyms/Cargo.toml index 9f06188..1efd5c5 100644 --- a/crates/pseudonyms/Cargo.toml +++ b/crates/pseudonyms/Cargo.toml @@ -32,8 +32,3 @@ warden-core = { workspace = true, features = ["pseudonyms", "serde-time"] } [dependencies.warden-stack] workspace = true features = ["api", "cache", "postgres", "opentelemetry-tonic", "tracing-loki"] - -[profile.release] -lto = true -strip = true -codegen-units = 1 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; diff --git a/crates/pseudonyms/tests/helpers.rs b/crates/pseudonyms/tests/helpers.rs index 9f512df..589049a 100644 --- a/crates/pseudonyms/tests/helpers.rs +++ b/crates/pseudonyms/tests/helpers.rs @@ -1,9 +1,9 @@ use sqlx::PgPool; -use warden_stack::{Configuration, cache::RedisManager}; use tokio::sync::oneshot; use tonic::transport::Channel; use warden_core::pseudonyms::transaction_relationship::mutate_pseudonym_client::MutatePseudonymClient; use warden_pseudonyms::state::{AppHandle, AppState, Services}; +use warden_stack::{Configuration, cache::RedisManager}; use std::sync::Arc; @@ -34,7 +34,7 @@ impl TestApp { cache, }; - let state = AppHandle(Arc::new(AppState::new(services, config, None).unwrap())); + let state = AppHandle(Arc::new(AppState::new(services, config, None).unwrap())); dbg!(&state.addr.port()); -- cgit v1.2.3