FM / Backblaze

/home/techb158/balacoffee.com/wp-content/plugins/updraftplus/includes/Backblaze/

/home/techb158/balacoffee.com/wp-content/plugins/updraftplus/includes/Backblaze

Name	Size	Mode	Actions
CurlClient.php	21603	0644	edit dl rm

Edit: /home/techb158/balacoffee.com/wp-content/plugins/updraftplus/includes/Backblaze/CurlClient.php (21603B)

<?php
// @codingStandardsIgnoreFile

if (!defined('UPDRAFTPLUS_DIR')) die('No direct access allowed');

class UpdraftPlus_Backblaze_CurlClient {

protected $accountId;
	protected $applicationKey;
	protected $credentials;

protected $authToken;
	protected $apiUrl;
	protected $downloadUrl;
	
	// Whether to verify the server certificate or not
	protected $sslVerify = true;
	
	// If set to a string, then it indicates a path for a CA store to use
	protected $useCACerts = false;

protected $singleBucketKeyId;

/**
	 * Constructor
	 *
	 * @param String $accountId
	 * @param String $applicationKey
	 * @param String $singleBucketKeyId
	 * @param Array	 $options
	 */
	public function __construct($accountId, $applicationKey, $singleBucketKeyId = '', array $options = array()) {
		$this->accountId = $accountId;
		$this->applicationKey = $applicationKey;
		$this->singleBucketKeyId = $singleBucketKeyId;
		if (isset($options['ssl_verify'])) $this->sslVerify = $options['ssl_verify'];
		if (isset($options['ssl_ca_certs'])) $this->useCACerts = $options['ssl_ca_certs'];
		$this->authorizeAccount();
	}
	
