diff --git a/src/activities/follow.rs b/src/activities/follow.rs index 858b86f..200a312 100644 --- a/src/activities/follow.rs +++ b/src/activities/follow.rs @@ -11,14 +11,10 @@ use serde::{Deserialize, Serialize}; use url::Url; use crate::{ - database::StateHandle, - entities::{ + database::StateHandle, entities::{ follow_relation::{self, Entity}, post, prelude, user, - }, - error, - utils::{generate_follow_accept_id, generate_random_object_id}, - DB, + }, error, lysand::funcs::send_follow_accept_to_lysand, utils::{generate_follow_accept_id, generate_random_object_id}, DB }; #[derive(Deserialize, Serialize, Debug)] @@ -196,5 +192,7 @@ async fn save_accept_follow( let res = prelude::FollowRelation::update(active_query); let model = res.exec(db).await?; + let _ = send_follow_accept_to_lysand(model.clone()).await?; + Ok(model) } diff --git a/src/lysand/funcs.rs b/src/lysand/funcs.rs index aecae2c..68d2049 100644 --- a/src/lysand/funcs.rs +++ b/src/lysand/funcs.rs @@ -14,7 +14,7 @@ use super::{ superx::request_client, }; -async fn send_follow_accept_to_lysand(model: follow_relation::Model) -> anyhow::Result<()> { +pub async fn send_follow_accept_to_lysand(model: follow_relation::Model) -> anyhow::Result<()> { let request_client = request_client(); let db = DB.get().unwrap();