zKillboard / RedisQ

src/RedisQ.php

Spacing +2 added lines, -2 removed lines

@@ -41,7 +41,7 @@ 
 
         $timeToWait = max(1, min(10, $timeToWait));
             
-        if ($ip != "37.59.50.21" && $redis->get("redisQ:banned:$ip") == "true")  {
+        if ($ip != "37.59.50.21" && $redis->get("redisQ:banned:$ip") == "true") {
             sleep(10);
             header("Location: /banned.html", 302);
             exit();
@@ -87,7 +87,7 @@ 
     }
 
     protected function recursive_array_search($needle, $haystack) {
-        foreach($haystack as $key=>$value) {
+        foreach ($haystack as $key=>$value) {
             $current_key = $key;
             if ($needle === $value || (is_array($value) && self::recursive_array_search($needle, $value) !== false)) {
                 return true;

Braces +9 added lines, -3 removed lines

@@ -52,7 +52,9 @@ 
         if ($redis->set($wQueueID, true, Array('nx', 'ex'=>15)) === false) {
             $redis->incr("redisQ:queueID:429count:$ip");
             $redis->expire("redisQ:queueID:429count:$ip", 300);
-            if ($redis->get("redisQ:queueID:429count:$ip") > 30) $redis->setex("redisQ:banned:$ip", 10000, "true");
+            if ($redis->get("redisQ:queueID:429count:$ip") > 30) {
+                $redis->setex("redisQ:banned:$ip", 10000, "true");
+            }
             header('HTTP/1.1 429 Too many requests.');
             exit();
         }
@@ -65,7 +67,9 @@ 
                 $object = false;
                 $pop = $redis->blPop($rQueueID, 1);
                 if (!isset($pop[1])) {
-                    if (time() >= ($time + $timeToWait)) return;
+                    if (time() >= ($time + $timeToWait)) {
+                        return;
+                    }
                 } else {
                     $objectID = $pop[1];
                     $object = $redis->get($objectID);
@@ -82,7 +86,9 @@ 
 
     protected function matchesFilter($filterValue, $object)
     {
-        if ($filterValue == null) return $object;
+        if ($filterValue == null) {
+            return $object;
+        }
         return self::recursive_array_search($filterValue, unserialize($object)) ? $object : false;
     }
 

public/listen.php

Braces +9 added lines, -3 removed lines

@@ -12,14 +12,20 @@
 }
 
 $ttw = (int) @$_GET['ttw'];
-if ($ttw == 0) $ttw = 10;
-if ($ttw < 0 || $ttw > 10) $ttw = 10;
+if ($ttw == 0) {
+    $ttw = 10;
+}
+if ($ttw < 0 || $ttw > 10) {
+    $ttw = 10;
+}
 
 $filterValue = @$_GET['filterValue'];
 $filterValue = $filterValue != null ? (int) $filterValue : null;
 
 $package = unserialize(RedisQ\RedisQ::listen($queueID, $ip, $ttw, $filterValue));
-if ($package === false) $package = null;
+if ($package === false) {
+    $package = null;
+}
 
 $response = ['package' => $package];
 header("Access-Control-Allow-Origin: *");