@@ -81,7 +81,7 @@ discard block |
||
81 | 81 | */ |
82 | 82 | public function append($id, DomainEventStream $eventStream, bool $ignorePlayhead = false) |
83 | 83 | { |
84 | - $id = (string)$id; //Used to thrown errors if ID will not cast to string |
|
84 | + $id = (string) $id; //Used to thrown errors if ID will not cast to string |
|
85 | 85 | |
86 | 86 | $this->db->beginTransaction(); |
87 | 87 | |
@@ -110,7 +110,7 @@ discard block |
||
110 | 110 | } catch (\PDOException $ex) { |
111 | 111 | if ((string) $ex->getCode() === '23000') { |
112 | 112 | if ($ignorePlayhead) { |
113 | - $eventRow['playhead'] ++; |
|
113 | + $eventRow['playhead']++; |
|
114 | 114 | return $this->insertEvent($eventRow, true); |
115 | 115 | } |
116 | 116 | throw new DuplicateAggregatePlayhead($eventRow['uuid'], $eventRow['playhead']); |
@@ -176,11 +176,11 @@ discard block |
||
176 | 176 | private function domainMessageToArray(DomainMessage $domainMessage): array |
177 | 177 | { |
178 | 178 | return [ |
179 | - 'uuid' => (string)$domainMessage->getId(), |
|
179 | + 'uuid' => (string) $domainMessage->getId(), |
|
180 | 180 | 'playhead' => $domainMessage->getPlayHead(), |
181 | 181 | 'metadata' => json_encode($this->serializer->serialize($domainMessage->getMetadata())), |
182 | 182 | 'payload' => json_encode($this->serializer->serialize($domainMessage->getPayload())), |
183 | - 'recorded_on' => (string)$domainMessage->getRecordedOn(), |
|
183 | + 'recorded_on' => (string) $domainMessage->getRecordedOn(), |
|
184 | 184 | 'type' => $domainMessage->getType(), |
185 | 185 | ]; |
186 | 186 | } |