YGGverse/ytd
1
0
Fork 0
mirror of https://codeberg.org/YGGverse/ytd.git synced 2026-04-08 12:55:32 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

handle db errors properly

Browse source
This commit is contained in:
yggverse 2026-04-06 23:44:28 +03:00
parent b676060798
commit 28b614d5db
1 changed files with 14 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/main.rs
View file

@ -44,13 +44,21 @@ async fn main() {
let items = result.content.items; let items = result.content.items;
debug!("received {:?} items to handle...", items.len()); debug!("received {:?} items to handle...", items.len());
for item in items { for item in items {
if database.get(&item.id).is_ok_and(|r| r.is_some()) { match database.get(&item.id) {
Ok(id) => {
if id.is_some() {
debug!( debug!(
"item `{}` for channel `{c}` already processed; skip handle.", "item `{}` for channel `{c}` already processed; skip handle.",
item.id item.id
); );
continue; continue;
} }
}
Err(e) => panic!(
"can't check item `{}` in DB for channel `{c}`: {e}",
item.id
),
}
if item.is_live != channel.is_live { if item.is_live != channel.is_live {
debug!( debug!(
"skip item `{}` for channel `{c}` by `is_live` filter (item: {:?}/config:{:?})", "skip item `{}` for channel `{c}` by `is_live` filter (item: {:?}/config:{:?})",
@ -85,7 +93,7 @@ async fn main() {
"exec `{cmd}` for channel `{c}` successful: `{:?}`", "exec `{cmd}` for channel `{c}` successful: `{:?}`",
response response
), ),
Err(e) => error!( Err(e) => panic!(
"can't persist processed item `{}` for channel `{c}` by `{cmd}`: `{e}`", "can't persist processed item `{}` for channel `{c}` by `{cmd}`: `{e}`",
item.id item.id
), ),