From 415ba8185e08c9262d67d095e83b9f1d8a92cd07 Mon Sep 17 00:00:00 2001 From: aniampio Date: Mon, 16 Dec 2019 16:36:59 +0100 Subject: [PATCH] Add to_bytes function --- sfw-provider-requests/src/responses.rs | 2 +- src/provider/client_handling/mod.rs | 5 +++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/sfw-provider-requests/src/responses.rs b/sfw-provider-requests/src/responses.rs index 896d4db171..2d33ea9221 100644 --- a/sfw-provider-requests/src/responses.rs +++ b/sfw-provider-requests/src/responses.rs @@ -109,7 +109,7 @@ impl ProviderResponse for PullResponse { impl ProviderResponse for RegisterResponse { fn to_bytes(&self) -> Vec{ - unimplemented!() + self.response.clone() } fn from_bytes(bytes: &[u8]) -> Result{ diff --git a/src/provider/client_handling/mod.rs b/src/provider/client_handling/mod.rs index 136f206610..1ad86e10bc 100644 --- a/src/provider/client_handling/mod.rs +++ b/src/provider/client_handling/mod.rs @@ -59,7 +59,7 @@ impl ClientRequestProcessor { processing_data: &RwLock, ) -> Result, ClientProcessingError> { let client_request = ProviderRequests::from_bytes(&data)?; - println!("received the following request: {:?}", client_request); + println!("Received the following request: {:?}", client_request); match client_request { ProviderRequests::Register(req) => { Ok(ClientRequestProcessor::register_new_client(req)?.to_bytes()) @@ -78,13 +78,14 @@ impl ClientRequestProcessor { req: PullRequest, store_dir: &Path, ) -> Result { - println!("processing pull!"); + println!("Processing pull!"); let retrieved_messages = ClientStorage::retrieve_client_files(req.destination_address, store_dir)?; Ok(PullResponse::new(retrieved_messages)) } fn register_new_client(req:RegisterRequest) -> Result{ + println!("Processing register new client request!"); let auth_token = ClientRequestProcessor::generate_new_auth_token(req.destination_address.to_vec()); //somehow register token Ok(RegisterResponse::new(auth_token.value))