@@ -53,10 +53,10 @@ discard block |
||
53 | 53 | public function load($id) |
54 | 54 | { |
55 | 55 | $rows = $this->db->table($this->eventStoreTableName) |
56 | - ->select(['uuid', 'playhead', 'metadata', 'payload', 'recorded_on']) |
|
57 | - ->where('uuid', $id) |
|
58 | - ->orderBy('playhead', 'asc') |
|
59 | - ->get(); |
|
56 | + ->select(['uuid', 'playhead', 'metadata', 'payload', 'recorded_on']) |
|
57 | + ->where('uuid', $id) |
|
58 | + ->orderBy('playhead', 'asc') |
|
59 | + ->get(); |
|
60 | 60 | $events = []; |
61 | 61 | |
62 | 62 | foreach ($rows as $row) { |
@@ -99,16 +99,16 @@ discard block |
||
99 | 99 | private function insertEvent(DomainMessage $domainMessage) |
100 | 100 | { |
101 | 101 | $this->db->table($this->eventStoreTableName) |
102 | - ->insert( |
|
103 | - [ |
|
104 | - 'uuid' => (string)$domainMessage->getId(), |
|
105 | - 'playhead' => $domainMessage->getPlayHead(), |
|
106 | - 'metadata' => json_encode($this->serializer->serialize($domainMessage->getMetadata())), |
|
107 | - 'payload' => json_encode($this->serializer->serialize($domainMessage->getPayload())), |
|
108 | - 'recorded_on' => (string)$domainMessage->getRecordedOn(), |
|
109 | - 'type' => $domainMessage->getType(), |
|
110 | - ] |
|
111 | - ); |
|
102 | + ->insert( |
|
103 | + [ |
|
104 | + 'uuid' => (string)$domainMessage->getId(), |
|
105 | + 'playhead' => $domainMessage->getPlayHead(), |
|
106 | + 'metadata' => json_encode($this->serializer->serialize($domainMessage->getMetadata())), |
|
107 | + 'payload' => json_encode($this->serializer->serialize($domainMessage->getPayload())), |
|
108 | + 'recorded_on' => (string)$domainMessage->getRecordedOn(), |
|
109 | + 'type' => $domainMessage->getType(), |
|
110 | + ] |
|
111 | + ); |
|
112 | 112 | } |
113 | 113 | |
114 | 114 | /** |
@@ -146,12 +146,12 @@ discard block |
||
146 | 146 | public function getEventsByType($eventTypes, $skip, $take) |
147 | 147 | { |
148 | 148 | $rows = $this->db->table($this->eventStoreTableName) |
149 | - ->select(['uuid', 'playhead', 'metadata', 'payload', 'recorded_on']) |
|
150 | - ->whereIn('type', $eventTypes) |
|
151 | - ->skip($skip) |
|
152 | - ->take($take) |
|
153 | - ->orderBy('recorded_on', 'asc') |
|
154 | - ->get(); |
|
149 | + ->select(['uuid', 'playhead', 'metadata', 'payload', 'recorded_on']) |
|
150 | + ->whereIn('type', $eventTypes) |
|
151 | + ->skip($skip) |
|
152 | + ->take($take) |
|
153 | + ->orderBy('recorded_on', 'asc') |
|
154 | + ->get(); |
|
155 | 155 | $events = []; |
156 | 156 | |
157 | 157 | foreach ($rows as $row) { |