badfarm / zanzara

src/Zanzara/MessageQueue.php

Spacing +2 added lines, -2 removed lines

@@ -66,7 +66,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);
@@ -76,7 +76,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/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/Context.php

Spacing +6 added lines, -6 removed lines

@@ -157,7 +157,7 @@ 
     }
 
 
-    public function deleteItemChatData($key){
+    public function deleteItemChatData($key) {
         $chatId = $this->update->getEffectiveChat()->getId();
         $cache = $this->container->get(ZanzaraCache::class);
         return $cache->deleteCacheItemChatData($chatId, $cache);
@@ -167,7 +167,7 @@ 
      * Delete all chat data 
      * @return PromiseInterface
      */
-    public function deleteAllChatData(){
+    public function deleteAllChatData() {
         $chatId = $this->update->getEffectiveChat()->getId();
         $cache = $this->container->get(ZanzaraCache::class);
         return $cache->deleteAllCacheChatData($chatId);
@@ -187,7 +187,7 @@ 
         return $cache->setCacheUserData($userId, $key, $data);
     }
 
-    public function deleteItemUserData($key){
+    public function deleteItemUserData($key) {
         $userId = $this->update->getEffectiveChat()->getUsername();
         $cache = $this->container->get(ZanzaraCache::class);
         return $cache->deleteCacheItemUserData($userId, $cache);
@@ -197,7 +197,7 @@ 
      * Delete all chat data
      * @return PromiseInterface
      */
-    public function deleteAllUserData(){
+    public function deleteAllUserData() {
         $chatId = $this->update->getEffectiveChat()->getUsername();
         $cache = $this->container->get(ZanzaraCache::class);
         return $cache->deleteAllCacheUserData($chatId);
@@ -228,12 +228,12 @@ 
         return $cache->deleteAllCacheGlobalData();
     }
 
-    public function wipeCache(){
+    public function wipeCache() {
         $cache = $this->container->get(ZanzaraCache::class);
         return $cache->wipeCache();
     }
 
-    public function deleteUserData(){
+    public function deleteUserData() {
         $userId = $this->update->getEffectiveChat()->getUsername();
         $cache = $this->container->get(ZanzaraCache::class);
         return $cache->deteleCacheChatData($userId);

src/Zanzara/Zanzara.php

Spacing +9 added lines, -9 removed lines

@@ -97,7 +97,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";
@@ -111,7 +111,7 @@ 
 
             case Config::POLLING_MODE:
                 $this->telegram->getWebhookInfo()->then(
-                    function (WebhookInfo $webhookInfo) {
+                    function(WebhookInfo $webhookInfo) {
                         if (!$webhookInfo->getUrl()) {
                             $this->loop->futureTick([$this, 'polling']);
                             echo "Zanzara is listening...\n";
@@ -124,7 +124,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']);
@@ -183,19 +183,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) {
@@ -225,7 +225,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);
@@ -244,10 +244,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/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/ZanzaraCache.php

Spacing +11 added lines, -11 removed lines

@@ -199,14 +199,14 @@ 
      */
     public function deleteCacheItem($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);
                 }
@@ -223,7 +223,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($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 {
@@ -251,7 +251,7 @@ 
 
     public function getCache($cacheKey)
     {
-        return $this->cache->get($cacheKey)->then(function ($arrayData) {
+        return $this->cache->get($cacheKey)->then(function($arrayData) {
             return $arrayData;
         });
     }
@@ -262,7 +262,7 @@ 
      */
     public function wipeCache()
     {
-        return $this->cache->clear()->then(function ($result) {
+        return $this->cache->clear()->then(function($result) {
             return $result;
         });
     }
@@ -277,7 +277,7 @@ 
      */
     public function setCache($cacheKey, $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;
@@ -285,7 +285,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);
                 }
@@ -303,14 +303,14 @@ 
      */
     public function callHandlerByChatId($chatId, $update, $container)
     {
-        return $this->cache->get($this->getKeyConversation($chatId))->then(function (array $conversation) use ($update, $chatId, $container) {
+        return $this->cache->get($this->getKeyConversation($chatId))->then(function(array $conversation) use ($update, $chatId, $container) {
             if ($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);
         });

src/Zanzara/ZanzaraLogger.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
         $this->error($message);
     }
 
-    public function errorGetCache($error){
+    public function errorGetCache($error) {
         $message = "Failed to get data from cache, reason: {$error}";
         $this->error($message);
     }

src/Zanzara/Telegram/TelegramTrait.php

Spacing +10 added lines, -10 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) use ($value) {
+                }, function($error) use ($value) {
                     $this->container->get(ZanzaraLogger::class)->error($error);
                     return $error;
                 }));
@@ -1509,12 +1509,12 @@ 
             }
         }
 
-        return all($promises)->then(function ($files) use($multipart_data) {
-            foreach ($files as $key => $value){
+        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;
         });
@@ -1563,8 +1563,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") {
@@ -1573,8 +1573,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;