refactor: clean up message notifications in handlers

Signed-off-by: Akiff Manji <akiff.manji@quartech.com>
openwallet-foundation · Jan 31, 2024 · 1adfe8f · 1adfe8f
1 parent f9dd26f
commit 1adfe8f
Showing 1 changed file with 16 additions and 16 deletions.
diff --git a/rpc/rpc/v1_0/handlers.py b/rpc/rpc/v1_0/handlers.py
@@ -44,14 +44,14 @@ async def handle(self, context: RequestContext, responder: BaseResponder):
             )
             await storage.add_record(record)
 
-        await context.profile.notify(
-            "acapy::webhook::drpc_request",
-            {
-                "connection_id": connection_id,
-                "thread_id": thread_id,
-                "request": serialized_request_record,
-            },
-        )
+        notification = {
+            "connection_id": connection_id,
+            "thread_id": thread_id,
+            "request": serialized_request_record,
+        }
+
+        await context.profile.notify("drpc::request::received", notification)
+        await context.profile.notify("acapy::webhook::drpc_request", notification)
 
 
 class DRPCResponseHandler(BaseHandler):
@@ -86,11 +86,11 @@ async def handle(self, context: RequestContext, responder: BaseResponder):
                 },
             )
 
-        await context.profile.notify(
-            "acapy::webhook::drpc_response",
-            {
-                "connection_id": connection_id,
-                "thread_id": thread_id,
-                "response": serialized_response_record,
-            },
-        )
+        notification = {
+            "connection_id": connection_id,
+            "thread_id": thread_id,
+            "response": serialized_response_record,
+        }
+
+        await context.profile.notify("drpc::response::received", notification)
+        await context.profile.notify("acapy::webhook::drpc_response", notification)