use crate::{ instance::DatabaseHandle, objects::{person::DbUser, post::Note}, DbPost, }; use activitypub_federation::{ config::Data, fetch::object_id::ObjectId, kinds::activity::CreateType, protocol::helpers::deserialize_one_or_many, traits::{ActivityHandler, Object}, }; use serde::{Deserialize, Serialize}; use url::Url; #[derive(Deserialize, Serialize, Debug)] #[serde(rename_all = "camelCase")] pub struct CreatePost { pub(crate) actor: ObjectId, #[serde(deserialize_with = "deserialize_one_or_many")] pub(crate) to: Vec, pub(crate) object: Note, #[serde(rename = "type")] pub(crate) kind: CreateType, pub(crate) id: Url, } impl CreatePost { pub fn new(note: Note, id: Url) -> CreatePost { CreatePost { actor: note.attributed_to.clone(), to: note.to.clone(), object: note, kind: CreateType::Create, id, } } } #[async_trait::async_trait] impl ActivityHandler for CreatePost { type DataType = DatabaseHandle; type Error = crate::error::Error; fn id(&self) -> &Url { &self.id } fn actor(&self) -> &Url { self.actor.inner() } async fn verify(&self, data: &Data) -> Result<(), Self::Error> { DbPost::verify(&self.object, &self.id, data).await?; Ok(()) } async fn receive(self, data: &Data) -> Result<(), Self::Error> { DbPost::from_json(self.object, data).await?; Ok(()) } }