zaaarf/upub
1
0
Fork 0
forked from alemi/upub
Code Pull requests Activity

fix: dispatcher fetch app key for app deliveries

Browse source
This commit is contained in:
əlemi 2024-04-22 04:23:11 +02:00
parent 1d8b69dda7
commit b62b461305
Signed by: alemi
GPG key ID: A4895B84D311642C
1 changed files with 17 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
src/server/dispatcher.rs
View file

@ -84,13 +84,25 @@ async fn worker(db: DatabaseConnection, domain: String, poll_interval: u64, mut
}, },
}; };
let Some(model::user::Model{ private_key: Some(key), .. }) = model::user::Entity::find_by_id(&delivery.actor) let key = if delivery.actor.ends_with(&domain) {
.one(&db).await? let Some(model::application::Model { private_key: key, .. }) = model::application::Entity::find()
else { .one(&db).await?
tracing::error!("can not dispatch activity for user without private key: {}", delivery.actor); else {
continue; tracing::error!("no private key configured for application");
continue;
};
key
} else {
let Some(model::user::Model{ private_key: Some(key), .. }) = model::user::Entity::find_by_id(&delivery.actor)
.one(&db).await?
else {
tracing::error!("can not dispatch activity for user without private key: {}", delivery.actor);
continue;
};
key
}; };
if let Err(e) = Context::request( if let Err(e) = Context::request(
Method::POST, &delivery.target, Method::POST, &delivery.target,
Some(&serde_json::to_string(&payload).unwrap()), Some(&serde_json::to_string(&payload).unwrap()),