chore: collapse stack-up

6 files changed, 45 insertions, 8 deletions

diff --git a/crates/pseudonyms/Cargo.toml b/crates/pseudonyms/Cargo.toml
index 4ddf179..02ecddc 100644
--- a/crates/pseudonyms/Cargo.toml
+++ b/crates/pseudonyms/Cargo.toml
@@ -8,4 +8,18 @@ documentation.workspace = true
 description.workspace = true
 
 [dependencies]
+anyhow.workspace = true
+clap = { workspace = true, features = ["derive"] }
+config = { workspace = true, features = ["convert-case", "toml"] }
+metrics.workspace = true
+metrics-exporter-prometheus.workspace = true
+serde = { workspace = true, features = ["derive"] }
+serde_json.workspace = true
+time.workspace = true
+tokio = { workspace = true, features = ["macros", "rt-multi-thread", "signal"] }
+tracing.workspace = true
 warden-core = { workspace = true, features = ["pseudonyms", "serde-time"] }
+
+[dependencies.warden-stack]
+workspace = true
+features = ["api", "cache", "postgres", "opentelemetry", "tracing-loki"]
diff --git a/crates/warden/Cargo.toml b/crates/warden/Cargo.toml
index b10ed45..dde983b 100644
--- a/crates/warden/Cargo.toml
+++ b/crates/warden/Cargo.toml
@@ -42,6 +42,6 @@ scalar = ["dep:utoipa-scalar", "utoipa-scalar/axum"]
 [dev-dependencies]
 tower = { workspace = true, features = ["util"] }
 
-[dependencies.stack-up]
+[dependencies.warden-stack]
 workspace = true
 features = ["api", "opentelemetry", "tracing-loki"]
diff --git a/crates/warden/src/main.rs b/crates/warden/src/main.rs
index b649280..68b185c 100644
--- a/crates/warden/src/main.rs
+++ b/crates/warden/src/main.rs
@@ -7,7 +7,7 @@ mod version;
 use std::net::{Ipv6Addr, SocketAddr};
 
 use clap::{Parser, command};
-use stack_up::{Configuration, tracing::Tracing};
+use warden_stack::{Configuration, tracing::Tracing};
 use tracing::info;
 
 use crate::state::AppState;
diff --git a/crates/warden/src/server.rs b/crates/warden/src/server.rs
index ce01fb8..6712516 100644
--- a/crates/warden/src/server.rs
+++ b/crates/warden/src/server.rs
@@ -58,8 +58,8 @@ pub async fn health_check() -> impl axum::response::IntoResponse {
 }
 
 #[cfg(test)]
-pub(crate) fn test_config() -> stack_up::Configuration {
-    use stack_up::Configuration;
+pub(crate) fn test_config() -> warden_stack::Configuration {
+    use warden_stack::Configuration;
 
     let config_path = "warden.toml";
 
diff --git a/crates/warden/src/server/routes/processor/pacs008.rs b/crates/warden/src/server/routes/processor/pacs008.rs
index 87f1fee..3efc7f1 100644
--- a/crates/warden/src/server/routes/processor/pacs008.rs
+++ b/crates/warden/src/server/routes/processor/pacs008.rs
@@ -1,10 +1,10 @@
 use axum::{extract::State, response::IntoResponse};
-use stack_up::tracing_opentelemetry::OpenTelemetrySpanExt;
+use warden_stack::tracing_opentelemetry::OpenTelemetrySpanExt;
 use tracing::{debug, error, trace, warn};
 use warden_core::{
     google::r#type::Money,
-    iso20022::{TransactionType, pacs008::Pacs008Document},
-    message::DataCache,
+    iso20022::{pacs008::Pacs008Document, TransactionType},
+    message::DataCache, pseudonyms::transaction_relationship::{CreatePseudonymRequest, TransactionRelationship},
 };
 
 use crate::{error::AppError, server::routes::PACS008_001_12, state::AppHandle, version::Version};
@@ -99,6 +99,29 @@ pub(super) async fn post_pacs008(
         None
     };
 
+    let transaction_relationship = TransactionRelationship {
+        from: data_cache.dbtr_acct_id.to_string(),
+        to: data_cache.cdtr_acct_id.to_string(),
+        amt: money,
+        cre_dt_tm: data_cache.cre_dt_tm,
+        end_to_end_id: end_to_end_id.to_string(),
+        msg_id: msg_id.to_string(),
+        pmt_inf_id: pmt_inf_id.into(),
+        tx_tp: tx_tp.to_owned(),
+        ..Default::default()
+    };
+
+   let request = CreatePseudonymRequest {
+        transaction_relationship: Some(transaction_relationship),
+        debtor_id: data_cache.dbtr_id.to_string(),
+        debtor_account_id: data_cache.dbtr_acct_id.to_string(),
+        creditor_id: data_cache.cdtr_id.to_string(),
+        creditor_account_id: data_cache.cdtr_acct_id.to_string(),
+    };
+
+
+    debug!(%msg_id, %end_to_end_id, "constructed transaction relationship");
+
     Ok(String::default())
 }
 
diff --git a/crates/warden/src/state.rs b/crates/warden/src/state.rs
index aabcaab..8e5b182 100644
--- a/crates/warden/src/state.rs
+++ b/crates/warden/src/state.rs
@@ -1,4 +1,4 @@
-use stack_up::{Configuration, Environment};
+use warden_stack::{Configuration, Environment};
 use std::{ops::Deref, sync::Arc};
 
 use crate::{cnfg::LocalConfig, error::AppError};