@@ -151,7 +151,7 @@ discard block |
||
151 | 151 | return []; |
152 | 152 | } |
153 | 153 | |
154 | - $primaryKeys = Collection::make($keys)->values()->map(function ($key) { |
|
154 | + $primaryKeys = Collection::make($keys)->values()->map(function($key) { |
|
155 | 155 | return $this->makePrimaryKey($key); |
156 | 156 | }); |
157 | 157 | |
@@ -165,7 +165,7 @@ discard block |
||
165 | 165 | |
166 | 166 | $response = $this->ots->batchGetRow($request); |
167 | 167 | |
168 | - $results = Collection::make($keys)->values()->mapWithKeys(function ($key) { |
|
168 | + $results = Collection::make($keys)->values()->mapWithKeys(function($key) { |
|
169 | 169 | return [$key => null]; |
170 | 170 | })->toArray(); |
171 | 171 | |
@@ -201,7 +201,7 @@ discard block |
||
201 | 201 | return true; |
202 | 202 | } |
203 | 203 | |
204 | - $rows = Collection::make($values)->map(function ($value, $key) use ($seconds) { |
|
204 | + $rows = Collection::make($values)->map(function($value, $key) use ($seconds) { |
|
205 | 205 | return [ |
206 | 206 | 'operation_type' => OperationTypeConst::CONST_PUT, |
207 | 207 | 'condition' => RowExistenceExpectationConst::CONST_IGNORE, |
@@ -245,7 +245,7 @@ discard block |
||
245 | 245 | */ |
246 | 246 | public function increment($key, $value = 1) |
247 | 247 | { |
248 | - return $this->incrementOrDecrement($key, $value, function ($current, $value) { |
|
248 | + return $this->incrementOrDecrement($key, $value, function($current, $value) { |
|
249 | 249 | return $current + $value; |
250 | 250 | }); |
251 | 251 | } |
@@ -259,7 +259,7 @@ discard block |
||
259 | 259 | */ |
260 | 260 | public function decrement($key, $value = 1) |
261 | 261 | { |
262 | - return $this->incrementOrDecrement($key, $value, function ($current, $value) { |
|
262 | + return $this->incrementOrDecrement($key, $value, function($current, $value) { |
|
263 | 263 | return $current - $value; |
264 | 264 | }); |
265 | 265 | } |
@@ -278,7 +278,7 @@ discard block |
||
278 | 278 | return false; |
279 | 279 | } |
280 | 280 | |
281 | - $new = $callback((int) $current, $value); |
|
281 | + $new = $callback((int)$current, $value); |
|
282 | 282 | |
283 | 283 | $request = [ |
284 | 284 | 'table_name' => $this->table, |
@@ -35,9 +35,9 @@ discard block |
||
35 | 35 | |
36 | 36 | protected function registerDatabaseExtend() |
37 | 37 | { |
38 | - $this->app->resolving('db', function ($db) { |
|
38 | + $this->app->resolving('db', function($db) { |
|
39 | 39 | /** @var DatabaseManager $db */ |
40 | - $db->extend('ots', function ($config, $name) { |
|
40 | + $db->extend('ots', function($config, $name) { |
|
41 | 41 | $config['name'] = $name; |
42 | 42 | return new Connection($config); |
43 | 43 | }); |
@@ -46,9 +46,9 @@ discard block |
||
46 | 46 | |
47 | 47 | protected function registerCacheExtend() |
48 | 48 | { |
49 | - $this->app->resolving('cache', function ($cache) { |
|
49 | + $this->app->resolving('cache', function($cache) { |
|
50 | 50 | /** @var CacheManager $cache */ |
51 | - $cache->extend('ots', function ($app, $config) { |
|
51 | + $cache->extend('ots', function($app, $config) { |
|
52 | 52 | /** @var CacheManager $this */ |
53 | 53 | |
54 | 54 | /** @var Connection $connection */ |