refactor iop code to support multi-sync requests

Author: grongierisc

src/tests/bench/bo.py

@@ -0,0 +1,8 @@
+from iop import BusinessOperation
+
+class BenchIoPOperation(BusinessOperation):
+    def on_message(self, request):
+
+        return request
+
+        

src/tests/bench/bp.py

@@ -0,0 +1,10 @@
+from iop import BusinessProcess
+
+class BenchIoPProcess(BusinessProcess):
+    def on_init(self):
+        if not hasattr(self, 'size'):
+            self.size = 100
+
+    def on_message(self, request):
+        for _ in range(self.size):
+            _ = self.send_request_sync("Python.BenchIoPOperation",request)

src/tests/bench/msg.py

@@ -0,0 +1,6 @@
+from grongier.pex import Message
+from dataclasses import dataclass
+
+@dataclass
+class MyMessage(Message):
+    message : str = None

src/tests/bench/settings.py

@@ -0,0 +1,64 @@
+from bo import BenchIoPOperation
+from bp import BenchIoPProcess
+
+import os
+
+# get current directory
+current_dir = os.path.dirname(os.path.realpath(__file__))
+# get working directory
+working_dir = os.path.abspath(os.path.join(current_dir, os.pardir))
+# get the absolute path of 'src'
+src_dir = os.path.abspath(os.path.join(working_dir, os.pardir))
+
+# create a strings with current_dir and src_dir with a | separator
+classpaths = f"{current_dir}|{src_dir}"
+
+CLASSES = {
+    "Python.BenchIoPOperation": BenchIoPOperation,
+    "Python.BenchIoPProcess": BenchIoPProcess,
+}
+
+PRODUCTIONS = [{
+    "Bench.Production": {
+        "@Name": "Bench.Production",
+        "@TestingEnabled": "true",
+        "@LogGeneralTraceEvents": "false",
+        "Description": "",
+        "ActorPoolSize": "1",
+        "Item": [
+            {
+                "@Name": "Python.BenchIoPOperation",
+                "@Category": "",
+                "@ClassName": "Python.BenchIoPOperation",
+                "@PoolSize": "1",
+                "@Enabled": "true",
+                "@Foreground": "false",
+                "@Comment": "",
+                "@LogTraceEvents": "false",
+                "@Schedule": "",
+                "Setting": {
+                    "@Target": "Host",
+                    "@Name": "%classpaths",
+                    "#text": classpaths
+                }
+            },
+            {
+                "@Name": "Python.BenchIoPProcess",
+                "@Category": "",
+                "@ClassName": "Python.BenchIoPProcess",
+                "@PoolSize": "0",
+                "@Enabled": "true",
+                "@Foreground": "false",
+                "@Comment": "",
+                "@LogTraceEvents": "false",
+                "@Schedule": "",
+                "Setting": {
+                    "@Target": "Host",
+                    "@Name": "%classpaths",
+                    "#text": classpaths
+                }
+            }
+        ]
+    }
+}
+]

src/tests/conftest.py

@@ -6,6 +6,6 @@
 # add registerFiles to the path
 sys.path.append(join(join(root_dir, 'tests'), 'registerFiles'))
 
-from grongier.pex import Utils
+from iop import Utils
 
 Utils.setup()

src/tests/test_bench.py

@@ -0,0 +1,49 @@
+from iop._director import _Director
+from iop._utils import _Utils
+
+import timeit
+import os
+
+import sys
+
+class TestBenchIoP:
+
+    #before all tests
+    @classmethod
+    def setup_class(cls):
+        # Add the 'bench' to sys.path
+        sys.path.insert(0,os.path.abspath('src/tests/bench'))
+        # migrate the production
+        _Utils.migrate()
+        # stop all productions
+        _Director.stop_production()
+        # set the default production
+        _Director.set_default_production('Bench.Production')
+        # start the production
+        _Director.start_production()
+
+    def test_bench_iris_message(self):
+        body = "test"
+        result = timeit.timeit(lambda: _Director.test_component('Python.BenchIoPProcess','','iris.Ens.StringRequest',body), number=1)
+        # print the time in pytest output
+        print(f"Time: {result}")
+        # assert the result
+        assert result > 0
+
+    def test_bench_python_message(self):
+        body = "test"*200000
+        result = timeit.timeit(lambda: _Director.test_component('Python.BenchIoPProcess','','msg.MyMessage',f'{{"message":"{body}"}}'), number=1)
+        # print the time in pytest output
+        print(f"Time: {result}")
+        # assert the result
+        assert result > 0
+
+    #after all tests
+    @classmethod
+    def teardown_class(cls):
+        # stop all productions
+        _Director.stop_production()
+        # set the default production
+        _Director.set_default_production('test')
+        # Remove the 'bench' from sys.path
+        sys.path.remove(os.path.abspath('src/tests/bench'))

src/tests/test_iop_business_host.py

@@ -168,6 +168,15 @@ def test_deseialize_message():
     assert msg.integer == 1
     assert msg.string == 'test'
 
+def test_big_message():
+    bh = _BusinessHost()
+    huge_string = 'test'*1000000
+    msg = TestSimpleMessage(integer=1, string=huge_string)
+    result = bh._serialize_message(msg)
+    msg = bh._deserialize_message(result)
+    assert msg.integer == 1
+    assert msg.string == huge_string
+
 def test_deseialize_message_japanese():
     bh = _BusinessHost()
     msg = TestSimpleMessage(integer=1, string='あいうえお')