Merge pull request #75 from didx-xyz/issue_66

Issue 66

Author: wip-abramson

libs/aries-basic-controller/aries_basic_controller/aries_controller.py

@@ -4,6 +4,7 @@
     ClientRequest,
 )
 from pubsub import pub
+import sys
 
 from .controllers.connections import ConnectionsController
 from .controllers.messaging import MessagingController
@@ -143,51 +144,88 @@ def update_tennant_jwt(self, tennant_jwt):
 
 
     def register_listeners(self, listeners, defaults=True):
-        if defaults:
-            if self.connections:
-                pub.subscribe(self.connections.default_handler, "connections")
-            if self.messaging:
-                pub.subscribe(self.messaging.default_handler, "basicmessages")
-            if self.proofs:
-                pub.subscribe(self.proofs.default_handler, "present_proof")
+        try:
+            if defaults:
+                if self.connections:
+                    pub.subscribe(self.connections.default_handler, "connections")
+                if self.messaging:
+                    pub.subscribe(self.messaging.default_handler, "basicmessages")
+                if self.proofs:
+                    pub.subscribe(self.proofs.default_handler, "present_proof")
+
+            for listener in listeners:
+                self.add_listener(listener)
+        except Exception as exc:
+            print(f"Register webhooks listeners failed! {exc!r} occurred.")
+            logger.warn(f"Register webhooks listeners failed! {exc!r} occurred.")
 
-        for listener in listeners:
-            self.add_listener(listener)
 
     def add_listener(self, listener):
-        pub.subscribe(listener["handler"], listener["topic"])
+        try:
+            pub.subscribe(listener["handler"], listener["topic"])
+        except Exception as exc:
+            print(f"Adding webhooks listener failed! {exc!r} occurred.")
+            logger.warn(f"Adding webhooks listener failed! {exc!r} occurred.")
+            
 
     def remove_listener(self, listener):
-        if pub.isSubscribed(listener["handler"], listener["topic"]):
-            pub.unsubscribe(listener["handler"], listener["topic"])
-        else:
-            logger.debug("Listener not subscribed", listener)
+        try:
+            if pub.isSubscribed(listener["handler"], listener["topic"]):
+                pub.unsubscribe(listener["handler"], listener["topic"])
+            else:
+                logger.debug("Listener not subscribed", listener)
+        except Exception as exc:
+            print(f"Removing webhooks listener failed! {exc!r} occurred.")
+            logger.warn(f"Removing webhooks listener failed! {exc!r} occurred.")
+            
 
     def remove_all_listeners(self, topic: str = None):
         # Note advanced use of function can include both listenerFilter and topicFilter for this
         # Add when needed
-        pub.unsubAll(topicName=topic)
+        try:
+            pub.unsubAll(topicName=topic)
+        except Exception as exc:
+            print(f"Removing all webhooks listeners failed! {exc!r} occurred.")
+            logger.warn(f"Removing all webhooks listeners failed! {exc!r} occurred.")
+            
 
     async def listen_webhooks(self):
-        app = web.Application()
-        app.add_routes([web.post(self.webhook_base + "/topic/{topic}/", self._receive_webhook)])
-        runner = web.AppRunner(app)
-        await runner.setup()
-        self.webhook_site = web.TCPSite(runner, self.webhook_host, self.webhook_port)
-        await self.webhook_site.start()
+        try:
+            app = web.Application()
+            app.add_routes([web.post(self.webhook_base + "/topic/{topic}/", self._receive_webhook)])
+            runner = web.AppRunner(app)
+            await runner.setup()
+            self.webhook_site = web.TCPSite(runner, self.webhook_host, self.webhook_port)
+            await self.webhook_site.start()
+        except Exception as exc:
+            print(f"Listening webhooks failed! {exc!r} occurred.")
+            logger.warn(f"Listening webhooks failed! {exc!r} occurred.")
+
 
     async def _receive_webhook(self, request: ClientRequest):
         topic = request.match_info["topic"]
-        payload = await request.json()
-        await self._handle_webhook(topic, payload)
-        return web.Response(status=200)
+        try:
+            payload = await request.json()
+            await self._handle_webhook(topic, payload)
+            return web.Response(status=200)
+        except Exception as exc:
+            logger.warn(f"Receiving webhooks failed! {exc!r} occurred.")
+        
 
     async def _handle_webhook(self, topic, payload):
-        logging.debug(f"Handle Webhook - {topic}", payload)
-        pub.sendMessage(topic, payload=payload)
-        # return web.Response(status=200)
+        try:
+            logging.debug(f"Handle Webhook - {topic}", payload)
+            pub.sendMessage(topic, payload=payload)
+            # return web.Response(status=200)
+        except Exception as exc:
+            logger.warn(f"Handling webhooks failed! {exc!r} occurred when trying to handle this topic: {topic}")
+            
 
     async def terminate(self):
-        await self.client_session.close()
-        if self.webhook_site:
-            await self.webhook_site.stop()
+        try:
+            await self.client_session.close()
+            if self.webhook_site:
+                await self.webhook_site.stop()
+        except Exception as exc:
+            print(f"Terminating webhooks listener failed! {exc!r} occurred.")
+            logger.warn(f"Terminating webhooks listener failed! {exc!r} occurred.")

tutorials/1. Learning Aries, ACA-Py and the Basic Controller/notebooks/alice/3 Messages/Part 1 - Basic Message.ipynb

@@ -121,7 +121,7 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "await agent_controller.messaging.trust_ping(id)"
+    "await agent_controller.messaging.trust_ping(id, \"hello, world!\")"
    ]
   },
   {

tutorials/1. Learning Aries, ACA-Py and the Basic Controller/notebooks/bob/3 Messages/Part 1 - Basic Message.ipynb

@@ -166,7 +166,7 @@
    "name": "python",
    "nbconvert_exporter": "python",
    "pygments_lexer": "ipython3",
-   "version": "3.7.6"
+   "version": "3.8.5"
   }
  },
  "nbformat": 4,