badfarm / zanzara

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/ZanzaraCache.php

Spacing +11 added lines, -11 removed lines

@@ -228,14 +228,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);
                 }
@@ -251,7 +251,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);
             }
@@ -267,7 +267,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 {
@@ -315,7 +315,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;
@@ -323,7 +323,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($result);
                 }
@@ -345,10 +345,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($result);
                 }
@@ -366,14 +366,14 @@ 
      */
     public function callHandlerByChatId(int $chatId, $update, $container)
     {
-        return $this->cache->get($this->getConversationKey($chatId))->then(function ($conversation) use ($update, $container) {
+        return $this->cache->get($this->getConversationKey($chatId))->then(function($conversation) use ($update, $container) {
             if (!empty($conversation["state"])) {
                 $handler = $conversation["state"];
                 $handler(new Context($update, $container));
             }
-        }, function ($err) use ($update) {
+        }, function($err) use ($update) {
             $this->logger->errorUpdate($update, $err);
-        })->/** @scrutinizer ignore-call */ otherwise(function ($err) use ($update, $chatId) {
+        })->/** @scrutinizer ignore-call */ otherwise(function($err) use ($update, $chatId) {
             $this->logger->errorUpdate($err, $update);
             $this->deleteConversationCache($chatId);
         });