generating metadata for action events

Signed-off-by: Pedro Escaleira <[email protected]>

Author: oEscal

serverlessworkflow/sdk/state_machine_generator.py

@@ -447,7 +447,11 @@ def generate_actions_info(
                                 ns := self.state_machine.state_cls(name)
                             )
                             ns.tags = ["event"]
-                            self.get_action_event(state=ns, e_name=name)
+                            self.get_action_event(
+                                state=ns,
+                                e_name=action.eventRef.triggerEventRef,
+                                er_name=action.eventRef.resultEventRef,
+                            )
                     if name:
                         if action_mode == "sequential":
                             if i < len(actions) - 1:
@@ -499,7 +503,9 @@ def generate_actions_info(
                                         )
                                         ns.tags = ["event"]
                                         self.get_action_event(
-                                            state=ns, e_name=next_name
+                                            state=ns,
+                                            e_name=action.eventRef.triggerEventRef,
+                                            er_name=action.eventRef.resultEventRef,
                                         )
                                 self.state_machine.add_transition(
                                     trigger="",
@@ -536,13 +542,14 @@ def get_action_function(self, state: NestedState, f_name: str):
                     state.metadata = {"function": current_function}
                     break
 
-    def get_action_event(self, state: NestedState, e_name: str):
+    def get_action_event(self, state: NestedState, e_name: str, er_name: str = ""):
         if self.workflow.events:
             for event in self.workflow.events:
                 current_event = event.serialize().__dict__
                 if current_event["name"] == e_name:
                     state.metadata = {"event": current_event}
-                    break
+                if current_event["name"] == er_name:
+                    state.metadata = {"result_event": current_event}
 
     def subflow_state_name(self, action: Action, subflow: Workflow):
         return (