aboutsummaryrefslogtreecommitdiffstats
path: root/crates/pseudonyms/src
diff options
context:
space:
mode:
authorrtkay123 <dev@kanjala.com>2025-08-10 18:07:13 +0200
committerrtkay123 <dev@kanjala.com>2025-08-10 18:07:13 +0200
commita9aef1863ff0fe0422eee403f85644fc76952e80 (patch)
treea233ca1ca7fb38d06592fa7296382b5e9b478d62 /crates/pseudonyms/src
parent8b4f27d2c39d1e1f5f1cc455c58800e806ee98d0 (diff)
downloadwarden-a9aef1863ff0fe0422eee403f85644fc76952e80.tar.bz2
warden-a9aef1863ff0fe0422eee403f85644fc76952e80.zip
feat(warden): save history
Diffstat (limited to 'crates/pseudonyms/src')
-rw-r--r--crates/pseudonyms/src/main.rs9
-rw-r--r--crates/pseudonyms/src/server/interceptor.rs4
-rw-r--r--crates/pseudonyms/src/state.rs6
-rw-r--r--crates/pseudonyms/src/state/mutate.rs6
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;