From cf0f140ba32d61d9ccfa151a2830f2da6b099f7b Mon Sep 17 00:00:00 2001 From: Patryk Hegenberg Date: Thu, 2 May 2024 10:57:02 +0200 Subject: [PATCH] feature(receiver): added success request to receiver --- src/receiver/http_client.rs | 15 ++++++++++++++- src/receiver/mod.rs | 5 +++++ 2 files changed, 19 insertions(+), 1 deletion(-) diff --git a/src/receiver/http_client.rs b/src/receiver/http_client.rs index 0fd8008..df700f0 100644 --- a/src/receiver/http_client.rs +++ b/src/receiver/http_client.rs @@ -1,5 +1,5 @@ use hex; -use reqwest; +use reqwest::{self, Client}; use sha2::{Digest, Sha256}; use tracing::error; @@ -23,3 +23,16 @@ pub async fn download_info(relay: &str, name: &str) -> Result } } } + +pub async fn download_success(relay: &str, name: &str) -> Result<()> { + let url = String::from("http://") + relay; + let hashed_name = Sha256::digest(name.as_bytes()); + let hashed_string = hex::encode(hashed_name); + + let client = Client::new(); + let _ = client + .post(format!("{}/download_success/{}", url, hashed_string)) + .send() + .await?; + Ok(()) +} diff --git a/src/receiver/mod.rs b/src/receiver/mod.rs index 9f12bff..3e071c7 100644 --- a/src/receiver/mod.rs +++ b/src/receiver/mod.rs @@ -57,6 +57,11 @@ pub async fn start_receiver(relay: &str, name: &str) { debug!("Failed to connect remote: {relay_err}"); } } + let success = http_client::download_success(relay, name).await; + match success { + Ok(()) => debug!("Success"), + Err(e) => error!("Error: {e:?}"), + }; // if let Err(e) = start_ws_com(res_ip.as_str(), res.local_room_id.as_str()).await { // debug!("Failed to connect local with first room_id: {e}");