linting and minor change

Author: wip-abramson

aries_cloudcontroller/aries_controller_base.py

@@ -148,7 +148,6 @@ def register_listeners(self, listeners, defaults=True):
         except Exception as exc:
             logger.warning(f"Register webhooks listeners failed! {exc!r} occurred.")
 
-
     def is_subscribed(self, listener):
         """Check if listener is subscribed
 
@@ -165,8 +164,6 @@ def is_subscribed(self, listener):
         except Exception as exc:
             logger.warning(f"Unable to check if listener subscribed {exc!r} occurred.")
 
-
-
     def add_listener(self, listener):
         """Subscribe to a listeners for a topic
 

tests/test_aries_controller_base.py

@@ -109,22 +109,16 @@ async def test_register_listeners(self):
         listeners = []
         # Receive connection messages
         def connections_handler(payload):
-            print("Connections Handler")
+            LOGGER.info("Connections Handler")
 
-        connection_listener = {
-            "handler": connections_handler,
-            "topic": "connections"
-        }
+        connection_listener = {"handler": connections_handler, "topic": "connections"}
 
         listeners.append(connection_listener)
 
         def issuer_handler(payload):
-            print("Issuer handler")
+            LOGGER.info("Issuer handler")
 
-        issuer_listener = {
-            "topic": "issue_credential",
-            "handler": issuer_handler
-        }
+        issuer_listener = {"topic": "issue_credential", "handler": issuer_handler}
 
         listeners.append(issuer_listener)
 
@@ -135,7 +129,6 @@ def issuer_handler(payload):
 
         await ac.terminate()
 
-
     @pytest.mark.asyncio
     async def test_add_listener(self):
         ac = AriesAgentControllerBase(admin_url="0.0.0.0")
@@ -144,10 +137,7 @@ async def test_add_listener(self):
         def connections_handler(payload):
             print("Connections Handler")
 
-        connection_listener = {
-            "handler": connections_handler,
-            "topic": "connections"
-        }
+        connection_listener = {"handler": connections_handler, "topic": "connections"}
 
         ac.add_listener(connection_listener)
 
@@ -162,10 +152,7 @@ async def test_remove_listener(self):
         def connections_handler(payload):
             print("Connections Handler")
 
-        connection_listener = {
-            "handler": connections_handler,
-            "topic": "connections"
-        }
+        connection_listener = {"handler": connections_handler, "topic": "connections"}
 
         ac.add_listener(connection_listener)
 
@@ -184,20 +171,14 @@ async def test_remove_all_listeners(self):
         def connections_handler(payload):
             print("Connections Handler")
 
-        connection_listener = {
-            "handler": connections_handler,
-            "topic": "connections"
-        }
+        connection_listener = {"handler": connections_handler, "topic": "connections"}
 
         listeners.append(connection_listener)
 
         def issuer_handler(payload):
             print("Issuer handler")
 
-        issuer_listener = {
-            "topic": "issue_credential",
-            "handler": issuer_handler
-        }
+        issuer_listener = {"topic": "issue_credential", "handler": issuer_handler}
 
         listeners.append(issuer_listener)