Skip to content

Commit

Permalink
Log messages
Browse files Browse the repository at this point in the history
  • Loading branch information
jschlyter committed Feb 5, 2025
1 parent 685aa39 commit 7d1edc5
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion evrec/server.py
Original file line number Diff line number Diff line change
Expand Up @@ -53,13 +53,14 @@ async def run(self):
await client.subscribe(self.settings.mqtt.topic_read)

async for message in client.messages:
self.logger.debug("Received message on %s", message.topic)
self.logger.debug("Received message on %s, %s", message.topic, message.payload.decode())
try:
jws = JWS()
jws.deserialize(message.payload)
key = self.clients_keyset.verify_jws(jws)
if self.settings.schema_validation:
self.message_validator.validate_message(str(message.topic), jws.objects["payload"])
self.logger.debug("Verified message: %s", jws.objects["payload"].decode())
if self.settings.mqtt.topic_write:
await self.handle_payload(client, message, jws, key)
else:
Expand Down

0 comments on commit 7d1edc5

Please sign in to comment.