55 lines
1.8 KiB
Rust
55 lines
1.8 KiB
Rust
use axum::{
|
||
extract::{State, Query},
|
||
http::StatusCode,
|
||
};
|
||
use serde::Deserialize;
|
||
use shared::{AppEvent, SystemNotification, NotificationLevel};
|
||
use crate::AppState;
|
||
|
||
#[derive(Deserialize)]
|
||
pub struct TorrentFinishedQuery {
|
||
pub name: String,
|
||
pub hash: String,
|
||
}
|
||
|
||
pub async fn torrent_finished_handler(
|
||
State(state): State<AppState>,
|
||
Query(params): Query<TorrentFinishedQuery>,
|
||
) -> StatusCode {
|
||
tracing::info!("WEBHOOK: Received notification from rTorrent. Name: {:?}, Hash: {:?}", params.name, params.hash);
|
||
|
||
let torrent_name = if params.name.is_empty() || params.name == "$d.name=" {
|
||
"Bilinmeyen Torrent".to_string()
|
||
} else {
|
||
params.name.clone()
|
||
};
|
||
|
||
let message = format!("Torrent tamamlandı: {}", torrent_name);
|
||
|
||
// 1. Send to active SSE clients (for Toast)
|
||
let notification = SystemNotification {
|
||
level: NotificationLevel::Success,
|
||
message: message.clone(),
|
||
};
|
||
let _ = state.event_bus.send(AppEvent::Notification(notification));
|
||
|
||
// 2. Send Web Push Notification (for Background)
|
||
#[cfg(feature = "push-notifications")]
|
||
{
|
||
let push_store = state.push_store.clone();
|
||
let title = "Torrent Tamamlandı".to_string();
|
||
let body = message;
|
||
let name_for_log = torrent_name.clone();
|
||
|
||
tokio::spawn(async move {
|
||
tracing::info!("Attempting to send Web Push notification for torrent: {}", name_for_log);
|
||
match crate::push::send_push_notification(&push_store, &title, &body).await {
|
||
Ok(_) => tracing::info!("Web Push notification task completed for: {}", name_for_log),
|
||
Err(e) => tracing::error!("Failed to send Web Push notification for {}: {:?}", name_for_log, e),
|
||
}
|
||
});
|
||
}
|
||
|
||
StatusCode::OK
|
||
}
|