From c1a4ef24318bb851b688db5a5b1af98b8f54bc14 Mon Sep 17 00:00:00 2001
From: Joshua Parker <joshua@joshuaparker.dev>
Date: Fri, 6 Dec 2024 10:51:52 -0800
Subject: [PATCH] Fixed error with getAggregateHistoryFor() method.

Signed-off-by: Joshua Parker <joshua@joshuaparker.dev>
---
 App/Infrastructure/Persistence/OrmTransactionalEventStore.php | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/App/Infrastructure/Persistence/OrmTransactionalEventStore.php b/App/Infrastructure/Persistence/OrmTransactionalEventStore.php
index c512889..0d0ef44 100644
--- 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);
     }