OroCRM\Bundle\ChannelBundle\Migrations\Schema\v1_6\UpdateChannelIntegrationsMode

Complexity

Total Complexity

6

Size/Duplication

Total Lines	75
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	3
Bugs	3	Features	3

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getDescription()	0	9	1
A	execute()	0	4	1
A	updateChannelIntegrationsMode()	0	13	2
A	getChannelIntegrations()	0	21	1

<?php

namespace OroCRM\Bundle\ChannelBundle\Migrations\Schema\v1_6;

use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Types\Type;

use Psr\Log\LoggerInterface;

use Oro\Bundle\MigrationBundle\Migration\ArrayLogger;
use Oro\Bundle\MigrationBundle\Migration\ParametrizedMigrationQuery;

use OroCRM\Bundle\ChannelBundle\Entity\Channel;

class UpdateChannelIntegrationsMode extends ParametrizedMigrationQuery
{
    /** @var int */
    protected $mode;

    /**
     * @param int $mode
     */
    public function __construct($mode)
    {
        $this->mode = $mode;
    }

    /**
     * {@inheritdoc}
     */
    public function getDescription()
    {
        $logger = new ArrayLogger();
        $logger->info('Set Channel Integrations mods restricted');

        $this->updateChannelIntegrationsMode($logger);

        return $logger->getMessages();
    }

    /**
     * {@inheritdoc}
     */
    public function execute(LoggerInterface $logger)
    {
        $this->updateChannelIntegrationsMode($logger, false);
    }

    protected function updateChannelIntegrationsMode(LoggerInterface $logger, $dryRun = true)
    {
        $ids = $this->getChannelIntegrations($logger);
        $updateSql = 'UPDATE oro_integration_channel SET edit_mode = :edit_mode WHERE id IN (:ids)';
        $params = ['ids' => $ids, 'edit_mode' => $this->mode];
        $types  = ['ids' => Connection::PARAM_INT_ARRAY, 'edit_mode' => Type::INTEGER];

        $this->logQuery($logger, $updateSql, $params, $types);

        if (!$dryRun) {
            $this->connection->executeUpdate($updateSql, $params, $types);
        }
    }

    /**
     * @param LoggerInterface $logger
     *
     * @return array
     */
    protected function getChannelIntegrations(LoggerInterface $logger)
    {
        $sql = 'SELECT i.id FROM oro_integration_channel i' .
               ' INNER JOIN orocrm_channel c ON c.data_source_id = i.id ' .
               ' WHERE c.status = :status';

        $params       = ['status' => Channel::STATUS_ACTIVE];
        $types        = ['status' => Type::BOOLEAN];

        $this->logQuery($logger, $sql, $params, $types);
        $integrations = $this->connection->fetchAll($sql, $params, $types);

        return array_reduce(
            $integrations,
            function ($ids, $integration) {
                $ids[] = $integration['id'];
                return $ids;
            },
            []
        );
    }
}