Facile\MongoDbBundle\Capsule\Collection

Complexity

Total Complexity

4

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	1	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	find()	0	8	1
A	insertOne()	0	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 insertOne($document, array $options = [])
    {
        $event = $this->startQueryLogging($document, __FUNCTION__);
        $result = parent::insertOne($document, $options);
        $this->logger->logQuery($event);

        return $result;
    }

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

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

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

        return $event;
    }
}