aboutsummaryrefslogtreecommitdiff
path: root/src/dav
diff options
context:
space:
mode:
Diffstat (limited to 'src/dav')
-rw-r--r--src/dav/calencoder.rs20
-rw-r--r--src/dav/encoder.rs146
2 files changed, 147 insertions, 19 deletions
diff --git a/src/dav/calencoder.rs b/src/dav/calencoder.rs
index 378d2bd..14b7903 100644
--- a/src/dav/calencoder.rs
+++ b/src/dav/calencoder.rs
@@ -19,6 +19,10 @@ impl Context for CalExtension {
async fn hook_error(&self, err: &Violation, xml: &mut Writer<impl AsyncWrite+Unpin>) -> Result<(), QError> {
err.write(xml, self.child()).await
}
+
+ async fn hook_property(&self, prop: &Self::Property, xml: &mut Writer<impl AsyncWrite+Unpin>) -> Result<(), QError> {
+ prop.write(xml, self.child()).await
+ }
}
impl CalExtension {
@@ -47,14 +51,14 @@ impl QuickWritable<CalExtension> for Violation {
}
}
-/*
- <?xml version="1.0" encoding="utf-8" ?>
- <D:error>
- <C:supported-filter>
- <C:prop-filter name="X-ABC-GUID"/>
- </C:supported-filter>
- </D:error>
-*/
+
+impl QuickWritable<CalExtension> for Property {
+ async fn write(&self, xml: &mut Writer<impl AsyncWrite+Unpin>, ctx: CalExtension) -> Result<(), QError> {
+ unimplemented!();
+ }
+}
+
+
#[cfg(test)]
mod tests {
diff --git a/src/dav/encoder.rs b/src/dav/encoder.rs
index 5392b18..332c13a 100644
--- a/src/dav/encoder.rs
+++ b/src/dav/encoder.rs
@@ -20,6 +20,7 @@ pub trait Context: Extension {
fn child(&self) -> Self;
fn create_dav_element(&self, name: &str) -> BytesStart;
async fn hook_error(&self, err: &Self::Error, xml: &mut Writer<impl AsyncWrite+Unpin>) -> Result<(), QError>;
+ async fn hook_property(&self, prop: &Self::Property, xml: &mut Writer<impl AsyncWrite+Unpin>) -> Result<(), QError>;
}
/// -------------- NoExtension Encoding Context
@@ -37,6 +38,9 @@ impl Context for NoExtension {
async fn hook_error(&self, err: &Disabled, xml: &mut Writer<impl AsyncWrite+Unpin>) -> Result<(), QError> {
unreachable!();
}
+ async fn hook_property(&self, prop: &Disabled, xml: &mut Writer<impl AsyncWrite+Unpin>) -> Result<(), QError> {
+ unreachable!();
+ }
}
@@ -196,23 +200,143 @@ impl<C: Context> QuickWritable<C> for Property<C> {
async fn write(&self, xml: &mut Writer<impl AsyncWrite+Unpin>, ctx: C) -> Result<(), QError> {
use Property::*;
match self {
- CreationDate(date) => unimplemented!(),
- DisplayName(name) => unimplemented!(),
- GetContentLanguage(lang) => unimplemented!(),
- GetContentLength(len) => unimplemented!(),
- GetContentType(ct) => unimplemented!(),
- GetEtag(et) => unimplemented!(),
- GetLastModified(dt) => unimplemented!(),
- LockDiscovery(locks) => unimplemented!(),
- ResourceType(res) => unimplemented!(),
- SupportedLock(sup) => unimplemented!(),
- Extension(inner) => unimplemented!(),
+ CreationDate(date) => {
+ // <D:creationdate>1997-12-01T17:42:21-08:00</D:creationdate>
+ let start = ctx.create_dav_element("creationdate");
+ let end = start.to_end();
+
+ xml.write_event_async(Event::Start(start.clone())).await?;
+ xml.write_event_async(Event::Text(BytesText::new(&date.to_rfc3339()))).await?;
+ xml.write_event_async(Event::End(end)).await?;
+ },
+ DisplayName(name) => {
+ // <D:displayname>Example collection</D:displayname>
+ let start = ctx.create_dav_element("displayname");
+ let end = start.to_end();
+
+ xml.write_event_async(Event::Start(start.clone())).await?;
+ xml.write_event_async(Event::Text(BytesText::new(name))).await?;
+ xml.write_event_async(Event::End(end)).await?;
+ },
+ GetContentLanguage(lang) => {
+ let start = ctx.create_dav_element("getcontentlanguage");
+ let end = start.to_end();
+
+ xml.write_event_async(Event::Start(start.clone())).await?;
+ xml.write_event_async(Event::Text(BytesText::new(lang))).await?;
+ xml.write_event_async(Event::End(end)).await?;
+ },
+ GetContentLength(len) => {
+ // <D:getcontentlength>4525</D:getcontentlength>
+ let start = ctx.create_dav_element("getcontentlength");
+ let end = start.to_end();
+
+ xml.write_event_async(Event::Start(start.clone())).await?;
+ xml.write_event_async(Event::Text(BytesText::new(&len.to_string()))).await?;
+ xml.write_event_async(Event::End(end)).await?;
+ },
+ GetContentType(ct) => {
+ // <D:getcontenttype>text/html</D:getcontenttype>
+ let start = ctx.create_dav_element("getcontenttype");
+ let end = start.to_end();
+
+ xml.write_event_async(Event::Start(start.clone())).await?;
+ xml.write_event_async(Event::Text(BytesText::new(&ct))).await?;
+ xml.write_event_async(Event::End(end)).await?;
+ },
+ GetEtag(et) => {
+ // <D:getetag>"zzyzx"</D:getetag>
+ let start = ctx.create_dav_element("getetag");
+ let end = start.to_end();
+
+ xml.write_event_async(Event::Start(start.clone())).await?;
+ xml.write_event_async(Event::Text(BytesText::new(et))).await?;
+ xml.write_event_async(Event::End(end)).await?;
+ },
+ GetLastModified(date) => {
+ // <D:getlastmodified>Mon, 12 Jan 1998 09:25:56 GMT</D:getlastmodified>
+ let start = ctx.create_dav_element("getlastmodified");
+ let end = start.to_end();
+
+ xml.write_event_async(Event::Start(start.clone())).await?;
+ xml.write_event_async(Event::Text(BytesText::new(&date.to_rfc3339()))).await?;
+ xml.write_event_async(Event::End(end)).await?;
+ },
+ LockDiscovery(many_locks) => {
+ // <D:lockdiscovery><D:activelock> ... </D:activelock></D:lockdiscovery>
+ let start = ctx.create_dav_element("lockdiscovery");
+ let end = start.to_end();
+
+ xml.write_event_async(Event::Start(start.clone())).await?;
+ for lock in many_locks.iter() {
+ lock.write(xml, ctx.child()).await?;
+ }
+ xml.write_event_async(Event::End(end)).await?;
+ },
+ ResourceType(many_types) => {
+ // <D:resourcetype><D:collection/></D:resourcetype>
+
+ // <D:resourcetype/>
+
+ // <x:resourcetype xmlns:x="DAV:">
+ // <x:collection/>
+ // <f:search-results xmlns:f="http://www.example.com/ns"/>
+ // </x:resourcetype>
+
+ let start = ctx.create_dav_element("resourcetype");
+ if many_types.is_empty() {
+ xml.write_event_async(Event::Empty(start)).await?;
+ } else {
+ let end = start.to_end();
+ xml.write_event_async(Event::Start(start.clone())).await?;
+ for restype in many_types.iter() {
+ restype.write(xml, ctx.child()).await?;
+ }
+ xml.write_event_async(Event::End(end)).await?;
+ }
+ },
+ SupportedLock(many_entries) => {
+ // <D:supportedlock/>
+
+ // <D:supportedlock> <D:lockentry> ... </D:lockentry> </D:supportedlock>
+
+ let start = ctx.create_dav_element("supportedlock");
+ if many_entries.is_empty() {
+ xml.write_event_async(Event::Empty(start)).await?;
+ } else {
+ let end = start.to_end();
+ xml.write_event_async(Event::Start(start.clone())).await?;
+ for entry in many_entries.iter() {
+ entry.write(xml, ctx.child()).await?;
+ }
+ xml.write_event_async(Event::End(end)).await?;
+ }
+ },
+ Extension(inner) => {
+ ctx.hook_property(inner, xml).await?;
+ },
};
Ok(())
}
}
+impl<C: Context> QuickWritable<C> for ActiveLock {
+ async fn write(&self, xml: &mut Writer<impl AsyncWrite+Unpin>, ctx: C) -> Result<(), QError> {
+ unimplemented!();
+ }
+}
+
+impl<C: Context> QuickWritable<C> for ResourceType<C> {
+ async fn write(&self, xml: &mut Writer<impl AsyncWrite+Unpin>, ctx: C) -> Result<(), QError> {
+ unimplemented!();
+ }
+}
+impl<C: Context> QuickWritable<C> for LockEntry {
+ async fn write(&self, xml: &mut Writer<impl AsyncWrite+Unpin>, ctx: C) -> Result<(), QError> {
+ unimplemented!();
+ }
+}
impl<C: Context> QuickWritable<C> for Error<C> {
async fn write(&self, xml: &mut Writer<impl AsyncWrite+Unpin>, ctx: C) -> Result<(), QError> {
generated by cgit v1.2.3 (git 2.25.1) at 2024-12-26 03:57:54 +0000