GKaszewski/thoughts
1
0
Fork 0
Code Issues 3 Pull Requests Actions Packages Projects Releases Wiki Activity

feat(worker): use EventConsumerAdapter<NatsMessageSource> — transport-agnostic consuming

Browse Source
This commit is contained in:
Gabriel Kaszewski
2026-05-14 12:37:16 +02:00
parent e995b29be1
commit 69b55058ce
2 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
crates/worker/Cargo.toml
View File

@@ -8,9 +8,10 @@ name = "thoughts-worker"
path = "src/main.rs" path = "src/main.rs"
[dependencies] [dependencies]
domain = { workspace = true } domain = { workspace = true }
nats = { workspace = true } nats = { workspace = true }
event-payload = { workspace = true } event-payload = { workspace = true }
event-transport = { workspace = true }
postgres = { workspace = true } postgres = { workspace = true }
async-nats = { workspace = true } async-nats = { workspace = true }
tokio = { workspace = true, features = ["full"] } tokio = { workspace = true, features = ["full"] }

2
crates/worker/src/main.rs
View File

@@ -20,7 +20,7 @@ async fn main() {
tracing::info!("Connecting to NATS at {nats_url}..."); tracing::info!("Connecting to NATS at {nats_url}...");
let nats_client = async_nats::connect(&nats_url).await.expect("NATS connect failed"); let nats_client = async_nats::connect(&nats_url).await.expect("NATS connect failed");
let consumer = nats::NatsEventConsumer::new(nats_client); let consumer = event_transport::EventConsumerAdapter::new(nats::NatsMessageSource::new(nats_client));
let notification_handler = handlers::NotificationHandler { let notification_handler = handlers::NotificationHandler {
thoughts: Arc::new(postgres::thought::PgThoughtRepository::new(pool.clone())), thoughts: Arc::new(postgres::thought::PgThoughtRepository::new(pool.clone())),