Facile\MongoDbBundle\Services\Explain\ExplainCommandBuilder

Complexity

Total Complexity

18

Size/Duplication

Total Lines	115
Duplicated Lines	5.22 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
D	createCommandArgs()	0	40	10
A	getCountArgs()	3	12	3
A	getFindArgs()	3	13	3
A	getDistinctArgs()	0	7	1
A	getDeleteArgs()	0	9	1

<?php declare(strict_types=1);

namespace Facile\MongoDbBundle\Services\Explain;

use Facile\MongoDbBundle\Models\Query;
use MongoDB\Driver\Command;

class ExplainCommandBuilder
{
    /**
     * @param Query  $query
     * @param string $verbosity
     *
     * @return array
     * @throws \Exception
     */
    public static function createCommandArgs(
        Query $query,
        string $verbosity = ExplainQueryService::VERBOSITY_ALL_PLAN_EXECUTION
    ): array
    {
        $args = [
            $query->getMethod() => $query->getCollection(),
        ];
        switch($query->getMethod()) {
            case 'count':
                $args += self::getCountArgs($query);
                break;
            case 'find':
            case 'findOne':
            case 'findOneAndUpdate':
            case 'findOneAndDelete':
                $args = self::getFindArgs($query);
                break;
            case 'distinct':
                $args += self::getDistinctArgs($query);
                break;
            case 'deleteOne':
            case 'deleteMany':
                $args = self::getDeleteArgs($query);
                break;
            case 'aggregate':
                return [
                    'aggregate' => $query->getCollection(),
                    'pipeline' => $query->getData(),
                    'explain' => true,
                ];
            default:
                throw new \Exception('Unable to recognize query to explain');
        }

        return [
            'explain' => $args,
            'verbosity' => $verbosity,
        ];
    }

    /**
     * @param Query $query
     *
     * @return array
     */
    private static function getCountArgs(Query $query): array
    {
        $args = [
            'query' => $query->getFilters(),
        ];

        foreach (['limit', 'hint', 'skip'] as $supportedOption) {

This code seems to be duplicated across your project.

            $args += (isset($query->getOptions()[$supportedOption]) ? [$supportedOption => $query->getOptions()[$supportedOption]] : []);
        }

        return $args;
    }

    /**
     * @param Query $query
     *
     * @return array
     */
    private static function getFindArgs(Query $query): array
    {
        $args = [
            'find' => $query->getCollection(),
            'filter' => $query->getFilters(),
        ];

        foreach (['sort', 'projection', 'hint', 'skip', 'limit'] as $supportedOption) {

This code seems to be duplicated across your project.

            $args += (isset($query->getOptions()[$supportedOption]) ? [$supportedOption => $query->getOptions()[$supportedOption]] : []);
        }

        return $args;
    }

    /**
     * @param Query $query
     *
     * @return array
     */
    private static function getDistinctArgs(Query $query): array
    {
        return [
            'key' => $query->getData()['fieldName'],
            'query' => $query->getFilters(),
        ];
    }

    /**
     * @param Query $query
     *
     * @return array
     */
    private static function getDeleteArgs(Query $query): array
    {
        return [
            'delete' => $query->getCollection(),
            'deletes' => [
                ['q' => $query->getFilters(), 'limit' => $query->getOptions()['limit'] ?? 0,]
            ]
        ];
    }
}