FOUR-26791 Implement Throw/Catch Event Message Mapping

.github/workflows/sonarqube.yml

@@ -44,8 +44,8 @@ jobs:
       - name: Run PHPUnit tests
         run: ./vendor/bin/phpunit -d memory_limit=-1
 
-      - name: List coverage files
-        run: ls -l coverage
+      - name: Check coverage
+        run: ./check_coverage.php
 
       - uses: sonarsource/sonarqube-scan-action@master
         env:

src/ProcessMaker/Nayra/Bpmn/Assignment.php

@@ -0,0 +1,34 @@
+<?php
+
+namespace ProcessMaker\Nayra\Bpmn;
+
+use ProcessMaker\Nayra\Contracts\Bpmn\AssignmentInterface;
+use ProcessMaker\Nayra\Contracts\Bpmn\FormalExpressionInterface;
+
+/**
+ * Assignment class that implements AssignmentInterface
+ */
+class Assignment implements AssignmentInterface
+{
+    use BaseTrait;
+
+    /**
+     * Get the 'from' formal expression.
+     *
+     * @return FormalExpressionInterface|callable
+     */
+    public function getFrom()
+    {
+        return $this->getProperty(self::BPMN_PROPERTY_FROM);
+    }
+
+    /**
+     * Get the 'to' formal expression.
+     *
+     * @return FormalExpressionInterface|callable
+     */
+    public function getTo()
+    {
+        return $this->getProperty(self::BPMN_PROPERTY_TO);
+    }
+}

src/ProcessMaker/Nayra/Bpmn/CatchEventTrait.php

@@ -30,6 +30,7 @@ protected function initCatchEventTrait()
     {
         $this->setProperty(CatchEventInterface::BPMN_PROPERTY_EVENT_DEFINITIONS, new Collection);
         $this->setProperty(CatchEventInterface::BPMN_PROPERTY_PARALLEL_MULTIPLE, false);
+        $this->setProperty(CatchEventInterface::BPMN_PROPERTY_DATA_OUTPUT_ASSOCIATION, new Collection);
     }
 
     /**
@@ -42,6 +43,11 @@ public function getEventDefinitions()
         return $this->getProperty(CatchEventInterface::BPMN_PROPERTY_EVENT_DEFINITIONS);
     }
 
+    public function getDataOutputAssociations()
+    {
+        return $this->getProperty(CatchEventInterface::BPMN_PROPERTY_DATA_OUTPUT_ASSOCIATION);
+    }
+
     /**
      * Register catch events.
      *

src/ProcessMaker/Nayra/Bpmn/DataInputAssociation.php

@@ -0,0 +1,38 @@
+<?php
+
+namespace ProcessMaker\Nayra\Bpmn;
+
+use ProcessMaker\Nayra\Contracts\Bpmn\DataInputAssociationInterface;
+
+/**
+ * Transition to check if the activity is a loop not yet completed or a single instance
+ */
+class DataInputAssociation implements DataInputAssociationInterface
+{
+    use BaseTrait;
+
+    protected function initDataInputAssociation()
+    {
+        $this->properties[static::BPMN_PROPERTY_ASSIGNMENT] = new Collection;
+    }
+
+    public function getSource()
+    {
+        return $this->getProperty(static::BPMN_PROPERTY_SOURCES_REF);
+    }
+
+    public function getTarget()
+    {
+        return $this->getProperty(static::BPMN_PROPERTY_TARGET_REF);
+    }
+
+    public function getTransformation()
+    {
+        return $this->getProperty(static::BPMN_PROPERTY_TRANSFORMATION);
+    }
+
+    public function getAssignments()
+    {
+        return $this->getProperty(static::BPMN_PROPERTY_ASSIGNMENT);
+    }
+}

src/ProcessMaker/Nayra/Bpmn/DataOutputAssociation.php

@@ -0,0 +1,38 @@
+<?php
+
+namespace ProcessMaker\Nayra\Bpmn;
+
+use ProcessMaker\Nayra\Contracts\Bpmn\DataOutputAssociationInterface;
+
+/**
+ * DataOutputAssociation class for handling data output associations in BPMN processes
+ */
+class DataOutputAssociation implements DataOutputAssociationInterface
+{
+    use BaseTrait;
+
+    protected function initDataOutputAssociation()
+    {
+        $this->properties[static::BPMN_PROPERTY_ASSIGNMENT] = new Collection;
+    }
+
+    public function getSource()
+    {
+        return $this->getProperty(static::BPMN_PROPERTY_SOURCES_REF);
+    }
+
+    public function getTarget()
+    {
+        return $this->getProperty(static::BPMN_PROPERTY_TARGET_REF);
+    }
+
+    public function getTransformation()
+    {
+        return $this->getProperty(static::BPMN_PROPERTY_TRANSFORMATION);
+    }
+
+    public function getAssignments()
+    {
+        return $this->getProperty(static::BPMN_PROPERTY_ASSIGNMENT);
+    }
+}

src/ProcessMaker/Nayra/Bpmn/DataStoreTrait.php

@@ -100,4 +100,76 @@ public function getItemSubject()
     {
         return $this->itemSubject;
     }
