admin/vibetorrent
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 194 Wiki Activity

chore(ui): add debug logs for SSE deserialization errors
All checks were successful
Build MIPS Binary / build (push) Successful in 1m56s
Details

Browse Source
This commit is contained in:
spinline
2026-02-21 00:23:23 +03:00
parent 7129c9a8eb
commit f8639f2967
1 changed files with 30 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

50
frontend/src/store.rs
View File

@@ -105,29 +105,39 @@ pub fn provide_torrent_store() {
} }
if let Some(data_str) = msg.data().as_string() { if let Some(data_str) = msg.data().as_string() {
if let Ok(bytes) = BASE64.decode(&data_str) { match BASE64.decode(&data_str) {
if let Ok(event) = rmp_serde::from_slice::<AppEvent>(&bytes) { Ok(bytes) => {
match event { match rmp_serde::from_slice::<AppEvent>(&bytes) {
AppEvent::FullList(list, _) => { Ok(event) => {
torrents_for_sse.update(|map| { match event {
let new_hashes: std::collections::HashSet<String> = list.iter().map(|t| t.hash.clone()).collect(); AppEvent::FullList(list, _) => {
map.retain(|hash, _| new_hashes.contains(hash)); torrents_for_sse.update(|map| {
for new_torrent in list { map.insert(new_torrent.hash.clone(), new_torrent); } let new_hashes: std::collections::HashSet<String> = list.iter().map(|t| t.hash.clone()).collect();
}); map.retain(|hash, _| new_hashes.contains(hash));
} for new_torrent in list { map.insert(new_torrent.hash.clone(), new_torrent); }
AppEvent::Update(patch) => { });
if let Some(hash) = patch.hash.clone() { }
torrents_for_sse.update(|map| { if let Some(t) = map.get_mut(&hash) { t.apply(patch); } }); AppEvent::Update(patch) => {
} if let Some(hash) = patch.hash.clone() {
} torrents_for_sse.update(|map| { if let Some(t) = map.get_mut(&hash) { t.apply(patch); } });
AppEvent::Stats(stats) => { global_stats_for_sse.set(stats); } }
AppEvent::Notification(n) => { }
show_toast(n.level.clone(), n.message.clone()); AppEvent::Stats(stats) => { global_stats_for_sse.set(stats); }
if n.message.contains("tamamlandı") || n.level == shared::NotificationLevel::Error { AppEvent::Notification(n) => {
show_browser_notification("VibeTorrent", &n.message); show_toast(n.level.clone(), n.message.clone());
if n.message.contains("tamamlandı") || n.level == shared::NotificationLevel::Error {
show_browser_notification("VibeTorrent", &n.message);
}
}
} }
},
Err(e) => {
log::error!("[SSE] Failed to deserialize AppEvent: {:?}", e);
} }
} }
},
Err(e) => {
log::error!("[SSE] Failed to decode base64: {:?}", e);
} }
} }
} }