@@ -11,14 +11,20 @@ |
||
11 | 11 | } |
12 | 12 | |
13 | 13 | $ttw = (int) @$_GET['ttw']; |
14 | -if ($ttw == 0) $ttw = 10; |
|
15 | -if ($ttw < 0 || $ttw > 10) $ttw = 10; |
|
14 | +if ($ttw == 0) { |
|
15 | + $ttw = 10; |
|
16 | +} |
|
17 | +if ($ttw < 0 || $ttw > 10) { |
|
18 | + $ttw = 10; |
|
19 | +} |
|
16 | 20 | |
17 | 21 | $filterValue = @$_GET['filterValue']; |
18 | 22 | $filterValue = $filterValue != null ? (int) $filterValue : null; |
19 | 23 | |
20 | 24 | $package = unserialize(RedisQ\RedisQ::listen($queueID, $ttw, $filterValue)); |
21 | -if ($package === false) $package = null; |
|
25 | +if ($package === false) { |
|
26 | + $package = null; |
|
27 | +} |
|
22 | 28 | |
23 | 29 | $response = ['package' => $package]; |
24 | 30 | header("Access-Control-Allow-Origin: *"); |
@@ -78,7 +78,7 @@ |
||
78 | 78 | } |
79 | 79 | |
80 | 80 | protected function recursive_array_search($needle, $haystack) { |
81 | - foreach($haystack as $key=>$value) { |
|
81 | + foreach ($haystack as $key=>$value) { |
|
82 | 82 | $current_key = $key; |
83 | 83 | if ($needle === $value || (is_array($value) && self::recursive_array_search($needle, $value) !== false)) { |
84 | 84 | return true; |
@@ -56,7 +56,9 @@ discard block |
||
56 | 56 | $object = false; |
57 | 57 | $pop = $redis->blPop($rQueueID, 1); |
58 | 58 | if (!isset($pop[1])) { |
59 | - if (time() >= ($time + $timeToWait)) return; |
|
59 | + if (time() >= ($time + $timeToWait)) { |
|
60 | + return; |
|
61 | + } |
|
60 | 62 | } else { |
61 | 63 | $objectID = $pop[1]; |
62 | 64 | $object = $redis->get($objectID); |
@@ -73,7 +75,9 @@ discard block |
||
73 | 75 | |
74 | 76 | protected function matchesFilter($filterValue, $object) |
75 | 77 | { |
76 | - if ($filterValue == null) return $object; |
|
78 | + if ($filterValue == null) { |
|
79 | + return $object; |
|
80 | + } |
|
77 | 81 | return self::recursive_array_search($filterValue, unserialize($object)) ? $object : false; |
78 | 82 | } |
79 | 83 |