implement item_name_regex option

This commit is contained in:
yggverse 2026-04-07 12:05:13 +03:00
parent f52fe3a710
commit 93f9bc4fee
5 changed files with 30 additions and 0 deletions

12
Cargo.lock generated
View file

@ -1511,6 +1511,16 @@ dependencies = [
"serde", "serde",
] ]
[[package]]
name = "serde_regex"
version = "1.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a8136f1a4ea815d7eac4101cfd0b16dc0cb5e1fe1b8609dfd728058656b7badf"
dependencies = [
"regex",
"serde",
]
[[package]] [[package]]
name = "serde_spanned" name = "serde_spanned"
version = "1.1.1" version = "1.1.1"
@ -2456,8 +2466,10 @@ dependencies = [
"env_logger", "env_logger",
"log", "log",
"redb", "redb",
"regex",
"rustypipe", "rustypipe",
"serde", "serde",
"serde_regex",
"tokio", "tokio",
"toml", "toml",
"tracing-subscriber", "tracing-subscriber",

View file

@ -16,8 +16,10 @@ clap = { version = "4.6", features = ["derive"] }
env_logger = "0.11.10" env_logger = "0.11.10"
log = "0.4.29" log = "0.4.29"
redb = "4.0.0" redb = "4.0.0"
regex = "1.12.3"
rustypipe = "0.11.4" rustypipe = "0.11.4"
serde = { version = "1.0.228", features = ["derive"] } serde = { version = "1.0.228", features = ["derive"] }
serde_regex = "1.1.0"
tokio = { version = "1.51.0", features = ["rt-multi-thread"] } tokio = { version = "1.51.0", features = ["rt-multi-thread"] }
toml = "1.1.2" toml = "1.1.2"
tracing-subscriber = { version = "0.3.23", features = ["env-filter"] } tracing-subscriber = { version = "0.3.23", features = ["env-filter"] }

View file

@ -17,6 +17,7 @@ sleep = 1
is_short = false is_short = false
is_upcoming = false is_upcoming = false
# limit = 1 # limit = 1
# name_regex = ".*"
# Channel item commands to apply (in order) # Channel item commands to apply (in order)

View file

@ -1,6 +1,7 @@
mod command; mod command;
use command::Command; use command::Command;
use regex::Regex;
use serde::Deserialize; use serde::Deserialize;
#[derive(Deserialize)] #[derive(Deserialize)]
@ -11,4 +12,6 @@ pub struct Channel {
pub is_short: bool, pub is_short: bool,
pub is_upcoming: bool, pub is_upcoming: bool,
pub limit: Option<usize>, pub limit: Option<usize>,
#[serde(with = "serde_regex")]
pub item_name_regex: Option<Regex>,
} }

View file

@ -48,6 +48,18 @@ async fn main() {
debug!("items limit for channel `{c}` reached at {i}; break."); debug!("items limit for channel `{c}` reached at {i}; break.");
break; break;
} }
if !channel
.item_name_regex
.as_ref()
.is_some_and(|regex| regex.is_match(&item.name))
{
debug!(
"item name `{}` for channel `{c}` does not match pattern `{}`; skip.",
&item.name,
&channel.item_name_regex.as_ref().unwrap()
);
continue;
}
match database.get(&item.id) { match database.get(&item.id) {
Ok(id) => { Ok(id) => {
if id.is_some() { if id.is_some() {