FOUR-8554 Refactor Sub Processes functions to use Nayra BPMN engine

ProcessMaker/Console/Commands/Consumer.php

@@ -4,6 +4,7 @@
 
 use Exception;
 use Illuminate\Console\Command;
+use Illuminate\Support\Facades\Log;
 use ProcessMaker\Facades\MessageBrokerService;
 
 class Consumer extends Command
@@ -40,7 +41,8 @@ public function handle()
         try {
             MessageBrokerService::worker();
         } catch (Exception $e) {
-            $this->warn($e->getMessage());
+            Log::error($e->getMessage());
+            Log::error($e->getTraceAsString());
         }
     }
 }

ProcessMaker/Models/ProcessRequest.php

@@ -907,4 +907,18 @@ public function getMedia(string $collectionName = 'default', $filters = []): Col
     {
         return \ProcessMaker\Models\Media::getFilesRequest($this);
     }
+
+    public function getErrors()
+    {
+        if ($this->errors) {
+            return $this->errors;
+        }
+        // select tokens with errors
+        return $this->tokens()
+            ->select('token_properties->error as message', 'created_at', 'element_name')
+            ->where('status', '=', ActivityInterface::TOKEN_STATE_FAILING)
+            ->limit(10)
+            ->get()
+            ->toArray();
+    }
 }

ProcessMaker/Models/ProcessRequestToken.php

