<?php

namespace ProcessMaker\Jobs;

use Illuminate\Contracts\Queue\ShouldQueue;

use Illuminate\Support\Facades\Log;

use ProcessMaker\Exception\ScriptException;

use ProcessMaker\Facades\WorkflowManager;

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;

/**

* Create a new job instance.

*

* @param \ProcessMaker\Models\Process $definitions

* @param \ProcessMaker\Models\ProcessRequest $instance

* @param \ProcessMaker\Models\ProcessRequestToken $token

* @param array $data

*/

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

{

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

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

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

$this->data = $data;

}

/**

* Execute the script task.

*

* @return void

*/

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

{

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

Log::info('Script started: ' . $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 = [];

}

$dataStore = $token->getInstance()->getDataStore();

$data = $dataStore->getData();

try {

if (empty($scriptRef)) {

$code = $element->getScript();

if (empty($code)) {

throw new ScriptException(__('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);

}

$this->unlockInstance($instance->getKey());

$response = $script->runScript($data, $configuration);

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

$dataStore = $token->getInstance()->getDataStore();

// Update data

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

// Validate data

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

foreach ($response['output'] as $key => $value) {

$dataStore->putData($key, $value);

}

}

$element->complete($token);

$this->engine = $engine;

$this->instance = $instance;

});

Log::info('Script completed: ' . $scriptRef);

} catch (Throwable $exception) {

// Change to error status

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

$token->getInstance()->logError($exception, $element);

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

}

}

}