@@ -55,13 +55,13 @@ |
||
55 | 55 | { |
56 | 56 | if ($this->getLocation()) { |
57 | 57 | try { |
58 | - $response = $this->client->request('GET', $this->getLocation(), ['stream' => true]); |
|
58 | + $response = $this->client->request('GET', $this->getLocation(), ['stream' => true]); |
|
59 | 59 | if ($response instanceof ResponseInterface) { |
60 | 60 | if ($response->getStatusCode() === 200) { |
61 | 61 | return $response->getBody(); |
62 | 62 | } else { |
63 | 63 | throw new CollectorFetchException( |
64 | - 'Failed fetching with response status code: '.$response->getStatusCode() |
|
64 | + 'Failed fetching with response status code: ' . $response->getStatusCode() |
|
65 | 65 | ); |
66 | 66 | } |
67 | 67 | } else { |
@@ -13,7 +13,7 @@ |
||
13 | 13 | public function filter($in, $out, &$consumed, $closing) |
14 | 14 | { |
15 | 15 | while ($bucket = stream_bucket_make_writeable($in)) { |
16 | - $bucket = $this->processBucket($bucket); |
|
16 | + $bucket = $this->processBucket($bucket); |
|
17 | 17 | $consumed = $bucket->datalen; |
18 | 18 | stream_bucket_prepend($out, $bucket); |
19 | 19 | } |
@@ -50,8 +50,7 @@ discard block |
||
50 | 50 | public function getParseWarningThreshold() |
51 | 51 | { |
52 | 52 | return is_null($this->parseWarningThreshold) ? |
53 | - self::DEFAULT_PARSE_WARNING_THRESHOLD : |
|
54 | - $this->parseWarningThreshold; |
|
53 | + self::DEFAULT_PARSE_WARNING_THRESHOLD : $this->parseWarningThreshold; |
|
55 | 54 | } |
56 | 55 | |
57 | 56 | /** |
@@ -77,7 +76,7 @@ discard block |
||
77 | 76 | */ |
78 | 77 | protected function getStreamData(StreamInterface $data = null) |
79 | 78 | { |
80 | - if (! is_null($data)) { |
|
79 | + if (!is_null($data)) { |
|
81 | 80 | return $data; |
82 | 81 | } |
83 | 82 | if ($this->getCollector()) { |
@@ -20,7 +20,7 @@ discard block |
||
20 | 20 | public function __construct(array $addresses = array()) |
21 | 21 | { |
22 | 22 | $this->position = 0; |
23 | - if (! empty($addresses)) { |
|
23 | + if (!empty($addresses)) { |
|
24 | 24 | $this->add($addresses); |
25 | 25 | } |
26 | 26 | } |
@@ -49,12 +49,12 @@ discard block |
||
49 | 49 | public static function fromParserWithCache(ParserInterface $parser, IpListCacheInterface $cache) |
50 | 50 | { |
51 | 51 | $ipList = $cache->fetch(); |
52 | - if (! is_null($ipList)) { |
|
52 | + if (!is_null($ipList)) { |
|
53 | 53 | return $ipList; |
54 | 54 | } else { |
55 | 55 | $ipList = self::fromParser($parser); |
56 | - if (! empty($ipList)) { |
|
57 | - if (! $cache->store($ipList)) { |
|
56 | + if (!empty($ipList)) { |
|
57 | + if (!$cache->store($ipList)) { |
|
58 | 58 | throw new \RuntimeException('Failed storing new tor exit node list in cache.'); |
59 | 59 | } |
60 | 60 | } |
@@ -78,7 +78,7 @@ discard block |
||
78 | 78 | |
79 | 79 | foreach ($addresses as $address) { |
80 | 80 | $ip = ip2long($address); |
81 | - if ($ip && ! isset($this->addressInList[$ip])) { |
|
81 | + if ($ip && !isset($this->addressInList[$ip])) { |
|
82 | 82 | $this->addresses[] = $ip; |
83 | 83 | $this->addressInList[$ip] = true; |
84 | 84 | } |
@@ -142,7 +142,7 @@ discard block |
||
142 | 142 | */ |
143 | 143 | public function doesNotContain($address) |
144 | 144 | { |
145 | - return ! $this->contains($address); |
|
145 | + return !$this->contains($address); |
|
146 | 146 | } |
147 | 147 | |
148 | 148 | /** |
@@ -76,8 +76,8 @@ discard block |
||
76 | 76 | $store->iplist = $ipList; |
77 | 77 | $store->expires = $this->calculateExpiration($ttl)->format('c'); |
78 | 78 | |
79 | - if (! is_writable(dirname($this->getLocation())) || |
|
80 | - (file_exists($this->getLocation()) && ! is_writable($this->getLocation())) |
|
79 | + if (!is_writable(dirname($this->getLocation())) || |
|
80 | + (file_exists($this->getLocation()) && !is_writable($this->getLocation())) |
|
81 | 81 | ) { |
82 | 82 | return false; |
83 | 83 | } |
@@ -89,11 +89,11 @@ discard block |
||
89 | 89 | */ |
90 | 90 | public function fetch() |
91 | 91 | { |
92 | - if (! is_readable($this->getLocation())) { |
|
92 | + if (!is_readable($this->getLocation())) { |
|
93 | 93 | return null; |
94 | 94 | } |
95 | 95 | $data = json_decode(file_get_contents($this->getLocation())); |
96 | - if (! isset($data->iplist) || ! isset($data->expires)) { |
|
96 | + if (!isset($data->iplist) || !isset($data->expires)) { |
|
97 | 97 | return null; |
98 | 98 | } |
99 | 99 | if (new \DateTime($data->expires) < new \DateTime()) { |
@@ -110,7 +110,7 @@ discard block |
||
110 | 110 | */ |
111 | 111 | protected function calculateExpiration($ttl = null) |
112 | 112 | { |
113 | - if (! is_int($ttl) && $ttl < 1) { |
|
113 | + if (!is_int($ttl) && $ttl < 1) { |
|
114 | 114 | throw new \InvalidArgumentException('Invalid ttl.'); |
115 | 115 | } |
116 | 116 | return new \DateTime(sprintf('+%d seconds', $ttl)); |