partner-it / b2-php

src/B2Client.php

Indentation +218 added lines, -218 removed lines

@@ -8,223 +8,223 @@
 class B2Client
 {
 
-    /**
-     * @var string
-     */
-    protected $accountId;
-
-    /**
-     * @var string
-     */
-    protected $applicationKey;
-
-    /**
-     * @var string
-     */
-    protected $apiUrl;
-
-    /**
-     * @var string
-     */
-    protected $authorizationToken;
-
-    /**
-     * @var string
-     */
-    protected $downloadUrl;
-
-    /**
-     * @var CurlRequest
-     */
-    protected $CurlRequest;
-
-    /**
-     * @var Files
-     */
-    public $Files;
-
-
-    /**
-     * B2Client constructor.
-     * @param string $accountId
-     * @param string $applicationKey
-     */
-    public function __construct($accountId, $applicationKey, CurlRequest $curlRequest = null)
-    {
-
-        if (!$curlRequest) {
-            $this->CurlRequest = new CurlRequest();
-        } else {
-            $this->CurlRequest = $curlRequest;
-        }
-
-        $this->accountId      = $accountId;
-        $this->applicationKey = $applicationKey;
-        $this->Files          = new Files($this);
-
-    }
-
-    /**
-     * @param array $result
-     */
-    public function setToken($result)
-    {
-        $this->authorizationToken = $result['authorizationToken'];
-        $this->apiUrl             = $result['apiUrl'];
-        $this->downloadUrl        = $result['downloadUrl'];
-    }
-
-    /**
-     *
-     */
-    public function requestToken()
-    {
-
-        $results = $this->curl('https://api.backblaze.com/b2api/v1/b2_authorize_account', 'GET', [
-            $this->buildBasicAuthHeader()
-        ]);
-
-        if ($results['statusCode'] === 200) {
-            $this->setToken($results['responseBody']);
-        } else {
-            throw new \RuntimeException('Failed to get token: ' . $results['responseBody']['message']);
-        }
-
-    }
-
-    /**
-     * @param $endpoint
-     * @param $method
-     * @param array $data
-     * @return mixed
-     * @throws \Exception
-     */
-    public function call($endpoint, $method, $data = [])
-    {
-
-        if (empty($this->authorizationToken)) {
-            throw new \Exception('You must set or generate a token');
-        }
-
-        $headers = [
-            $this->buildTokenAuthHeader()
-        ];
-
-        $result = $this->curl($this->apiUrl . '/b2api/v1/' . $endpoint, $method, $headers, $data);
-
-        if ($result['statusCode'] >= 200 && $result['statusCode'] < 300) {
-            return $result['responseBody'];
-        }
-
-        if ($result['statusCode'] >= 400) {
-            throw new \RuntimeException('Error ' . $result['statusCode'] . ' - ' . $result['responseBody']['message']);
-        }
-
-    }
-
-    /**
-     * @param $uri
-     * @param string $method
-     * @param array $headers
-     * @param array $body
-     * @return array
-     * @throws \Exception
-     */
-    public function curl($uri, $method = 'GET', $headers = [], $body = [])
-    {
-
-        $this->CurlRequest->setOption(CURLOPT_URL, $uri);
-        $this->CurlRequest->setOption(CURLOPT_CUSTOMREQUEST, $method);
-        $this->CurlRequest->setOption(CURLOPT_RETURNTRANSFER, 1);
-
-        $headers[] = 'Content-Type: application/json';
-        $headers[] = "Accept: application/json";
-
-        $this->CurlRequest->setOption(CURLOPT_POST, 1);
-        $body = json_encode($body);
-        $this->CurlRequest->setOption(CURLOPT_POSTFIELDS, $body);
-        $this->CurlRequest->setOption(CURLOPT_HTTPHEADER, $headers);
-
-        $resp = $this->CurlRequest->execute();
-        if ($this->CurlRequest->getErrorNo() !== 0) {
-            throw new \RuntimeException('curl error ' . $this->CurlRequest->getError() . '" - Code: ' . $this->CurlRequest->getErrorNo());
-        } else {
-            return [
-                'statusCode'   => $this->CurlRequest->getInfo(CURLINFO_HTTP_CODE),
-                'responseBody' => json_decode($resp, true)
-            ];
-        }
-    }
-
-    /**
-     * @return string
-     */
-    public function buildBasicAuthHeader()
-    {
-        return 'Authorization: Basic ' . base64_encode($this->accountId . ':' . $this->applicationKey);
-    }
-
-    /**
-     * @return string
-     */
-    public function buildTokenAuthHeader()
-    {
-        return 'Authorization: ' . $this->authorizationToken;
-    }
-
-    /**
-     * @param $data
-     * @param $sha1
-     * @param $fileName
-     * @param $url
-     * @param $token
-     */
-    public function uploadData($fileData, $fileDataSha1, $fileName, $contentType, $uploadUrl, $uploadToken)
-    {
-        $headers   = [];
-        $headers[] = "Authorization: " . $uploadToken;
-        $headers[] = "X-Bz-File-Name: " . $fileName;
-        $headers[] = "Content-Type: " . $contentType;
-        $headers[] = "X-Bz-Content-Sha1: " . $fileDataSha1;
-
-        $this->CurlRequest->setOption(CURLOPT_URL, $uploadUrl);
-        $this->CurlRequest->setOption(CURLOPT_POST, true);
-        $this->CurlRequest->setOption(CURLOPT_POSTFIELDS, $fileData);
-        $this->CurlRequest->setOption(CURLOPT_HTTPHEADER, $headers);
-
-        $resp = $this->CurlRequest->execute();
-        if ($this->CurlRequest->getErrorNo() !== 0) {
-            throw new \RuntimeException('curl error ' . $this->CurlRequest->getError() . '" - Code: ' . $this->CurlRequest->getErrorNo());
-        } else {
-            return [
-                'statusCode'   => $this->CurlRequest->getInfo(CURLINFO_HTTP_CODE),
-                'responseBody' => json_decode($resp, true)
-            ];
-        }
-    }
-
-    /**
-     * @param $url
-     */
-    public function downloadFileByName($uri) {
-
-        $uri = $this->downloadUrl . "/file/" . $uri;
-        $this->CurlRequest->setOption(CURLOPT_URL, $uri);
-        $this->CurlRequest->setOption(CURLOPT_CUSTOMREQUEST, 'GET');
-        $this->CurlRequest->setOption(CURLOPT_RETURNTRANSFER, 1);
-
-        $headers = [
-            $this->buildTokenAuthHeader()
-        ];
-
-        $this->CurlRequest->setOption(CURLOPT_HTTPHEADER, $headers);
-
-        $resp = $this->CurlRequest->execute();
-        if ($this->CurlRequest->getErrorNo() !== 0) {
-            throw new \RuntimeException('curl error ' . $this->CurlRequest->getError() . '" - Code: ' . $this->CurlRequest->getErrorNo());
-        } else {
-            return $resp;
-        }
-    }
+	/**
+	 * @var string
+	 */
+	protected $accountId;
+
+	/**
+	 * @var string
+	 */
+	protected $applicationKey;
+
+	/**
+	 * @var string
+	 */
+	protected $apiUrl;
+
+	/**
+	 * @var string
+	 */
+	protected $authorizationToken;
+
+	/**
+	 * @var string
+	 */
+	protected $downloadUrl;
+
+	/**
+	 * @var CurlRequest
+	 */
+	protected $CurlRequest;
+
+	/**
+	 * @var Files
+	 */
+	public $Files;
+
+
+	/**
+	 * B2Client constructor.
+	 * @param string $accountId
+	 * @param string $applicationKey
+	 */
+	public function __construct($accountId, $applicationKey, CurlRequest $curlRequest = null)
+	{
+
+		if (!$curlRequest) {
+			$this->CurlRequest = new CurlRequest();
+		} else {
+			$this->CurlRequest = $curlRequest;
+		}
+
+		$this->accountId      = $accountId;
+		$this->applicationKey = $applicationKey;
+		$this->Files          = new Files($this);
+
+	}
+
+	/**
+	 * @param array $result
+	 */
+	public function setToken($result)
+	{
+		$this->authorizationToken = $result['authorizationToken'];
+		$this->apiUrl             = $result['apiUrl'];
+		$this->downloadUrl        = $result['downloadUrl'];
+	}
+
+	/**
+	 *
+	 */
+	public function requestToken()
+	{
+
+		$results = $this->curl('https://api.backblaze.com/b2api/v1/b2_authorize_account', 'GET', [
+			$this->buildBasicAuthHeader()
+		]);
+
+		if ($results['statusCode'] === 200) {
+			$this->setToken($results['responseBody']);
+		} else {
+			throw new \RuntimeException('Failed to get token: ' . $results['responseBody']['message']);
+		}
+
+	}
+
+	/**
+	 * @param $endpoint
+	 * @param $method
+	 * @param array $data
+	 * @return mixed
+	 * @throws \Exception
+	 */
+	public function call($endpoint, $method, $data = [])
+	{
+
+		if (empty($this->authorizationToken)) {
+			throw new \Exception('You must set or generate a token');
+		}
+
+		$headers = [
+			$this->buildTokenAuthHeader()
+		];
+
+		$result = $this->curl($this->apiUrl . '/b2api/v1/' . $endpoint, $method, $headers, $data);
+
+		if ($result['statusCode'] >= 200 && $result['statusCode'] < 300) {
+			return $result['responseBody'];
+		}
+
+		if ($result['statusCode'] >= 400) {
+			throw new \RuntimeException('Error ' . $result['statusCode'] . ' - ' . $result['responseBody']['message']);
+		}
+
+	}
+
+	/**
+	 * @param $uri
+	 * @param string $method
+	 * @param array $headers
+	 * @param array $body
+	 * @return array
+	 * @throws \Exception
+	 */
+	public function curl($uri, $method = 'GET', $headers = [], $body = [])
+	{
+
+		$this->CurlRequest->setOption(CURLOPT_URL, $uri);
+		$this->CurlRequest->setOption(CURLOPT_CUSTOMREQUEST, $method);
+		$this->CurlRequest->setOption(CURLOPT_RETURNTRANSFER, 1);
+
+		$headers[] = 'Content-Type: application/json';
+		$headers[] = "Accept: application/json";
+
+		$this->CurlRequest->setOption(CURLOPT_POST, 1);
+		$body = json_encode($body);
+		$this->CurlRequest->setOption(CURLOPT_POSTFIELDS, $body);
+		$this->CurlRequest->setOption(CURLOPT_HTTPHEADER, $headers);
+
+		$resp = $this->CurlRequest->execute();
+		if ($this->CurlRequest->getErrorNo() !== 0) {
+			throw new \RuntimeException('curl error ' . $this->CurlRequest->getError() . '" - Code: ' . $this->CurlRequest->getErrorNo());
+		} else {
+			return [
+				'statusCode'   => $this->CurlRequest->getInfo(CURLINFO_HTTP_CODE),
+				'responseBody' => json_decode($resp, true)
+			];
+		}
+	}
+
+	/**
+	 * @return string
+	 */
+	public function buildBasicAuthHeader()
+	{
+		return 'Authorization: Basic ' . base64_encode($this->accountId . ':' . $this->applicationKey);
+	}
+
+	/**
+	 * @return string
+	 */
+	public function buildTokenAuthHeader()
+	{
+		return 'Authorization: ' . $this->authorizationToken;
+	}
+
+	/**
+	 * @param $data
+	 * @param $sha1
+	 * @param $fileName
+	 * @param $url
+	 * @param $token
+	 */
+	public function uploadData($fileData, $fileDataSha1, $fileName, $contentType, $uploadUrl, $uploadToken)
+	{
+		$headers   = [];
+		$headers[] = "Authorization: " . $uploadToken;
+		$headers[] = "X-Bz-File-Name: " . $fileName;
+		$headers[] = "Content-Type: " . $contentType;
+		$headers[] = "X-Bz-Content-Sha1: " . $fileDataSha1;
+
+		$this->CurlRequest->setOption(CURLOPT_URL, $uploadUrl);
+		$this->CurlRequest->setOption(CURLOPT_POST, true);
+		$this->CurlRequest->setOption(CURLOPT_POSTFIELDS, $fileData);
+		$this->CurlRequest->setOption(CURLOPT_HTTPHEADER, $headers);
+
+		$resp = $this->CurlRequest->execute();
+		if ($this->CurlRequest->getErrorNo() !== 0) {
+			throw new \RuntimeException('curl error ' . $this->CurlRequest->getError() . '" - Code: ' . $this->CurlRequest->getErrorNo());
+		} else {
+			return [
+				'statusCode'   => $this->CurlRequest->getInfo(CURLINFO_HTTP_CODE),
+				'responseBody' => json_decode($resp, true)
+			];
+		}
+	}
+
+	/**
+	 * @param $url
+	 */
+	public function downloadFileByName($uri) {
+
+		$uri = $this->downloadUrl . "/file/" . $uri;
+		$this->CurlRequest->setOption(CURLOPT_URL, $uri);
+		$this->CurlRequest->setOption(CURLOPT_CUSTOMREQUEST, 'GET');
+		$this->CurlRequest->setOption(CURLOPT_RETURNTRANSFER, 1);
+
+		$headers = [
+			$this->buildTokenAuthHeader()
+		];
+
+		$this->CurlRequest->setOption(CURLOPT_HTTPHEADER, $headers);
+
+		$resp = $this->CurlRequest->execute();
+		if ($this->CurlRequest->getErrorNo() !== 0) {
+			throw new \RuntimeException('curl error ' . $this->CurlRequest->getError() . '" - Code: ' . $this->CurlRequest->getErrorNo());
+		} else {
+			return $resp;
+		}
+	}
 
 }

