objects::{community::ApubCommunity, person::ApubPerson},
protocol::objects::{group::Group, person::Person},
};
-use activitystreams::{chrono::NaiveDateTime, url::Url};
+use chrono::NaiveDateTime;
use lemmy_apub_lib::traits::{ActorType, ApubObject};
use lemmy_utils::LemmyError;
use lemmy_websocket::LemmyContext;
use serde::Deserialize;
+use url::Url;
#[derive(Clone, Debug)]
pub enum UserOrCommunity {
unimplemented!()
}
+ async fn verify(
+ apub: &Self::ApubType,
+ expected_domain: &Url,
+ data: &Self::DataType,
+ request_counter: &mut i32,
+ ) -> Result<(), LemmyError> {
+ match apub {
+ PersonOrGroup::Person(a) => {
+ ApubPerson::verify(a, expected_domain, data, request_counter).await
+ }
+ PersonOrGroup::Group(a) => {
+ ApubCommunity::verify(a, expected_domain, data, request_counter).await
+ }
+ }
+ }
+
async fn from_apub(
apub: Self::ApubType,
data: &Self::DataType,
- expected_domain: &Url,
request_counter: &mut i32,
) -> Result<Self, LemmyError> {
Ok(match apub {
- PersonOrGroup::Person(p) => UserOrCommunity::User(
- ApubPerson::from_apub(p, data, expected_domain, request_counter).await?,
- ),
- PersonOrGroup::Group(p) => UserOrCommunity::Community(
- ApubCommunity::from_apub(p, data, expected_domain, request_counter).await?,
- ),
+ PersonOrGroup::Person(p) => {
+ UserOrCommunity::User(ApubPerson::from_apub(p, data, request_counter).await?)
+ }
+ PersonOrGroup::Group(p) => {
+ UserOrCommunity::Community(ApubCommunity::from_apub(p, data, request_counter).await?)
+ }
})
}
}
impl ActorType for UserOrCommunity {
- fn is_local(&self) -> bool {
- todo!()
- }
-
fn actor_id(&self) -> Url {
- todo!()
- }
-
- fn name(&self) -> String {
- todo!()
+ match self {
+ UserOrCommunity::User(p) => p.actor_id(),
+ UserOrCommunity::Community(p) => p.actor_id(),
+ }
}
- fn public_key(&self) -> Option<String> {
+ fn public_key(&self) -> String {
match self {
UserOrCommunity::User(p) => p.public_key(),
UserOrCommunity::Community(p) => p.public_key(),