DDDominio\EventSourcing\Snapshotting\Vendor\DoctrineDbalSnapshotStore

Complexity

Total Complexity

9

Size/Duplication

Total Lines	107
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	addSnapshot()	0	11	1
A	findLastSnapshot()	0	10	2
A	findNearestSnapshotToVersion()	0	11	2
A	initialize()	0	20	2
A	initialized()	0	4	1

<?php

namespace DDDominio\EventSourcing\Snapshotting\Vendor;

use DDDominio\EventSourcing\EventStore\InitializableInterface;
use DDDominio\EventSourcing\Snapshotting\SnapshotInterface;
use DDDominio\EventSourcing\Snapshotting\SnapshotStoreInterface;
use DDDominio\EventSourcing\Serialization\SerializerInterface;
use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Schema\Schema;

class DoctrineDbalSnapshotStore implements SnapshotStoreInterface, InitializableInterface
{
    const SNAPSHOTS_TABLE = 'snapshots';

    /**
     * @var Connection
     */
    private $connection;

    /**
     * @var SerializerInterface
     */
    private $serializer;

    /**
     * @param Connection $connection
     * @param SerializerInterface $serializer
     */
    public function __construct(Connection $connection, SerializerInterface $serializer)
    {
        $this->connection = $connection;
        $this->serializer = $serializer;
    }

    /**
     * @param SnapshotInterface $snapshot
     */
    public function addSnapshot($snapshot)
    {
        $stmt = $this->connection
            ->prepare('INSERT INTO snapshots (aggregate_type, aggregate_id, type, version, snapshot) VALUES (:aggregateType, :aggregateId, :type, :version, :snapshot)');
        $stmt->bindValue(':aggregateType', $snapshot->aggregateClass());
        $stmt->bindValue(':aggregateId', $snapshot->aggregateId());
        $stmt->bindValue(':type', get_class($snapshot));
        $stmt->bindValue(':version', $snapshot->version());
        $stmt->bindValue(':snapshot', $this->serializer->serialize($snapshot));
        $stmt->execute();
    }

    /**
     * @param string $aggregateClass
     * @param string $aggregateId
     * @return SnapshotInterface|null
     */
    public function findLastSnapshot($aggregateClass, $aggregateId)
    {
        $stmt = $this->connection
            ->prepare('SELECT type, snapshot FROM snapshots WHERE aggregate_type = :aggregateType AND aggregate_id = :aggregateId ORDER BY id DESC LIMIT 1');
        $stmt->bindValue(':aggregateType', $aggregateClass);
        $stmt->bindValue(':aggregateId', $aggregateId);
        $stmt->execute();
        $snapshot = $stmt->fetch();
        return $snapshot ? $this->serializer->deserialize($snapshot['snapshot'], $snapshot['type']) : null;

The expression $snapshot ? $this->serializer->deserialize($snapshot['snapshot'], $snapshot['type']) : null; of type object|array|null adds the type array to the return on line 64 which is incompatible with the return type declared by the interface DDDominio\EventSourcing\Snapshotting\SnapshotStoreInterface::findLastSnapshot of type DDDominio\EventSourcing\Snapshotting\SnapshotInterface|null.

    }

    /**
     * @param string $aggregateClass
     * @param string $aggregateId
     * @param int $version
     * @return SnapshotInterface|null
     */
    public function findNearestSnapshotToVersion($aggregateClass, $aggregateId, $version)
    {
        $stmt = $this->connection
            ->prepare('SELECT type, snapshot FROM snapshots WHERE aggregate_type = :aggregateType AND aggregate_id = :aggregateId AND version <= :version ORDER BY version DESC LIMIT 1');
        $stmt->bindValue(':aggregateType', $aggregateClass);
        $stmt->bindValue(':aggregateId', $aggregateId);
        $stmt->bindValue(':version', $version);
        $stmt->execute();
        $snapshot = $stmt->fetch();
        return $snapshot ? $this->serializer->deserialize($snapshot['snapshot'], $snapshot['type']) : null;

The expression $snapshot ? $this->serializer->deserialize($snapshot['snapshot'], $snapshot['type']) : null; of type object|array|null adds the type array to the return on line 82 which is incompatible with the return type declared by the interface DDDominio\EventSourcing\Snapshotting\SnapshotStoreInterface::findNearestSnapshotToVersion of type DDDominio\EventSourcing\Snapshotting\SnapshotInterface|null.

    }

    /**
     * Initialize the Event Store
     */
    public function initialize()
    {
        $schema = new Schema();

        $snapshotsTable = $schema->createTable(self::SNAPSHOTS_TABLE);
        $snapshotsTable->addColumn('id', 'integer', ['autoincrement' => true]);
        $snapshotsTable->addColumn('aggregate_type', 'string');
        $snapshotsTable->addColumn('aggregate_id', 'string');
        $snapshotsTable->addColumn('type', 'string');
        $snapshotsTable->addColumn('version', 'integer');
        $snapshotsTable->addColumn('snapshot', 'text');
        $snapshotsTable->setPrimaryKey(['id']);

        $queries = $schema->toSql($this->connection->getDatabasePlatform());
        $this->connection->transactional(function(Connection $connection) use ($queries) {
            foreach ($queries as $query) {
                $connection->exec($query);
            }
        });
    }

    /**
     * Check if the Event Store has been initialized
     *
     * @return bool
     */
    public function initialized()
    {
        return $this->connection->getSchemaManager()->tablesExist([self::SNAPSHOTS_TABLE]);
    }
}