App\EventListener\Submission\Transfer\BpmListener

Complexity

Total Complexity

7

Size/Duplication

Total Lines	86
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
B	postPersist()	0	49	6

<?php

namespace App\EventListener\Submission\Transfer;

use App\Entity\Submission;
use App\Entity\Scenario;
use App\Service\SubmissionService;
use Ds\Component\Api\Api\Api;

The type Ds\Component\Api\Api\Api was not found. Maybe you did not declare it correctly or list all dependencies?

use Ds\Component\Camunda\Model\Variable;

The type Ds\Component\Camunda\Model\Variable was not found. Maybe you did not declare it correctly or list all dependencies?

use Ds\Component\Camunda\Query\ProcessDefinitionParameters;

The type Ds\Component\Camunda\Query\ProcessDefinitionParameters was not found. Maybe you did not declare it correctly or list all dependencies?

use Ds\Component\Config\Service\ConfigService;

The type Ds\Component\Config\Service\ConfigService was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\DependencyInjection\ContainerInterface;

The type Symfony\Component\DependencyInjection\ContainerInterface was not found. Maybe you did not declare it correctly or list all dependencies?

/**
 * Class BpmListener
 */
final class BpmListener
{
    /**
     * @var \Symfony\Component\DependencyInjection\ContainerInterface
     */
    private $container;

    /**
     * @var \Ds\Component\Api\Api\Api
     */
    private $api;

    /**
     * @var \Ds\Component\Config\Service\ConfigService
     */
    private $configService;

    /**
     * @var \App\Service\SubmissionService
     */
    private $submissionService;

    /**
     * Constructor
     *
     * @param \Symfony\Component\DependencyInjection\ContainerInterface $container
     */
    public function __construct(ContainerInterface $container)
    {
        $this->container = $container;
    }

    /**
     * Forward the submission to the bpm service
     *
     * @param \App\Entity\Submission $submission
     */
    public function postPersist(Submission $submission)
    {
        // Circular reference error workaround
        // @todo Look into fixing this
        $this->api = $this->container->get(Api::class);
        $this->configService = $this->container->get(ConfigService::class);
        $this->submissionService = $this->container->get(SubmissionService::class);
        //

        $scenario = $submission->getScenario();

        if (Scenario::TYPE_BPM !== $scenario->getType()) {
            return;
        }

//        $parameters = new ProcessDefinitionParameters;
//        $parameters->setKey($scenario->getConfig()['process_definition_key']);
//        $xml = $this->api->camunda->processDefinition->getXml(null, $parameters);
        $service = $scenario->getService();
        $parameters = new ProcessDefinitionParameters;
        $variables = [];
        $variables[] = new Variable($this->configService->get('app.bpm.variables.api_url'), '');
        $variables[] = new Variable($this->configService->get('app.bpm.variables.api_user'), '');
        $variables[] = new Variable($this->configService->get('app.bpm.variables.api_key'), '');
        $variables[] = new Variable($this->configService->get('app.bpm.variables.service_uuid'), $service->getUuid());
        $variables[] = new Variable($this->configService->get('app.bpm.variables.scenario_uuid'), $scenario->getUuid());
        $config = $scenario->getConfig();

        if (array_key_exists('process_custom_data', $config)
            && array_key_exists('enabled', $config['process_custom_data'])
            && $config['process_custom_data']['enabled']
            && array_key_exists('value', $config['process_custom_data'])
        ) {
            $variables[] = new Variable($this->configService->get('app.bpm.variables.scenario_custom_data'), $config['process_custom_data']['value'], Variable::TYPE_JSON);
        }

        $variables[] = new Variable($this->configService->get('app.bpm.variables.identity'), $submission->getIdentity());
        $variables[] = new Variable($this->configService->get('app.bpm.variables.identity_uuid'), $submission->getIdentityUuid());
        $variables[] = new Variable($this->configService->get('app.bpm.variables.submission_uuid'), $submission->getUuid());
        $variables[] = new Variable($this->configService->get('app.bpm.variables.start_data'), $submission->getData(), Variable::TYPE_JSON);
        $parameters
            ->setVariables($variables)
            ->setKey($scenario->getConfig()['process_definition_key'])
            ->setTenantId($scenario->getTenant());
        $this->api->get('workflow.process_definition')->start(null, $parameters);
        $submission->setState(Submission::STATE_TRANSFERRED);
        $manager = $this->submissionService->getManager();
        $manager->persist($submission);
        $manager->flush();
    }
}