Application\Repository\ExportRepository

Complexity

Total Complexity

5

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	insertMultiple()	0	14	3
A	updateCards()	0	38	2

<?php

declare(strict_types=1);

namespace Application\Repository;

use Application\Model\Card;
use Application\Model\Export;
use Application\Model\User;

/**
 * @extends AbstractRepository<Export>
 */
class ExportRepository extends AbstractRepository
{
    public function updateCards(Export $export, array $collectionIds, array $cardIds): int
    {
        // Inject all collections and cards picked one-by-one
        $this->insertMultiple($export, 'export_collection', 'collection_id', $collectionIds);
        $this->insertMultiple($export, 'export_card', 'card_id', $cardIds);

        $connection = $this->getEntityManager()->getConnection();
        $params = ['export' => $export->getId()];

        // "Expand" collections into cards
        $sql = <<<STRING
                REPLACE INTO export_card (export_id, card_id)
                SELECT export_id, card_id FROM card_collection
                INNER JOIN export_collection
                ON card_collection.collection_id = export_collection.collection_id
                AND export_collection.export_id = :export
            STRING;
        $connection->executeStatement($sql, $params);

        /** @var CardRepository $cardRepository */
        $cardRepository = $this->getEntityManager()->getRepository(Card::class);
        $cardSubQuery = $cardRepository->getAccessibleSubQuery(User::getCurrent());

        // Remove cards to which we have no access
        if ($cardSubQuery) {
            $connection->executeStatement('DELETE FROM export_card WHERE export_id = :export AND card_id NOT IN (' . $cardSubQuery . ')', $params);
        }

        $cardCount = $connection->fetchOne('SELECT COUNT(*) FROM export_card WHERE export_id = :export', $params);

        $params = [
            'export' => $export->getId(),
            'cardCount' => $cardCount,
        ];

        $connection->executeStatement('UPDATE export SET card_count = :cardCount WHERE id = :export', $params);

        return (int) $cardCount;
    }

    private function insertMultiple(Export $export, string $table, string $field, array $ids): void
    {
        $connection = $this->getEntityManager()->getConnection();

        $cardValues = [];
        $exportId = $export->getId();
        foreach ($ids as $id) {
            $cardValues[] = '(' . $exportId . ', ' . $id . ')';
        }

        // Inject all card picked one-by-oneS
        if ($cardValues) {
            $values = implode(', ', $cardValues);
            $connection->executeStatement("REPLACE INTO $table (export_id, $field) VALUES $values");
        }
    }
}