GG-403 added getEventsFilteredByAggregate to EventStoreRepository

Author: Mario Marco

src/Repository/EventStoreRepository.php

@@ -15,6 +15,8 @@ public function countEventsForSince(Uuid $aggregateId, DateTimeValueObject $sinc
 
     public function getGivenEventsByAggregate(Uuid $aggregateId, int $offset, int $limit, string ...$events): array;
 
+    public function getEventsFilteredByAggregate(Uuid $aggregateId, int $offset, int $limit, string ...$events): array;
+
     public function countEventsForSinceVersion(Uuid $aggregateId, int $aggregateVersion): int;
 
     public function getSinceVersion(Uuid $aggregateId, int $aggregateVersion): array;

src/Repository/PostgresBaseAggregateRepository.php

@@ -264,6 +264,35 @@ protected function queryGivenEventsByAggregateIdPaginated(
         return $events;
     }
 
+    protected function queryEventsFilteredByAggregateIdPaginated(
+        Uuid $aggregateId,
+        int $offset,
+        int $limit,
+        string ...$eventNames
+    ): array {
+        $stmt = $this->connection
+            ->createQueryBuilder()
+            ->addSelect('a.message_id, a.aggregate_id, a.aggregate_version, a.occurred_on, a.message_name, a.payload')
+            ->from($this->tableName(), 'a')
+            ->where('a.aggregate_id = :aggregateId')
+            ->andWhere('a.message_name NOT IN (:eventNames)')
+            ->setParameter('aggregateId', $aggregateId->value(), \PDO::PARAM_STR)
+            ->setParameter('eventNames', $eventNames, Connection::PARAM_STR_ARRAY)
+            ->setFirstResult($offset)
+            ->setMaxResults($limit)
+            ->orderBy('a.occurred_on', 'DESC')
+            ->addOrderBy('a.aggregate_version', 'ASC')
+            ->execute();
+
+        $events = $stmt->fetchAll();
+
+        foreach ($events as $key => $event) {
+            $events[$key]['payload'] = \json_decode($event['payload'], true);
+        }
+
+        return $events;
+    }
+
     protected function execute(Statement $stmt): void
     {
         $result = $stmt->execute();

src/Repository/PostgresEventStoreRepository.php

@@ -32,6 +32,11 @@ public function getGivenEventsByAggregate(Uuid $aggregateId, int $offset, int $l
         return $this->queryGivenEventsByAggregateIdPaginated($aggregateId, $offset, $limit, ...$events);
     }
 
+    public function getEventsFilteredByAggregate(Uuid $aggregateId, int $offset, int $limit, string ...$events): array
+    {
+        return $this->queryEventsFilteredByAggregateIdPaginated($aggregateId, $offset, $limit, ...$events);
+    }
+
     public function getSince(Uuid $aggregateId, DateTimeValueObject $since): array
     {
         return $this->findByAggregateIdSince($aggregateId, $since);