Replace this internal_props stuff with CommonPropertiesExtension

This commit is contained in:
Lennart
2025-01-18 22:59:02 +01:00
parent 1dda9dea8d
commit eb1a8578d7
19 changed files with 263 additions and 233 deletions

23
Cargo.lock generated
View File

@@ -2825,7 +2825,6 @@ dependencies = [
"rustical_store", "rustical_store",
"rustical_xml", "rustical_xml",
"serde", "serde",
"strum",
"thiserror 2.0.11", "thiserror 2.0.11",
"tokio", "tokio",
"tracing", "tracing",
@@ -3384,28 +3383,6 @@ version = "0.11.1"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "7da8b5736845d9f2fcb837ea5d9e2628564b3b043a70948a3f0b778838c5fb4f" checksum = "7da8b5736845d9f2fcb837ea5d9e2628564b3b043a70948a3f0b778838c5fb4f"
[[package]]
name = "strum"
version = "0.26.3"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8fec0f0aef304996cf250b31b5a10dee7980c85da9d759361292b8bca5a18f06"
dependencies = [
"strum_macros",
]
[[package]]
name = "strum_macros"
version = "0.26.4"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "4c6bee85a5a24955dc440386795aa378cd9cf82acd5f764469152d2270e581be"
dependencies = [
"heck",
"proc-macro2",
"quote",
"rustversion",
"syn",
]
[[package]] [[package]]
name = "subtle" name = "subtle"
version = "2.6.1" version = "2.6.1"

View File

@@ -1,5 +1,5 @@
use crate::{ use crate::{
calendar_object::resource::{CalendarObjectProp, CalendarObjectResource}, calendar_object::resource::{CalendarObjectPropWrapper, CalendarObjectResource},
Error, Error,
}; };
use actix_web::{ use actix_web::{
@@ -8,7 +8,7 @@ use actix_web::{
HttpRequest, HttpRequest,
}; };
use rustical_dav::{ use rustical_dav::{
resource::{CommonPropertiesProp, EitherProp, Resource}, resource::Resource,
xml::{multistatus::ResponseElement, MultistatusElement, PropElement, PropfindType}, xml::{multistatus::ResponseElement, MultistatusElement, PropElement, PropfindType},
}; };
use rustical_store::{auth::User, CalendarObject, CalendarStore}; use rustical_store::{auth::User, CalendarObject, CalendarStore};
@@ -60,8 +60,7 @@ pub async fn handle_calendar_multiget<C: CalendarStore>(
principal: &str, principal: &str,
cal_id: &str, cal_id: &str,
cal_store: &C, cal_store: &C,
) -> Result<MultistatusElement<EitherProp<CalendarObjectProp, CommonPropertiesProp>, String>, Error> ) -> Result<MultistatusElement<CalendarObjectPropWrapper, String>, Error> {
{
let (objects, not_found) = let (objects, not_found) =
get_objects_calendar_multiget(&cal_multiget, req.path(), principal, cal_id, cal_store) get_objects_calendar_multiget(&cal_multiget, req.path(), principal, cal_id, cal_store)
.await?; .await?;

View File

@@ -2,14 +2,14 @@ use std::ops::Deref;
use actix_web::HttpRequest; use actix_web::HttpRequest;
use rustical_dav::{ use rustical_dav::{
resource::{CommonPropertiesProp, EitherProp, Resource}, resource::Resource,
xml::{MultistatusElement, PropElement, PropfindType}, xml::{MultistatusElement, PropElement, PropfindType},
}; };
use rustical_store::{auth::User, calendar::UtcDateTime, CalendarObject, CalendarStore}; use rustical_store::{auth::User, calendar::UtcDateTime, CalendarObject, CalendarStore};
use rustical_xml::XmlDeserialize; use rustical_xml::XmlDeserialize;
use crate::{ use crate::{
calendar_object::resource::{CalendarObjectProp, CalendarObjectResource}, calendar_object::resource::{CalendarObjectPropWrapper, CalendarObjectResource},
Error, Error,
}; };
@@ -185,8 +185,7 @@ pub async fn handle_calendar_query<C: CalendarStore>(
principal: &str, principal: &str,
cal_id: &str, cal_id: &str,
cal_store: &C, cal_store: &C,
) -> Result<MultistatusElement<EitherProp<CalendarObjectProp, CommonPropertiesProp>, String>, Error> ) -> Result<MultistatusElement<CalendarObjectPropWrapper, String>, Error> {
{
let objects = get_objects_calendar_query(&cal_query, principal, cal_id, cal_store).await?; let objects = get_objects_calendar_query(&cal_query, principal, cal_id, cal_store).await?;
let props = match cal_query.prop { let props = match cal_query.prop {

View File

@@ -1,6 +1,6 @@
use actix_web::{http::StatusCode, HttpRequest}; use actix_web::{http::StatusCode, HttpRequest};
use rustical_dav::{ use rustical_dav::{
resource::{CommonPropertiesProp, EitherProp, Resource}, resource::Resource,
xml::{ xml::{
multistatus::ResponseElement, sync_collection::SyncCollectionRequest, MultistatusElement, multistatus::ResponseElement, sync_collection::SyncCollectionRequest, MultistatusElement,
PropElement, PropfindType, PropElement, PropfindType,
@@ -13,7 +13,7 @@ use rustical_store::{
}; };
use crate::{ use crate::{
calendar_object::resource::{CalendarObjectProp, CalendarObjectResource}, calendar_object::resource::{CalendarObjectPropWrapper, CalendarObjectResource},
Error, Error,
}; };
@@ -24,8 +24,7 @@ pub async fn handle_sync_collection<C: CalendarStore>(
principal: &str, principal: &str,
cal_id: &str, cal_id: &str,
cal_store: &C, cal_store: &C,
) -> Result<MultistatusElement<EitherProp<CalendarObjectProp, CommonPropertiesProp>, String>, Error> ) -> Result<MultistatusElement<CalendarObjectPropWrapper, String>, Error> {
{
let props = match sync_collection.prop { let props = match sync_collection.prop {
PropfindType::Allprop => { PropfindType::Allprop => {
vec!["allprop".to_owned()] vec!["allprop".to_owned()]

View File

@@ -11,7 +11,8 @@ use actix_web::web;
use async_trait::async_trait; use async_trait::async_trait;
use derive_more::derive::{From, Into}; use derive_more::derive::{From, Into};
use rustical_dav::extensions::{ use rustical_dav::extensions::{
DavPushExtension, DavPushExtensionProp, SyncTokenExtension, SyncTokenExtensionProp, CommonPropertiesExtension, CommonPropertiesProp, DavPushExtension, DavPushExtensionProp,
SyncTokenExtension, SyncTokenExtensionProp,
}; };
use rustical_dav::privileges::UserPrivilegeSet; use rustical_dav::privileges::UserPrivilegeSet;
use rustical_dav::resource::{Resource, ResourceService}; use rustical_dav::resource::{Resource, ResourceService};
@@ -66,6 +67,7 @@ pub enum CalendarPropWrapper {
Calendar(CalendarProp), Calendar(CalendarProp),
SyncToken(SyncTokenExtensionProp), SyncToken(SyncTokenExtensionProp),
DavPush(DavPushExtensionProp), DavPush(DavPushExtensionProp),
Common(CommonPropertiesProp),
} }
#[derive(Clone, Debug, From, Into)] #[derive(Clone, Debug, From, Into)]
@@ -117,8 +119,8 @@ impl Resource for CalendarResource {
fn get_prop( fn get_prop(
&self, &self,
_rmap: &ResourceMap, rmap: &ResourceMap,
_user: &User, user: &User,
prop: &Self::PropName, prop: &Self::PropName,
) -> Result<Self::Prop, Self::Error> { ) -> Result<Self::Prop, Self::Error> {
Ok(match prop { Ok(match prop {
@@ -160,18 +162,19 @@ impl Resource for CalendarResource {
CalendarPropName::SupportedReportSet => { CalendarPropName::SupportedReportSet => {
CalendarProp::SupportedReportSet(SupportedReportSet::default()) CalendarProp::SupportedReportSet(SupportedReportSet::default())
} }
// CalendarPropName::SyncToken => CalendarProp::SyncToken(self.get_synctoken()),
// CalendarPropName::Getctag => CalendarProp::Getctag(self.get_synctoken()),
CalendarPropName::Source => CalendarProp::Source( CalendarPropName::Source => CalendarProp::Source(
self.cal.subscription_url.to_owned().map(HrefElement::from), self.cal.subscription_url.to_owned().map(HrefElement::from),
), ),
}), }),
CalendarPropWrapperName::SyncToken(prop) => { CalendarPropWrapperName::SyncToken(prop) => {
CalendarPropWrapper::SyncToken(<Self as SyncTokenExtension>::get_prop(self, prop)?) CalendarPropWrapper::SyncToken(SyncTokenExtension::get_prop(self, prop)?)
} }
CalendarPropWrapperName::DavPush(prop) => { CalendarPropWrapperName::DavPush(prop) => {
CalendarPropWrapper::DavPush(<Self as DavPushExtension>::get_prop(self, prop)?) CalendarPropWrapper::DavPush(DavPushExtension::get_prop(self, prop)?)
} }
CalendarPropWrapperName::Common(prop) => CalendarPropWrapper::Common(
CommonPropertiesExtension::get_prop(self, rmap, user, prop)?,
),
}) })
} }
@@ -227,10 +230,9 @@ impl Resource for CalendarResource {
// Converting between a calendar subscription calendar and a normal one would be weird // Converting between a calendar subscription calendar and a normal one would be weird
CalendarProp::Source(_) => Err(rustical_dav::Error::PropReadOnly), CalendarProp::Source(_) => Err(rustical_dav::Error::PropReadOnly),
}, },
CalendarPropWrapper::SyncToken(prop) => { CalendarPropWrapper::SyncToken(prop) => SyncTokenExtension::set_prop(self, prop),
<Self as SyncTokenExtension>::set_prop(self, prop) CalendarPropWrapper::DavPush(prop) => DavPushExtension::set_prop(self, prop),
} CalendarPropWrapper::Common(prop) => CommonPropertiesExtension::set_prop(self, prop),
CalendarPropWrapper::DavPush(prop) => <Self as DavPushExtension>::set_prop(self, prop),
} }
} }
@@ -275,11 +277,10 @@ impl Resource for CalendarResource {
// Converting a calendar subscription calendar into a normal one would be weird // Converting a calendar subscription calendar into a normal one would be weird
CalendarPropName::Source => Err(rustical_dav::Error::PropReadOnly), CalendarPropName::Source => Err(rustical_dav::Error::PropReadOnly),
}, },
CalendarPropWrapperName::SyncToken(prop) => { CalendarPropWrapperName::SyncToken(prop) => SyncTokenExtension::remove_prop(self, prop),
<Self as SyncTokenExtension>::remove_prop(self, prop) CalendarPropWrapperName::DavPush(prop) => DavPushExtension::remove_prop(self, prop),
} CalendarPropWrapperName::Common(prop) => {
CalendarPropWrapperName::DavPush(prop) => { CommonPropertiesExtension::remove_prop(self, prop)
<Self as DavPushExtension>::remove_prop(self, prop)
} }
} }
} }

View File

@@ -4,6 +4,7 @@ use actix_web::dev::ResourceMap;
use async_trait::async_trait; use async_trait::async_trait;
use derive_more::derive::{From, Into}; use derive_more::derive::{From, Into};
use rustical_dav::{ use rustical_dav::{
extensions::{CommonPropertiesExtension, CommonPropertiesProp},
privileges::UserPrivilegeSet, privileges::UserPrivilegeSet,
resource::{Resource, ResourceService}, resource::{Resource, ResourceService},
xml::Resourcetype, xml::Resourcetype,
@@ -37,6 +38,13 @@ pub enum CalendarObjectProp {
CalendarData(String), CalendarData(String),
} }
#[derive(XmlDeserialize, XmlSerialize, PartialEq, Clone, EnumVariants, EnumUnitVariants)]
#[xml(unit_variants_ident = "CalendarObjectPropWrapperName", untagged)]
pub enum CalendarObjectPropWrapper {
CalendarObject(CalendarObjectProp),
Common(CommonPropertiesProp),
}
#[derive(Clone, From, Into)] #[derive(Clone, From, Into)]
pub struct CalendarObjectResource { pub struct CalendarObjectResource {
pub object: CalendarObject, pub object: CalendarObject,
@@ -44,8 +52,8 @@ pub struct CalendarObjectResource {
} }
impl Resource for CalendarObjectResource { impl Resource for CalendarObjectResource {
type PropName = CalendarObjectPropName; type PropName = CalendarObjectPropWrapperName;
type Prop = CalendarObjectProp; type Prop = CalendarObjectPropWrapper;
type Error = Error; type Error = Error;
type PrincipalResource = PrincipalResource; type PrincipalResource = PrincipalResource;
@@ -55,18 +63,27 @@ impl Resource for CalendarObjectResource {
fn get_prop( fn get_prop(
&self, &self,
_rmap: &ResourceMap, rmap: &ResourceMap,
_user: &User, user: &User,
prop: &Self::PropName, prop: &Self::PropName,
) -> Result<Self::Prop, Self::Error> { ) -> Result<Self::Prop, Self::Error> {
Ok(match prop { Ok(match prop {
CalendarObjectPropName::Getetag => CalendarObjectProp::Getetag(self.object.get_etag()), CalendarObjectPropWrapperName::CalendarObject(prop) => {
CalendarObjectPropName::CalendarData => { CalendarObjectPropWrapper::CalendarObject(match prop {
CalendarObjectProp::CalendarData(self.object.get_ics().to_owned()) CalendarObjectPropName::Getetag => {
} CalendarObjectProp::Getetag(self.object.get_etag())
CalendarObjectPropName::Getcontenttype => { }
CalendarObjectProp::Getcontenttype("text/calendar;charset=utf-8") CalendarObjectPropName::CalendarData => {
CalendarObjectProp::CalendarData(self.object.get_ics().to_owned())
}
CalendarObjectPropName::Getcontenttype => {
CalendarObjectProp::Getcontenttype("text/calendar;charset=utf-8")
}
})
} }
CalendarObjectPropWrapperName::Common(prop) => CalendarObjectPropWrapper::Common(
CommonPropertiesExtension::get_prop(self, rmap, user, prop)?,
),
}) })
} }

View File

@@ -3,6 +3,7 @@ use crate::principal::PrincipalResource;
use crate::Error; use crate::Error;
use actix_web::dev::ResourceMap; use actix_web::dev::ResourceMap;
use async_trait::async_trait; use async_trait::async_trait;
use rustical_dav::extensions::{CommonPropertiesExtension, CommonPropertiesProp};
use rustical_dav::privileges::UserPrivilegeSet; use rustical_dav::privileges::UserPrivilegeSet;
use rustical_dav::resource::{NamedRoute, Resource, ResourceService}; use rustical_dav::resource::{NamedRoute, Resource, ResourceService};
use rustical_dav::xml::{HrefElement, Resourcetype, ResourcetypeInner}; use rustical_dav::xml::{HrefElement, Resourcetype, ResourcetypeInner};
@@ -24,9 +25,16 @@ pub enum PrincipalProp {
PrincipalUrl(HrefElement), PrincipalUrl(HrefElement),
} }
#[derive(XmlDeserialize, XmlSerialize, PartialEq, Clone, EnumVariants, EnumUnitVariants)]
#[xml(unit_variants_ident = "PrincipalPropWrapperName", untagged)]
pub enum PrincipalPropWrapper {
Principal(PrincipalProp),
Common(CommonPropertiesProp),
}
impl Resource for CalendarSetResource { impl Resource for CalendarSetResource {
type PropName = PrincipalPropName; type PropName = PrincipalPropWrapperName;
type Prop = PrincipalProp; type Prop = PrincipalPropWrapper;
type Error = Error; type Error = Error;
type PrincipalResource = PrincipalResource; type PrincipalResource = PrincipalResource;
@@ -40,7 +48,7 @@ impl Resource for CalendarSetResource {
fn get_prop( fn get_prop(
&self, &self,
rmap: &ResourceMap, rmap: &ResourceMap,
_user: &User, user: &User,
prop: &Self::PropName, prop: &Self::PropName,
) -> Result<Self::Prop, Self::Error> { ) -> Result<Self::Prop, Self::Error> {
let principal_href = HrefElement::new( let principal_href = HrefElement::new(
@@ -48,7 +56,15 @@ impl Resource for CalendarSetResource {
); );
Ok(match prop { Ok(match prop {
PrincipalPropName::PrincipalUrl => PrincipalProp::PrincipalUrl(principal_href), PrincipalPropWrapperName::Principal(prop) => {
PrincipalPropWrapper::Principal(match prop {
PrincipalPropName::PrincipalUrl => PrincipalProp::PrincipalUrl(principal_href),
})
}
PrincipalPropWrapperName::Common(prop) => PrincipalPropWrapper::Common(
<Self as CommonPropertiesExtension>::get_prop(self, rmap, user, prop)?,
),
}) })
} }

View File

@@ -2,6 +2,7 @@ use crate::calendar_set::CalendarSetResource;
use crate::Error; use crate::Error;
use actix_web::dev::ResourceMap; use actix_web::dev::ResourceMap;
use async_trait::async_trait; use async_trait::async_trait;
use rustical_dav::extensions::{CommonPropertiesExtension, CommonPropertiesProp};
use rustical_dav::privileges::UserPrivilegeSet; use rustical_dav::privileges::UserPrivilegeSet;
use rustical_dav::resource::{NamedRoute, Resource, ResourceService}; use rustical_dav::resource::{NamedRoute, Resource, ResourceService};
use rustical_dav::xml::{HrefElement, Resourcetype, ResourcetypeInner}; use rustical_dav::xml::{HrefElement, Resourcetype, ResourcetypeInner};
@@ -38,6 +39,13 @@ pub enum PrincipalProp {
CalendarHomeSet(CalendarHomeSet), CalendarHomeSet(CalendarHomeSet),
} }
#[derive(XmlDeserialize, XmlSerialize, PartialEq, Clone, EnumVariants, EnumUnitVariants)]
#[xml(unit_variants_ident = "PrincipalPropWrapperName", untagged)]
pub enum PrincipalPropWrapper {
Principal(PrincipalProp),
Common(CommonPropertiesProp),
}
impl PrincipalResource { impl PrincipalResource {
pub fn get_principal_url(rmap: &ResourceMap, principal: &str) -> String { pub fn get_principal_url(rmap: &ResourceMap, principal: &str) -> String {
Self::get_url(rmap, vec![principal]).unwrap() Self::get_url(rmap, vec![principal]).unwrap()
@@ -51,8 +59,8 @@ impl NamedRoute for PrincipalResource {
} }
impl Resource for PrincipalResource { impl Resource for PrincipalResource {
type PropName = PrincipalPropName; type PropName = PrincipalPropWrapperName;
type Prop = PrincipalProp; type Prop = PrincipalPropWrapper;
type Error = Error; type Error = Error;
type PrincipalResource = PrincipalResource; type PrincipalResource = PrincipalResource;
@@ -66,7 +74,7 @@ impl Resource for PrincipalResource {
fn get_prop( fn get_prop(
&self, &self,
rmap: &ResourceMap, rmap: &ResourceMap,
_user: &User, user: &User,
prop: &Self::PropName, prop: &Self::PropName,
) -> Result<Self::Prop, Self::Error> { ) -> Result<Self::Prop, Self::Error> {
let principal_url = Self::get_url(rmap, vec![&self.principal]).unwrap(); let principal_url = Self::get_url(rmap, vec![&self.principal]).unwrap();
@@ -78,13 +86,26 @@ impl Resource for PrincipalResource {
); );
Ok(match prop { Ok(match prop {
PrincipalPropName::CalendarUserType => PrincipalProp::CalendarUserType("INDIVIDUAL"), PrincipalPropWrapperName::Principal(prop) => {
PrincipalPropName::Displayname => PrincipalProp::Displayname(self.principal.to_owned()), PrincipalPropWrapper::Principal(match prop {
PrincipalPropName::PrincipalUrl => PrincipalProp::PrincipalUrl(principal_url.into()), PrincipalPropName::CalendarUserType => {
PrincipalPropName::CalendarHomeSet => PrincipalProp::CalendarHomeSet(home_set), PrincipalProp::CalendarUserType("INDIVIDUAL")
PrincipalPropName::CalendarUserAddressSet => { }
PrincipalProp::CalendarUserAddressSet(principal_url.into()) PrincipalPropName::Displayname => {
PrincipalProp::Displayname(self.principal.to_owned())
}
PrincipalPropName::PrincipalUrl => {
PrincipalProp::PrincipalUrl(principal_url.into())
}
PrincipalPropName::CalendarHomeSet => PrincipalProp::CalendarHomeSet(home_set),
PrincipalPropName::CalendarUserAddressSet => {
PrincipalProp::CalendarUserAddressSet(principal_url.into())
}
})
} }
PrincipalPropWrapperName::Common(prop) => PrincipalPropWrapper::Common(
<Self as CommonPropertiesExtension>::get_prop(self, rmap, user, prop)?,
),
}) })
} }

View File

@@ -3,6 +3,7 @@ use actix_web::dev::ResourceMap;
use async_trait::async_trait; use async_trait::async_trait;
use derive_more::derive::{Constructor, From, Into}; use derive_more::derive::{Constructor, From, Into};
use rustical_dav::{ use rustical_dav::{
extensions::{CommonPropertiesExtension, CommonPropertiesProp},
privileges::UserPrivilegeSet, privileges::UserPrivilegeSet,
resource::{Resource, ResourceService}, resource::{Resource, ResourceService},
xml::Resourcetype, xml::Resourcetype,
@@ -33,6 +34,13 @@ pub enum AddressObjectProp {
AddressData(String), AddressData(String),
} }
#[derive(XmlDeserialize, XmlSerialize, PartialEq, Clone, EnumVariants, EnumUnitVariants)]
#[xml(unit_variants_ident = "AddressObjectPropWrapperName", untagged)]
pub enum AddressObjectPropWrapper {
AddressObject(AddressObjectProp),
Common(CommonPropertiesProp),
}
#[derive(Clone, From, Into)] #[derive(Clone, From, Into)]
pub struct AddressObjectResource { pub struct AddressObjectResource {
pub object: AddressObject, pub object: AddressObject,
@@ -40,8 +48,8 @@ pub struct AddressObjectResource {
} }
impl Resource for AddressObjectResource { impl Resource for AddressObjectResource {
type PropName = AddressObjectPropName; type PropName = AddressObjectPropWrapperName;
type Prop = AddressObjectProp; type Prop = AddressObjectPropWrapper;
type Error = Error; type Error = Error;
type PrincipalResource = PrincipalResource; type PrincipalResource = PrincipalResource;
@@ -51,18 +59,27 @@ impl Resource for AddressObjectResource {
fn get_prop( fn get_prop(
&self, &self,
_rmap: &ResourceMap, rmap: &ResourceMap,
_user: &User, user: &User,
prop: &Self::PropName, prop: &Self::PropName,
) -> Result<Self::Prop, Self::Error> { ) -> Result<Self::Prop, Self::Error> {
Ok(match prop { Ok(match prop {
AddressObjectPropName::Getetag => AddressObjectProp::Getetag(self.object.get_etag()), AddressObjectPropWrapperName::AddressObject(prop) => {
AddressObjectPropName::AddressData => { AddressObjectPropWrapper::AddressObject(match prop {
AddressObjectProp::AddressData(self.object.get_vcf().to_owned()) AddressObjectPropName::Getetag => {
} AddressObjectProp::Getetag(self.object.get_etag())
AddressObjectPropName::Getcontenttype => { }
AddressObjectProp::Getcontenttype("text/vcard;charset=utf-8") AddressObjectPropName::AddressData => {
AddressObjectProp::AddressData(self.object.get_vcf().to_owned())
}
AddressObjectPropName::Getcontenttype => {
AddressObjectProp::Getcontenttype("text/vcard;charset=utf-8")
}
})
} }
AddressObjectPropWrapperName::Common(prop) => AddressObjectPropWrapper::Common(
CommonPropertiesExtension::get_prop(self, rmap, user, prop)?,
),
}) })
} }

View File

@@ -1,5 +1,5 @@
use crate::{ use crate::{
address_object::resource::{AddressObjectProp, AddressObjectResource}, address_object::resource::{AddressObjectPropWrapper, AddressObjectResource},
Error, Error,
}; };
use actix_web::{ use actix_web::{
@@ -8,7 +8,7 @@ use actix_web::{
HttpRequest, HttpRequest,
}; };
use rustical_dav::{ use rustical_dav::{
resource::{CommonPropertiesProp, EitherProp, Resource}, resource::Resource,
xml::{multistatus::ResponseElement, MultistatusElement, PropElement, PropfindType}, xml::{multistatus::ResponseElement, MultistatusElement, PropElement, PropfindType},
}; };
use rustical_store::{auth::User, AddressObject, AddressbookStore}; use rustical_store::{auth::User, AddressObject, AddressbookStore};
@@ -60,8 +60,7 @@ pub async fn handle_addressbook_multiget<AS: AddressbookStore>(
principal: &str, principal: &str,
cal_id: &str, cal_id: &str,
addr_store: &AS, addr_store: &AS,
) -> Result<MultistatusElement<EitherProp<AddressObjectProp, CommonPropertiesProp>, String>, Error> ) -> Result<MultistatusElement<AddressObjectPropWrapper, String>, Error> {
{
let (objects, not_found) = let (objects, not_found) =
get_objects_addressbook_multiget(&addr_multiget, req.path(), principal, cal_id, addr_store) get_objects_addressbook_multiget(&addr_multiget, req.path(), principal, cal_id, addr_store)
.await?; .await?;

View File

@@ -1,10 +1,10 @@
use crate::{ use crate::{
address_object::resource::{AddressObjectProp, AddressObjectResource}, address_object::resource::{AddressObjectPropWrapper, AddressObjectResource},
Error, Error,
}; };
use actix_web::{http::StatusCode, HttpRequest}; use actix_web::{http::StatusCode, HttpRequest};
use rustical_dav::{ use rustical_dav::{
resource::{CommonPropertiesProp, EitherProp, Resource}, resource::Resource,
xml::{ xml::{
multistatus::ResponseElement, sync_collection::SyncCollectionRequest, MultistatusElement, multistatus::ResponseElement, sync_collection::SyncCollectionRequest, MultistatusElement,
PropElement, PropfindType, PropElement, PropfindType,
@@ -23,8 +23,7 @@ pub async fn handle_sync_collection<AS: AddressbookStore>(
principal: &str, principal: &str,
addressbook_id: &str, addressbook_id: &str,
addr_store: &AS, addr_store: &AS,
) -> Result<MultistatusElement<EitherProp<AddressObjectProp, CommonPropertiesProp>, String>, Error> ) -> Result<MultistatusElement<AddressObjectPropWrapper, String>, Error> {
{
let props = match sync_collection.prop { let props = match sync_collection.prop {
PropfindType::Allprop => { PropfindType::Allprop => {
vec!["allprop".to_owned()] vec!["allprop".to_owned()]

View File

@@ -11,7 +11,8 @@ use actix_web::web;
use async_trait::async_trait; use async_trait::async_trait;
use derive_more::derive::{From, Into}; use derive_more::derive::{From, Into};
use rustical_dav::extensions::{ use rustical_dav::extensions::{
DavPushExtension, DavPushExtensionProp, SyncTokenExtension, SyncTokenExtensionProp, CommonPropertiesExtension, CommonPropertiesProp, DavPushExtension, DavPushExtensionProp,
SyncTokenExtension, SyncTokenExtensionProp,
}; };
use rustical_dav::privileges::UserPrivilegeSet; use rustical_dav::privileges::UserPrivilegeSet;
use rustical_dav::resource::{Resource, ResourceService}; use rustical_dav::resource::{Resource, ResourceService};
@@ -63,6 +64,7 @@ pub enum AddressbookPropWrapper {
Addressbook(AddressbookProp), Addressbook(AddressbookProp),
SyncToken(SyncTokenExtensionProp), SyncToken(SyncTokenExtensionProp),
DavPush(DavPushExtensionProp), DavPush(DavPushExtensionProp),
Common(CommonPropertiesProp),
} }
#[derive(Clone, Debug, From, Into)] #[derive(Clone, Debug, From, Into)]
@@ -95,8 +97,8 @@ impl Resource for AddressbookResource {
fn get_prop( fn get_prop(
&self, &self,
_rmap: &ResourceMap, rmap: &ResourceMap,
_user: &User, user: &User,
prop: &Self::PropName, prop: &Self::PropName,
) -> Result<Self::Prop, Self::Error> { ) -> Result<Self::Prop, Self::Error> {
Ok(match prop { Ok(match prop {
@@ -129,6 +131,9 @@ impl Resource for AddressbookResource {
AddressbookPropWrapperName::DavPush(prop) => { AddressbookPropWrapperName::DavPush(prop) => {
AddressbookPropWrapper::DavPush(<Self as DavPushExtension>::get_prop(self, prop)?) AddressbookPropWrapper::DavPush(<Self as DavPushExtension>::get_prop(self, prop)?)
} }
AddressbookPropWrapperName::Common(prop) => AddressbookPropWrapper::Common(
CommonPropertiesExtension::get_prop(self, rmap, user, prop)?,
),
}) })
} }
@@ -148,12 +153,9 @@ impl Resource for AddressbookResource {
AddressbookProp::SupportedReportSet(_) => Err(rustical_dav::Error::PropReadOnly), AddressbookProp::SupportedReportSet(_) => Err(rustical_dav::Error::PropReadOnly),
AddressbookProp::SupportedAddressData(_) => Err(rustical_dav::Error::PropReadOnly), AddressbookProp::SupportedAddressData(_) => Err(rustical_dav::Error::PropReadOnly),
}, },
AddressbookPropWrapper::SyncToken(prop) => { AddressbookPropWrapper::SyncToken(prop) => SyncTokenExtension::set_prop(self, prop),
<Self as SyncTokenExtension>::set_prop(self, prop) AddressbookPropWrapper::DavPush(prop) => DavPushExtension::set_prop(self, prop),
} AddressbookPropWrapper::Common(prop) => CommonPropertiesExtension::set_prop(self, prop),
AddressbookPropWrapper::DavPush(prop) => {
<Self as DavPushExtension>::set_prop(self, prop)
}
} }
} }
@@ -174,10 +176,11 @@ impl Resource for AddressbookResource {
AddressbookPropName::SupportedAddressData => Err(rustical_dav::Error::PropReadOnly), AddressbookPropName::SupportedAddressData => Err(rustical_dav::Error::PropReadOnly),
}, },
AddressbookPropWrapperName::SyncToken(prop) => { AddressbookPropWrapperName::SyncToken(prop) => {
<Self as SyncTokenExtension>::remove_prop(self, prop) SyncTokenExtension::remove_prop(self, prop)
} }
AddressbookPropWrapperName::DavPush(prop) => { AddressbookPropWrapperName::DavPush(prop) => DavPushExtension::remove_prop(self, prop),
<Self as DavPushExtension>::remove_prop(self, prop) AddressbookPropWrapperName::Common(prop) => {
CommonPropertiesExtension::remove_prop(self, prop)
} }
} }
} }

View File

@@ -2,6 +2,7 @@ use crate::addressbook::resource::AddressbookResource;
use crate::Error; use crate::Error;
use actix_web::dev::ResourceMap; use actix_web::dev::ResourceMap;
use async_trait::async_trait; use async_trait::async_trait;
use rustical_dav::extensions::{CommonPropertiesExtension, CommonPropertiesProp};
use rustical_dav::privileges::UserPrivilegeSet; use rustical_dav::privileges::UserPrivilegeSet;
use rustical_dav::resource::{NamedRoute, Resource, ResourceService}; use rustical_dav::resource::{NamedRoute, Resource, ResourceService};
use rustical_dav::xml::{HrefElement, Resourcetype, ResourcetypeInner}; use rustical_dav::xml::{HrefElement, Resourcetype, ResourcetypeInner};
@@ -43,6 +44,13 @@ pub enum PrincipalProp {
PrincipalAddress(Option<HrefElement>), PrincipalAddress(Option<HrefElement>),
} }
#[derive(XmlDeserialize, XmlSerialize, PartialEq, Clone, EnumVariants, EnumUnitVariants)]
#[xml(unit_variants_ident = "PrincipalPropWrapperName", untagged)]
pub enum PrincipalPropWrapper {
Principal(PrincipalProp),
Common(CommonPropertiesProp),
}
impl PrincipalResource { impl PrincipalResource {
pub fn get_principal_url(rmap: &ResourceMap, principal: &str) -> String { pub fn get_principal_url(rmap: &ResourceMap, principal: &str) -> String {
Self::get_url(rmap, vec![principal]).unwrap() Self::get_url(rmap, vec![principal]).unwrap()
@@ -56,8 +64,8 @@ impl NamedRoute for PrincipalResource {
} }
impl Resource for PrincipalResource { impl Resource for PrincipalResource {
type PropName = PrincipalPropName; type PropName = PrincipalPropWrapperName;
type Prop = PrincipalProp; type Prop = PrincipalPropWrapper;
type Error = Error; type Error = Error;
type PrincipalResource = PrincipalResource; type PrincipalResource = PrincipalResource;
@@ -71,18 +79,28 @@ impl Resource for PrincipalResource {
fn get_prop( fn get_prop(
&self, &self,
rmap: &ResourceMap, rmap: &ResourceMap,
_user: &User, user: &User,
prop: &Self::PropName, prop: &Self::PropName,
) -> Result<Self::Prop, Self::Error> { ) -> Result<Self::Prop, Self::Error> {
let principal_href = HrefElement::new(Self::get_principal_url(rmap, &self.principal)); let principal_href = HrefElement::new(Self::get_principal_url(rmap, &self.principal));
Ok(match prop { Ok(match prop {
PrincipalPropName::Displayname => PrincipalProp::Displayname(self.principal.to_owned()), PrincipalPropWrapperName::Principal(prop) => {
PrincipalPropName::PrincipalUrl => PrincipalProp::PrincipalUrl(principal_href), PrincipalPropWrapper::Principal(match prop {
PrincipalPropName::AddressbookHomeSet => { PrincipalPropName::Displayname => {
PrincipalProp::AddressbookHomeSet(principal_href) PrincipalProp::Displayname(self.principal.to_owned())
}
PrincipalPropName::PrincipalUrl => PrincipalProp::PrincipalUrl(principal_href),
PrincipalPropName::AddressbookHomeSet => {
PrincipalProp::AddressbookHomeSet(principal_href)
}
PrincipalPropName::PrincipalAddress => PrincipalProp::PrincipalAddress(None),
})
} }
PrincipalPropName::PrincipalAddress => PrincipalProp::PrincipalAddress(None),
PrincipalPropWrapperName::Common(prop) => PrincipalPropWrapper::Common(
CommonPropertiesExtension::get_prop(self, rmap, user, prop)?,
),
}) })
} }

View File

@@ -14,7 +14,6 @@ futures-util = { workspace = true }
quick-xml = { workspace = true } quick-xml = { workspace = true }
rustical_store = { workspace = true } rustical_store = { workspace = true }
serde = { workspace = true } serde = { workspace = true }
strum = { workspace = true }
thiserror = { workspace = true } thiserror = { workspace = true }
itertools = { workspace = true } itertools = { workspace = true }
log = { workspace = true } log = { workspace = true }

View File

@@ -0,0 +1,70 @@
use crate::{
privileges::UserPrivilegeSet,
resource::{NamedRoute, Resource},
xml::{HrefElement, Resourcetype},
};
use actix_web::dev::ResourceMap;
use rustical_store::auth::User;
use rustical_xml::{EnumUnitVariants, EnumVariants, XmlDeserialize, XmlSerialize};
#[derive(XmlDeserialize, XmlSerialize, PartialEq, Clone, EnumUnitVariants, EnumVariants)]
#[xml(unit_variants_ident = "CommonPropertiesPropName")]
pub enum CommonPropertiesProp {
// WebDAV (RFC 2518)
#[xml(skip_deserializing)]
#[xml(ns = "crate::namespace::NS_DAV")]
Resourcetype(Resourcetype),
// WebDAV Current Principal Extension (RFC 5397)
#[xml(ns = "crate::namespace::NS_DAV")]
CurrentUserPrincipal(HrefElement),
// WebDAV Access Control Protocol (RFC 3477)
#[xml(skip_deserializing)]
#[xml(ns = "crate::namespace::NS_DAV")]
CurrentUserPrivilegeSet(UserPrivilegeSet),
#[xml(ns = "crate::namespace::NS_DAV")]
Owner(Option<HrefElement>),
}
pub trait CommonPropertiesExtension: Resource {
fn get_prop(
&self,
rmap: &ResourceMap,
user: &User,
prop: &CommonPropertiesPropName,
) -> Result<CommonPropertiesProp, <Self as Resource>::Error> {
Ok(match prop {
CommonPropertiesPropName::Resourcetype => {
CommonPropertiesProp::Resourcetype(self.get_resourcetype())
}
CommonPropertiesPropName::CurrentUserPrincipal => {
CommonPropertiesProp::CurrentUserPrincipal(
Self::PrincipalResource::get_url(rmap, [&user.id])
.unwrap()
.into(),
)
}
CommonPropertiesPropName::CurrentUserPrivilegeSet => {
CommonPropertiesProp::CurrentUserPrivilegeSet(self.get_user_privileges(user)?)
}
CommonPropertiesPropName::Owner => {
CommonPropertiesProp::Owner(self.get_owner().map(|owner| {
Self::PrincipalResource::get_url(rmap, [owner])
.unwrap()
.into()
}))
}
})
}
fn set_prop(&self, _prop: CommonPropertiesProp) -> Result<(), crate::Error> {
Err(crate::Error::PropReadOnly)
}
fn remove_prop(&self, _prop: &CommonPropertiesPropName) -> Result<(), crate::Error> {
Err(crate::Error::PropReadOnly)
}
}
impl<T: Resource> CommonPropertiesExtension for T {}

View File

@@ -1,5 +1,7 @@
mod common;
mod davpush; mod davpush;
mod synctoken; mod synctoken;
pub use common::*;
pub use davpush::*; pub use davpush::*;
pub use synctoken::*; pub use synctoken::*;

View File

@@ -1,7 +1,5 @@
use crate::depth_header::Depth; use crate::depth_header::Depth;
use crate::privileges::UserPrivilege; use crate::privileges::UserPrivilege;
use crate::resource::CommonPropertiesProp;
use crate::resource::EitherProp;
use crate::resource::Resource; use crate::resource::Resource;
use crate::resource::ResourceService; use crate::resource::ResourceService;
use crate::xml::MultistatusElement; use crate::xml::MultistatusElement;
@@ -28,10 +26,7 @@ pub(crate) async fn route_propfind<R: ResourceService>(
root_span: RootSpan, root_span: RootSpan,
resource_service: Data<R>, resource_service: Data<R>,
) -> Result< ) -> Result<
MultistatusElement< MultistatusElement<<R::Resource as Resource>::Prop, <R::MemberType as Resource>::Prop>,
EitherProp<<R::Resource as Resource>::Prop, CommonPropertiesProp>,
EitherProp<<R::MemberType as Resource>::Prop, CommonPropertiesProp>,
>,
R::Error, R::Error,
> { > {
let resource = resource_service.get_resource(&path).await?; let resource = resource_service.get_resource(&path).await?;

View File

@@ -1,7 +1,7 @@
use crate::privileges::UserPrivilegeSet; use crate::privileges::UserPrivilegeSet;
use crate::xml::multistatus::{PropTagWrapper, PropstatElement, PropstatWrapper}; use crate::xml::multistatus::{PropTagWrapper, PropstatElement, PropstatWrapper};
use crate::xml::Resourcetype;
use crate::xml::{multistatus::ResponseElement, TagList}; use crate::xml::{multistatus::ResponseElement, TagList};
use crate::xml::{HrefElement, Resourcetype};
use crate::Error; use crate::Error;
use actix_web::dev::ResourceMap; use actix_web::dev::ResourceMap;
use actix_web::{http::StatusCode, ResponseError}; use actix_web::{http::StatusCode, ResponseError};
@@ -11,7 +11,6 @@ pub use resource_service::ResourceService;
use rustical_store::auth::User; use rustical_store::auth::User;
use rustical_xml::{EnumVariants, XmlDeserialize, XmlSerialize}; use rustical_xml::{EnumVariants, XmlDeserialize, XmlSerialize};
use std::str::FromStr; use std::str::FromStr;
use strum::EnumString;
mod methods; mod methods;
mod resource_service; mod resource_service;
@@ -24,41 +23,6 @@ impl<T: XmlSerialize + XmlDeserialize> ResourceProp for T {}
pub trait ResourcePropName: FromStr {} pub trait ResourcePropName: FromStr {}
impl<T: FromStr> ResourcePropName for T {} impl<T: FromStr> ResourcePropName for T {}
#[derive(XmlDeserialize, XmlSerialize, PartialEq, EnumVariants)]
pub enum CommonPropertiesProp {
// WebDAV (RFC 2518)
#[xml(skip_deserializing)]
#[xml(ns = "crate::namespace::NS_DAV")]
Resourcetype(Resourcetype),
// WebDAV Current Principal Extension (RFC 5397)
#[xml(ns = "crate::namespace::NS_DAV")]
CurrentUserPrincipal(HrefElement),
// WebDAV Access Control Protocol (RFC 3477)
#[xml(skip_deserializing)]
#[xml(ns = "crate::namespace::NS_DAV")]
CurrentUserPrivilegeSet(UserPrivilegeSet),
#[xml(ns = "crate::namespace::NS_DAV")]
Owner(Option<HrefElement>),
}
#[derive(XmlSerialize)]
#[xml(untagged)]
pub enum EitherProp<Left: ResourceProp, Right: ResourceProp> {
Left(Left),
Right(Right),
}
#[derive(EnumString, Clone)]
#[strum(serialize_all = "kebab-case")]
pub enum CommonPropertiesPropName {
Resourcetype,
CurrentUserPrincipal,
CurrentUserPrivilegeSet,
Owner,
}
pub trait Resource: Clone + 'static { pub trait Resource: Clone + 'static {
type PropName: ResourcePropName type PropName: ResourcePropName
+ From<Self::Prop> + From<Self::Prop>
@@ -70,41 +34,7 @@ pub trait Resource: Clone + 'static {
fn get_resourcetype(&self) -> Resourcetype; fn get_resourcetype(&self) -> Resourcetype;
fn list_props() -> Vec<(Option<Namespace<'static>>, &'static str)> { fn list_props() -> Vec<(Option<Namespace<'static>>, &'static str)> {
[ Self::Prop::variant_names()
Self::Prop::variant_names(),
CommonPropertiesProp::variant_names(),
]
.concat()
}
fn get_internal_prop(
&self,
rmap: &ResourceMap,
user: &User,
prop: &CommonPropertiesPropName,
) -> Result<CommonPropertiesProp, Self::Error> {
Ok(match prop {
CommonPropertiesPropName::Resourcetype => {
CommonPropertiesProp::Resourcetype(self.get_resourcetype())
}
CommonPropertiesPropName::CurrentUserPrincipal => {
CommonPropertiesProp::CurrentUserPrincipal(
Self::PrincipalResource::get_url(rmap, [&user.id])
.unwrap()
.into(),
)
}
CommonPropertiesPropName::CurrentUserPrivilegeSet => {
CommonPropertiesProp::CurrentUserPrivilegeSet(self.get_user_privileges(user)?)
}
CommonPropertiesPropName::Owner => {
CommonPropertiesProp::Owner(self.get_owner().map(|owner| {
Self::PrincipalResource::get_url(rmap, [owner])
.unwrap()
.into()
}))
}
})
} }
fn get_prop( fn get_prop(
@@ -134,7 +64,7 @@ pub trait Resource: Clone + 'static {
props: &[&str], props: &[&str],
user: &User, user: &User,
rmap: &ResourceMap, rmap: &ResourceMap,
) -> Result<ResponseElement<EitherProp<Self::Prop, CommonPropertiesProp>>, Self::Error> { ) -> Result<ResponseElement<Self::Prop>, Self::Error> {
let mut props = props.to_vec(); let mut props = props.to_vec();
if props.contains(&"propname") { if props.contains(&"propname") {
@@ -174,30 +104,19 @@ pub trait Resource: Clone + 'static {
} }
let mut valid_props = vec![]; let mut valid_props = vec![];
let mut internal_props = vec![];
let mut invalid_props = vec![]; let mut invalid_props = vec![];
for prop in props { for prop in props {
if let Ok(valid_prop) = Self::PropName::from_str(prop) { if let Ok(valid_prop) = Self::PropName::from_str(prop) {
valid_props.push(valid_prop); valid_props.push(valid_prop);
} else if let Ok(internal_prop) = CommonPropertiesPropName::from_str(prop) {
internal_props.push(internal_prop);
} else { } else {
invalid_props.push(prop.to_string()) invalid_props.push(prop.to_string())
} }
} }
let internal_prop_responses: Vec<_> = internal_props let prop_responses = valid_props
.into_iter()
.map(|prop| self.get_internal_prop(rmap, user, &prop))
.map_ok(EitherProp::Right)
.collect::<Result<_, Self::Error>>()?;
let mut prop_responses = valid_props
.into_iter() .into_iter()
.map(|prop| self.get_prop(rmap, user, &prop)) .map(|prop| self.get_prop(rmap, user, &prop))
.map_ok(EitherProp::Left)
.collect::<Result<Vec<_>, Self::Error>>()?; .collect::<Result<Vec<_>, Self::Error>>()?;
prop_responses.extend(internal_prop_responses);
let mut propstats = vec![PropstatWrapper::Normal(PropstatElement { let mut propstats = vec![PropstatWrapper::Normal(PropstatElement {
status: StatusCode::OK, status: StatusCode::OK,

View File

@@ -1,14 +1,13 @@
use crate::extensions::{
CommonPropertiesExtension, CommonPropertiesProp, CommonPropertiesPropName,
};
use crate::privileges::UserPrivilegeSet; use crate::privileges::UserPrivilegeSet;
use crate::resource::{NamedRoute, Resource, ResourceService}; use crate::resource::{NamedRoute, Resource, ResourceService};
use crate::xml::{Resourcetype, ResourcetypeInner}; use crate::xml::{Resourcetype, ResourcetypeInner};
use actix_web::dev::ResourceMap; use actix_web::dev::ResourceMap;
use async_trait::async_trait; use async_trait::async_trait;
use quick_xml::name::Namespace;
use rustical_store::auth::User; use rustical_store::auth::User;
use rustical_xml::{EnumVariants, XmlDeserialize, XmlSerialize};
use serde::Serialize;
use std::marker::PhantomData; use std::marker::PhantomData;
use strum::{EnumString, IntoStaticStr};
#[derive(Clone)] #[derive(Clone)]
pub struct RootResource<PR: Resource>(PhantomData<PR>); pub struct RootResource<PR: Resource>(PhantomData<PR>);
@@ -19,28 +18,9 @@ impl<PR: Resource> Default for RootResource<PR> {
} }
} }
#[derive(EnumString, Clone, IntoStaticStr)]
#[strum(serialize_all = "kebab-case")]
pub enum RootResourcePropName {}
impl From<RootResourcePropName> for (Option<Namespace<'static>>, &'static str) {
fn from(_value: RootResourcePropName) -> Self {
(None, "unreachable")
}
}
#[derive(XmlDeserialize, XmlSerialize, Serialize, Clone, PartialEq, EnumVariants)]
pub enum RootResourceProp {}
impl From<RootResourceProp> for RootResourcePropName {
fn from(_value: RootResourceProp) -> Self {
unreachable!()
}
}
impl<PR: Resource + NamedRoute> Resource for RootResource<PR> { impl<PR: Resource + NamedRoute> Resource for RootResource<PR> {
type PropName = RootResourcePropName; type PropName = CommonPropertiesPropName;
type Prop = RootResourceProp; type Prop = CommonPropertiesProp;
type Error = PR::Error; type Error = PR::Error;
type PrincipalResource = PR; type PrincipalResource = PR;
@@ -53,11 +33,11 @@ impl<PR: Resource + NamedRoute> Resource for RootResource<PR> {
fn get_prop( fn get_prop(
&self, &self,
_rmap: &ResourceMap, rmap: &ResourceMap,
_user: &User, user: &User,
_prop: &Self::PropName, prop: &Self::PropName,
) -> Result<Self::Prop, Self::Error> { ) -> Result<Self::Prop, Self::Error> {
unreachable!("we shouldn't end up here") CommonPropertiesExtension::get_prop(self, rmap, user, prop)
} }
fn get_user_privileges(&self, _user: &User) -> Result<UserPrivilegeSet, Self::Error> { fn get_user_privileges(&self, _user: &User) -> Result<UserPrivilegeSet, Self::Error> {