Add webhooks for OOB connection reuse

Signed-off-by: Ian Costanzo <[email protected]>

aries_cloudagent/protocols/out_of_band/v1_0/manager.py

@@ -54,7 +54,7 @@
 
 LOGGER = logging.getLogger(__name__)
 REUSE_WEBHOOK_TOPIC = "acapy::webhook::connection_reuse"
-REUSE_ACCEPTED_WEBHOOK_TOPIC = "acapy::webhook:connection_reuse_accepted"
+REUSE_ACCEPTED_WEBHOOK_TOPIC = "acapy::webhook::connection_reuse_accepted"
 
 
 class OutOfBandManagerError(BaseError):

demo/runners/agent_container.py

@@ -100,14 +100,18 @@ async def handle_oob_invitation(self, message):
         pass
 
     async def handle_connection_reuse(self, message):
-        print("handle_connection_reuse():", json.dumps(message))
-        # TODO we are reusing an existing connection, set our status to the existing connection
-        pass
+        # we are reusing an existing connection, set our status to the existing connection
+        if not self._connection_ready.done():
+            self.connection_id = message["connection_id"]
+            self.log("Connected")
+            self._connection_ready.set_result(True)
 
     async def handle_connection_reuse_accepted(self, message):
-        print("handle_connection_reuse_accepted():", json.dumps(message))
-        # TODO we are reusing an existing connection, set our status to the existing connection
-        pass
+        # we are reusing an existing connection, set our status to the existing connection
+        if not self._connection_ready.done():
+            self.connection_id = message["connection_id"]
+            self.log("Connected")
+            self._connection_ready.set_result(True)
 
     async def handle_connections(self, message):
         # a bit of a hack, but for the mediator connection self._connection_ready

demo/runners/support/agent.py

@@ -775,7 +775,6 @@ async def handle_webhook(self, topic: str, payload, headers: dict):
             handler = f"handle_{topic}"
             wallet_id = headers.get("x-wallet-id")
             method = getattr(self, handler, None)
-            print("Handling:", handler, payload)
             if method:
                 EVENT_LOGGER.debug(
                     "Agent called controller webhook: %s%s%s%s",