Implement msgspec Encoding and Decoding Support

nautilus_trader/config/common.py

@@ -25,6 +25,8 @@
 from nautilus_trader.config.validation import PositiveInt
 from nautilus_trader.core.correctness import PyCondition
 from nautilus_trader.persistence.catalog.parquet import ParquetDataCatalog
+from nautilus_trader.serialization.base import msgspec_decoding_hook
+from nautilus_trader.serialization.base import msgspec_encoding_hook
 
 
 def resolve_path(path: str) -> type:
@@ -105,7 +107,7 @@ def json(self) -> bytes:
         bytes
 
         """
-        return msgspec.json.encode(self)
+        return msgspec.json.encode(self, enc_hook=msgspec_encoding_hook)
 
     @classmethod
     def parse(cls, raw: bytes) -> Any:
@@ -124,7 +126,7 @@ def parse(cls, raw: bytes) -> Any:
         Any
 
         """
-        return msgspec.json.decode(raw, type=cls)
+        return msgspec.json.decode(raw, type=cls, dec_hook=msgspec_decoding_hook)
 
     def validate(self) -> bool:
         """
@@ -135,7 +137,7 @@ def validate(self) -> bool:
         bool
 
         """
-        return bool(msgspec.json.decode(self.json(), type=self.__class__))
+        return bool(self.parse(self.json()))
 
     def __hash__(self):
         return generate_structure_hash(self.dict())

nautilus_trader/serialization/base.pyx

@@ -63,6 +63,9 @@ from nautilus_trader.model.instruments.futures_contract cimport FuturesContract
 from nautilus_trader.model.instruments.options_contract cimport OptionsContract
 from nautilus_trader.model.instruments.synthetic cimport SyntheticInstrument
 
+from nautilus_trader.model.identifiers import Identifier
+from nautilus_trader.model.identifiers import InstrumentId
+
 
 # Default mappings for Nautilus objects
 _OBJECT_TO_DICT_MAP: dict[str, Callable[[None], dict]] = {
@@ -267,3 +270,27 @@ cdef class Serializer:
     cpdef object deserialize(self, bytes obj_bytes):
         """Abstract method (implement in subclass)."""
         raise NotImplementedError("method must be implemented in the subclass")  # pragma: no cover
+
+
+def msgspec_encoding_hook(obj: Any):
+    if isinstance(obj, Identifier):
+        return str(obj)
+    else:
+        obj_to_dict = _OBJECT_TO_DICT_MAP.get(type(obj).__name__)
+        if obj_to_dict:
+            return obj_to_dict(obj)
+        else:
+            raise NotImplementedError
+
+
+def msgspec_decoding_hook(obj_type: type, obj: Any) -> Any:
+    if issubclass(obj_type, InstrumentId):
+        return InstrumentId.from_str(obj)
+    elif issubclass(obj_type, Identifier):
+        return obj_type(obj)
+    else:
+        obj_from_dict = _OBJECT_FROM_DICT_MAP.get(obj_type.__name__)
+        if obj_from_dict and isinstance(obj, dict):
+            return obj_from_dict(obj)
+        else:
+            raise NotImplementedError