Merge pull request #215 from Clariteia/0.0.11

0.0.11

HISTORY.md

@@ -106,3 +106,9 @@ History
 * Added JSON Binary format
 * Improved LMDB support for Saga Binary format
 
+0.0.11 (2021-05-12)
+------------------
+
+* EventModel modified the list of items from Aggregate to MinosModel, for better compatibility
+* Added DB Storage Abstract class
+* Added code documentation

minos/common/__init__.py

@@ -6,7 +6,7 @@
 Minos framework can not be copied and/or distributed without the express permission of Clariteia SL.
 """
 
-__version__ = "0.0.10"
+__version__ = "0.0.11"
 
 from .broker import (
     MinosBaseBroker,
@@ -63,6 +63,11 @@
     MinosRPCHeadersRequest,
     MinosRPCResponse,
 )
+from .meta import (
+    classproperty,
+    property_or_classproperty,
+    self_or_classmethod,
+)
 from .model import (
     ARRAY,
     BOOLEAN,

minos/common/protocol/json.py

@@ -5,15 +5,12 @@
 
 Minos framework can not be copied and/or distributed without the express permission of Clariteia SL.
 """
-import json
-from base64 import (
-    b64decode,
-    b64encode,
-)
 from typing import (
     Any,
 )
 
+import orjson
+
 from .abc import (
     MinosBinaryProtocol,
 )
@@ -31,7 +28,7 @@ def encode(cls, data: Any, *args, **kwargs) -> bytes:
         :param kwargs: Additional named arguments.
         :return: A bytes instance.
         """
-        return b64encode(json.dumps(data).encode())
+        return orjson.dumps(data)
 
     @classmethod
     def decode(cls, data: bytes) -> Any:
@@ -40,4 +37,4 @@ def decode(cls, data: bytes) -> Any:
         :param data: bytes data to be decoded.
         :return: De decoded data.
         """
-        return json.loads(b64decode(data.decode()))
+        return orjson.loads(data)

setup.py

@@ -48,6 +48,6 @@
     setup_requires=setup_requirements,
     test_suite="tests",
     tests_require=test_requirements,
-    version="0.0.10",
+    version="0.0.11",
     zip_safe=False,
 )

tests/test_common/test_protocol/test_avro.py

@@ -80,7 +80,7 @@ def test_encode_raises(self):
 
     def test_decode_raises(self):
         with self.assertRaises(MinosProtocolException):
-            MinosAvroValuesDatabase.decode(bytes())
+            MinosAvroProtocol.decode(bytes())
 
 
 class TestMinosAvroValuesDatabase(unittest.TestCase):