Spiral\Snapshotter\AggregationHandler

Complexity

Total Complexity

2

Size/Duplication

Total Lines	36
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	registerSnapshot()	0	10	1

<?php

namespace Spiral\Snapshotter;

use Spiral\Core\Service;
use Spiral\Debug\SnapshotInterface;
use Spiral\Snapshotter\AggregationHandler\Database\IncidentRecord;
use Spiral\Snapshotter\AggregationHandler\Database\SnapshotRecord;
use Spiral\Snapshotter\AggregationHandler\Database\Sources\IncidentSource;
use Spiral\Snapshotter\AggregationHandler\Services\SnapshotService;

class AggregationHandler extends Service implements HandlerInterface
{
    /** @var IncidentSource */
    private $source;

    /** @var SnapshotService */
    private $service;

    /**
     * Aggregation constructor.
     *
     * @param IncidentSource  $snapshots
     * @param SnapshotService $service
     */
    public function __construct(IncidentSource $snapshots, SnapshotService $service)
    {
        $this->source = $snapshots;
        $this->service = $service;
    }

    /**
     * Create snapshot aggregation and aggregated snapshot and tie them together.
     *
     * @param SnapshotInterface $snapshot
     */
    public function registerSnapshot(SnapshotInterface $snapshot)
    {
        /** @var IncidentRecord $incident */
        $incident = $this->source->createFromSnapshot($snapshot);

        /** @var SnapshotRecord $snapshotRecord */
        $snapshotRecord = $this->service->getByHash($this->service->makeHash($snapshot));
        $snapshotRecord->pushIncident($incident);
        $snapshotRecord->save();
    }
}