nebkor/joecalsend
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix handler

Browse source
This commit is contained in:
Joe Ardent 2025-07-05 12:12:58 -07:00
parent 627bf71703
commit 31c31801ce
1 changed files with 3 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/transfer/upload.rs
View file

@ -10,7 +10,6 @@ use axum::{
use julid::Julid; use julid::Julid;
use native_dialog::MessageDialogBuilder; use native_dialog::MessageDialogBuilder;
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use tokio::sync::Mutex;
use crate::{ use crate::{
Client, JoecalState, Client, JoecalState,
@ -44,7 +43,7 @@ impl Client {
} }
let peer = self.peers.lock().await.get(&peer).unwrap().clone(); let peer = self.peers.lock().await.get(&peer).unwrap().clone();
println!("Peer: {:?}", peer); println!("Peer: {peer:?}");
let response = self let response = self
.http_client .http_client
@ -298,9 +297,9 @@ pub struct UploadParams {
pub async fn register_cancel( pub async fn register_cancel(
Query(params): Query<CancelParams>, Query(params): Query<CancelParams>,
Extension(sessions): Extension<Arc<Mutex<HashMap<String, Session>>>>, State(state): State<JoecalState>,
) -> impl IntoResponse { ) -> impl IntoResponse {
let mut sessions_lock = sessions.lock().await; let mut sessions_lock = state.sessions.lock().await;
let session = match sessions_lock.get_mut(&params.session_id) { let session = match sessions_lock.get_mut(&params.session_id) {
Some(session) => session, Some(session) => session,
None => return StatusCode::BAD_REQUEST.into_response(), None => return StatusCode::BAD_REQUEST.into_response(),