aboutsummaryrefslogtreecommitdiff
path: root/src/dav
diff options
context:
space:
mode:
authorQuentin Dufour <quentin@deuxfleurs.fr>2024-03-01 18:20:51 +0100
committerQuentin Dufour <quentin@deuxfleurs.fr>2024-03-01 18:20:51 +0100
commit4490afb1bfef7af4afe8ada9c99f9bf7925ad40e (patch)
tree14cb9ef2a78f3a525be2a445bd42b257997366fc /src/dav
parentdee970afe5db1886b3e1816703ef841acbd07463 (diff)
downloadaerogramme-4490afb1bfef7af4afe8ada9c99f9bf7925ad40e.tar.gz
aerogramme-4490afb1bfef7af4afe8ada9c99f9bf7925ad40e.zip
Implement propertyupdate
Diffstat (limited to 'src/dav')
-rw-r--r--src/dav/encoder.rs47
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;