badfarm / zanzara

src/Zanzara/ZanzaraMapper.php

Spacing +2 added lines, -4 removed lines

@@ -38,8 +38,7 @@ 
     {
         $decoded = json_decode($json);
         return is_array($decoded) ?
-            $this->jsonMapper->mapArray($decoded, [], $class) :
-            $this->jsonMapper->map($decoded, new $class);
+            $this->jsonMapper->mapArray($decoded, [], $class) : $this->jsonMapper->map($decoded, new $class);
     }
 
     /**
@@ -51,8 +50,7 @@ 
     public function mapObject($object, $class)
     {
         return is_array($object) ?
-            $this->jsonMapper->mapArray($object, [], $class) :
-            $this->jsonMapper->map($object, new $class);
+            $this->jsonMapper->mapArray($object, [], $class) : $this->jsonMapper->map($object, new $class);
     }
 
 }

src/Zanzara/UpdateMode/ReactPHPWebhook.php

Spacing +4 added lines, -4 removed lines

@@ -39,19 +39,19 @@ 
     private function init()
     {
         $processingUpdate = null;
-        $server = new Server($this->loop, function (ServerRequestInterface $request) use (&$processingUpdate) {
+        $server = new Server($this->loop, function(ServerRequestInterface $request) use (&$processingUpdate) {
             $token = $this->resolveTokenFromPath($request->getUri()->getPath());
             if (!$this->isWebhookAuthorized($token)) {
                 $this->logger->errorNotAuthorized();
                 return new Response(403, [], $this->logger->getNotAuthorizedMessage());
             }
-            $json = (string)$request->getBody();
+            $json = (string) $request->getBody();
             /** @var Update $processingUpdate */
             $processingUpdate = $this->zanzaraMapper->mapJson($json, Update::class);
             $this->processUpdate($processingUpdate);
             return new Response();
         });
