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

add method to send event and log error

Browse source
This commit is contained in:
Joe Ardent 2025-08-01 16:59:31 -07:00
parent 98e2897438
commit 3e094c46dc
2 changed files with 11 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/lib.rs
View file

@ -183,6 +183,12 @@ impl JoecalState {
.entry(id) .entry(id)
.insert_entry(request); .insert_entry(request);
} }
pub fn send_event(&self, event: TransferEvent) {
if let Err(e) = self.transfer_event_tx.send(event.clone()) {
error!("got error sending transfer event '{event:?}': {e:?}");
}
}
} }
#[derive(Debug, Clone, Copy, PartialEq, Eq)] #[derive(Debug, Clone, Copy, PartialEq, Eq)]

13
src/transfer.rs
View file

@ -321,10 +321,8 @@ pub async fn register_upload(
.into_response(); .into_response();
} }
if let Ok(id) = Julid::from_str(session_id) if let Ok(id) = Julid::from_str(session_id) {
&& let Err(e) = state.transfer_event_tx.send(TransferEvent::Received(id)) state.send_event(TransferEvent::Received(id));
{
error!("got error sending upload received event: {e:?}");
}; };
StatusCode::OK.into_response() StatusCode::OK.into_response()
@ -352,10 +350,9 @@ pub async fn register_cancel(
debug!("got cancel request for {}", params.session_id); debug!("got cancel request for {}", params.session_id);
session.status = SessionStatus::Cancelled; session.status = SessionStatus::Cancelled;
if let Ok(id) = Julid::from_str(&params.session_id)
&& let Err(e) = state.transfer_event_tx.send(TransferEvent::Cancelled(id)) if let Ok(id) = Julid::from_str(&params.session_id) {
{ state.send_event(TransferEvent::Cancelled(id));
error!("got error sending upload canceled event: {e:?}");
}; };
StatusCode::OK.into_response() StatusCode::OK.into_response()