@@ -21,7 +21,7 @@ |
||
| 21 | 21 | } |
| 22 | 22 | |
| 23 | 23 | $precision = 0; |
| 24 | - return new Price((int) round($value * 100, $precision)); |
|
| 24 | + return new Price((int)round($value * 100, $precision)); |
|
| 25 | 25 | } |
| 26 | 26 | |
| 27 | 27 | /** |
@@ -25,7 +25,7 @@ |
||
| 25 | 25 | public function getCdbId($externalId) |
| 26 | 26 | { |
| 27 | 27 | if (isset($this->externalIdMapping[$externalId])) { |
| 28 | - return (string) $this->externalIdMapping[$externalId]; |
|
| 28 | + return (string)$this->externalIdMapping[$externalId]; |
|
| 29 | 29 | } else { |
| 30 | 30 | return null; |
| 31 | 31 | } |
@@ -12,7 +12,7 @@ |
||
| 12 | 12 | { |
| 13 | 13 | if (!is_string($string)) { |
| 14 | 14 | throw new \InvalidArgumentException( |
| 15 | - 'Argument should be string, got ' . gettype($string) . ' instead.' |
|
| 15 | + 'Argument should be string, got '.gettype($string).' instead.' |
|
| 16 | 16 | ); |
| 17 | 17 | } |
| 18 | 18 | |
@@ -70,7 +70,7 @@ discard block |
||
| 70 | 70 | $this->payloadSerializer = $payloadSerializer; |
| 71 | 71 | $this->metadataSerializer = $metadataSerializer; |
| 72 | 72 | $this->tableName = $tableName; |
| 73 | - $this->aggregateType = (string) $aggregateType; |
|
| 73 | + $this->aggregateType = (string)$aggregateType; |
|
| 74 | 74 | } |
| 75 | 75 | |
| 76 | 76 | /** |
@@ -105,7 +105,7 @@ discard block |
||
| 105 | 105 | $this->guardStream($eventStream); |
| 106 | 106 | |
| 107 | 107 | // Make the transaction more robust by using the transactional statement. |
| 108 | - $this->connection->transactional(function (Connection $connection) use ($eventStream) { |
|
| 108 | + $this->connection->transactional(function(Connection $connection) use ($eventStream) { |
|
| 109 | 109 | try { |
| 110 | 110 | foreach ($eventStream as $domainMessage) { |
| 111 | 111 | $this->insertMessage($connection, $domainMessage); |
@@ -123,7 +123,7 @@ discard block |
||
| 123 | 123 | private function insertMessage(Connection $connection, DomainMessage $domainMessage) |
| 124 | 124 | { |
| 125 | 125 | $data = array( |
| 126 | - 'uuid' => (string) $domainMessage->getId(), |
|
| 126 | + 'uuid' => (string)$domainMessage->getId(), |
|
| 127 | 127 | 'playhead' => $domainMessage->getPlayhead(), |
| 128 | 128 | 'metadata' => json_encode($this->metadataSerializer->serialize($domainMessage->getMetadata())), |
| 129 | 129 | 'payload' => json_encode($this->payloadSerializer->serialize($domainMessage->getPayload())), |
@@ -228,7 +228,7 @@ discard block |
||
| 228 | 228 | { |
| 229 | 229 | foreach ($eventStream as $domainMessage) { |
| 230 | 230 | /** @var DomainMessage $domainMessage */ |
| 231 | - $id = (string) $domainMessage->getId(); |
|
| 231 | + $id = (string)$domainMessage->getId(); |
|
| 232 | 232 | } |
| 233 | 233 | } |
| 234 | 234 | } |
@@ -153,7 +153,7 @@ discard block |
||
| 153 | 153 | } |
| 154 | 154 | |
| 155 | 155 | /** |
| 156 | - * @return mixed |
|
| 156 | + * @return Table |
|
| 157 | 157 | */ |
| 158 | 158 | public function configureTable() |
| 159 | 159 | { |
@@ -181,7 +181,7 @@ discard block |
||
| 181 | 181 | } |
| 182 | 182 | |
| 183 | 183 | /** |
| 184 | - * @return \Doctrine\DBAL\Driver\Statement|null |
|
| 184 | + * @return \Doctrine\DBAL\Statement|null |
|
| 185 | 185 | */ |
| 186 | 186 | private function prepareLoadStatement() |
| 187 | 187 | { |
@@ -108,7 +108,7 @@ |
||
| 108 | 108 | throw new RuntimeException(); |
| 109 | 109 | } |
| 110 | 110 | |
| 111 | - return [ $priceName => floatval($priceValue) ]; |
|
| 111 | + return [$priceName => floatval($priceValue)]; |
|
| 112 | 112 | } |
| 113 | 113 | |
| 114 | 114 | private function getCurrencyFormatter() |
@@ -12,7 +12,7 @@ |
||
| 12 | 12 | { |
| 13 | 13 | if (!preg_match('/^[a-z]{2}$/', $code)) { |
| 14 | 14 | throw new \InvalidArgumentException( |
| 15 | - 'Invalid language code: ' . $code |
|
| 15 | + 'Invalid language code: '.$code |
|
| 16 | 16 | ); |
| 17 | 17 | } |
| 18 | 18 | $this->code = $code; |
@@ -10,9 +10,9 @@ |
||
| 10 | 10 | */ |
| 11 | 11 | public function format(Address $address) |
| 12 | 12 | { |
| 13 | - return $address->getStreetAddress() . ', ' . |
|
| 14 | - $address->getPostalCode() . ' ' . |
|
| 15 | - $address->getLocality() . ', ' . |
|
| 13 | + return $address->getStreetAddress().', '. |
|
| 14 | + $address->getPostalCode().' '. |
|
| 15 | + $address->getLocality().', '. |
|
| 16 | 16 | $address->getCountry()->getCode(); |
| 17 | 17 | } |
| 18 | 18 | } |
@@ -66,7 +66,7 @@ |
||
| 66 | 66 | { |
| 67 | 67 | return array_filter( |
| 68 | 68 | iterator_to_array($eventStream), |
| 69 | - function (DomainMessage $message) use ($playhead) { |
|
| 69 | + function(DomainMessage $message) use ($playhead) { |
|
| 70 | 70 | return intval($message->getPlayhead()) < $playhead; |
| 71 | 71 | } |
| 72 | 72 | ); |
@@ -32,7 +32,7 @@ |
||
| 32 | 32 | |
| 33 | 33 | if (!is_string($originalEventId)) { |
| 34 | 34 | throw new \InvalidArgumentException( |
| 35 | - 'Expected originalEventId to be a string, received ' . gettype($originalEventId) |
|
| 35 | + 'Expected originalEventId to be a string, received '.gettype($originalEventId) |
|
| 36 | 36 | ); |
| 37 | 37 | } |
| 38 | 38 | |