mirrors/Plume
1
0
Fork 0
mirror of https://git.joinplu.me/Plume/Plume.git synced 2024-11-22 19:41:03 +00:00
Code Issues Projects Releases Packages Wiki Activity

Run HTTP request in broadcast() on tokio runtime

Browse source
This commit is contained in:
Kitaiti Makoto 2022-05-05 09:04:54 +09:00
parent e0258003b9
commit a7b899817a
1 changed files with 48 additions and 40 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
plume-common/src/activity_pub/mod.rs
View file

@ -1,12 +1,13 @@
use activitypub::{Activity, Link, Object};
use array_tool::vec::Uniq;
use reqwest::{blocking::ClientBuilder, header::HeaderValue, Url};
use reqwest::{header::HeaderValue, ClientBuilder, Url};
use rocket::{
http::Status,
request::{FromRequest, Request},
response::{Responder, Response},
Outcome,
};
use tokio::runtime;
use tracing::{debug, warn};
use self::sign::Signable;
@ -139,6 +140,11 @@ where
.connect_timeout(std::time::Duration::from_secs(5))
.build()
.expect("Can't build client");
let rt = runtime::Builder::new_current_thread()
.enable_all()
.build()
.expect("Error while initializing tokio runtime for federation");
rt.block_on(async {
for inbox in boxes {
let body = signed.to_string();
let mut headers = request::headers();
@ -169,6 +175,7 @@ where
)
.body(body)
.send()
.await
.map(move |r| {
if r.status().is_success() {
debug!("Successfully sent activity to inbox ({})", &inbox);
@ -179,6 +186,7 @@ where
})
.map_err(|e| warn!("Error while sending to inbox ({:?})", e));
}
});
}
#[derive(Shrinkwrap, Clone, Serialize, Deserialize)]