src/Files/Files.php

Indentation +106 added lines, -106 removed lines

@@ -10,111 +10,111 @@
 class Files
 {
 
-    /**
-     * @var B2Client
-     */
-    public $B2Client;
-
-    /**
-     * Files constructor.
-     * @param B2Client $B2Client
-     */
-    public function __construct(B2Client $B2Client)
-    {
-        $this->B2Client = $B2Client;
-    }
-
-    /**
-     * @param $bucketId
-     * @param $startFileName
-     * @return mixed
-     * @throws \Exception
-     */
-    public function listFileNames($bucketId, $startFileName = null, $maxFileCount = 100)
-    {
-        return $this->B2Client->call('b2_list_file_names', 'POST', [
-            'startFileName' => $startFileName,
-            'bucketId'      => $bucketId,
-            'maxFileCount'  => $maxFileCount
-        ]);
-    }
-
-    /**
-     * Lists all files in a bucket and starting filename. For very large buckets this may fail, use listFileNames() directly
-     *
-     * @param $bucketId
-     * @param $startFileName
-     * @return array
-     */
-    public function listAllFileNames($bucketId, $startFileName)
-    {
-
-        $allresults = [];
-        $result     = $this->listFileNames($bucketId, $startFileName);
-        $allresults = array_merge($allresults, $result['responseBody']['files']);
-
-        if ($result['responseBody']['nextFileName'] !== null) {
-            $allresults = array_merge($allresults,
-                $this->listAllFileNames($bucketId, $result['responseBody']['nextFileName']));
-        }
-
-        return $allresults;
-    }
-
-    /**
-     * @param $fileID
-     * @return mixed
-     * @throws \Exception
-     */
-    public function getFileInfo($fileId)
-    {
-        return $this->B2Client->call('b2_get_file_info', 'POST', ['fileId' => $fileId]);
-    }
-
-    /**
-     * @param $bucketId
-     * @return mixed
-     * @throws \Exception
-     */
-    public function getUploadUrl($bucketId)
-    {
-        return $this->B2Client->call('b2_get_upload_url', 'POST', ['bucketId' => $bucketId]);
-    }
-
-    /**
-     * @param $bucketId
-     * @param string $filePath The path to the local file
-     * @param string $fileName The name/path on B2
-     * @param string $contentType
-     * @param array $uploadUrlResponse
-     * @return array
-     */
-    public function uploadFile($bucketId, $filePath, $fileName, $contentType, $uploadUrlResponse = [])
-    {
-
-        if (empty($uploadUrlResponse)) {
-            $uploadUrlResponse = $this->getUploadUrl($bucketId);
-        }
-
-        $handle       = fopen($filePath, 'r');
-        $fileData     = fread($handle, filesize($filePath));
-        $fileDataSha1 = sha1_file($filePath);
-
-        return $this->B2Client->uploadData($fileData, $fileDataSha1, $fileName, $contentType,
-            $uploadUrlResponse['uploadUrl'],
-            $uploadUrlResponse['authorizationToken']);
-
-    }
-
-    /**
-     * @param $bucketId
-     * @param $fileName
-     * @return mixed
-     * @throws \Exception
-     */
-    public function downloadFileByName($bucketName, $fileName)
-    {
-        return $this->B2Client->downloadFileByName($bucketName . '/' . $fileName);
-    }
+	/**
+	 * @var B2Client
+	 */
+	public $B2Client;
+
+	/**
+	 * Files constructor.
+	 * @param B2Client $B2Client
+	 */
+	public function __construct(B2Client $B2Client)
+	{
+		$this->B2Client = $B2Client;
+	}
+
+	/**
+	 * @param $bucketId
+	 * @param $startFileName
+	 * @return mixed
+	 * @throws \Exception
+	 */
+	public function listFileNames($bucketId, $startFileName = null, $maxFileCount = 100)
+	{
+		return $this->B2Client->call('b2_list_file_names', 'POST', [
+			'startFileName' => $startFileName,
+			'bucketId'      => $bucketId,
+			'maxFileCount'  => $maxFileCount
+		]);
+	}
+
+	/**
+	 * Lists all files in a bucket and starting filename. For very large buckets this may fail, use listFileNames() directly
+	 *
+	 * @param $bucketId
+	 * @param $startFileName
+	 * @return array
+	 */
+	public function listAllFileNames($bucketId, $startFileName)
+	{
+
+		$allresults = [];
+		$result     = $this->listFileNames($bucketId, $startFileName);
+		$allresults = array_merge($allresults, $result['responseBody']['files']);
+
+		if ($result['responseBody']['nextFileName'] !== null) {
+			$allresults = array_merge($allresults,
+				$this->listAllFileNames($bucketId, $result['responseBody']['nextFileName']));
+		}
+
+		return $allresults;
+	}
+
+	/**
+	 * @param $fileID
+	 * @return mixed
+	 * @throws \Exception
+	 */
+	public function getFileInfo($fileId)
+	{
+		return $this->B2Client->call('b2_get_file_info', 'POST', ['fileId' => $fileId]);
+	}
+
+	/**
+	 * @param $bucketId
+	 * @return mixed
+	 * @throws \Exception
+	 */
+	public function getUploadUrl($bucketId)
+	{
+		return $this->B2Client->call('b2_get_upload_url', 'POST', ['bucketId' => $bucketId]);
+	}
+
+	/**
+	 * @param $bucketId
+	 * @param string $filePath The path to the local file
+	 * @param string $fileName The name/path on B2
+	 * @param string $contentType
+	 * @param array $uploadUrlResponse
+	 * @return array
+	 */
+	public function uploadFile($bucketId, $filePath, $fileName, $contentType, $uploadUrlResponse = [])
+	{
+
+		if (empty($uploadUrlResponse)) {
+			$uploadUrlResponse = $this->getUploadUrl($bucketId);
+		}
+
+		$handle       = fopen($filePath, 'r');
+		$fileData     = fread($handle, filesize($filePath));
+		$fileDataSha1 = sha1_file($filePath);
+
+		return $this->B2Client->uploadData($fileData, $fileDataSha1, $fileName, $contentType,
+			$uploadUrlResponse['uploadUrl'],
+			$uploadUrlResponse['authorizationToken']);
+
+	}
+
+	/**
+	 * @param $bucketId
+	 * @param $fileName
+	 * @return mixed
+	 * @throws \Exception
+	 */
+	public function downloadFileByName($bucketName, $fileName)
+	{
+		return $this->B2Client->downloadFileByName($bucketName . '/' . $fileName);
+	}
 
 }