OldTown\Workflow\Engine\Functions

Complexity

Total Complexity

4

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	9

Test Coverage

Coverage

76.47%

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
B	executeFunction()	0	28	4

<?php
/**
 * @link https://github.com/old-town/old-town-workflow
 * @author  Malofeykin Andrey  <and-rey2@yandex.ru>
 */
namespace OldTown\Workflow\Engine;

use OldTown\PropertySet\PropertySetInterface;
use OldTown\Workflow\Exception\InternalWorkflowException;
use OldTown\Workflow\Exception\WorkflowException;
use OldTown\Workflow\Loader\FunctionDescriptor;
use OldTown\Workflow\TransientVars\TransientVarsInterface;


/**
 * Class Functions
 *
 * @package OldTown\Workflow\Engine
 */
class Functions extends AbstractEngine implements FunctionsInterface
{
    /**
     * @param FunctionDescriptor $function
     * @param TransientVarsInterface $transientVars
     * @param PropertySetInterface $ps
     *
     * @throws WorkflowException
     * @throws InternalWorkflowException
     */
    public function executeFunction(FunctionDescriptor $function, TransientVarsInterface $transientVars, PropertySetInterface $ps)
    {
        if (null !== $function) {
            $type = $function->getType();

            $argsOriginal = $function->getArgs();

            $workflowManager = $this->getWorkflowManager();

            $args = $workflowManager->getEngineManager()->getArgsEngine()->prepareArgs($argsOriginal, $transientVars, $ps);

            $provider = $workflowManager->getResolver()->getFunction($type, $args);

            if (null === $provider) {
                $workflowManager->getContext()->setRollbackOnly();
                $errMsg = 'Не загружен провайдер для функции';
                throw new WorkflowException($errMsg);
            }

            try {
                $provider->execute($transientVars, $args, $ps);
            } catch (WorkflowException $e) {
                $workflowManager->getContext()->setRollbackOnly();
                /** @var  WorkflowException $e*/
                throw $e;
            }
        }
    }
}