From 9f56f5390c1eae41a4dface393fff6b63fa72708 Mon Sep 17 00:00:00 2001
From: Felix Ableitner <me@nutomic.com>
Date: Mon, 16 Jun 2025 14:46:03 +0200
Subject: [PATCH] Add hook for incoming activities

---
 src/actix_web/inbox.rs | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/src/actix_web/inbox.rs b/src/actix_web/inbox.rs
index 0912e72..6dd9ef3 100644
--- a/src/actix_web/inbox.rs
+++ b/src/actix_web/inbox.rs
@@ -10,14 +10,16 @@ use crate::{
 };
 use actix_web::{web::Bytes, HttpRequest, HttpResponse};
 use serde::de::DeserializeOwned;
+use std::future::Future;
 use tracing::debug;
 
 /// Handles incoming activities, verifying HTTP signatures and other checks
 ///
 /// After successful validation, activities are passed to respective [trait@ActivityHandler].
-pub async fn receive_activity<Activity, ActorT, Datatype>(
+pub async fn receive_activity<Activity, ActorT, Datatype, Fut>(
     request: HttpRequest,
     body: Bytes,
+    hook: impl FnOnce(&Activity, &ActorT) -> Fut,
     data: &Data<Datatype>,
 ) -> Result<HttpResponse, <Activity as ActivityHandler>::Error>
 where
@@ -27,6 +29,7 @@ where
     <Activity as ActivityHandler>::Error: From<Error> + From<<ActorT as Object>::Error>,
     <ActorT as Object>::Error: From<Error>,
     Datatype: Clone,
+    Fut: Future<Output = Result<(), <Activity as ActivityHandler>::Error>>,
 {
     let digest_header = request
         .headers()
@@ -41,6 +44,8 @@ where
     let uri = http_compat::uri(request.uri());
     verify_signature(&headers, &method, &uri, actor.public_key_pem())?;
 
+    hook(&activity, &actor).await?;
+
     debug!("Receiving activity {}", activity.id().to_string());
     activity.verify(data).await?;
     activity.receive(data).await?;