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