refactor iop code to support multi-sync requests

Author: grongierisc

demo/python/multi_sync/bo.py

@@ -0,0 +1,12 @@
+from iop import BusinessOperation
+from msg import MyMessage
+
+import time
+
+class MyMultiBO(BusinessOperation):
+    def on_message(self, request):
+        print(f"Received message: {request.message}")
+        time.sleep(1)
+        return MyMessage(message=f"Hello, {request.message}")
+
+        

demo/python/multi_sync/bp.py

@@ -0,0 +1,18 @@
+from iop import BusinessProcess
+from msg import MyMessage
+
+
+class MyMultiBP(BusinessProcess):
+
+    def on_message(self, request):
+        msg_one = MyMessage(message="Message1")
+        msg_two = MyMessage(message="Message2")
+
+        tuple_responses = self.send_multi_request_sync([("Python.MyMultiBO", msg_one), ("Python.MyMultiBO", msg_two)])
+
+        self.log_info("All requests have been processed")
+        for target,request,response,status in tuple_responses:
+            self.log_info(f"Received response: {response.message}")
+
+
+

demo/python/multi_sync/msg.py

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

demo/python/multi_sync/settings.py

@@ -0,0 +1,7 @@
+from bo import MyMultiBO
+from bp import MyMultiBP
+
+CLASSES = {
+    "Python.MyMultiBO": MyMultiBO,
+    "Python.MyMultiBP": MyMultiBP,
+}

src/iop/_business_host.py

@@ -152,6 +152,39 @@ def send_request_async(self, target, request, description=None):
 
         return self.iris_handle.dispatchSendRequestAsync(target,request,description)
 
+    def send_multi_request_sync(self, target_request:list, timeout=-1, description=None)->list:
+        """ Send the specified list of tuple (target,request) to business process or business operation synchronously.
+            
+        Parameters:
+        target_request: a list of tuple (target,request) that specifies the name of the business process or operation to receive the request. 
+            The target is the name of the component as specified in the Item Name property in the production definition, not the class name of the component.
+            The request is either an instance of a class that is a subclass of Message class or of IRISObject class.
+        timeout: an optional integer that specifies the number of seconds to wait before treating the send request as a failure. The default value is -1, which means wait forever.
+        description: an optional string parameter that sets a description property in the message header. The default is None.
+        Returns:
+            the list of tuple (target,request,response,status).
+        """
+        # create a list of iris.Ens.CallStructure for each target_request
+        call_list = []
+        for target,request in target_request:
+            call = iris.cls("Ens.CallStructure")._New()
+            call.TargetDispatchName = target
+            call.Request = self._dispatch_serializer(request)
+            call_list.append(call)
+        # call the dispatchSendMultiRequestSync method
+        response_list = self.iris_handle.dispatchSendRequestSyncMultiple(call_list,timeout)
+        # create a list of tuple (target,request,response,status)
+        result = []
+        for i in range(len(target_request)):
+            result.append(
+                (target_request[i][0],
+                 target_request[i][1],
+                 self._dispatch_deserializer(response_list[i].Response),
+                 response_list[i].ResponseCode
+                ))
+        return result
+
+
     def _serialize_pickle_message(self,message):
         """ Converts a python dataclass message into an iris iop.message.
 

src/iop/cls/IOP/Common.cls

@@ -149,6 +149,30 @@ Method dispatchSendRequestSync(
     quit $g(objResponse)
 }
 
+Method dispatchSendRequestSyncMultiple(
+	pCallStructList As %List,
+	pTimeout As %Numeric = -1) As %List
+{
+    set builtins = ##class(%SYS.Python).Import("builtins")
+    // Convert %List to multidimensional array
+    set tCallStructList=builtins.len(pCallStructList)
+    $$$LOGINFO("pCallStructList: "_pCallStructList)
+    for i=0:1:builtins.len(pCallStructList)-1 {
+        set tCallStructList(i+1) = pCallStructList."__getitem__"(i)
+    }
+
+    $$$LOGINFO("tCallStructList: "_tCallStructList(1))
+    set tSC = ..SendRequestSyncMultiple(.tCallStructList,pTimeout)
+    if $$$ISERR(tSC) throw ##class(%Exception.StatusException).CreateFromStatus(tSC)
+    // Convert multidimensional array to Python list
+    set tResponseList = builtins.list()
+    
+    for i=1:1:tCallStructList {
+        do tResponseList.append(tCallStructList(i))
+    }
+    quit tResponseList
+}
+
 Method dispatchSendRequestAsync(
 	target,
 	request,