Facile\MongoDbBundle\Capsule\Collection

Complexity

Total Complexity

10

Size/Duplication

Total Lines	146
Duplicated Lines	43.84 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	1	Features	1

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	find()	0	8	1
A	findOne()	8	8	1
A	findOneAndUpdate()	12	12	1
A	findOneAndDelete()	8	8	1
A	deleteMany()	8	8	1
A	deleteOne()	8	8	1
A	replaceOne()	12	12	1
A	insertOne()	8	8	1
A	startQueryLogging()	0	13	1

<?php

declare(strict_types=1);

namespace Facile\MongoDbBundle\Capsule;

use Facile\MongoDbBundle\Services\Loggers\DataCollectorLoggerInterface;
use Facile\MongoDbBundle\Services\Loggers\Model\LogEvent;
use MongoDB\Collection as MongoCollection;
use MongoDB\Driver\Manager;

/**
 * Class Collection.
 */
final class Collection extends MongoCollection
{
    /**
     * @var DataCollectorLoggerInterface
     */
    private $logger;

    /**
     * Collection constructor.
     *
     * @param Manager                      $manager
     * @param string                       $databaseName
     * @param string                       $collectionName
     * @param array                        $options
     * @param DataCollectorLoggerInterface $logger
     */
    public function __construct(Manager $manager, $databaseName, $collectionName, array $options = [], DataCollectorLoggerInterface $logger)
    {
        parent::__construct($manager, $databaseName, $collectionName, $options);
        $this->logger = $logger;
    }

    /**
     * {@inheritdoc}
     */
    public function find($filter = [], array $options = [])
    {
        $event = $this->startQueryLogging($filter, __FUNCTION__);
        $result = parent::find($filter, $options);
        $this->logger->logQuery($event);

        return $result;
    }

    /**
     * {@inheritdoc}
     */
    public function findOne($filter = [], array $options = [])

This method seems to be duplicated in your project.

    {
        $event = $this->startQueryLogging($filter, __FUNCTION__);
        $result = parent::findOne($filter, $options);
        $this->logger->logQuery($event);

        return $result;
    }

    /**
     * {@inheritdoc}
     */
    public function findOneAndUpdate($filter, $update, array $options = [])

This method seems to be duplicated in your project.

    {
        $data = [
            "filter" => $filter,
            "update" => $update,
        ];
        $event = $this->startQueryLogging($data, __FUNCTION__);
        $result = parent::findOneAndUpdate($filter, $update, $options);
        $this->logger->logQuery($event);

        return $result;
    }

    /**
     * {@inheritdoc}
     */
    public function findOneAndDelete($filter, array $options = [])

This method seems to be duplicated in your project.

    {
        $event = $this->startQueryLogging($filter, __FUNCTION__);
        $result = parent::findOneAndDelete($filter, $options);
        $this->logger->logQuery($event);

        return $result;
    }

    /**
     * {@inheritdoc}
     */
    public function deleteMany($filter, array $options = [])

This method seems to be duplicated in your project.

    {
        $event = $this->startQueryLogging($filter, __FUNCTION__);
        $result = parent::deleteMany($filter, $options);
        $this->logger->logQuery($event);

        return $result;
    }

    /**
     * {@inheritdoc}
     */
    public function deleteOne($filter, array $options = [])

This method seems to be duplicated in your project.

    {
        $event = $this->startQueryLogging($filter, __FUNCTION__);
        $result = parent::deleteOne($filter, $options);
        $this->logger->logQuery($event);

        return $result;
    }

    /**
     * {@inheritdoc}
     */
    public function replaceOne($filter, $replacement, array $options = [])

This method seems to be duplicated in your project.

    {
        $data = [
            "filter" => $filter,
            "replacement" => $replacement,
        ];
        $event = $this->startQueryLogging($data, __FUNCTION__);
        $result = parent::replaceOne($filter, $replacement, $options);
        $this->logger->logQuery($event);

        return $result;
    }

    /**
     * {@inheritdoc}
     */
    public function insertOne($document, array $options = [])

This method seems to be duplicated in your project.

    {
        $event = $this->startQueryLogging($document, __FUNCTION__);
        $result = parent::insertOne($document, $options);
        $this->logger->logQuery($event);

        return $result;
    }

    /**
     * @param array  $data
     * @param string $method
     *
     * @return LogEvent
     */
    private function startQueryLogging(array $data, string $method): LogEvent
    {
        $debugInfo = $this->__debugInfo();

        $event = new LogEvent();
        $event->setData($data);
        $event->setMethod($method);
        $event->setCollection($debugInfo['collectionName']);

        $this->logger->startLogging($event);

        return $event;
    }
}