euzu/tuliprox
1
0
Fork 0
mirror of https://github.com/euzu/tuliprox.git synced 2026-10-20 23:02:34 +02:00
Code Issues Packages Projects Releases 5 Wiki Activity

fixed only one programme entry for one channel in epg data

Browse Source
This commit is contained in:
euzu
2023-12-08 08:53:38 +01:00
parent 40947238c4
commit d5efe1f420
1 changed files with 23 additions and 43 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/processing/xmltv_parser.rs
+23 -43
View File
@@ -73,50 +73,30 @@ pub(crate) fn flatten_tvguide(tv_guides: &[Epg]) -> Option<Epg> {
attributes: None,
children: vec![],
};
let mut channel_ids: Vec<&String> = vec![];
let mut program_ids: Vec<&String> = vec![];
tv_guides.iter().for_each(|guide| {
if epg.attributes.is_none() {
epg.attributes = guide.attributes.clone();
}
guide.children.iter().for_each(|c| {
let add_child = match c.name.as_str() {
"channel" => {
let chan_id = c.get_attribute_value("id");
match chan_id {
Some(id) => {
if channel_ids.contains(&id) {
false
} else {
channel_ids.push(id);
true
}
},
None => false,
}
},
"programme" => {
let chan_id = c.get_attribute_value("channel");
match chan_id {
Some(id) => {
if program_ids.contains(&id) {
false
} else {
program_ids.push(id);
true
}
},
None => false,
}
}
_ => false,
};
if add_child {
epg.children.push(c.clone())
}
});
tv_guides.iter().for_each(|guide| {
if epg.attributes.is_none() {
epg.attributes = guide.attributes.clone();
}
guide.children.iter().for_each(|c| {
if c.name.as_str() == "channel" {
if let Some(chan_id) = c.get_attribute_value("id") {
if !channel_ids.contains(&chan_id) {
channel_ids.push(chan_id);
epg.children.push(c.clone())
}
}
}
});
guide.children.iter().for_each(|c| {
if c.name.as_str() == "programme" {
if let Some(chan_id) = c.get_attribute_value("channel") {
if channel_ids.contains(&chan_id) {
epg.children.push(c.clone());
}
}
}
});
});
Some(epg)
}