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/Listener/ListenerCollector.php

Spacing +1 added lines, -1 removed lines

@@ -368,7 +368,7 @@
      */
     protected function feedMiddlewareStack()
     {
-        array_walk_recursive($this->listeners, function ($value) {
+        array_walk_recursive($this->listeners, function($value) {
             if ($value instanceof Listener) {
                 foreach ($this->middleware as $m) {
                     $value->middleware($m);

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);
@@ -75,7 +75,7 @@ 
             // pop and process
             $params = array_pop($payload);
             $this->telegram->doSendMessage($params)
-                ->otherwise(function (TelegramException $error) {
+                ->otherwise(function(TelegramException $error) {
                     $this->logger->error("Failed to send message in bulk mode, reason: $error");
                 }
                 );

src/Zanzara/Telegram/TelegramTrait.php

Spacing +9 added lines, -9 removed lines

@@ -1463,7 +1463,7 @@ 
                 $async = $this->container->get(Config::class)->isReactFileSystem();
 
                 if ($async) {
-                    return $this->prepareMultipartDataAsync($params)->then(function ($result) use ($method) {
+                    return $this->prepareMultipartDataAsync($params)->then(function($result) use ($method) {
                         $headers = array("Content-Length" => $result->getSize(), "Content-Type" => "multipart/form-data; boundary={$result->getBoundary()}");
                         return $this->browser->post($method, $headers, $result);
                     });
@@ -1492,12 +1492,12 @@ 
         foreach ($params as $key => $value) {
 
             if ($value instanceof InputFile) {
-                array_push($promises, $filesystem->getContents($value->getPath())->then(function ($contents) use ($value, $multipart_data, $key) {
+                array_push($promises, $filesystem->getContents($value->getPath())->then(function($contents) use ($value, $multipart_data, $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;
                 }));
@@ -1509,12 +1509,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;
         });
@@ -1562,8 +1562,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") {
@@ -1572,8 +1572,8 @@ 
 
                 return $mapper->mapObject($object->result, $class);
 
-            }, function (ResponseException $exception) use ($logger, $mapper) {
-                $json = (string)$exception->getResponse()->getBody();
+            }, function(ResponseException $exception) use ($logger, $mapper) {
+                $json = (string) $exception->getResponse()->getBody();
                 $telegramException = $mapper->mapJson($json, TelegramException::class);
                 $logger->error($telegramException);
                 throw $telegramException;

src/Zanzara/Zanzara.php

Spacing +9 added lines, -9 removed lines

@@ -100,7 +100,7 @@ 
 
             case Config::REACTPHP_WEBHOOK_MODE:
                 $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";
@@ -114,7 +114,7 @@ 
 
             case Config::POLLING_MODE:
                 $this->telegram->getWebhookInfo()->then(
-                    function (WebhookInfo $webhookInfo) {
+                    function(WebhookInfo $webhookInfo) {
                         if (!$webhookInfo->getUrl()) {
                             $this->loop->futureTick([$this, 'polling']);
                             $this->logger->info("Zanzara is listening...");
@@ -127,7 +127,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, 'polling']);
@@ -186,19 +186,19 @@ 
     private function prepareServer()
     {
         $processingUpdate = null;
-        $this->server = new Server(function (ServerRequestInterface $request) use (&$processingUpdate) {
+        $this->server = new Server(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();
         });
-        $this->server->on('error', function ($e) use (&$processingUpdate) {
+        $this->server->on('error', function($e) use (&$processingUpdate) {
             $this->logger->errorUpdate($e, $processingUpdate);
             $errorHandler = $this->config->getErrorHandler();
             if ($errorHandler) {
@@ -228,7 +228,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);
@@ -247,10 +247,10 @@ 
                 }
                 $this->polling($offset);
             }
-        }, function (TelegramException $error) use (&$offset) {
+        }, function(TelegramException $error) use (&$offset) {
             $this->logger->error("Failed to fetch updates from Telegram: $error");
             $this->polling($offset); // consider place a delay before restarting to poll
-        })->otherwise(function ($e) use (&$offset, &$processingUpdate) {
+        })->otherwise(function($e) use (&$offset, &$processingUpdate) {
             $this->logger->errorUpdate($e);
             $errorHandler = $this->config->getErrorHandler();
             if ($errorHandler) {

src/Zanzara/ZanzaraCache.php

Spacing +9 added lines, -9 removed lines

@@ -201,14 +201,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($result);
                 }
@@ -224,7 +224,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($result);
             }
@@ -240,7 +240,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 {
@@ -272,7 +272,7 @@ 
      */
     public function doSet(string $cacheKey, string $key, $data)
     {
-        return $this->cache->get($cacheKey)->then(function ($arrayData) use ($key, $data, $cacheKey) {
+        return $this->cache->get($cacheKey)->then(function($arrayData) use ($key, $data, $cacheKey) {
             if (!$arrayData) {
                 $arrayData = array();
                 $arrayData[$key] = $data;
@@ -280,7 +280,7 @@ 
                 $arrayData[$key] = $data;
             }
 
-            return $this->cache->set($cacheKey, $arrayData)->then(function ($result) {
+            return $this->cache->set($cacheKey, $arrayData)->then(function($result) {
                 if ($result !== true) {
                     $this->logger->errorWriteCache($result);
                 }
@@ -298,14 +298,14 @@ 
      */
     public function callHandlerByChatId(int $chatId, $update, $container)
     {
-        return $this->cache->get($this->getConversationKey($chatId))->then(function (array $conversation) use ($update, $chatId, $container) {
+        return $this->cache->get($this->getConversationKey($chatId))->then(function(array $conversation) use ($update, $chatId, $container) {
             if (!empty($conversation)) {
                 $handler = $conversation["state"];
                 $handler(new Context($update, $container));
             }
-        }, function ($err) use ($container, $update) {
+        }, function($err) use ($container, $update) {
             $this->logger->errorUpdate($update, $err);
-        })->otherwise(function ($err, $update, $chatId) {
+        })->otherwise(function($err, $update, $chatId) {
             $this->logger->errorUpdate($err, $update);
             $this->deleteConversationCache($chatId);
         });