for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace Chocofamily\LaravelEventSauce;
use EventSauce\EventSourcing\AggregateRootId;
use EventSauce\EventSourcing\Snapshotting\Snapshot;
use EventSauce\EventSourcing\Snapshotting\SnapshotRepository as EventSauceSnapshotRepository;
use Illuminate\Database\Connection;
use Illuminate\Support\Carbon;
class SnapshotRepository implements EventSauceSnapshotRepository
{
/** @var Connection */
protected $connection;
/** @var string */
protected $table;
public function __construct(Connection $connection, string $table)
$this->connection = $connection;
$this->table = $table;
}
public function persist(Snapshot $snapshot): void
$this->connection
->table($this->table)
->insert([
'aggregate_root_id' => $snapshot->aggregateRootId()->toString(),
'aggregate_root_version' => $snapshot->aggregateRootVersion(),
'state' => json_encode($snapshot->state()),
'recorded_at' => Carbon::now()->toDateTimeString(),
]);
public function retrieve(AggregateRootId $id): ?Snapshot
$snapshot = $this->connection
->where('aggregate_root_id', $id->toString())
->first();
if (is_null($snapshot)) {
return null;
return new Snapshot(
$id,
$snapshot->aggregate_root_version,
json_decode($snapshot->state)
);
chocofamilyme /
laravel-eventsauce
