diff --git a/Cargo.lock b/Cargo.lock index 6449897..ce9c962 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -1933,7 +1933,7 @@ checksum = "b5eb417147ba9860a96cfe72a0b93bf88fee1744b5636ec99ab20c1aa9376581" [[package]] name = "relay" -version = "0.2.4" +version = "0.2.5" dependencies = [ "activitystreams", "activitystreams-ext", diff --git a/Cargo.toml b/Cargo.toml index b1b38b6..283c9f5 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,7 +1,7 @@ [package] name = "relay" description = "A simple activitypub relay" -version = "0.2.4" +version = "0.2.5" authors = ["asonix "] license-file = "LICENSE" readme = "README.md" diff --git a/src/jobs/apub/follow.rs b/src/jobs/apub/follow.rs index a691a50..38bb748 100644 --- a/src/jobs/apub/follow.rs +++ b/src/jobs/apub/follow.rs @@ -3,7 +3,7 @@ use crate::{ config::{Config, UrlKind}, db::Actor, error::MyError, - jobs::{apub::prepare_activity, Deliver, JobState}, + jobs::{apub::prepare_activity, Deliver, JobState, QueryInstance, QueryNodeinfo}, }; use activitystreams::{ activity::{Accept as AsAccept, Follow as AsFollow}, @@ -49,6 +49,13 @@ impl Follow { state .job_server .queue(Deliver::new(self.actor.inbox, accept)?)?; + + state + .job_server + .queue(QueryInstance::new(self.actor.id.clone()))?; + + state.job_server.queue(QueryNodeinfo::new(self.actor.id))?; + Ok(()) } }