Cargo.toml

@@ -14,7 +14,7 @@ members = [
     "crates/adapters/auth",
     "crates/adapters/nats",
     "crates/adapters/event-payload",
-    "crates/adapters/event-publisher",
+    "crates/adapters/event-transport",
 ]
 resolver = "2"
 
@@ -51,4 +51,4 @@ activitypub      = { path = "crates/adapters/activitypub" }
 auth             = { path = "crates/adapters/auth" }
 nats             = { path = "crates/adapters/nats" }
 event-payload    = { path = "crates/adapters/event-payload" }
-event-publisher  = { path = "crates/adapters/event-publisher" }
+event-transport  = { path = "crates/adapters/event-transport" }

crates/adapters/event-transport/Cargo.toml

@@ -1,5 +1,5 @@
 [package]
-name = "event-publisher"
+name = "event-transport"
 version = "0.1.0"
 edition = "2021"
 

crates/adapters/nats/Cargo.toml

@@ -6,7 +6,7 @@ edition = "2021"
 [dependencies]
 domain           = { workspace = true }
 event-payload    = { workspace = true }
-event-publisher  = { workspace = true }
+event-transport  = { workspace = true }
 async-nats       = { workspace = true }
 async-stream     = { workspace = true }
 serde_json       = { workspace = true }

crates/adapters/nats/src/lib.rs

@@ -5,7 +5,7 @@ use domain::{
     ports::EventConsumer,
 };
 use event_payload::EventPayload;
-use event_publisher::Transport;
+use event_transport::Transport;
 use futures::stream::BoxStream;
 
 // ── NatsTransport — raw NATS publish backend ────────────────────────────────

crates/bootstrap/Cargo.toml

@@ -16,7 +16,7 @@ postgres-federation = { workspace = true }
 activitypub         = { workspace = true }
 activitypub-base    = { workspace = true }
 nats                = { workspace = true }
-event-publisher     = { workspace = true }
+event-transport     = { workspace = true }
 auth                = { workspace = true }
 sqlx                = { workspace = true }
 async-nats          = { workspace = true }

crates/bootstrap/src/factory.rs

@@ -5,7 +5,7 @@ use sqlx::PgPool;
 use activitypub::ThoughtsObjectHandler;
 use activitypub_base::{ApFederationConfig, FederationData};
 use domain::{errors::DomainError, events::DomainEvent, ports::EventPublisher};
-use event_publisher::EventPublisherAdapter;
+use event_transport::EventPublisherAdapter;
 use nats::NatsTransport;
 use postgres::activitypub::PgActivityPubRepository;
 use postgres_federation::{PostgresApUserRepository, PostgresFederationRepository};