@@ -823,7 +823,7 @@ public function logError(Throwable $error, FlowElementInterface $bpmnElement)
 
     public function updateTokenProperties()
     {
-        $allowed = ['conditionals', 'loopCharacteristics', 'data'];
+        $allowed = ['conditionals', 'loopCharacteristics', 'data', 'error'];
         $this->token_properties = array_filter(
             $this->getProperties(),
             function ($key) use ($allowed) {

ProcessMaker/Nayra/Managers/WorkflowManagerRabbitMq.php

@@ -480,17 +480,25 @@ private function serializeState(ProcessRequest $instance)
             $tokensRows = [];
             $tokens = $request->tokens()->where('status', '!=', 'CLOSED')->where('status', '!=', 'TRIGGERED')->get();
             foreach ($tokens as $token) {
-                $tokensRows[] = array_merge($token->token_properties ?: [], [
+                $tokenRow = array_merge($token->token_properties ?: [], [
                     'id' => $token->uuid,
                     'status' => $token->status,
                     'index' => $token->element_index,
                     'element_id' => $token->element_id,
                     'created_at' => $token->created_at->getTimestamp(),
                 ]);
+                if ($token->subprocess_request_id) {
+                    $subRequest = ProcessRequest::select(['process_version_id', 'uuid'])
+                        ->find($token->subprocess_request_id);
+                    $tokenRow['subprocess_request_id'] = $subRequest->uuid;
+                    $tokenRow['subprocess_request_version'] = $subRequest->process_version_id;
+                }
+                $tokensRows[] = $tokenRow;
             }
 
             return [
                 'id' => $request->uuid,
+                'process_version_id' => $request->process_version_id,
                 'callable_id' => $request->callable_id,
                 'collaboration_uuid' => $request->collaboration_uuid,
                 'data' => $request->data,

ProcessMaker/Nayra/Repositories/Deserializer.php

@@ -12,6 +12,7 @@
 use ProcessMaker\Nayra\Contracts\Bpmn\EventDefinitionInterface;
 use ProcessMaker\Nayra\Contracts\Bpmn\TokenInterface;
 use ProcessMaker\Nayra\Contracts\Engine\ExecutionInstanceInterface;
+use ProcessMaker\Nayra\Contracts\Storage\BpmnDocumentInterface;
 use ProcessMaker\Repositories\BpmnDocument;
 use ProcessMaker\Repositories\DefinitionsRepository;
 use ProcessMaker\Repositories\ExecutionInstanceRepository;
@@ -56,7 +57,7 @@ private function findProcessDefinition($modelId): BpmnDocument
             $version = ProcessVersion::find($modelId);
             $model = $version->process;
 
-            $definition = new BpmnDocument($model);
+            $definition = app(BpmnDocumentInterface::class, ['process' => $model]);
             $definition->setFactory($this->factory);
             $definition->loadXML($version->bpmn);
 

ProcessMaker/Nayra/Repositories/PersistenceHandler.php

@@ -116,6 +116,9 @@ public function save(array $transaction)
                 case 'instance_updated':
                     $this->persistInstanceUpdated($transaction);
                     break;
+                case 'call_activity_activated':
+                    $this->persistCallActivityActivated($transaction);
+                    break;
                 case 'schedule_date':
                     $this->persistScheduleDate($transaction);
                     break;
@@ -139,7 +142,8 @@ public function save(array $transaction)
             }
         } catch (Exception $error) {
             Log::error($error->getMessage());
-            if ($transaction['token']) {
+            Log::error($error->getTraceAsString());
+            if (!empty($transaction['token'])) {
                 $token = $this->deserializer->unserializeToken($transaction['token']);
                 $request = $token->getInstance();
                 if ($request && $request instanceof ProcessRequest) {

ProcessMaker/Nayra/Repositories/PersistenceTokenTrait.php

@@ -2,8 +2,12 @@
 
 namespace ProcessMaker\Nayra\Repositories;
 
+use ProcessMaker\Repositories\TokenRepository;
+
 trait PersistenceTokenTrait
 {
+    protected TokenRepository $tokenRepository;
+
     /**
      * Persists instance and token data when a token arrives to an activity
      *
@@ -208,4 +212,17 @@ public function persistEventBasedGatewayActivated(array $transaction)
         $consumedTokens = $this->deserializer->unserializeTokensCollection($transaction['consumed_tokens']);
         $this->tokenRepository->persistEventBasedGatewayActivated($gateway, $passedToken, $consumedTokens);
     }
+
+    /**
+     * Persists a Call Activity Activated
+     *
+     * @param array $transaction
+     */
+    public function persistCallActivityActivated(array $transaction)
+    {
+        $token = $this->deserializer->unserializeToken($transaction['token']);
+        $subprocessInstance = $this->deserializer->unserializeInstance($transaction['subprocess']);
+        $startId = $transaction['start_id'];
+        $this->tokenRepository->persistCallActivityActivated($token, $subprocessInstance, $startId);
+    }
 }

ProcessMaker/Repositories/TokenRepository.php

@@ -8,6 +8,7 @@
 use ProcessMaker\Models\ProcessCollaboration;
 use ProcessMaker\Models\ProcessRequest as Instance;
 use ProcessMaker\Models\ProcessRequestToken as Token;
+use ProcessMaker\Models\ProcessRequestToken;
 use ProcessMaker\Models\User;
 use ProcessMaker\Nayra\Bpmn\Collection;
 use ProcessMaker\Nayra\Bpmn\Models\EndEvent;
@@ -201,7 +202,7 @@ private function assignTaskUser(ActivityInterface $activity, TokenInterface $tok
      * Persists instance and token data when a token within an activity change to error state
      *
      * @param ActivityInterface $activity
-     * @param TokenInterface $token
+     * @param TokenInterface|ProcessRequestToken $token
      *
      * @return mixed
      */

resources/js/requests/components/RequestErrors.vue

@@ -63,7 +63,7 @@
 <style lang="scss" scoped>
     .error-body {
       word-break: break-word;
-      overflow-x: scroll;
+      overflow-x: auto;
       font-size: 87.5%;
       max-width: 992px; // Not a fan of hard-coding this value, but it's equivalent to $screen-md-max
     }

resources/views/requests/show.blade.php

@@ -398,7 +398,7 @@ class="d-inline-flex pull-left align-items-center" :input-data="requestBy" displ
           canViewPrint: @json($canPrintScreens),
           status: 'ACTIVE',
           userRequested: [],
-          errorLogs: @json(['data' => $request->errors]),
+          errorLogs: @json(['data' => $request->getErrors()]),
           disabled: false,
           retryDisabled: false,
           packages: [],