git/caesar-transfer
1
0
Fork 0
Code Issues Pull requests Projects Releases 2 Packages Wiki Activity Actions

Almost completed sender

Browse source
This commit is contained in:
ikeen0807 2024-05-15 21:01:33 +02:00
parent 1f355a5d3e
commit 96340622d8
11 changed files with 666 additions and 52 deletions
Download patch file Download diff file Expand all files Collapse all files

10
caesar-core/src/sender/mod.rs
View file

@ -18,11 +18,16 @@ use tower_http::trace::{DefaultMakeSpan, TraceLayer};
use tracing::{debug, error, info};
use uuid::Uuid;
pub async fn start_sender(relay: Arc<String>, files: Arc<Vec<String>>) {
pub async fn start_sender(relay: Arc<String>, files: Arc<Vec<String>>, transfer_name: String) {
let (tx, mut rx) = mpsc::channel(1);
debug!("Got relay: {relay}");
let room_id = Uuid::new_v4().to_string();
let rand_name = generate_random_name();
let rand_name: String;
if transfer_name.is_empty() {
rand_name = generate_random_name();
} else {
rand_name = transfer_name.clone();
}
let local_room_id = room_id.clone();
let local_files = files.clone();
let local_relay = relay.clone();
@ -56,6 +61,7 @@ pub async fn start_sender(relay: Arc<String>, files: Arc<Vec<String>>) {
.await
});
rx.recv().await.unwrap();
local_ws_thread.abort();
relay_thread.abort();