Merge pull request #598 from TeskaLabs/feature/json-ser-dataclasses

JSON serializer can handle dataclasses + better exception handling in threadsafe PubSub

asab/pubsub.py

@@ -215,7 +215,10 @@ def publish_threadsafe(self, message_type: str, *args, **kwargs):
 			asynchronously (bool, optional): If `True`, `call_soon()` method will be used for the asynchronous delivery of the message. Defaults to `False`.
 		"""
 		def in_main_thread():
-			self.publish(message_type, *args, **kwargs)
+			try:
+				self.publish(message_type, *args, **kwargs)
+			except Exception:
+				L.exception("Error in a PubSub threadsafe", struct_data={'message_type': message_type})
 		self.Loop.call_soon_threadsafe(in_main_thread)
 
 

asab/web/rest/json.py

@@ -1,8 +1,11 @@
-import functools
 import json
-import logging
 import uuid
+import logging
 import datetime
+import functools
+import dataclasses
+
+
 import aiohttp.web
 import fastjsonschema
 
@@ -62,6 +65,9 @@ def default(self, o):
 		elif isinstance(o, bytes):
 			return o.hex()
 
+		elif dataclasses.is_dataclass(o):
+			return dataclasses.asdict(o)
+
 		try:
 			return json.JSONEncoder.default(self, o)
 		except TypeError: