<?php

namespace ProcessMaker\Jobs;

use Illuminate\Contracts\Queue\ShouldQueue;

use Illuminate\Database\Eloquent\ModelNotFoundException;

use Illuminate\Support\Facades\Log;

use ProcessMaker\Enums\ScriptExecutorType;

use ProcessMaker\Exception\ConfigurationException;

use ProcessMaker\Exception\ScriptException;

use ProcessMaker\Facades\Metrics;

use ProcessMaker\Facades\WorkflowManager;

use ProcessMaker\Managers\DataManager;

use ProcessMaker\Models\Process as Definitions;

use ProcessMaker\Models\ProcessRequest;

use ProcessMaker\Models\ProcessRequestToken;

use ProcessMaker\Models\Script;

use ProcessMaker\Models\ScriptExecutor;

use ProcessMaker\Nayra\Contracts\Bpmn\ScriptTaskInterface;

use Throwable;

class RunScriptTask extends BpmnAction implements ShouldQueue

{

public $definitionsId;

public $instanceId;

public $tokenId;

public $data;

public $attemptNum;

/**

* Create a new job instance.

*

* @param Definitions $definitions

* @param ProcessRequest $instance

* @param ProcessRequestToken $token

* @param array $data

*/

public function __construct(Definitions $definitions, ProcessRequest $instance, ProcessRequestToken $token, array $data, $attemptNum = 1)

{

$this->onQueue('bpmn');

$this->definitionsId = $definitions->getKey();

$this->instanceId = $instance->getKey();

$this->tokenId = $token->getKey();

$this->elementId = $token->getProperty('element_ref');

$this->data = $data;

$this->attemptNum = $attemptNum;

}

/**

* Execute the script task.

*

* @return void

*/

public function action(ProcessRequestToken $token = null, ScriptTaskInterface $element = null, ProcessRequest $instance)

{

// Exit if the task was completed or closed

if (!$token || !$element) {

return;

}

$scriptRef = $element->getProperty('scriptRef');

$configuration = json_decode($element->getProperty('config'), true);

// Check to see if we've failed parsing. If so, let's convert to empty array.

if ($configuration === null) {

$configuration = [];

}

$errorHandling = null;

$scriptExecutor = null;

try {

if (empty($scriptRef)) {

$code = $element->getScript();

if (empty($code)) {

throw new ConfigurationException(__('No code or script assigned to ":name"', ['name' => $element->getName()]));

}

$language = Script::scriptFormat2Language($element->getProperty('scriptFormat', 'application/x-php'));

$script = new Script([

'code' => $code,

'language' => $language,

'run_as_user_id' => Script::defaultRunAsUser()->id,

'script_executor_id' => ScriptExecutor::initialExecutor($language)->id,

]);

} else {

$script = Script::find($scriptRef);

if (!$script) {

throw new ConfigurationException(__('Script ":id" not found', ['id' => $scriptRef]));

}

$scriptExecutor = $script->scriptExecutor;

$script = $script->versionFor($instance);

}

$errorHandling = new ErrorHandling($element, $token);

$errorHandling->setDefaultsFromScript($script);

$this->unlock();

$dataManager = new DataManager();

$data = $dataManager->getData($token);

$metadata = [

'script_task' => [

'script_id' => $scriptRef,

'definition_id' => $this->definitionsId,

'instance_id' => $this->instanceId,

'token_id' => $this->tokenId,

'data' => $data,

'attempts' => $this->attemptNum,

],

];

$response = $script->runScript($data, $configuration, $token->getId(), $errorHandling->timeout(), 1, $metadata);

$this->updateData($response);

Metrics::counterInc(

'script_task_completed_total',

'Total number of script tasks completed',

[

'activity_id' => $element->getId(),

'activity_name' => $element->getName(),

'process_id' => $this->definitionsId,

'request_id' => $this->instanceId,

'script_executor' => $scriptExecutor ? $scriptExecutor->title : 'inline',

]

);

} catch (ConfigurationException $exception) {

$this->unlock();

$this->updateData(['output' => $exception->getMessageForData($token)]);

} catch (Throwable $exception) {

$message = $exception->getMessage();

$finalAttempt = true;

if ($errorHandling) {

[$message, $finalAttempt] = $errorHandling->handleRetries($this, $exception);

} else {

$message = $exception->getMessage();

}

if ($finalAttempt) {

$token->setStatus(ScriptTaskInterface::TOKEN_STATE_FAILING);

}

$error = $element->getRepository()->createError();

$error->setName($message);

$token->setProperty('error', $error);

$exceptionClass = get_class($exception);

$modifiedException = new $exceptionClass($message);

$token->logError($modifiedException, $element);

Log::error('Script failed: ' . $scriptRef . ' - ' . $message);

Log::error($exception->getTraceAsString());

}

}

private function updateData($response)

{

$this->withUpdatedContext(function ($engine, $instance, $element, $processModel, $token) use ($response) {

// Exit if the task was completed or closed

if (!$token || !$element) {

return;

}

// Update data

if (is_array($response['output'])) {

// Validate data

WorkflowManager::validateData($response['output'], $processModel, $element);

$dataManager = new DataManager();

$dataManager->updateData($token, $response['output']);

$engine->runToNextState();

}

$element->complete($token);

$this->engine = $engine;

$this->instance = $instance;

});

}

/**

* When Job fails

*/

public function failed(Throwable $exception)

{

if (!$this->tokenId) {

Log::error('Script failed: ' . $exception->getMessage());

return;

}

if (get_class($exception) === 'Illuminate\\Queue\\MaxAttemptsExceededException') {

$message = 'This is a type MaxAttemptsExceededException exception, it appears '

. 'that the global value configured in config/horizon.php has been exceeded '

. 'in the retries. Please consult with your main administrator.';

Log::error($message);

}

Log::error('Script (#' . $this->tokenId . ') failed: ' . $exception->getMessage());

$token = ProcessRequestToken::find($this->tokenId);

if ($token) {

$element = $token->getBpmnDefinition();

$token->setStatus(ScriptTaskInterface::TOKEN_STATE_FAILING);

if (method_exists($element, 'getRepository')) {

$error = $element->getRepository()->createError();

$error->setName($exception->getMessage());

$token->setProperty('error', $error);

}

Log::error($exception->getTraceAsString());

$token->save();

}

}

}