@@ -55,10 +55,10 @@ discard block |
||
55 | 55 | public function load(string $id) : DomainEventStream |
56 | 56 | { |
57 | 57 | $rows = $this->db->table($this->eventStoreTableName) |
58 | - ->select(['uuid', 'playhead', 'metadata', 'payload', 'recorded_on']) |
|
59 | - ->where('uuid', $id) |
|
60 | - ->orderBy('playhead', 'asc') |
|
61 | - ->get(); |
|
58 | + ->select(['uuid', 'playhead', 'metadata', 'payload', 'recorded_on']) |
|
59 | + ->where('uuid', $id) |
|
60 | + ->orderBy('playhead', 'asc') |
|
61 | + ->get(); |
|
62 | 62 | $events = []; |
63 | 63 | |
64 | 64 | foreach ($rows as $row) { |
@@ -152,12 +152,12 @@ discard block |
||
152 | 152 | $rows = $this->db->table( |
153 | 153 | $this->db->raw("`{$this->eventStoreTableName}` FORCE INDEX (eventstore_type_index)") |
154 | 154 | ) |
155 | - ->select(['id', 'uuid', 'playhead', 'metadata', 'payload', 'recorded_on']) |
|
156 | - ->whereIn('type', $eventTypes) |
|
157 | - ->where('id', '>', $lastId) |
|
158 | - ->take($take) |
|
159 | - ->orderBy('id') |
|
160 | - ->get(); |
|
155 | + ->select(['id', 'uuid', 'playhead', 'metadata', 'payload', 'recorded_on']) |
|
156 | + ->whereIn('type', $eventTypes) |
|
157 | + ->where('id', '>', $lastId) |
|
158 | + ->take($take) |
|
159 | + ->orderBy('id') |
|
160 | + ->get(); |
|
161 | 161 | $events = []; |
162 | 162 | foreach ($rows as $row) { |
163 | 163 | $events[] = $this->deserializeEvent($row); |
@@ -190,7 +190,7 @@ discard block |
||
190 | 190 | public function deleteStream(string $streamId) : void |
191 | 191 | { |
192 | 192 | $this->db->table($this->eventStoreTableName) |
193 | - ->where('uuid', $streamId) |
|
194 | - ->delete(); |
|
193 | + ->where('uuid', $streamId) |
|
194 | + ->delete(); |
|
195 | 195 | } |
196 | 196 | } |
197 | 197 | \ No newline at end of file |