-        $server->on('error', function ($e) use (&$processingUpdate) {
+        $server->on('error', function($e) use (&$processingUpdate) {
             $this->logger->errorUpdate($e, $processingUpdate);
             $errorHandler = $this->config->getErrorHandler();
             if ($errorHandler) {
@@ -67,7 +67,7 @@ 
     public function run()
     {
         $this->telegram->getWebhookInfo()->then(
-            function (WebhookInfo $webhookInfo) {
+            function(WebhookInfo $webhookInfo) {
                 if (!$webhookInfo->getUrl()) {
                     $message = "Your bot doesn't have a webhook set, please set one before running Zanzara in webhook" .
                         " mode. See https://github.com/badfarm/zanzara/wiki#set-webhook";

src/Zanzara/MessageQueue.php

Spacing +2 added lines, -2 removed lines

@@ -65,7 +65,7 @@ 
             $clone['chat_id'] = $chatId;
             array_push($payload, $clone);
         }
-        $dequeue = function (TimerInterface $timer) use (&$payload) {
+        $dequeue = function(TimerInterface $timer) use (&$payload) {
             // if there's no more message to dequeue cancel the timer
             if (!$payload) {
                 $this->loop->cancelTimer($timer);
@@ -74,7 +74,7 @@ 
 
             // pop and process
             $params = array_pop($payload);
-            $this->telegram->doSendMessage($params)->/** @scrutinizer ignore-call */ otherwise(function (TelegramException $error) {
+            $this->telegram->doSendMessage($params)->/** @scrutinizer ignore-call */ otherwise(function(TelegramException $error) {
                 $this->logger->error("Failed to send message in bulk mode, reason: $error");
             });
         };

src/Zanzara/UpdateMode/Polling.php

Spacing +5 added lines, -5 removed lines

@@ -21,7 +21,7 @@ 
     public function run()
     {
         $this->telegram->getWebhookInfo()->then(
-            function (WebhookInfo $webhookInfo) {
+            function(WebhookInfo $webhookInfo) {
                 if (!$webhookInfo->getUrl()) {
                     $this->loop->futureTick([$this, 'startPolling']);
                     $this->logger->logIsListening();
@@ -34,7 +34,7 @@ 
                 $answer = readline();
                 if (strtoupper($answer) === "YES") {
                     $this->telegram->deleteWebhook()->then(
-                        function ($res) {
+                        function($res) {
                             if ($res === true) {
                                 $this->logger->info("Webhook is deleted, Zanzara is starting in polling ...");
                                 $this->loop->futureTick([$this, 'startPolling']);
@@ -61,7 +61,7 @@ 
             'limit' => $this->config->getPollingLimit(),
             'timeout' => $this->config->getPollingTimeout(),
             'allowed_updates' => $this->config->getPollingAllowedUpdates(),
-        ])->then(function (array $updates) use (&$offset, &$processingUpdate) {
+        ])->then(function(array $updates) use (&$offset, &$processingUpdate) {
             if ($offset === 1) {
                 //first run I need to get the current updateId from telegram
                 $lastUpdate = end($updates);
@@ -80,10 +80,10 @@ 
                 }
                 $this->startPolling($offset);
             }
-        }, function (TelegramException $error) use (&$offset) {
+        }, function(TelegramException $error) use (&$offset) {
             $this->logger->error("Failed to fetch updates from Telegram: $error");
             $this->startPolling($offset); // consider place a delay before restarting to poll
-        })->/** @scrutinizer ignore-call */ otherwise(function ($e) use (&$offset, &$processingUpdate) {
+        })->/** @scrutinizer ignore-call */ otherwise(function($e) use (&$offset, &$processingUpdate) {
             $this->logger->errorUpdate($e);
             $errorHandler = $this->config->getErrorHandler();
             if ($errorHandler) {

src/Zanzara/Telegram/TelegramTrait.php

Spacing +9 added lines, -9 removed lines

@@ -1640,7 +1640,7 @@ 
                 $async = $this->container->get(Config::class)->isReactFileSystem();
 
                 if ($async) {
-                    return $this->prepareMultipartDataAsync($params)->then(function ($result) use ($class, $params, $method) {
+                    return $this->prepareMultipartDataAsync($params)->then(function($result) use ($class, $params, $method) {
                         $headers = array("Content-Length" => $result->getSize(), "Content-Type" => "multipart/form-data; boundary={$result->getBoundary()}");
                         return $this->wrapPromise($this->browser->post($method, $headers, $result), $method, $params, $class);
                     });
@@ -1669,12 +1669,12 @@ 
         foreach ($params as $key => $value) {
 
             if ($value instanceof InputFile) {
-                array_push($promises, $filesystem->getContents($value->getPath())->then(function ($contents) use ($value, $key) {
+                array_push($promises, $filesystem->getContents($value->getPath())->then(function($contents) use ($value, $key) {
                     $data = ['name' => $key];
                     $data['contents'] = $contents;
                     $data['filename'] = basename($value->getPath());
                     return $data;
-                }, function ($error) {
+                }, function($error) {
                     $this->container->get(ZanzaraLogger::class)->error($error);
                     return $error;
                 }));
@@ -1686,12 +1686,12 @@ 
             }
         }
 
-        return all($promises)->then(function ($files) use ($multipart_data) {
+        return all($promises)->then(function($files) use ($multipart_data) {
             foreach ($files as $key => $value) {
                 array_push($multipart_data, $value);
             }
             return new MultipartStream($multipart_data);
-        }, function ($error) {
+        }, function($error) {
             $this->container->get(ZanzaraLogger::class)->error($error);
             return $error;
         });
@@ -1741,8 +1741,8 @@ 
         $logger = $this->container->get(ZanzaraLogger::class);
 
         return $promise
-            ->then(function (ResponseInterface $response) use ($class, $mapper) {
-                $json = (string)$response->getBody();
+            ->then(function(ResponseInterface $response) use ($class, $mapper) {
+                $json = (string) $response->getBody();
                 $object = json_decode($json);
 
                 if (is_scalar($object->result) && $class === "Scalar") {
@@ -1750,13 +1750,13 @@ 
                 }
 
                 return $mapper->mapObject($object->result, $class);
-            }, function ($e) use ($method, $params, $logger, $mapper) {
+            }, function($e) use ($method, $params, $logger, $mapper) {
                 if ($e instanceof ResponseException) {
                     // with the introduction of Local Api server (https://core.telegram.org/bots/api#using-a-local-bot-api-server)
                     // we can no longer assume that the response is with the TelegramException format, so catch any mapping
                     // exception
                     try {
-                        $json = (string)$e->getResponse()->getBody();
+                        $json = (string) $e->getResponse()->getBody();
                         $e = $mapper->mapJson($json, TelegramException::class);
                     } catch (\Exception $ignore) {
                         // ignore

src/Zanzara/ConversationManager.php

Spacing +1 added lines, -1 removed lines

@@ -49,7 +49,7 @@
     public function getConversationHandler($chatId): PromiseInterface
     {
         return $this->cache->get($this->getConversationKey($chatId))
-            ->then(function ($conversation) {
+            ->then(function($conversation) {
                 if (empty($conversation["state"])) {
                     return null;
                 }

src/Zanzara/ZanzaraCache.php

Spacing +8 added lines, -8 removed lines

@@ -199,14 +199,14 @@ 
      */
     public function deleteCacheItem(string $cacheKey, $key)
     {
-        return $this->cache->get($cacheKey)->then(function ($arrayData) use ($cacheKey, $key) {
+        return $this->cache->get($cacheKey)->then(function($arrayData) use ($cacheKey, $key) {
             if (!$arrayData) {
                 return true; //there isn't anything so it's deleted
             } else {
                 unset($arrayData[$key]);
             }
 
-            return $this->cache->set($cacheKey, $arrayData)->then(function ($result) {
+            return $this->cache->set($cacheKey, $arrayData)->then(function($result) {
                 if ($result !== true) {
                     $this->logger->errorWriteCache();
                 }
@@ -222,7 +222,7 @@ 
      */
     public function deleteCache(array $keys)
     {
-        return $this->cache->deleteMultiple($keys)->then(function ($result) {
+        return $this->cache->deleteMultiple($keys)->then(function($result) {
             if ($result !== true) {
                 $this->logger->errorClearCache();
             }
@@ -238,7 +238,7 @@ 
      */
     public function getCacheItem(string $cacheKey, $key)
     {
-        return $this->cache->get($cacheKey)->then(function ($arrayData) use ($key) {
+        return $this->cache->get($cacheKey)->then(function($arrayData) use ($key) {
             if ($arrayData && array_key_exists($key, $arrayData)) {
                 return $arrayData[$key];
             } else {
@@ -286,7 +286,7 @@ 
     public function doSet(string $cacheKey, string $key, $data, $ttl = false)
     {
         $ttl = $this->checkTtl($ttl);
-        return $this->cache->get($cacheKey)->then(function ($arrayData) use ($ttl, $key, $data, $cacheKey) {
+        return $this->cache->get($cacheKey)->then(function($arrayData) use ($ttl, $key, $data, $cacheKey) {
             if (!$arrayData) {
                 $arrayData = array();
                 $arrayData[$key] = $data;
@@ -294,7 +294,7 @@ 
                 $arrayData[$key] = $data;
             }
 
-            return $this->cache->set($cacheKey, $arrayData, $ttl)->then(function ($result) {
+            return $this->cache->set($cacheKey, $arrayData, $ttl)->then(function($result) {
                 if ($result !== true) {
                     $this->logger->errorWriteCache();
                 }
@@ -316,10 +316,10 @@ 
     {
 
         $ttl = $this->checkTtl($ttl);
-        return $this->cache->get($cacheKey)->then(function ($arrayData) use ($ttl, $key, $data, $cacheKey) {
+        return $this->cache->get($cacheKey)->then(function($arrayData) use ($ttl, $key, $data, $cacheKey) {
             $arrayData[$key][] = $data;
 
-            return $this->cache->set($cacheKey, $arrayData, $ttl)->then(function ($result) {
+            return $this->cache->set($cacheKey, $arrayData, $ttl)->then(function($result) {
                 if ($result !== true) {
                     $this->logger->errorWriteCache();
                 }

src/Zanzara/UpdateMode/UpdateMode.php

Spacing +2 added lines, -2 removed lines

@@ -84,14 +84,14 @@
     {
         $update->detectUpdateType();
         $this->zanzara->resolveListeners($update)
-            ->then(function ($listeners) use ($update) {
+            ->then(function($listeners) use ($update) {
                 /** @var Listener[] $listeners */
                 foreach ($listeners as $listener) {
                     $context = new Context($update, $this->container);
                     $middlewareTip = $listener->getTip();
                     $middlewareTip($context);
                 }
-            })->otherwise(function ($e) use ($update) {
+            })->otherwise(function($e) use ($update) {
                 $this->logger->error("Unable to resolve listeners for update $update, reason: $e");
             });
     }

src/Zanzara/Listener/ListenerResolver.php

Spacing +4 added lines, -4 removed lines

@@ -41,7 +41,7 @@ 
                 $callbackQuery = $update->getCallbackQuery();
                 $text = $callbackQuery->getMessage() ? $callbackQuery->getMessage()->getText() : null;
                 $this->conversationManager->getConversationHandler($chatId)
-                    ->then(function ($handlerInfo) use ($deferred, $callbackQuery, $text, &$listeners) {
+                    ->then(function($handlerInfo) use ($deferred, $callbackQuery, $text, &$listeners) {
                         if (!$handlerInfo) { // if we are not in a conversation, call the listeners as usual
                             if ($text) {
                                 $this->findListenerAndPush($listeners, 'cb_query_texts', $text);
@@ -53,7 +53,7 @@ 
                             $listeners[] = new Listener($handlerInfo[0], $this->container);
                         }
                         $deferred->resolve($listeners);
-                    })->otherwise(function ($e) use ($deferred) {
+                    })->otherwise(function($e) use ($deferred) {
                         // if something goes wrong, reject the promise
                         $deferred->reject($e);
                     });
@@ -63,7 +63,7 @@ 
                 $text = $update->getMessage()->getText();
                 $chatId = $update->getEffectiveChat()->getId();
                 $this->conversationManager->getConversationHandler($chatId)
-                    ->then(function ($handlerInfo) use ($chatId, $text, $deferred, &$listeners) {
+                    ->then(function($handlerInfo) use ($chatId, $text, $deferred, &$listeners) {
                         if (!$handlerInfo) { // if we are not in a conversation, call the listeners as usual
                             $this->findListenerAndPush($listeners, 'messages', $text);
                         } elseif (!$handlerInfo[1] && $text) {
@@ -83,7 +83,7 @@ 
                             $listeners[] = new Listener($handlerInfo[0], $this->container);
                         }
                         $deferred->resolve($listeners);
-                    })->otherwise(function ($e) use ($deferred) {
+                    })->otherwise(function($e) use ($deferred) {
                         // if something goes wrong, reject the promise
                         $deferred->reject($e);
                     });