Adding activity table inserts.

1 files changed, 16 insertions, 4 deletions

diff --git a/server/src/apub/user.rs b/server/src/apub/user.rs
index b4b3b35b..bb9f064c 100644
--- a/server/src/apub/user.rs
+++ b/server/src/apub/user.rs
@@ -54,20 +54,32 @@ impl ActorType for User_ {
     self.public_key.to_owned().unwrap()
   }
 
-  // TODO might be able to move this to a default trait fn
   /// As a given local user, send out a follow request to a remote community.
-  fn send_follow(&self, follow_actor_id: &str) -> Result<(), Error> {
+  fn send_follow(&self, follow_actor_id: &str, conn: &PgConnection) -> Result<(), Error> {
     let mut follow = Follow::new();
+
+    // TODO using a fake accept id
+    let id = format!("{}/follow/{}", self.actor_id, uuid::Uuid::new_v4());
+
     follow
       .object_props
       .set_context_xsd_any_uri(context())?
-      // TODO: needs proper id
-      .set_id(self.actor_id.to_owned())?;
+      .set_id(id)?;
     follow
       .follow_props
       .set_actor_xsd_any_uri(self.actor_id.to_owned())?
       .set_object_xsd_any_uri(follow_actor_id)?;
     let to = format!("{}/inbox", follow_actor_id);
+
+    // Insert the sent activity into the activity table
+    let activity_form = activity::ActivityForm {
+      user_id: self.id,
+      data: serde_json::to_value(&follow)?,
+      local: true,
+      updated: None,
+    };
+    activity::Activity::create(&conn, &activity_form)?;
+
     send_activity(
       &follow,
       &self.private_key.as_ref().unwrap(),