@@ -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 |