Fixed error with getAggregateHistoryFor() method.

Signed-off-by: Joshua Parker <joshua@joshuaparker.dev>
getdevflow · Dec 6, 2024 · c1a4ef2 · c1a4ef2
1 parent 6cf4791
commit c1a4ef2
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/App/Infrastructure/Persistence/OrmTransactionalEventStore.php b/App/Infrastructure/Persistence/OrmTransactionalEventStore.php
@@ -114,9 +114,7 @@ public function getAggregateHistoryFor(AggregateId $aggregateId): EventStream
     {
         $query = $this->dfdb->qb()->table(tableName: $this->dfdb->basePrefix . 'event_store')
         ->select(columns: '*')
-        ->where(condition: 'aggregate_id', parameters: (string) $aggregateId)
-        ->and__()
-        ->where('site', $this->dfdb->prefix);
+        ->where(condition: 'aggregate_id', parameters: (string) $aggregateId);
 
         return $this->eventStream($query, $aggregateId);
     }