@@ -13,7 +13,7 @@ |
||
13 | 13 | */ |
14 | 14 | public function up() |
15 | 15 | { |
16 | - Schema::create('openvidu_cache', function (Blueprint $table) { |
|
16 | + Schema::create('openvidu_cache', function(Blueprint $table) { |
|
17 | 17 | $table->string('key')->unique(); |
18 | 18 | $table->text('value'); |
19 | 19 | $table->integer('expiration'); |
@@ -123,7 +123,7 @@ discard block |
||
123 | 123 | */ |
124 | 124 | public function unpublish(string $streamId) |
125 | 125 | { |
126 | - $this->publishers = array_filter($this->publishers, function (Publisher $publisher) use ($streamId) { |
|
126 | + $this->publishers = array_filter($this->publishers, function(Publisher $publisher) use ($streamId) { |
|
127 | 127 | return $streamId !== $publisher->getStreamId(); |
128 | 128 | }); |
129 | 129 | } |
@@ -135,7 +135,7 @@ discard block |
||
135 | 135 | public function unsubscribe(string $streamId) |
136 | 136 | { |
137 | 137 | if (!empty($this->subscribers)) { |
138 | - $this->subscribers = array_filter($this->subscribers, function ($subscriber) use ($streamId) { |
|
138 | + $this->subscribers = array_filter($this->subscribers, function($subscriber) use ($streamId) { |
|
139 | 139 | if (is_string($subscriber)) { |
140 | 140 | return $subscriber !== $streamId; |
141 | 141 | } |
@@ -103,7 +103,7 @@ discard block |
||
103 | 103 | return; |
104 | 104 | } |
105 | 105 | |
106 | - $cache = is_array($cache) ? (object) $cache : $cache; |
|
106 | + $cache = is_array($cache) ? (object)$cache : $cache; |
|
107 | 107 | |
108 | 108 | // If this cache expiration date is past the current time, we will remove this |
109 | 109 | // item from the cache. Then we will return a null value since the cache is |
@@ -162,7 +162,7 @@ discard block |
||
162 | 162 | return; |
163 | 163 | } |
164 | 164 | |
165 | - $cache = is_array($cache) ? (object) $cache : $cache; |
|
165 | + $cache = is_array($cache) ? (object)$cache : $cache; |
|
166 | 166 | // If this cache expiration date is past the current time, we will remove this |
167 | 167 | // item from the cache. Then we will return a null value since the cache is |
168 | 168 | // expired. We will use "Carbon" to make this comparison with the column. |
@@ -189,7 +189,7 @@ discard block |
||
189 | 189 | */ |
190 | 190 | public function increment($key, $value = 1) |
191 | 191 | { |
192 | - return $this->incrementOrDecrement($key, $value, function ($current, $value) { |
|
192 | + return $this->incrementOrDecrement($key, $value, function($current, $value) { |
|
193 | 193 | return $current + $value; |
194 | 194 | }); |
195 | 195 | } |
@@ -205,7 +205,7 @@ discard block |
||
205 | 205 | */ |
206 | 206 | protected function incrementOrDecrement($key, $value, Closure $callback) |
207 | 207 | { |
208 | - return $this->connection->transaction(function () use ($key, $value, $callback) { |
|
208 | + return $this->connection->transaction(function() use ($key, $value, $callback) { |
|
209 | 209 | |
210 | 210 | |
211 | 211 | $cache = $this->table()->where('key', $key) |
@@ -218,14 +218,14 @@ discard block |
||
218 | 218 | return false; |
219 | 219 | } |
220 | 220 | |
221 | - $cache = is_array($cache) ? (object) $cache : $cache; |
|
221 | + $cache = is_array($cache) ? (object)$cache : $cache; |
|
222 | 222 | |
223 | 223 | $current = $this->unserialize($cache->value); |
224 | 224 | |
225 | 225 | // Here we'll call this callback function that was given to the function which |
226 | 226 | // is used to either increment or decrement the function. We use a callback |
227 | 227 | // so we do not have to recreate all this logic in each of the functions. |
228 | - $new = $callback((int) $current, $value); |
|
228 | + $new = $callback((int)$current, $value); |
|
229 | 229 | |
230 | 230 | if (!is_numeric($current)) { |
231 | 231 | return false; |
@@ -252,7 +252,7 @@ discard block |
||
252 | 252 | */ |
253 | 253 | public function decrement($key, $value = 1) |
254 | 254 | { |
255 | - return $this->incrementOrDecrement($key, $value, function ($current, $value) { |
|
255 | + return $this->incrementOrDecrement($key, $value, function($current, $value) { |
|
256 | 256 | return $current - $value; |
257 | 257 | }); |
258 | 258 | } |
@@ -18,6 +18,6 @@ |
||
18 | 18 | |
19 | 19 | public function __toString() |
20 | 20 | { |
21 | - return __CLASS__.":[{$this->code}]:{$this->message}\n"; |
|
21 | + return __CLASS__ . ":[{$this->code}]:{$this->message}\n"; |
|
22 | 22 | } |
23 | 23 | } |
@@ -74,7 +74,7 @@ discard block |
||
74 | 74 | case 409: |
75 | 75 | return $this->properties->getCustomSessionId(); |
76 | 76 | default: |
77 | - throw new OpenViduException("Invalid response status code ".$response->getStatusCode(), $response->getStatusCode()); |
|
77 | + throw new OpenViduException("Invalid response status code " . $response->getStatusCode(), $response->getStatusCode()); |
|
78 | 78 | } |
79 | 79 | } else { |
80 | 80 | return $this->sessionId; |
@@ -95,7 +95,7 @@ discard block |
||
95 | 95 | $this->getSessionId(); |
96 | 96 | try { |
97 | 97 | if (!$tokenOptions) { |
98 | - $tokenOptions = new TokenOptions(OpenViduRole::PUBLISHER);; |
|
98 | + $tokenOptions = new TokenOptions(OpenViduRole::PUBLISHER); ; |
|
99 | 99 | } |
100 | 100 | $response = $this->client->post(Uri::TOKEN_URI, [ |
101 | 101 | RequestOptions::JSON => array_merge($tokenOptions->toArray(), ['session' => $this->sessionId]) |
@@ -113,7 +113,7 @@ discard block |
||
113 | 113 | */ |
114 | 114 | public function close() |
115 | 115 | { |
116 | - $response = $this->client->delete(Uri::SESSION_URI.'/'.$this->sessionId); |
|
116 | + $response = $this->client->delete(Uri::SESSION_URI . '/' . $this->sessionId); |
|
117 | 117 | switch ($response->getStatusCode()) { |
118 | 118 | case 204: |
119 | 119 | Cache::store('openvidu')->forget($this->sessionId); |
@@ -122,7 +122,7 @@ discard block |
||
122 | 122 | throw new OpenViduSessionNotFoundException(); |
123 | 123 | break; |
124 | 124 | default: |
125 | - throw new OpenViduException("Invalid response status code ".$response->getStatusCode(), $response->getStatusCode()); |
|
125 | + throw new OpenViduException("Invalid response status code " . $response->getStatusCode(), $response->getStatusCode()); |
|
126 | 126 | } |
127 | 127 | } |
128 | 128 | |
@@ -144,7 +144,7 @@ discard block |
||
144 | 144 | |
145 | 145 | public function fetch() |
146 | 146 | { |
147 | - $response = $this->client->get(Uri::SESSION_URI.'/'.$this->sessionId, [ |
|
147 | + $response = $this->client->get(Uri::SESSION_URI . '/' . $this->sessionId, [ |
|
148 | 148 | 'headers' => [ |
149 | 149 | 'Content-Type' => 'application/x-www-form-urlencoded', |
150 | 150 | 'Accept' => 'application/json', |
@@ -258,7 +258,7 @@ discard block |
||
258 | 258 | */ |
259 | 259 | public function forceDisconnect(string $connectionId) |
260 | 260 | { |
261 | - $response = $this->client->delete(Uri::SESSION_URI.'/'.$this->sessionId.'/connection/'.$connectionId, [ |
|
261 | + $response = $this->client->delete(Uri::SESSION_URI . '/' . $this->sessionId . '/connection/' . $connectionId, [ |
|
262 | 262 | 'headers' => [ |
263 | 263 | 'Content-Type' => 'application/x-www-form-urlencoded', |
264 | 264 | 'Accept' => 'application/json', |
@@ -276,7 +276,7 @@ discard block |
||
276 | 276 | throw new OpenViduConnectionNotFoundException(); |
277 | 277 | break; |
278 | 278 | default: |
279 | - throw new OpenViduException("Invalid response status code ".$response->getStatusCode(), $response->getStatusCode()); |
|
279 | + throw new OpenViduException("Invalid response status code " . $response->getStatusCode(), $response->getStatusCode()); |
|
280 | 280 | } |
281 | 281 | } |
282 | 282 | |
@@ -289,7 +289,7 @@ discard block |
||
289 | 289 | private function leaveSession(string $connectionId) |
290 | 290 | { |
291 | 291 | $connectionClosed = null; |
292 | - $this->activeConnections = array_filter($this->activeConnections, function (Connection $connection) use (&$connectionClosed, $connectionId) { |
|
292 | + $this->activeConnections = array_filter($this->activeConnections, function(Connection $connection) use (&$connectionClosed, $connectionId) { |
|
293 | 293 | if ($connection->getConnectionId() !== $connectionId) { |
294 | 294 | return true; |
295 | 295 | } |
@@ -327,7 +327,7 @@ discard block |
||
327 | 327 | */ |
328 | 328 | public function forceUnpublish(string $streamId) |
329 | 329 | { |
330 | - $response = $this->client->delete(Uri::SESSION_URI.'/'.$this->sessionId.'/stream/'.$streamId, [ |
|
330 | + $response = $this->client->delete(Uri::SESSION_URI . '/' . $this->sessionId . '/stream/' . $streamId, [ |
|
331 | 331 | 'headers' => [ |
332 | 332 | 'Content-Type' => 'application/x-www-form-urlencoded', |
333 | 333 | 'Accept' => 'application/json', |
@@ -348,7 +348,7 @@ discard block |
||
348 | 348 | throw new OpenViduConnectionNotFoundException(); |
349 | 349 | break; |
350 | 350 | default: |
351 | - throw new OpenViduException("Invalid response status code ".$response->getStatusCode(), $response->getStatusCode()); |
|
351 | + throw new OpenViduException("Invalid response status code " . $response->getStatusCode(), $response->getStatusCode()); |
|
352 | 352 | } |
353 | 353 | } |
354 | 354 |
@@ -20,7 +20,7 @@ discard block |
||
20 | 20 | */ |
21 | 21 | public function register() |
22 | 22 | { |
23 | - $this->app->singleton(OpenVidu::class, function () { |
|
23 | + $this->app->singleton(OpenVidu::class, function() { |
|
24 | 24 | return new OpenVidu(/** @scrutinizer ignore-call */ config('services.openvidu')); |
25 | 25 | }); |
26 | 26 | |
@@ -35,8 +35,8 @@ discard block |
||
35 | 35 | */ |
36 | 36 | private function registerRoutes() |
37 | 37 | { |
38 | - Route::group($this->routeConfiguration(), function () { |
|
39 | - $this->loadRoutesFrom(__DIR__.'/../Http/routes.php'); |
|
38 | + Route::group($this->routeConfiguration(), function() { |
|
39 | + $this->loadRoutesFrom(__DIR__ . '/../Http/routes.php'); |
|
40 | 40 | }); |
41 | 41 | } |
42 | 42 | |
@@ -62,14 +62,14 @@ discard block |
||
62 | 62 | public function boot() |
63 | 63 | { |
64 | 64 | if ($this->app->runningInConsole()) { |
65 | - $this->loadMigrationsFrom(__DIR__.'/../../database/migrations'); |
|
65 | + $this->loadMigrationsFrom(__DIR__ . '/../../database/migrations'); |
|
66 | 66 | |
67 | 67 | $this->publishes([ |
68 | - __DIR__.'/../../database/migrations' => /** @scrutinizer ignore-call */ database_path('migrations'), |
|
68 | + __DIR__ . '/../../database/migrations' => /** @scrutinizer ignore-call */ database_path('migrations'), |
|
69 | 69 | ], 'openvidu-migrations'); |
70 | 70 | |
71 | 71 | } |
72 | - Cache::extend('openvidu', function () { |
|
72 | + Cache::extend('openvidu', function() { |
|
73 | 73 | return Cache::repository(new SessionStore(DB::connection(), /** @scrutinizer ignore-call */ config('cache.stores.openvidu.table'))); |
74 | 74 | }); |
75 | 75 | } |
@@ -18,6 +18,6 @@ |
||
18 | 18 | |
19 | 19 | public function __toString() |
20 | 20 | { |
21 | - return __CLASS__.":[{$this->code}]:{$this->message}\n"; |
|
21 | + return __CLASS__ . ":[{$this->code}]:{$this->message}\n"; |
|
22 | 22 | } |
23 | 23 | } |
@@ -18,6 +18,6 @@ |
||
18 | 18 | |
19 | 19 | public function __toString() |
20 | 20 | { |
21 | - return __CLASS__.":[{$this->code}]:{$this->message}\n"; |
|
21 | + return __CLASS__ . ":[{$this->code}]:{$this->message}\n"; |
|
22 | 22 | } |
23 | 23 | } |
@@ -18,6 +18,6 @@ |
||
18 | 18 | |
19 | 19 | public function __toString() |
20 | 20 | { |
21 | - return __CLASS__.":[{$this->code}]:{$this->message}\n"; |
|
21 | + return __CLASS__ . ":[{$this->code}]:{$this->message}\n"; |
|
22 | 22 | } |
23 | 23 | } |