versia-pub/activitypub
2
0
Fork 0
mirror of https://github.com/versia-pub/activitypub.git synced 2025-12-06 06:38:20 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

kurwa header

Browse source
This commit is contained in:
April John 2024-11-23 22:40:58 +01:00
parent 366c2b7e81
commit 6f4451c3a9
1 changed files with 3 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/activities/create_post.rs
View file

@ -1,12 +1,8 @@
use crate::{ use crate::{
database::StateHandle, database::StateHandle, entities::{self, post, user}, error::Error, objects::{
entities::{self, post, user},
error::Error,
objects::{
person::DbUser, person::DbUser,
post::{DbPost, Note}, post::{DbPost, Note},
}, }, utils::{base_url_encode, generate_create_id, generate_random_object_id}, versia::{conversion::versia_post_from_db, objects::SortAlphabetically, superx::request_client}, API_DOMAIN, DB
utils::{base_url_encode, generate_create_id, generate_random_object_id}, versia::{conversion::versia_post_from_db, objects::SortAlphabetically, superx::request_client}, DB,
}; };
use activitypub_federation::{ use activitypub_federation::{
activity_sending::SendActivityTask, activity_sending::SendActivityTask,
@ -126,6 +122,7 @@ async fn federate_inbox(note: crate::entities::post::Model) -> anyhow::Result<()
let req_client = request_client(); let req_client = request_client();
for inbox in array { for inbox in array {
let push = req_client.post(inbox.clone()) let push = req_client.post(inbox.clone())
.header("X-Signed-By", format!("instance {}", API_DOMAIN.to_string()))
.json(&json); .json(&json);
warn!("{}", inbox.to_string()); warn!("{}", inbox.to_string());
tokio::spawn(push_to_inbox(push)); tokio::spawn(push_to_inbox(push));