Skip to content

Commit e139a4a

Browse files
authored
Merge pull request #8 from PcComponentes/GG-403-add-get-filtered-event-to-repository
GG-400 fixed counter
2 parents 3c57590 + 6c07580 commit e139a4a

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/Repository/PostgresBaseAggregateRepository.php

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -175,7 +175,8 @@ protected function countGivenEventsByAggregateId(Uuid $aggregateId, string ...$e
175175
->createQueryBuilder()
176176
->select('count(message_id) as count')
177177
->from($this->tableName())
178-
->where('message_name IN (:eventNames)');
178+
->where('aggregate_id = :aggregateId')
179+
->andWhere('message_name IN (:eventNames)');
179180

180181
$stmt->setParameter('aggregateId', $aggregateId->value(), \PDO::PARAM_STR);
181182
$stmt->setParameter('eventNames', $eventNames, Connection::PARAM_STR_ARRAY);
@@ -189,7 +190,8 @@ protected function countFilteredEventsByAggregateId(Uuid $aggregateId, string ..
189190
->createQueryBuilder()
190191
->select('count(message_id) as count')
191192
->from($this->tableName())
192-
->where('message_name NOT IN (:eventNames)');
193+
->where('aggregate_id = :aggregateId')
194+
->andWhere('message_name NOT IN (:eventNames)');
193195

194196
$stmt->setParameter('aggregateId', $aggregateId->value(), \PDO::PARAM_STR);
195197
$stmt->setParameter('eventNames', $eventNames, Connection::PARAM_STR_ARRAY);

0 commit comments

Comments
 (0)