diff --git a/pyproject.toml b/pyproject.toml index 5303717..b98dabd 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,6 +1,6 @@ [project] name = "srpcLib" -version = "1.0.0" +version = "2.0.0" description = "SRPC is a lightweight Remote Procedure Call (RPC) library." authors = [{ name="Oseas Andre", email="oseasandrepro@gmail.com" }] dependencies = ["pytest>=8.4.1"] diff --git a/requirements.txt b/requirements.txt index 1420434..159c150 100644 --- a/requirements.txt +++ b/requirements.txt @@ -4,3 +4,4 @@ black>=23.9.1 flake8>=3.4.0 isort>=5.13.2 rich>=13.7.0 +msgpack==1.2.1 diff --git a/srpcLib/stub_generator/srpc_server_stub_gen.py b/srpcLib/stub_generator/srpc_server_stub_gen.py index 5c7748e..34328b5 100644 --- a/srpcLib/stub_generator/srpc_server_stub_gen.py +++ b/srpcLib/stub_generator/srpc_server_stub_gen.py @@ -83,7 +83,7 @@ def __handle_request(self, client_socket, client_addr): request_tuple = self.__serializer.deserialize(msg) procedure_name = request_tuple[0] - if isinstance(request_tuple, tuple): + if isinstance(request_tuple, list): self.__logger.info(f"Request: {{request_tuple}} from: {{client_addr[0]}}") start_time = time.time() # Start time measurement result = self.__call_procedure(request_tuple) diff --git a/srpcLib/utils/srpc_serializer.py b/srpcLib/utils/srpc_serializer.py index 1b68c3a..affb757 100644 --- a/srpcLib/utils/srpc_serializer.py +++ b/srpcLib/utils/srpc_serializer.py @@ -1,12 +1,12 @@ -import pickle +import msgpack from ..interface.srpc_serializer_interface import SrpcSerializerInterface class SrpcSerializer(SrpcSerializerInterface): def serialize(self, data): - return pickle.dumps(data) + return msgpack.packb(data) def deserialize(self, data): - deserialized_data = pickle.loads(data) + deserialized_data = msgpack.unpackb(data) return deserialized_data