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

oh god this code

Browse source
This commit is contained in:
April John 2024-11-23 23:53:38 +01:00
parent 6fe3509718
commit 3f26d5d731
1 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/activities/create_post.rs
View file

@ -1,8 +1,8 @@
use crate::{ use crate::{
database::StateHandle, entities::{self, post, user}, error::Error, objects::{ database::StateHandle, entities::{self, post, prelude, 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, versia_user_from_db}, objects::SortAlphabetically, superx::request_client}, API_DOMAIN, DB
}; };
use activitypub_federation::{ use activitypub_federation::{
activity_sending::SendActivityTask, activity_sending::SendActivityTask,
@ -120,9 +120,15 @@ async fn federate_inbox(note: crate::entities::post::Model) -> anyhow::Result<()
array.dedup(); array.dedup();
let req_client = request_client(); let req_client = request_client();
let model = prelude::User::find()
.filter(user::Column::Id.eq(note.creator.as_str()))
.one(db)
.await?.unwrap();
let versia_user = versia_user_from_db(model).await?;
let header = format!("https://{}/apbridge/versia/query?user_url={}", API_DOMAIN.to_string(), versia_user.uri.to_string());
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", note.url.to_string()) .header("X-Signed-By", header.clone())
.json(&json); .json(&json);
warn!("{}", inbox.to_string()); warn!("{}", inbox.to_string());
tokio::spawn(push_to_inbox(push)); tokio::spawn(push_to_inbox(push));