mirrors/buzzrelay
1
0
Fork 0
mirror of https://github.com/astro/buzzrelay.git synced 2024-11-21 11:41:00 +00:00
Code Issues Projects Releases Packages Wiki Activity

forward all POSTs to redis

Browse source
This commit is contained in:
Astro 2023-10-12 23:38:26 +02:00
parent 2980a15eb6
commit 7f91afa35e
1 changed files with 14 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
src/main.rs
View file

@ -143,6 +143,18 @@ async fn post_relay(
).into_response();
}
};
if let Some((redis, in_topic)) = &state.redis {
if let Ok(data) = serde_json::to_vec(&endpoint.payload) {
if let Err(e) = redis::Cmd::publish(in_topic.as_ref(), data)
.query_async::<_, redis::Value>(&mut redis.clone())
.await
{
tracing::error!("redis publish: {}", e);
}
}
}
let action = match serde_json::from_value::<activitypub::Action<serde_json::Value>>(endpoint.payload.clone()) {
Ok(action) => action,
Err(e) => {
@ -229,29 +241,12 @@ async fn post_relay(
).into_response()
}
}
} else if action.action_type == "Create" || action.action_type == "Announce" {
tracing::trace!("Received on {} from {}: {} {:?}", target.uri(), endpoint.remote_actor_uri, action.action_type, action.object);
if let Some((redis, in_topic)) = &state.redis {
if let Some(data) = &action.object
.and_then(|o| serde_json::to_vec(&o).ok())
{
if let Err(e) = redis::Cmd::publish(in_topic.as_ref(), data)
.query_async::<_, redis::Value>(&mut redis.clone())
.await
{
tracing::error!("redis publish: {}", e);
}
}
}
} else {
track_request("POST", "relay", "unrecognized");
(StatusCode::ACCEPTED,
[("content-type", "application/activity+json")],
"{}"
).into_response()
} else {
tracing::error!("Unrecognized action type {:?}", action.action_type);
track_request("POST", "relay", "unrecognized");
(StatusCode::BAD_REQUEST, "Not a recognized request").into_response()
}
}