@@ -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 | |