more file reorganization

marshal/src/handlers.rs

@@ -0,0 +1,32 @@
+use proto::{
+    connection::{
+        auth::marshal::MarshalAuth,
+        protocols::{Protocol, Sender},
+    },
+    crypto::{Scheme, Serializable},
+    redis,
+};
+
+use crate::Marshal;
+
+impl<SignatureScheme: Scheme, ProtocolType: Protocol> Marshal<SignatureScheme, ProtocolType>
+where
+    SignatureScheme::VerificationKey: Serializable,
+    SignatureScheme::Signature: Serializable,
+{
+    /// Handles a user's connection, including authentication.
+    pub async fn handle_connection(
+        mut connection: (ProtocolType::Sender, ProtocolType::Receiver),
+        mut redis_client: redis::Client,
+    ) {
+        // Verify (authenticate) the connection
+        let _ = MarshalAuth::<SignatureScheme, ProtocolType>::verify_user(
+            &mut connection,
+            &mut redis_client,
+        )
+        .await;
+
+        // We don't care about this, just drop the connection immediately.
+        let _ = connection.0.finish().await;
+    }
+}

marshal/src/lib.rs

@@ -5,12 +5,11 @@
 
 use std::{marker::PhantomData, sync::Arc};
 
+mod handlers;
+
 use proto::{
     bail,
-    connection::{
-        auth::marshal::MarshalAuth,
-        protocols::{Listener, Protocol, Sender},
-    },
+    connection::protocols::{Listener, Protocol},
     crypto::{Scheme, Serializable},
     error::{Error, Result},
     redis,
@@ -74,22 +73,6 @@ where
         })
     }
 
-    /// Handles a user's connection, including authentication.
-    pub async fn handle_connection(
-        mut connection: (ProtocolType::Sender, ProtocolType::Receiver),
-        mut redis_client: redis::Client,
-    ) {
-        // Verify (authenticate) the connection
-        let _ = MarshalAuth::<SignatureScheme, ProtocolType>::verify_user(
-            &mut connection,
-            &mut redis_client,
-        )
-        .await;
-
-        // We don't care about this, just drop the connection immediately.
-        let _ = connection.0.finish().await;
-    }
-
     /// The main loop for a marshal.
     /// Consumes self.
     ///