GG-403 added getEventsFilteredByAggregate, countGivenEventsByAggregate, countEventsFilteredByAggregate to EventStoreRepository

Author: Mario Marco

src/Repository/EventStoreRepository.php

@@ -11,6 +11,10 @@ interface EventStoreRepository extends DddEventStoreRepository
 {
     public function countEventsFor(Uuid $aggregateId): int;
 
+    public function countGivenEventsByAggregate(Uuid $aggregateId, string ...$events): int;
+
+    public function countEventsFilteredByAggregate(Uuid $aggregateId, string ...$events): int;
+
     public function countEventsForSince(Uuid $aggregateId, DateTimeValueObject $since): int;
 
     public function getGivenEventsByAggregate(Uuid $aggregateId, int $offset, int $limit, string ...$events): array;

src/Repository/PostgresBaseAggregateRepository.php

@@ -169,6 +169,35 @@ protected function countByAggregateId(Uuid $aggregateId): int
         return $result['count'];
     }
 
+    protected function countGivenEventsByAggregateId(Uuid $aggregateId, string ...$eventNames): int
+    {
+        $stmt = $this->connection
+            ->createQueryBuilder()
+            ->select('count(message_id) as count')
+            ->from($this->tableName())
+            ->where('message_name IN (:eventNames)');
+
+        $stmt->setParameter('aggregateId', $aggregateId->value(), \PDO::PARAM_STR);
+        $stmt->setParameter('eventNames', $eventNames, Connection::PARAM_STR_ARRAY);
+
+        return $stmt->execute()->fetchOne();
+    }
+
+    protected function countFilteredEventsByAggregateId(Uuid $aggregateId, string ...$eventNames): int
+    {
+        $stmt = $this->connection
+            ->createQueryBuilder()
+            ->select('count(message_id) as count')
+            ->from($this->tableName())
+            ->where('message_name NOT IN (:eventNames)');
+
+        $stmt->setParameter('aggregateId', $aggregateId->value(), \PDO::PARAM_STR);
+        $stmt->setParameter('eventNames', $eventNames, Connection::PARAM_STR_ARRAY);
+
+        return $stmt->execute()->fetchOne();
+    }
+
+
     protected function countByAggregateIdSince(Uuid $aggregateId, DateTimeValueObject $since): int
     {
         $stmt = $this->connection->prepare(

src/Repository/PostgresEventStoreRepository.php

@@ -67,6 +67,16 @@ public function countEventsFor(Uuid $aggregateId): int
         return $this->countByAggregateId($aggregateId);
     }
 
+    public function countGivenEventsByAggregate(Uuid $aggregateId, string ...$events): int
+    {
+        return $this->countGivenEventsByAggregateId( $aggregateId, ...$events);
+    }
+
+    public function countEventsFilteredByAggregate(Uuid $aggregateId, string ...$events): int
+    {
+        return $this->countFilteredEventsByAggregateId($aggregateId, ...$events);
+    }
+
     public function countEventsForSince(Uuid $aggregateId, DateTimeValueObject $since): int
     {
         return $this->countByAggregateIdSince($aggregateId, $since);