1 files changed, 33 insertions, 7 deletions
diff --git a/src/server/activities/follow.rs b/src/server/activities/follow.rs
index 9148f02..466edb7 100644
--- a/src/server/activities/follow.rs
+++ b/src/server/activities/follow.rs
@@ -1,11 +1,20 @@
 use activitypub_federation::{
-    config::Data, fetch::object_id::ObjectId, kinds::activity::FollowType, traits::Activity,
+    config::Data,
+    fetch::object_id::ObjectId,
+    kinds::activity::FollowType,
+    traits::{Activity, Actor},
 };
 use async_trait::async_trait;
 use serde::{Deserialize, Serialize};
 use url::Url;
+use uuid::Uuid;
 
-use crate::{entity::user::User, error::AppError, state::AppHandle};
+use crate::{
+    entity::user::User,
+    error::AppError,
+    server::{activities::accept::Accept, generate_object_id},
+    state::AppHandle,
+};
 
 #[derive(Deserialize, Serialize, Clone, Debug)]
 #[serde(rename_all = "camelCase")]
@@ -39,20 +48,20 @@ impl Activity for Follow {
 
     #[doc = " `id` field of the activity"]
     fn id(&self) -> &Url {
-        todo!()
+        &self.id
     }
 
     #[doc = " `actor` field of activity"]
     fn actor(&self) -> &Url {
-        todo!()
+        self.actor.inner()
     }
 
     #[doc = " Verifies that the received activity is valid."]
     #[doc = ""]
     #[doc = " This needs to be a separate method, because it might be used for activities"]
     #[doc = " like `Undo/Follow`, which shouldn\'t perform any database write for the inner `Follow`."]
-    async fn verify(&self, data: &Data<Self::DataType>) -> Result<(), Self::Error> {
-        todo!()
+    async fn verify(&self, _data: &Data<Self::DataType>) -> Result<(), Self::Error> {
+        Ok(())
     }
 
     #[doc = " Called when an activity is received."]
@@ -60,6 +69,23 @@ impl Activity for Follow {
     #[doc = " Should perform validation and possibly write action to the database. In case the activity"]
     #[doc = " has a nested `object` field, must call `object.from_json` handler."]
     async fn receive(self, data: &Data<Self::DataType>) -> Result<(), Self::Error> {
-        todo!()
+        let id = Uuid::now_v7();
+
+        sqlx::query!("insert into following (id, follower, followee) values ($1, $2, $3) on conflict (follower, followee) do nothing"
+            ,id,
+            self.actor.inner().as_str(),
+            self.object.inner().as_str(),
+            ).execute(&data.services.postgres).await?;
+
+        let follower = self.actor.dereference(data).await?;
+        let id = generate_object_id(data.domain(), data.environment)?;
+
+        let local_user = self.object.dereference(data).await?;
+        let accept = Accept::new(self.object.clone(), self, id.clone());
+
+        local_user
+            .send(accept, vec![follower.shared_inbox_or_inbox()], false, data)
+            .await?;
+        Ok(())
     }
 }