DDDominio\EventSourcing\Snapshotting\Vendor\MySqlJsonSnapshotStore

Complexity

Total Complexity

9

Size/Duplication

Total Lines	103
Duplicated Lines	8.74 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	addSnapshot()	0	11	1
A	findLastSnapshot()	0	10	2
A	findNearestSnapshotToVersion()	0	11	2
A	initialize()	0	14	1
A	initialized()	9	9	2

<?php

namespace DDDominio\EventSourcing\Snapshotting\Vendor;

use DDDominio\EventSourcing\EventStore\InitializableInterface;
use DDDominio\EventSourcing\Serialization\SerializerInterface;
use DDDominio\EventSourcing\Snapshotting\SnapshotInterface;
use DDDominio\EventSourcing\Snapshotting\SnapshotStoreInterface;

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

    /**
     * @var \PDO
     */
    private $connection;

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

    /**
     * @param \PDO $connection
     * @param SerializerInterface $serializer
     */
    public function __construct(
        \PDO $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.

    }

    public function initialize()
    {
        $this->connection->exec(
            'CREATE TABLE `'.self::SNAPSHOTS_TABLE.'` (
                `id` int(11) NOT NULL AUTO_INCREMENT,
                `aggregate_type` varchar(255) NOT NULL,
                `aggregate_id` varchar(255) NOT NULL,
                `type` varchar(255) NOT NULL,
                `version` int(11) NOT NULL,
                `snapshot` json NOT NULL,
                PRIMARY KEY (`id`)
            )'
        );
    }

    /**
     * @return bool
     */
    public function initialized()

This method seems to be duplicated in your project.

    {
        try {
            $result = $this->connection->query('SELECT 1 FROM `'.self::SNAPSHOTS_TABLE.'` LIMIT 1');
        } catch (\Exception $e) {
            return false;
        }
        return $result !== false;
    }
}