+
+    /**
+     * Get data using dot notation.
+     *
+     * @param string $path Dot notation path (e.g., 'user.profile.name')
+     * @param mixed $default Default value if path doesn't exist
+     *
+     * @return mixed
+     */
+    public function getDotData($path, $default = null)
+    {
+        $keys = explode('.', $path);
+        $current = $this->data;
+
+        // Navigate through the path
+        foreach ($keys as $key) {
+            // Handle numeric keys for arrays
+            if (is_numeric($key)) {
+                $key = (int) $key;
+            }
+
+            if (!isset($current[$key])) {
+                return $default;
+            }
+
+            $current = $current[$key];
+        }
+
+        return $current;
+    }
+
+    /**
+     * Set data using dot notation.
+     *
+     * @param string $path Dot notation path (e.g., 'user.profile.name')
+     * @param mixed $value Value to set
+     *
+     * @return $this
+     */
+    public function setDotData($path, $value)
+    {
+        $keys = explode('.', $path);
+        $firstKey = $keys[0];
+        $current = &$this->data;
+
+        // Navigate to the parent of the target key
+        for ($i = 0; $i < count($keys) - 1; $i++) {
+            $key = $keys[$i];
+
+            // Handle numeric keys for arrays
+            if (is_numeric($key)) {
+                $key = (int) $key;
+            }
+
+            if (!isset($current[$key]) || !is_array($current[$key])) {
+                $current[$key] = [];
+            }
+            $current = &$current[$key];
+        }
+
+        // Set the final value
+        $finalKey = $keys[count($keys) - 1];
+        if (is_numeric($finalKey)) {
+            $finalKey = (int) $finalKey;
+        }
+
+        $current[$finalKey] = $value;
+        // Keep compatibility with putData method (required by PM Core)
+        $this->putData($firstKey, $this->data[$firstKey]);
+
+        return $this;
+    }
 }

src/ProcessMaker/Nayra/Bpmn/Models/EndEvent.php

@@ -2,6 +2,7 @@
 
 namespace ProcessMaker\Nayra\Bpmn\Models;
 
+use ProcessMaker\Nayra\Bpmn\Collection;
 use ProcessMaker\Nayra\Bpmn\EndEventTrait;
 use ProcessMaker\Nayra\Contracts\Bpmn\EndEventInterface;
 use ProcessMaker\Nayra\Model\DataInputAssociationInterface;
@@ -19,12 +20,18 @@ class EndEvent implements EndEventInterface
 {
     use EndEventTrait;
 
-    private $dataInputs;
-
-    private $dataInputAssociations;
-
     private $inputSet;
 
+    /**
+     * Initialize intermediate throw event.
+     */
+    protected function initEndEvent()
+    {
+        $this->properties[static::BPMN_PROPERTY_DATA_INPUT_ASSOCIATION] = new Collection();
+        $this->properties[static::BPMN_PROPERTY_DATA_INPUT] = new Collection;
+        $this->setProperty(static::BPMN_PROPERTY_EVENT_DEFINITIONS, new Collection);
+    }
+
     /**
      * Array map of custom event classes for the bpmn element.
      *
@@ -52,7 +59,7 @@ public function getTargetInstances(EventDefinitionInterface $message, TokenInter
      */
     public function getDataInputs()
     {
-        return $this->dataInputs;
+        return $this->getProperty(static::BPMN_PROPERTY_DATA_INPUT);
     }
 
     /**
@@ -62,7 +69,7 @@ public function getDataInputs()
      */
     public function getDataInputAssociations()
     {
-        return $this->getDataInputAssociations();
+        return $this->getProperty(static::BPMN_PROPERTY_DATA_INPUT_ASSOCIATION);
     }
 
     /**

src/ProcessMaker/Nayra/Bpmn/Models/IntermediateThrowEvent.php

@@ -13,16 +13,6 @@ class IntermediateThrowEvent implements IntermediateThrowEventInterface
 {
     use IntermediateThrowEventTrait;
 
-    /**
-     * @var \ProcessMaker\Nayra\Contracts\Bpmn\DataInputAssociationInterface[]
-     */
-    private $dataInputAssociations;
-
-    /**
-     * @var \ProcessMaker\Nayra\Contracts\Bpmn\DataInputInterface[]
-     */
-    private $dataInputs;
-
     /**
      * @var \ProcessMaker\Nayra\Contracts\Bpmn\InputSetInterface
      */
@@ -38,8 +28,8 @@ class IntermediateThrowEvent implements IntermediateThrowEventInterface
      */
     protected function initIntermediateThrowEvent()
     {
-        $this->dataInputAssociations = new Collection;
-        $this->dataInputs = new Collection;
+        $this->properties[static::BPMN_PROPERTY_DATA_INPUT_ASSOCIATION] = new Collection;
+        $this->properties[static::BPMN_PROPERTY_DATA_INPUT] = new Collection;
         $this->setProperty(static::BPMN_PROPERTY_EVENT_DEFINITIONS, new Collection);
     }
 
@@ -60,7 +50,7 @@ protected function getBpmnEventClasses()
      */
     public function getDataInputAssociations()
     {
-        return $this->dataInputAssociations;
+        return $this->getProperty(static::BPMN_PROPERTY_DATA_INPUT_ASSOCIATION);
     }
 
     /**
@@ -70,7 +60,7 @@ public function getDataInputAssociations()
      */
     public function getDataInputs()
     {
-        return $this->dataInputs;
+        return $this->getProperty(static::BPMN_PROPERTY_DATA_INPUT);
     }
 
     /**