h4kuna / fio

src/Request/Queue.php

Spacing +7 added lines, -7 removed lines

@@ -65,7 +65,7 @@ 
 	 */
 	public function download($token, $url)
 	{
-		return $this->request($token, function (GuzzleHttp\Client $client) use ($url) {
+		return $this->request($token, function(GuzzleHttp\Client $client) use ($url) {
 			return $client->request('GET', $url, $this->downloadOptions);
 		}, 'download');
 	}
@@ -83,7 +83,7 @@ 
 		}
 		$newPost[] = ['name' => 'file', 'contents' => fopen($filename, 'r')];
 
-		$response = $this->request($token, function (GuzzleHttp\Client $client) use ($url, $newPost) {
+		$response = $this->request($token, function(GuzzleHttp\Client $client) use ($url, $newPost) {
 			return $client->request('POST', $url, [GuzzleHttp\RequestOptions::MULTIPART => $newPost]);
 		}, 'upload');
 		return self::createXmlResponse($response);
@@ -114,13 +114,13 @@ 
 					throw $e;
 				} elseif ($i >= $this->limitLoop) {
 					fclose($file);
-					throw new Fio\QueueLimitException('You have limit up requests to server ' . $this->limitLoop);
+					throw new Fio\QueueLimitException('You have limit up requests to server '.$this->limitLoop);
 				}
 				self::sleep($tempFile);
 				$next = true;
 			} catch (GuzzleHttp\Exception\ServerException $e) {
-				if($e->hasResponse()) {
-					self::detectDownloadResponse( $e->getResponse() );
+				if ($e->hasResponse()) {
+					self::detectDownloadResponse($e->getResponse());
 				}
 				throw new Fio\ServiceUnavailableException('Service is currently unavailable');
 			} catch (GuzzleHttp\Exception\ConnectException $e) {
@@ -170,7 +170,7 @@ 
 	{
 		$key = substr($token, 10, -10);
 		if (!isset(self::$tokens[$key])) {
-			self::$tokens[$key] = $this->tempDir . DIRECTORY_SEPARATOR . md5($key);
+			self::$tokens[$key] = $this->tempDir.DIRECTORY_SEPARATOR.md5($key);
 		}
 
 		return self::$tokens[$key];
@@ -178,7 +178,7 @@ 
 
 	private static function safeProtocol($filename)
 	{
-		return Utils\SafeStream::PROTOCOL . '://' . $filename;
+		return Utils\SafeStream::PROTOCOL.'://'.$filename;
 	}
 
 	/**

Doc Comments +11 added lines, -2 removed lines

@@ -26,6 +26,9 @@ 
 	/** @var string */
 	private $tempDir;
 
+	/**
+	 * @param string $tempDir
+	 */
 	public function __construct($tempDir)
 	{
 		$this->tempDir = $tempDir;
@@ -60,7 +63,7 @@ 
 	/**
 	 * @param $token
 	 * @param string $url
-	 * @return mixed|string
+	 * @return GuzzleHttp\Psr7\Stream
 	 * @throws Fio\QueueLimitException
 	 * @throws Fio\ServiceUnavailableException
 	 */
@@ -91,7 +94,7 @@ 
 
 	/**
 	 * @param $token
-	 * @param $fallback
+	 * @param \Closure $fallback
 	 * @param string $action
 	 * @return GuzzleHttp\Psr7\Stream
 	 * @throws Fio\QueueLimitException
@@ -154,6 +157,9 @@ 
 		}
 	}
 
+	/**
+	 * @param string $filename
+	 */
 	private static function sleep($filename)
 	{
 		$criticalTime = time() - filemtime($filename);
@@ -176,6 +182,9 @@ 
 		return self::$tokens[$key];
 	}
 
+	/**
+	 * @param string $filename
+	 */
 	private static function safeProtocol($filename)
 	{
 		return Utils\SafeStream::PROTOCOL . '://' . $filename;

Unused Use Statements +4 added lines, -4 removed lines

@@ -2,10 +2,10 @@
 
 namespace h4kuna\Fio\Request;
 
-use GuzzleHttp,
-	h4kuna\Fio,
-	h4kuna\Fio\Response\Pay,
-	Nette\Utils;
+use GuzzleHttp;
+use h4kuna\Fio;
+use h4kuna\Fio\Response\Pay;
+use Nette\Utils;
 use Psr\Http\Message\ResponseInterface;
 
 class Queue implements IQueue