🔊 Logging in emit_events

Signed-off-by: ff137 <[email protected]>

Author: ff137

acapy_agent/messaging/models/base_record.py

@@ -507,8 +507,6 @@ async def emit_event(self, session: ProfileSession, payload: Optional[Any] = Non
         else:
             topic = f"{self.EVENT_NAMESPACE}::{self.RECORD_TOPIC}"
 
-        LOGGER.debug("Emitting event with topic %s", topic)
-
         if not payload:
             LOGGER.debug("Serializing payload for %s record", self.RECORD_TYPE)
             payload = self.serialize()

acapy_agent/protocols/issue_credential/v2_0/models/cred_ex_record.py

@@ -193,6 +193,10 @@ async def emit_event(self, session: ProfileSession, payload: Optional[Any] = Non
         """
 
         if not self.RECORD_TOPIC:
+            LOGGER.warning(
+                "Emit event called but RECORD_TOPIC is not set for %s",
+                self.RECORD_TYPE,
+            )
             return
 
         if self.state:
@@ -202,11 +206,13 @@ async def emit_event(self, session: ProfileSession, payload: Optional[Any] = Non
 
         # serialize payload before checking for webhook contents
         if not payload:
+            LOGGER.debug("Serializing payload for %s record", self.RECORD_TYPE)
             payload = self.serialize()
         if not session.profile.settings.get("debug.webhooks"):
             payload = V20CredExRecordWebhook(**payload)
             payload = payload.__dict__
 
+        LOGGER.debug("Emitting %s event for profile %s", topic, session.profile.name)
         await session.profile.notify(topic, payload)
 
     @property

acapy_agent/protocols/present_proof/v2_0/models/pres_exchange.py

@@ -191,6 +191,10 @@ async def emit_event(self, session: ProfileSession, payload: Optional[Any] = Non
         """
 
         if not self.RECORD_TOPIC:
+            LOGGER.warning(
+                "Emit event called but RECORD_TOPIC is not set for %s",
+                self.RECORD_TYPE,
+            )
             return
 
         if self.state:
@@ -200,11 +204,13 @@ async def emit_event(self, session: ProfileSession, payload: Optional[Any] = Non
 
         # serialize payload before checking for webhook contents
         if not payload:
+            LOGGER.debug("Serializing payload for %s record", self.RECORD_TYPE)
             payload = self.serialize()
         if not session.profile.settings.get("debug.webhooks"):
             payload = V20PresExRecordWebhook(**payload)
             payload = payload.__dict__
 
+        LOGGER.debug("Emitting %s event for profile %s", topic, session.profile.name)
         await session.profile.notify(topic, payload)
 
     @property