diff options
author | Quentin Dufour <quentin@deuxfleurs.fr> | 2024-03-01 18:20:51 +0100 |
---|---|---|
committer | Quentin Dufour <quentin@deuxfleurs.fr> | 2024-03-01 18:20:51 +0100 |
commit | 4490afb1bfef7af4afe8ada9c99f9bf7925ad40e (patch) | |
tree | 14cb9ef2a78f3a525be2a445bd42b257997366fc /src/dav | |
parent | dee970afe5db1886b3e1816703ef841acbd07463 (diff) | |
download | aerogramme-4490afb1bfef7af4afe8ada9c99f9bf7925ad40e.tar.gz aerogramme-4490afb1bfef7af4afe8ada9c99f9bf7925ad40e.zip |
Implement propertyupdate
Diffstat (limited to 'src/dav')
-rw-r--r-- | src/dav/encoder.rs | 47 |
1 files changed, 44 insertions, 3 deletions
diff --git a/src/dav/encoder.rs b/src/dav/encoder.rs index 4a9bcf4..41e93f3 100644 --- a/src/dav/encoder.rs +++ b/src/dav/encoder.rs @@ -81,7 +81,14 @@ impl<C: Context> QuickWritable<C> for PropFind<C> { /// PROPPATCH REQUEST impl<C: Context> QuickWritable<C> for PropertyUpdate<C> { async fn write(&self, xml: &mut Writer<impl AsyncWrite+Unpin>, ctx: C) -> Result<(), QError> { - unimplemented!(); + let start = ctx.create_dav_element("propertyupdate"); + let end = start.to_end(); + + xml.write_event_async(Event::Start(start.clone())).await?; + for update in self.0.iter() { + update.write(xml, ctx.child()).await?; + } + xml.write_event_async(Event::End(end)).await } } @@ -137,6 +144,36 @@ impl<C: Context> QuickWritable<C> for PropValue<C> { } // --- XML inner elements +impl<C: Context> QuickWritable<C> for PropertyUpdateItem<C> { + async fn write(&self, xml: &mut Writer<impl AsyncWrite+Unpin>, ctx: C) -> Result<(), QError> { + match self { + Self::Set(set) => set.write(xml, ctx).await, + Self::Remove(rm) => rm.write(xml, ctx).await, + } + } +} + +impl<C: Context> QuickWritable<C> for Set<C> { + async fn write(&self, xml: &mut Writer<impl AsyncWrite+Unpin>, ctx: C) -> Result<(), QError> { + let start = ctx.create_dav_element("set"); + let end = start.to_end(); + xml.write_event_async(Event::Start(start.clone())).await?; + self.0.write(xml, ctx.child()).await?; + xml.write_event_async(Event::End(end)).await + } +} + +impl<C: Context> QuickWritable<C> for Remove<C> { + async fn write(&self, xml: &mut Writer<impl AsyncWrite+Unpin>, ctx: C) -> Result<(), QError> { + let start = ctx.create_dav_element("remove"); + let end = start.to_end(); + xml.write_event_async(Event::Start(start.clone())).await?; + self.0.write(xml, ctx.child()).await?; + xml.write_event_async(Event::End(end)).await + } +} + + impl<C: Context> QuickWritable<C> for AnyProp<C> { async fn write(&self, xml: &mut Writer<impl AsyncWrite+Unpin>, ctx: C) -> Result<(), QError> { match self { @@ -998,8 +1035,12 @@ mod tests { let got = serialize( NoExtension { root: true }, &PropertyUpdate(vec![ - PropertyUpdateItem::Set(Set(PropValue(vec![ ]))), - PropertyUpdateItem::Remove(Remove(PropName(vec![]))), + PropertyUpdateItem::Set(Set(PropValue(vec![ + Property::GetContentLanguage("fr-FR".into()), + ]))), + PropertyUpdateItem::Remove(Remove(PropName(vec![ + PropertyRequest::DisplayName, + ]))), ]), ).await; |