@@ -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->reconnect(); |
87 | 87 | $this->db->beginTransaction(); |
@@ -111,7 +111,7 @@ discard block |
||
111 | 111 | } catch (\PDOException $ex) { |
112 | 112 | if ((string) $ex->getCode() === '23000') { |
113 | 113 | if ($ignorePlayhead) { |
114 | - $eventRow['playhead'] ++; |
|
114 | + $eventRow['playhead']++; |
|
115 | 115 | return $this->insertEvent($eventRow, true); |
116 | 116 | } |
117 | 117 | throw new DuplicateAggregatePlayhead($eventRow['uuid'], $eventRow['playhead']); |
@@ -178,11 +178,11 @@ discard block |
||
178 | 178 | private function domainMessageToArray(DomainMessage $domainMessage): array |
179 | 179 | { |
180 | 180 | return [ |
181 | - 'uuid' => (string)$domainMessage->getId(), |
|
181 | + 'uuid' => (string) $domainMessage->getId(), |
|
182 | 182 | 'playhead' => $domainMessage->getPlayHead(), |
183 | 183 | 'metadata' => json_encode($this->serializer->serialize($domainMessage->getMetadata())), |
184 | 184 | 'payload' => json_encode($this->serializer->serialize($domainMessage->getPayload())), |
185 | - 'recorded_on' => (string)$domainMessage->getRecordedOn(), |
|
185 | + 'recorded_on' => (string) $domainMessage->getRecordedOn(), |
|
186 | 186 | 'type' => $domainMessage->getType(), |
187 | 187 | ]; |
188 | 188 | } |