Trigger global signals dispatched by Nayra Service

ProcessMaker/Nayra/Managers/WorkflowManagerDefault.php

@@ -32,7 +32,6 @@
 use ProcessMaker\Nayra\Contracts\Bpmn\ThrowEventInterface;
 use ProcessMaker\Nayra\Contracts\Bpmn\TokenInterface;
 use ProcessMaker\Nayra\Contracts\Engine\ExecutionInstanceInterface;
-use ProcessMaker\Repositories\DefinitionsRepository;
 
 class WorkflowManagerDefault implements WorkflowManagerInterface
 {
@@ -265,12 +264,28 @@ public function throwSignalEventDefinition(EventDefinitionInterface $sourceEvent
         }
 
         $excludeProcesses = [$token->getInstance()->getModel()->process_id];
-        $excludeRequests = [];
-        $instances = $token->getInstance()->getProcess()->getEngine()->getExecutionInstances();
+
+        $excludeRequests = $this->getCollaboratingInstanceIds($token->getInstance());
+        ThrowSignalEvent::dispatch($signalRef, $data, $excludeProcesses, $excludeRequests)->onQueue('bpmn');
+    }
+
+    /**
+     * Retrieves IDs of all instances collaborating with the given instance.
+     *
+     * This function compiles a list of IDs from execution instances associated 
+     * with the same process as the input instance, including the instance itself.
+     *
+     * @param ProcessRequest $instance The instance to find collaborators for.
+     * @return int[] Array of collaborating instance IDs.
+     */
+    protected function getCollaboratingInstanceIds($instance)
+    {
+        $ids = [];
+        $instances = $instance->getProcess()->getEngine()->getExecutionInstances();
         foreach ($instances as $instance) {
-            $excludeRequests[] = $instance->getId();
+            $ids[] = $instance->getId();
         }
-        ThrowSignalEvent::dispatch($signalRef, $data, $excludeProcesses, $excludeRequests)->onQueue('bpmn');
+        return $ids;
     }
 
     /**

ProcessMaker/Nayra/Managers/WorkflowManagerRabbitMq.php

@@ -553,6 +553,24 @@ public function throwSignalEventRequest(ProcessRequest $request, $signalRef, arr
         ]);
     }
 
+    /**
+     * Retrieves IDs of all instances collaborating with the given instance.
+     *
+     * This function compiles a list of IDs from execution instances associated 
+     * with the same process as the input instance, including the instance itself.
+     *
+     * @param ProcessRequest $instance The instance to find collaborators for.
+     * @return int[] Array of collaborating instance IDs.
+     */
+    protected function getCollaboratingInstanceIds($instance)
+    {
+        $ids = ProcessRequest::
+            where('process_collaboration_id', $instance->process_collaboration_id)
+            ->pluck('id')
+            ->toArray();
+        return $ids;
+    }
+
     /**
      * Build a state object.
      *

ProcessMaker/Nayra/Repositories/PersistenceHandler.php

@@ -108,6 +108,9 @@ public function save(array $transaction)
                 case 'start_event_triggered':
                     $this->persistStartEventTriggered($transaction);
                     break;
+                case 'throw_global_signal_event':
+                    $this->throwGlobalSignalEvent($transaction);
+                    break;
                 case 'event_based_gateway_activated':
                     $this->persistEventBasedGatewayActivated($transaction);
                     break;

ProcessMaker/Nayra/Repositories/PersistenceTokenTrait.php

@@ -3,6 +3,7 @@
 namespace ProcessMaker\Nayra\Repositories;
 
 use Illuminate\Support\Facades\Cache;
+use ProcessMaker\Facades\WorkflowManager;
 use ProcessMaker\Listeners\BpmnSubscriber;
 use ProcessMaker\Listeners\CommentsSubscriber;
 use ProcessMaker\Nayra\Bpmn\Events\ActivityActivatedEvent;
@@ -298,4 +299,12 @@ public function persistAbout(array $aboutInfo)
         error_log("Microservice $name version $version is running.");
         Cache::put(self::$aboutCacheKey, $aboutInfo, 60);
     }
+
+    public function throwGlobalSignalEvent(array $transaction)
+    {
+        $throwElement = $this->deserializer->unserializeEntity($transaction['throw_element']);
+        $token = $transaction['token'] ? $this->deserializer->unserializeToken($transaction['token']) : null;
+        $eventDefinition = $throwElement->getEventDefinitions()->item(0);
+        WorkflowManager::throwSignalEventDefinition($eventDefinition, $token);
+    }
 }