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