diff --git a/bin/core/src/connection/server.rs b/bin/core/src/connection/server.rs
index 6adfacb03..5f135e494 100644
--- a/bin/core/src/connection/server.rs
+++ b/bin/core/src/connection/server.rs
@@ -17,11 +17,12 @@ use komodo_client::{
     user::system_user,
   },
 };
-use periphery_client::transport::LoginMessage;
+use periphery_client::{
+  api::PeripheryConnectionQuery, transport::LoginMessage,
+};
 use resolver_api::Resolve;
 use serror::{AddStatusCode, AddStatusCodeError};
 use transport::{
-  PeripheryConnectionQuery,
   auth::{
     HeaderConnectionIdentifiers, LoginFlow, LoginFlowArgs,
     PublicKeyValidator, ServerLoginFlow,
diff --git a/bin/periphery/src/connection/server.rs b/bin/periphery/src/connection/server.rs
index 884854cc5..b6685b49b 100644
--- a/bin/periphery/src/connection/server.rs
+++ b/bin/periphery/src/connection/server.rs
@@ -18,10 +18,11 @@ use axum::{
   routing::get,
 };
 use axum_server::tls_rustls::RustlsConfig;
-use periphery_client::transport::LoginMessage;
+use periphery_client::{
+  api::CoreConnectionQuery, transport::LoginMessage,
+};
 use serror::{AddStatusCode, AddStatusCodeError};
 use transport::{
-  CoreConnectionQuery,
   auth::{
     ConnectionIdentifiers, HeaderConnectionIdentifiers,
     ServerLoginFlow,
diff --git a/client/periphery/rs/src/api/mod.rs b/client/periphery/rs/src/api/mod.rs
index 40eb251b2..2759b0515 100644
--- a/client/periphery/rs/src/api/mod.rs
+++ b/client/periphery/rs/src/api/mod.rs
@@ -23,6 +23,20 @@ pub mod terminal;
 
 //
 
+#[derive(Deserialize, Debug, Clone)]
+pub struct CoreConnectionQuery {
+  /// Core host (eg demo.komo.do)
+  pub core: String,
+}
+
+#[derive(Deserialize, Debug, Clone)]
+pub struct PeripheryConnectionQuery {
+  /// Server Id or name
+  pub server: String,
+}
+
+//
+
 #[derive(Serialize, Deserialize, Debug, Clone, Resolve)]
 #[response(GetHealthResponse)]
 #[error(anyhow::Error)]
diff --git a/lib/transport/src/lib.rs b/lib/transport/src/lib.rs
index 288d97530..c9df6c4b3 100644
--- a/lib/transport/src/lib.rs
+++ b/lib/transport/src/lib.rs
@@ -1,30 +1,8 @@
-use ::bytes::Bytes;
-use serde::Deserialize;
-
 pub mod auth;
 pub mod channel;
 pub mod timeout;
 pub mod websocket;
 
-pub trait TransportHandler {
-  fn handle_incoming_bytes(
-    &self,
-    bytes: Bytes,
-  ) -> impl Future<Output = ()> + Send;
-}
-
-#[derive(Deserialize, Debug, Clone)]
-pub struct CoreConnectionQuery {
-  /// Core host (eg demo.komo.do)
-  pub core: String,
-}
-
-#[derive(Deserialize, Debug, Clone)]
-pub struct PeripheryConnectionQuery {
-  /// Server Id or name
-  pub server: String,
-}
-
 /// - Fixes ws addresses:
 ///   - `server.domain` => `wss://server.domain`
 ///   - `http://server.domain` => `ws://server.domain`