diff --git a/shared/backup_client/src/lib.rs b/shared/backup_client/src/lib.rs
--- a/shared/backup_client/src/lib.rs
+++ b/shared/backup_client/src/lib.rs
@@ -168,6 +168,59 @@
     Ok((tx, rx))
   }
 
+  pub async fn download_logs(
+    &self,
+    user_identity: &UserIdentity,
+    backup_id: &str,
+  ) -> Result<
+    (
+      impl Sink<DownloadLogsRequest, Error = WSError>,
+      impl Stream<Item = Result<LogWSResponse, WSError>>,
+    ),
+    Error,
+  > {
+    let request = self.create_ws_request(user_identity, backup_id)?;
+    let (stream, response) = connect_async(request).await?;
+
+    if response.status().is_client_error() {
+      return Err(Error::WSInitError(TungsteniteError::Http(response)));
+    }
+
+    let (tx, rx) = stream.split();
+
+    let tx = tx.with(|request: DownloadLogsRequest| async {
+      let request = LogWSRequest::DownloadLogs(request);
+      let request = bincode::serialize(&request)?;
+      Ok(Binary(request))
+    });
+
+    let rx = rx.filter_map(|msg| async {
+      let bytes = match msg {
+        Ok(Binary(bytes)) => bytes,
+        // Handled by tungstenite
+        Ok(Ping(_)) => return None,
+        Ok(_) => return Some(Err(WSError::InvalidWSMessage)),
+        Err(err) => return Some(Err(err.into())),
+      };
+
+      let response = match bincode::deserialize(&bytes) {
+        Ok(response) => response,
+        Err(err) => return Some(Err(err.into())),
+      };
+
+      match response {
+        LogWSResponse::LogDownloadFinished { .. }
+        | LogWSResponse::LogDownload { .. } => Some(Ok(response)),
+        LogWSResponse::LogUploaded { .. } => {
+          return Some(Err(WSError::InvalidBackupMessage))
+        }
+        LogWSResponse::ServerError => return Some(Err(WSError::ServerError)),
+      }
+    });
+
+    Ok((tx, rx))
+  }
+
   fn create_ws_request(
     &self,
     user_identity: &UserIdentity,