Skip to content

Commit 8889fc3

Browse files
committed
Change logging levels in aries controller to warn for caught exceptions
in webhook handlers
1 parent 489ce81 commit 8889fc3

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

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

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -157,15 +157,15 @@ def register_listeners(self, listeners, defaults=True):
157157
self.add_listener(listener)
158158
except Exception as exc:
159159
print(f"Register webhooks listeners failed! {exc!r} occurred.")
160-
logger.debug(f"Register webhooks listeners failed! {exc!r} occurred.")
160+
logger.warn(f"Register webhooks listeners failed! {exc!r} occurred.")
161161

162162

163163
def add_listener(self, listener):
164164
try:
165165
pub.subscribe(listener["handler"], listener["topic"])
166166
except Exception as exc:
167167
print(f"Adding webhooks listener failed! {exc!r} occurred.")
168-
logger.debug(f"Adding webhooks listener failed! {exc!r} occurred.")
168+
logger.warn(f"Adding webhooks listener failed! {exc!r} occurred.")
169169

170170

171171
def remove_listener(self, listener):
@@ -176,7 +176,7 @@ def remove_listener(self, listener):
176176
logger.debug("Listener not subscribed", listener)
177177
except Exception as exc:
178178
print(f"Removing webhooks listener failed! {exc!r} occurred.")
179-
logger.debug(f"Removing webhooks listener failed! {exc!r} occurred.")
179+
logger.warn(f"Removing webhooks listener failed! {exc!r} occurred.")
180180

181181

182182
def remove_all_listeners(self, topic: str = None):
@@ -186,7 +186,7 @@ def remove_all_listeners(self, topic: str = None):
186186
pub.unsubAll(topicName=topic)
187187
except Exception as exc:
188188
print(f"Removing all webhooks listeners failed! {exc!r} occurred.")
189-
logger.debug(f"Removing all webhooks listeners failed! {exc!r} occurred.")
189+
logger.warn(f"Removing all webhooks listeners failed! {exc!r} occurred.")
190190

191191

192192
async def listen_webhooks(self):
@@ -199,7 +199,7 @@ async def listen_webhooks(self):
199199
await self.webhook_site.start()
200200
except Exception as exc:
201201
print(f"Listening webhooks failed! {exc!r} occurred.")
202-
logger.debug(f"Listening webhooks failed! {exc!r} occurred.")
202+
logger.warn(f"Listening webhooks failed! {exc!r} occurred.")
203203

204204

205205
async def _receive_webhook(self, request: ClientRequest):
@@ -209,7 +209,7 @@ async def _receive_webhook(self, request: ClientRequest):
209209
await self._handle_webhook(topic, payload)
210210
return web.Response(status=200)
211211
except Exception as exc:
212-
logger.debug(f"Receiving webhooks failed! {exc!r} occurred.")
212+
logger.warn(f"Receiving webhooks failed! {exc!r} occurred.")
213213

214214

215215
async def _handle_webhook(self, topic, payload):
@@ -218,7 +218,7 @@ async def _handle_webhook(self, topic, payload):
218218
pub.sendMessage(topic, payload=payload)
219219
# return web.Response(status=200)
220220
except Exception as exc:
221-
logger.debug(f"Handling webhooks failed! {exc!r} occurred when trying to handle this topic: {topic}")
221+
logger.warn(f"Handling webhooks failed! {exc!r} occurred when trying to handle this topic: {topic}")
222222

223223

224224
async def terminate(self):
@@ -228,4 +228,4 @@ async def terminate(self):
228228
await self.webhook_site.stop()
229229
except Exception as exc:
230230
print(f"Terminating webhooks listener failed! {exc!r} occurred.")
231-
logger.debug(f"Terminating webhooks listener failed! {exc!r} occurred.")
231+
logger.warn(f"Terminating webhooks listener failed! {exc!r} occurred.")

0 commit comments

Comments
 (0)