aboutsummaryrefslogtreecommitdiff
path: root/aero-proto
diff options
context:
space:
mode:
authorQuentin Dufour <quentin@deuxfleurs.fr>2024-05-16 21:47:21 +0200
committerQuentin Dufour <quentin@deuxfleurs.fr>2024-05-16 21:47:21 +0200
commitb2c75242eb5788242787428883471da3ec54ea7e (patch)
treed70e69bb75737d870f11f70955721ab19f5dff3d /aero-proto
parent32dfd25f570b7a55bf43752684d286be0f6b2dc2 (diff)
downloadaerogramme-b2c75242eb5788242787428883471da3ec54ea7e.tar.gz
aerogramme-b2c75242eb5788242787428883471da3ec54ea7e.zip
WIP filter
Diffstat (limited to 'aero-proto')
-rw-r--r--aero-proto/src/dav/controller.rs56
1 files changed, 48 insertions, 8 deletions
diff --git a/aero-proto/src/dav/controller.rs b/aero-proto/src/dav/controller.rs
index 0bf7a7d..541beb6 100644
--- a/aero-proto/src/dav/controller.rs
+++ b/aero-proto/src/dav/controller.rs
@@ -137,7 +137,7 @@ impl Controller {
}
cal::Report::Query(q) => {
calprop = q.selector;
- ok_node = apply_filter(&self.user, self.node.children(&self.user).await, q.filter)
+ ok_node = apply_filter(self.node.children(&self.user).await, &q.filter)
.try_collect()
.await?;
}
@@ -327,13 +327,11 @@ impl<'a> Path<'a> {
//@FIXME move somewhere else
//@FIXME naive implementation, must be refactored later
use futures::stream::Stream;
-use icalendar;
-fn apply_filter(
- user: &ArcUser,
+fn apply_filter<'a>(
nodes: Vec<Box<dyn DavNode>>,
- filter: cal::Filter,
-) -> impl Stream<Item = std::result::Result<Box<dyn DavNode>, std::io::Error>> {
- futures::stream::iter(nodes).filter_map(|single_node| async move {
+ filter: &'a cal::Filter,
+) -> impl Stream<Item = std::result::Result<Box<dyn DavNode>, std::io::Error>> + 'a {
+ futures::stream::iter(nodes).filter_map(move |single_node| async move {
// Get ICS
let chunks: Vec<_> = match single_node.content().try_collect().await {
Ok(v) => v,
@@ -346,11 +344,53 @@ fn apply_filter(
});
// Parse ICS
- let ics = icalendar::parser::read_calendar(&raw_ics).unwrap();
+ let ics = match icalendar::parser::read_calendar(&raw_ics) {
+ Ok(v) => v,
+ Err(e) => {
+ tracing::warn!(err=?e, "Unable to parse ICS in calendar-query");
+ return Some(Err(std::io::Error::from(std::io::ErrorKind::InvalidData)));
+ }
+ };
// Do checks
+ //@FIXME VCalendar root component is hardcoded
+ let root_filter = &filter.0;
+ if root_filter.name != cal::Component::VCalendar {
+ return None;
+ }
+
+ let matcher = match &root_filter.additional_rules {
+ None => return Some(Ok(single_node)),
+ Some(cal::CompFilterRules::IsNotDefined) => return None,
+ Some(cal::CompFilterRules::Matches(m)) => m,
+ };
+
+ let evts = ics
+ .components
+ .iter()
+ .all(|single_comp| is_component_match(single_comp, matcher));
// Object has been kept
Some(Ok(single_node))
})
}
+
+fn is_component_match(
+ component: &icalendar::parser::Component,
+ matcher: &cal::CompFilterMatch,
+) -> bool {
+ if let Some(time_range) = &matcher.time_range {
+ todo!(); // check DTSTART and DTEND
+ }
+
+ if !matcher.prop_filter.iter().all(|single_prop_filter| {
+ true // check prop filter against component
+ }) {
+ return false;
+ }
+
+ //component.components.iter().any
+ matcher.comp_filter.iter().all(|single_comp_filter| {
+ true //@TODO find component, find
+ })
+}