	protected function request($method = 'GET', $uri = '', array $options = array(), $as_json = true) {
		$session = curl_init($uri);

$headers = array();

if (isset($options['auth'])) {
			$account_id = empty($this->singleBucketKeyId) ? $this->accountId : $this->singleBucketKeyId;
			$headers[] = 'Authorization: Basic ' . base64_encode($account_id . ':' . $this->applicationKey);
		}

if (isset($options['headers'])) {
			foreach ($options['headers'] as $key => $header) {
				$headers[] = $key . ': ' . $header;
			}
		}
		
		if ($this->sslVerify) {
			curl_setopt($session, CURLOPT_SSL_VERIFYPEER, true);
			curl_setopt($session, CURLOPT_SSL_VERIFYHOST, 2);
		} else {
			curl_setopt($session, CURLOPT_SSL_VERIFYPEER, false);
			curl_setopt($session, CURLOPT_SSL_VERIFYHOST, 0);
		}
		
		if ($this->useCACerts) {
			curl_setopt($session, CURLOPT_CAINFO, $this->useCACerts);
		}
		
		if ('GET' == $method) {

curl_setopt($session, CURLOPT_HTTPGET, true);

} else {

$data = array();

if (isset($options['json'])) {

$headers[] = "Accept: application/json";
				$data	  = json_encode($options['json']);

}

if (isset($options['body'])) {

$data = $options['body'];

}

curl_setopt($session, CURLOPT_POSTFIELDS, $data);
			curl_setopt($session, CURLOPT_POST, true);
		}

curl_setopt($session, CURLOPT_HTTPHEADER, $headers);
		curl_setopt($session, CURLOPT_RETURNTRANSFER, true);

if (isset($options['sink'])) {
			$sink = fopen($options['sink'], 'w+');
			curl_setopt($session, CURLOPT_FILE, $sink);
			curl_setopt($session, CURLOPT_FOLLOWLOCATION, true);
		}

if (isset($options['session'])) {
			return $session;
		}

$response = curl_exec($session);
		
		if (0 != ($curl_error = curl_errno($session))) {
			throw new Exception("Curl error ($curl_error): ".curl_error($session), $curl_error);
		}

$decode_response = json_decode($response, true);

if (isset($decode_response['status']) && 200 !== $decode_response['status']) {

throw new Exception($decode_response['message'], $decode_response['status']);

}

curl_close($session);

if (!empty($sink)) @fclose($sink);

if ($as_json) return $decode_response;

return $response;
	}

public function uploadLargeStart($options) {
		// Request body parameters
		if ('/' === substr($options['FileName'], 0, 1)) {
			$options['FileName'] = ltrim($options['FileName'], '/');
		}

if (!isset($options['BucketId']) && isset($options['BucketName'])) {
			$options['BucketId'] = $this->getBucketIdFromName($options['BucketName']);
		}

if (!isset($options['FileContentType'])) {
			$options['FileContentType'] = 'b2/x-auto';
		}

// Request start large file upload
		$response = $this->request('POST', $this->apiUrl . '/b2_start_large_file', array(
			'headers' => array(
				'Authorization' => $this->authToken,
			),
			'json'	=> array(
				'bucketId'	=> $options['BucketId'],
				'fileName'	=> $options['FileName'],
				'contentType' => $options['FileContentType'],
			),
		));

/*
		 * fileId
		 * fileName
		 * accountId
		 * bucketId
		 * contentType
		 * fileInfo
		 * uploadTimestamp
		 */
		return $response;
	}

public function uploadLargeUrl($options) {
		if (!isset($options['FileId'])) {
			throw new Exception('FileId required');
		}

$response = $this->request('POST', $this->apiUrl . '/b2_get_upload_part_url', array(
			'headers' => array(
				'Authorization' => $this->authToken,
			),
			'json'	=> array(
				'fileId' => $options['FileId'],
			),
		));

/*
		 * authorizationToken
		 * fileId
		 * uploadUrl
		 */
		return $response;
	}

public function uploadLargePart($options) {

if (!isset($options['AuthorizationToken'])) {
			throw new Exception('AuthorizationToken required');
		}

if (!isset($options['FilePartNo'])) {
			throw new Exception('FilePartNo required');
		}

if (!isset($options['UploadUrl'])) {
			throw new Exception('UploadUrl required');
		}

if (!isset($options['Body'])) {
			throw new Exception('Body required');
		}

if (is_resource($options['Body'])) {
			// We need to calculate the file's hash incrementally from the stream.
			$context = hash_init('sha1');
			hash_update_stream($context, $options['Body']);
			$hash = hash_final($context);

// Similarly, we have to use fstat to get the size of the stream.
			$fstat = fstat($options['Body']);
			$size  = $fstat['size'];

// Rewind the stream before passing it to the HTTP client.
			rewind($options['Body']);
		} else {
			// We've been given a simple string body, it's super simple to calculate the hash and size.
			$hash = sha1($options['Body']);
			$size = mb_strlen($options['Body'], '8bit');
		}

$response = $this->request('POST', $options['UploadUrl'], array(
			'headers' => array(
				'Authorization'	 => $options['AuthorizationToken'],
				'X-Bz-Part-Number'  => $options['FilePartNo'],
				'Content-Length'	=> $size,
				'X-Bz-Content-Sha1' => $hash,
			),
			'body'	=> $options['Body'],
		));

/*
		 * fileId
		 * partNumber
		 * contentLength
		 * contentSha1
		 */
		return $response;
	}

public function uploadLargeFinish($options) {

if (!isset($options['FileId'])) {
			throw new Exception('FileId required');
		}

if (!isset($options['FilePartSha1Array'])) {
			throw new Exception('FilePartSha1Array required');
		}

if (!is_array($options['FilePartSha1Array'])) {
			throw new Exception("FilePartSha1Array must be an array");

}

$response = $this->request('POST', $this->apiUrl . '/b2_finish_large_file', array(
			'headers' => array(
				'Authorization' => $this->authToken,
			),
			'json'	=> array(
				'fileId'		=> (string) $options['FileId'],
				'partSha1Array' => $options['FilePartSha1Array'],
			),
		));

if (empty($response['contentLength'])) {
			throw new Exception('B2: uploadLargeFinish error: contentLength returned was empty ('.serialize($response).')');
		}
		
		return new UpdraftPlus_Backblaze_File(
			$response['fileId'],
			$response['fileName'],
			$response['contentSha1'],
			$response['contentLength'],
			$response['contentType'],
			$response['fileInfo']
		);
	}

protected function authorizeAccount() {
		$response = $this->request("GET", 'https://api.backblazeb2.com/b2api/v1/b2_authorize_account', array(
			'auth' => array($this->accountId, $this->applicationKey),
		));

$this->authToken   = $response['authorizationToken'];
		$this->apiUrl	  = $response['apiUrl'] . '/b2api/v1';
		$this->downloadUrl = $response['downloadUrl'];
	}

public function listBuckets() {
		$buckets = array();

$response = $this->request('POST', $this->apiUrl . '/b2_list_buckets', array(
			'headers' => array(
				'Authorization' => $this->authToken,
			),
			'json'	=> array(
				'accountId' => $this->accountId,
			),
		));

if (!isset($response['buckets'])) throw new Exception('Failed to list buckets: '.serialize($response));
		
		foreach ($response['buckets'] as $bucket) {
			$buckets[] = new UpdraftPlus_Backblaze_Bucket($bucket['bucketId'], $bucket['bucketName'], $bucket['bucketType']);
		}

return $buckets;
	}

protected function getBucketIdFromName($name) {
		$buckets = $this->listBuckets();

foreach ($buckets as $bucket) {
			if ($bucket->getName() === $name) {
				return $bucket->getId();
			}
		}

return null;
	}

protected function getBucketNameFromId($id) {
		$buckets = $this->listBuckets();

foreach ($buckets as $bucket) {
			if ($bucket->getId() === $id) {
				return $bucket->getName();
			}
		}

return null;
	}

protected function getFileIdFromBucketAndFileName($bucketName, $fileName) {
		$files = $this->listFiles(array(
			'BucketName' => $bucketName,
			'FileName'   => $fileName,
		));

foreach ($files as $file) {
			if ($file->getName() === $fileName) {
				return $file->getId();
			}
		}

return null;
	}

public function listFiles($options) {
		// if FileName is set, we only attempt to retrieve information about that single file.
		$fileName = !empty($options['FileName']) ? $options['FileName'] : null;

$nextFileName = null;
		$maxFileCount = 1000;
		$files		= array();

if (!isset($options['BucketId']) && isset($options['BucketName'])) {
			$options['BucketId'] = $this->getBucketIdFromName($options['BucketName']);
		}

if ($fileName) {
			$nextFileName = $fileName;
			$maxFileCount = 1;
		}

$json = array(
			'bucketId'	  => $options['BucketId'],
			'startFileName' => $nextFileName,
			'maxFileCount'  => $maxFileCount,
		);
		
		if (!empty($options['Prefix'])) $json['prefix'] = $options['Prefix'];
		
		// B2 returns, at most, 1000 files per "page". Loop through the pages and compile an array of File objects.
		while (true) {
			$response = $this->request('POST', $this->apiUrl . '/b2_list_file_names', array(
				'headers' => array(
					'Authorization' => $this->authToken,
				),
				'json'	=> $json
			));

if (!isset($response['files'])) throw new Exception('Failed to list files. '.serialize($files));
			
			foreach ($response['files'] as $file) {
				// if we have a file name set, only retrieve information if the file name matches
				if (!$fileName || ($fileName === $file['fileName'])) {
					$files[] = new UpdraftPlus_Backblaze_File($file['fileId'], $file['fileName'], null, $file['size']);
				}
			}

if ($fileName || $response['nextFileName'] === null) {
				// We've got all the files - break out of loop.
				break;
			}

$json['startFileName'] = $response['nextFileName'];
		}

return $files;
	}

public function upload($options) {
		// Clean the path if it starts with /.
		if (substr($options['FileName'], 0, 1) === '/') {
			$options['FileName'] = ltrim($options['FileName'], '/');
		}

if (!isset($options['BucketId']) && isset($options['BucketName'])) {
			$options['BucketId'] = $this->getBucketIdFromName($options['BucketName']);
		}

// Retrieve the URL that we should be uploading to.
		$response = $this->request('POST', $this->apiUrl . '/b2_get_upload_url', array(
			'headers' => array(
				'Authorization' => $this->authToken,
			),
			'json'	=> array(
				'bucketId' => $options['BucketId'],
			),
		));

$uploadEndpoint  = $response['uploadUrl'];
		$uploadAuthToken = $response['authorizationToken'];

// Similarly, we have to use fstat to get the size of the stream.
			$fstat = fstat($options['Body']);
			$size  = $fstat['size'];

if (!isset($options['FileLastModified'])) {
			$options['FileLastModified'] = round(microtime(true) * 1000);
		}

if (!isset($options['FileContentType'])) {
			$options['FileContentType'] = 'b2/x-auto';
		}

$response = $this->request('POST', $uploadEndpoint, array(
			'headers' => array(
				'Authorization'					  => $uploadAuthToken,
				'Content-Type'					   => $options['FileContentType'],
				'Content-Length'					 => $size,
				'X-Bz-File-Name'					 => $options['FileName'],
				'X-Bz-Content-Sha1'				  => $hash,
				'X-Bz-Info-src_last_modified_millis' => $options['FileLastModified'],
			),
			'body'	=> $options['Body'],
		));

return new UpdraftPlus_Backblaze_File(
			$response['fileId'],
			$response['fileName'],
			$response['contentSha1'],
			$response['contentLength'],
			$response['contentType'],
			$response['fileInfo']
		);
	}

public function download($options) {
		$requestUrl	 = null;
		$requestOptions = array(
			'headers' => array(
				'Authorization' => $this->authToken,
			),
			'sink'	=> isset($options['SaveAs']) ? $options['SaveAs'] : null,
		);

if (isset($options['FileId'])) {
			$requestOptions['query'] = array('fileId' => $options['FileId']);
			$requestUrl			  = $this->downloadUrl . '/b2api/v1/b2_download_file_by_id';
		} else {
			if (!isset($options['BucketName']) && isset($options['BucketId'])) {
				$options['BucketName'] = $this->getBucketNameFromId($options['BucketId']);
			}

$requestUrl = sprintf('%s/file/%s/%s', $this->downloadUrl, $options['BucketName'], $options['FileName']);
		}
		
		if (isset($options['headers'])) {
			$requestOptions['headers'] = array_merge($requestOptions['headers'], $options['headers']);
		}

$response = $this->request('GET', $requestUrl, $requestOptions, false);

return isset($options['SaveAs']) ? true : $response;
	}

public function getFile($options) {
		if (!isset($options['FileId']) && isset($options['BucketName']) && isset($options['FileName'])) {
			$options['FileId'] = $this->getFileIdFromBucketAndFileName($options['BucketName'], $options['FileName']);

if (!$options['FileId']) {
				throw new UpdraftPlus_Backblaze_NotFoundException();
			}
		}

$response = $this->request('POST', $this->apiUrl . '/b2_get_file_info', array(
			'headers' => array(
				'Authorization' => $this->authToken,
			),
			'json'	=> array(
				'fileId' => $options['FileId'],
			),
		));

/**
	 * Delete a file
	 *
	 * @param Array $options - possible keys are FileName, FileId, BucketName
	 *
	 * @return Boolean. Can also throw an exception; including UpdraftPlus_Backblaze_NotFoundException if the file was not found.
	 */
	public function deleteFile($options) {
		if (!isset($options['FileName'])) {
			$file = $this->getFile($options);

$options['FileName'] = $file->getName();
		}

if (!isset($options['FileId']) && isset($options['BucketName']) && isset($options['FileName'])) {
			$file = $this->getFile($options);

$options['FileId'] = $file->getId();
		}

$delete_result = $this->request('POST', $this->apiUrl . '/b2_delete_file_version', array(
			'headers' => array(
				'Authorization' => $this->authToken,
			),
			'json'	=> array(
				'fileName' => $options['FileName'],
				'fileId'   => $options['FileId'],
			),
		));

return (is_array($delete_result) && !empty($delete_result['fileId'])) ? true : false;
	}

/**
	 * Delete multiple files
	 *
	 * @param Array  $files_to_delete - array of possible files to delete; sub-keys are FileName, FileId, BucketName
	 * @param String $bucket_name	  - the bucket that files are being deleted from
	 * @param String|Null			  - path prefix (to prevent unnecessary scanning of other paths)
	 *
	 * @return Array|Boolean
	 */
	public function deleteMultipleFiles($files_to_delete, $bucket_name, $path_prefix = null) {
		if (count($files_to_delete) == 0) {
			return false;
		}

$active       = null;
		$sessions     = [];
		$result       = [];
		$bulk_session = curl_multi_init();

$list_options = array(
			'BucketName' => $bucket_name
		);
		
		if (is_string($path_prefix) && '' !== $path_prefix) $list_options['Prefix'] = $path_prefix;
		
		$files = $this->listFiles($list_options);

$files_lookup = array();

foreach ($files as $file_object) {
			$file_name = $file_object->getName();
			$file_id = $file_object->getId();
			$files_lookup[$file_name] = $file_id;
		}

foreach ($files_to_delete as $file_identification) {
			
			try {
				if (!isset($file_identification['FileName'])) {
					// We should not enter here as we always pass a file name but just in case
					$file = $this->getFile($file_identification);
					$file_identification['FileName'] = $file->getName();
					$file_identification['FileId'] = $file->getId();
				} elseif (!isset($file_identification['FileId'])) {
					if (isset($files_lookup[$file_identification['FileName']])) {
						$file_identification['FileId'] = $files_lookup[$file_identification['FileName']];
					} else {
						// We should not enter here as all the files should be in the same bucket but just in case
						$file = $this->getFile($file_identification);
						$file_identification['FileId'] = $file->getId();
					}
				}
			} catch (UpdraftPlus_Backblaze_NotFoundException $e) {
				array_push($sessions, true);
				continue;
			}

$session = $this->request('POST', $this->apiUrl . '/b2_delete_file_version', array(
				'headers' => array(
					'Authorization' => $this->authToken,
				),
				'json'	=> array(
					'fileName' => $file_identification['FileName'],
					'fileId'   => $file_identification['FileId'],
				),
				'session' => true
			));
			array_push($sessions, $session);
			curl_multi_add_handle($bulk_session, $session);
		}

do {
			$status = curl_multi_exec($bulk_session, $active);
			if ($active) {
				curl_multi_select($bulk_session);
			}
		} while ($active && $status == CURLM_OK);

foreach ($sessions as $session) {
			if (is_bool($session)) {
				array_push($result, $session);
				continue;
			}
			$response = curl_multi_getcontent($session);
			array_push($result, $response);
			curl_multi_remove_handle($bulk_session, $session);
		}
		curl_multi_close($bulk_session);

return (is_array($result) && !empty($result)) ? $result : false;
	}
	
	/**
	 * Create a private bucket with the given name.
	 *
	 * @param String $bucket_name - valid bucket name
	 * @throws Exception
	 *
	 * @return boolean - If bucket created successfully, it returns true otherwise false.
	 */
    public function createPrivateBucket($bucket_name) {
		try {
			$response = $this->request('POST', $this->apiUrl.'/b2_create_bucket',
				array(
					'headers' => array(
						'Authorization' => $this->authToken,
					),
					'json' => array(
						'accountId' => $this->accountId,
						'bucketName' => $bucket_name,
						'bucketType' => 'allPrivate'
					)
				)
			);
		} catch (Exception $e) {
			if (400 == $e->getCode()) {
				throw new Exception("Bucket can't be created because Bucket name is already in use.", $e->getCode());
			} else {
				throw $e;	
			}
			return false;
		}
		if (isset($response['bucketId']) && isset($response['bucketName']) && isset($response['bucketType'])) {
			return true;
		}
		return false;
    }

}

final class UpdraftPlus_Backblaze_Bucket {
	const TYPE_PUBLIC  = 'allPublic';
	const TYPE_PRIVATE = 'allPrivate';

protected $id;
	protected $name;
	protected $type;

/**
	 * Bucket constructor.
	 *
	 * @param $id
	 * @param $name
	 * @param $type
	 */
	public function __construct($id, $name, $type) {
		$this->id   = $id;
		$this->name = $name;
		$this->type = $type;
	}

public function getId() {
		return $this->id;
	}

public function getName() {
		return $this->name;
	}

public function getType() {
		return $this->type;
	}
}

final class UpdraftPlus_Backblaze_File {
	protected $id;
	protected $name;
	protected $hash;
	protected $size;
	protected $type;
	protected $info;
	protected $bucketId;
	protected $action;
	protected $uploadTimestamp;

/**
	 * File constructor.
	 *
	 * @param $id
	 * @param $name
	 * @param $hash
	 * @param $size
	 * @param $type
	 * @param $info
	 * @param $bucketId
	 * @param $action
	 * @param $uploadTimestamp
	 */
	public function __construct($id, $name, $hash = null, $size = null, $type = null, $info = null, $bucketId = null, $action = null, $uploadTimestamp = null) {
		$this->id			  = $id;
		$this->name			= $name;
		$this->hash			= $hash;
		$this->size			= $size;
		$this->type			= $type;
		$this->info			= $info;
		$this->bucketId		= $bucketId;
		$this->action		  = $action;
		$this->uploadTimestamp = $uploadTimestamp;
	}

/**
	 * @return string
	 */
	public function getId() {
		return $this->id;
	}

/**
	 * @return string
	 */
	public function getName() {
		return $this->name;
	}

/**
	 * @return string
	 */
	public function getHash() {
		return $this->hash;
	}

/**
	 * @return int
	 */
	public function getSize() {
		return $this->size;
	}

/**
	 * @return string
	 */
	public function getType() {
		return $this->type;
	}

/**
	 * @return array
	 */
	public function getInfo()
	{
		return $this->info;
	}

/**
	 * @return string
	 */
	public function getBucketId() {
		return $this->bucketId;
	}

/**
	 * @return string
	 */
	public function getAction() {
		return $this->action;
	}

/**
	 * @return string
	 */
	public function getUploadTimestamp() {
		return $this->uploadTimestamp;
	}
}

class UpdraftPlus_Backblaze_NotFoundException extends Exception {
}

cmd: