<?php

namespace ProcessMaker\Jobs;

use Illuminate\Contracts\Queue\ShouldQueue;

use ProcessMaker\Models\Process as Definitions;

use ProcessMaker\Nayra\Contracts\Bpmn\ActivityInterface;

use ProcessMaker\Nayra\Contracts\Bpmn\TokenInterface;

use ProcessMaker\Nayra\Contracts\Engine\ExecutionInstanceInterface;

class CompleteActivity extends BpmnAction implements ShouldQueue

{

public $definitionsId;

public $instanceId;

public $tokenId;

public $data;

/**

* Create a new job instance.

*

* @return void

*/

public function __construct(Definitions $definitions, ExecutionInstanceInterface $instance, TokenInterface $token, array $data)

{

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

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

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

$this->data = $data;

}

/**

* Execute the job.

*

* @return void

*/

public function action(TokenInterface $token, ActivityInterface $element, array $data)

{

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

//@todo requires a class to manage the data access and control the updates

foreach ($data as $key => $value) {

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

}

$element->complete($token);

}

}