| Server IP : 78.140.185.180 / Your IP : 216.73.216.170 Web Server : LiteSpeed System : Linux cpanel13.v.fozzy.com 4.18.0-513.11.1.lve.el8.x86_64 #1 SMP Thu Jan 18 16:21:02 UTC 2024 x86_64 User : builderbox ( 1072) PHP Version : 7.3.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /proc/thread-self/root/home/builderbox/././www/vendor/gliterd/backblaze-b2/tests/ |
Upload File : |
<?php
namespace BackblazeB2\Tests;
use BackblazeB2\Bucket;
use BackblazeB2\Client;
use BackblazeB2\Exceptions\BadJsonException;
use BackblazeB2\Exceptions\BadValueException;
use BackblazeB2\Exceptions\BucketAlreadyExistsException;
use BackblazeB2\Exceptions\BucketNotEmptyException;
use BackblazeB2\Exceptions\NotFoundException;
use BackblazeB2\Exceptions\ValidationException;
use BackblazeB2\File;
use GuzzleHttp\Middleware;
use GuzzleHttp\Psr7\Stream;
use PHPUnit\Framework\TestCase;
use ReflectionClass;
class ClientTest extends TestCase
{
use TestHelper;
public function testCreatePublicBucket()
{
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'create_bucket_public.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
// Test that we get a public bucket back after creation
$bucket = $client->createBucket([
'BucketName' => 'Test bucket',
'BucketType' => Bucket::TYPE_PUBLIC,
]);
$this->assertInstanceOf(Bucket::class, $bucket);
$this->assertEquals('Test bucket', $bucket->getName());
$this->assertEquals(Bucket::TYPE_PUBLIC, $bucket->getType());
}
public function testCreatePrivateBucket()
{
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'create_bucket_private.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
// Test that we get a private bucket back after creation
$bucket = $client->createBucket([
'BucketName' => 'Test bucket',
'BucketType' => Bucket::TYPE_PRIVATE,
]);
$this->assertInstanceOf(Bucket::class, $bucket);
$this->assertEquals('Test bucket', $bucket->getName());
$this->assertEquals(Bucket::TYPE_PRIVATE, $bucket->getType());
}
public function testBucketAlreadyExistsExceptionThrown()
{
$this->expectException(BucketAlreadyExistsException::class);
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(400, [], 'create_bucket_exists.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$client->createBucket([
'BucketName' => 'I already exist',
'BucketType' => Bucket::TYPE_PRIVATE,
]);
}
public function testInvalidBucketTypeThrowsException()
{
$this->expectException(ValidationException::class);
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$client->createBucket([
'BucketName' => 'Test bucket',
'BucketType' => 'i am not valid',
]);
}
public function testUpdateBucketToPrivate()
{
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'update_bucket_to_private.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$bucket = $client->updateBucket([
'BucketId' => 'bucketId',
'BucketType' => Bucket::TYPE_PRIVATE,
]);
$this->assertInstanceOf(Bucket::class, $bucket);
$this->assertEquals('bucketId', $bucket->getId());
$this->assertEquals(Bucket::TYPE_PRIVATE, $bucket->getType());
}
public function testUpdateBucketToPublic()
{
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'update_bucket_to_public.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$bucket = $client->updateBucket([
'BucketId' => 'bucketId',
'BucketType' => Bucket::TYPE_PUBLIC,
]);
$this->assertInstanceOf(Bucket::class, $bucket);
$this->assertEquals('bucketId', $bucket->getId());
$this->assertEquals(Bucket::TYPE_PUBLIC, $bucket->getType());
}
public function testList3Buckets()
{
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'list_buckets_3.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$buckets = $client->listBuckets();
$this->assertIsArray($buckets);
$this->assertCount(3, $buckets);
$this->assertInstanceOf(Bucket::class, $buckets[0]);
}
public function testEmptyArrayWithNoBuckets()
{
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'list_buckets_0.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$buckets = $client->listBuckets();
$this->assertIsArray($buckets);
$this->assertCount(0, $buckets);
}
public function testDeleteBucket()
{
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'delete_bucket.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$this->assertTrue($client->deleteBucket([
'BucketId' => 'bucketId',
]));
}
public function testBadJsonThrownDeletingNonExistentBucket()
{
$this->expectException(BadJsonException::class);
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(400, [], 'delete_bucket_non_existent.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$client->deleteBucket([
'BucketId' => 'bucketId',
]);
}
public function testBucketNotEmptyThrownDeletingNonEmptyBucket()
{
$this->expectException(BucketNotEmptyException::class);
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(400, [], 'bucket_not_empty.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$client->deleteBucket([
'BucketId' => 'bucketId',
]);
}
public function testUploadingResource()
{
$container = [];
$history = Middleware::history($container);
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'get_upload_url.json'),
$this->buildResponseFromStub(200, [], 'upload.json'),
], $history);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
// Set up the resource being uploaded.
$content = 'The quick brown box jumps over the lazy dog';
$resource = fopen('php://memory', 'r+');
fwrite($resource, $content);
rewind($resource);
$file = $client->upload([
'BucketId' => 'bucketId',
'FileName' => 'test.txt',
'Body' => $resource,
]);
$this->assertInstanceOf(File::class, $file);
// We'll also check the Guzzle history to make sure the upload request got created correctly.
$uploadRequest = $container[2]['request'];
$this->assertEqualsWithDelta('uploadUrl', $uploadRequest->getRequestTarget(), 0);
$this->assertEqualsWithDelta('authToken', $uploadRequest->getHeader('Authorization')[0], 0);
$this->assertEqualsWithDelta(strlen($content), $uploadRequest->getHeader('Content-Length')[0], 0);
$this->assertEqualsWithDelta('test.txt', $uploadRequest->getHeader('X-Bz-File-Name')[0], 0);
$this->assertEqualsWithDelta(sha1($content), $uploadRequest->getHeader('X-Bz-Content-Sha1')[0], 0);
$this->assertEqualsWithDelta(
round(microtime(true) * 1000),
$uploadRequest->getHeader('X-Bz-Info-src_last_modified_millis')[0],
100
);
$this->assertInstanceOf(Stream::class, $uploadRequest->getBody());
}
public function testUploadingString()
{
$container = [];
$history = Middleware::history($container);
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'get_upload_url.json'),
$this->buildResponseFromStub(200, [], 'upload.json'),
], $history);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$content = 'The quick brown box jumps over the lazy dog';
$file = $client->upload([
'BucketId' => 'bucketId',
'FileName' => 'test.txt',
'Body' => $content,
]);
$this->assertInstanceOf(File::class, $file);
// We'll also check the Guzzle history to make sure the upload request got created correctly.
$uploadRequest = $container[2]['request'];
$this->assertEqualsWithDelta('uploadUrl', $uploadRequest->getRequestTarget(), 0.0);
$this->assertEqualsWithDelta('authToken', $uploadRequest->getHeader('Authorization')[0], 0.0);
$this->assertEqualsWithDelta(strlen($content), $uploadRequest->getHeader('Content-Length')[0], 0.0);
$this->assertEqualsWithDelta('test.txt', $uploadRequest->getHeader('X-Bz-File-Name')[0], 0.0);
$this->assertEqualsWithDelta(sha1($content), $uploadRequest->getHeader('X-Bz-Content-Sha1')[0], 0.0);
$this->assertEqualsWithDelta(
round(microtime(true) * 1000),
$uploadRequest->getHeader('X-Bz-Info-src_last_modified_millis')[0],
100
);
$this->assertInstanceOf(Stream::class, $uploadRequest->getBody());
}
public function testUploadingWithCustomContentTypeAndLastModified()
{
$container = [];
$history = Middleware::history($container);
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'get_upload_url.json'),
$this->buildResponseFromStub(200, [], 'upload.json'),
], $history);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
// My birthday :)
$lastModified = 701568000000;
$contentType = 'text/plain';
$file = $client->upload([
'BucketId' => 'bucketId',
'FileName' => 'test.txt',
'Body' => 'Test file content',
'FileContentType' => $contentType,
'FileLastModified' => $lastModified,
]);
$this->assertInstanceOf(File::class, $file);
// We'll also check the Guzzle history to make sure the upload request got created correctly.
$uploadRequest = $container[2]['request'];
$this->assertEquals($lastModified, $uploadRequest->getHeader('X-Bz-Info-src_last_modified_millis')[0]);
$this->assertEquals($contentType, $uploadRequest->getHeader('Content-Type')[0]);
$this->assertInstanceOf(Stream::class, $uploadRequest->getBody());
}
public function testDownloadUrl()
{
$authorizeAccountString = file_get_contents(dirname(__FILE__).'/responses/authorize_account.json');
$authorizeAccount = json_decode($authorizeAccountString);
$expectedFileContents = 'foo';
$uriResponses = [
'https://api.backblazeb2.com/b2api/v1//b2_authorize_account' => $authorizeAccountString,
$authorizeAccount->downloadUrl.'/b2api/v1/b2_download_file_by_id' => $expectedFileContents,
];
$clientMock = $this->getMockBuilder(\BackblazeB2\Http\Client::class)->getMock();
$mockGuzzleRequest = function ($method, $uri = null, array $options = [], $asJson = true) use ($uriResponses) {
if (isset($options['headers']) && array_key_exists('Authorization', $options['headers'])) {
//If header is present, it must not be empty
$this->assertNotEmpty($options['headers']['Authorization'], sprintf('No authorization for uri %s', $uri));
}
if (isset($uriResponses[$uri])) {
$response = new \GuzzleHttp\Psr7\Response(200, [], $uriResponses[$uri]);
} else {
$response = new \GuzzleHttp\Psr7\Response(404, [], null);
}
if ($asJson) {
return json_decode($response->getBody(), true);
}
return $response->getBody()->getContents();
};
$clientMock->expects($this->any())
->method('guzzleRequest')
->will($this->returnCallback($mockGuzzleRequest));
$client = new Client('testId', 'testKey', ['client' => $clientMock]);
$actualFileContents = $client->download([
'FileId' => 'fileId',
]);
$this->assertSame($expectedFileContents, $actualFileContents);
}
public function testDownloadByIdWithoutSavePath()
{
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'download_content'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$fileContent = $client->download([
'FileId' => 'fileId',
]);
$this->assertEquals($fileContent, 'The quick brown fox jumps over the lazy dog');
}
public function testDownloadByIdWithSavePath()
{
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'download_content'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$client->download([
'FileId' => 'fileId',
'SaveAs' => __DIR__.'/test.txt',
]);
$this->assertFileExists(__DIR__.'/test.txt');
$this->assertEquals('The quick brown fox jumps over the lazy dog', file_get_contents(__DIR__.'/test.txt'));
unlink(__DIR__.'/test.txt');
}
public function testDownloadingByIncorrectIdThrowsException()
{
$this->expectException(BadValueException::class);
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(400, [], 'download_by_incorrect_id.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$client->download([
'FileId' => 'incorrect',
]);
}
public function testDownloadByPathWithoutSavePath()
{
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'download_content'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$fileContent = $client->download([
'BucketName' => 'test-bucket',
'FileName' => 'test.txt',
]);
$this->assertEquals($fileContent, 'The quick brown fox jumps over the lazy dog');
}
public function testDownloadByPathWithSavePath()
{
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'download_content'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$client->download([
'BucketName' => 'test-bucket',
'FileName' => 'test.txt',
'SaveAs' => __DIR__.'/test.txt',
]);
$this->assertFileExists(__DIR__.'/test.txt');
$this->assertEquals('The quick brown fox jumps over the lazy dog', file_get_contents(__DIR__.'/test.txt'));
unlink(__DIR__.'/test.txt');
}
public function testDownloadingByIncorrectPathThrowsException()
{
$this->expectException(NotFoundException::class);
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(400, [], 'download_by_incorrect_path.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$client->download([
'BucketName' => 'test-bucket',
'FileName' => 'path/to/incorrect/file.txt',
]);
}
public function testListFilesHandlesMultiplePages()
{
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'list_files_page1.json'),
$this->buildResponseFromStub(200, [], 'list_files_page2.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$files = $client->listFiles([
'BucketId' => 'bucketId',
]);
$this->assertIsArray($files);
$this->assertInstanceOf(File::class, $files[0]);
$this->assertCount(1500, $files);
}
public function testListFilesReturnsEmptyArrayWithNoFiles()
{
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'list_files_empty.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$files = $client->listFiles([
'BucketId' => 'bucketId',
]);
$this->assertIsArray($files);
$this->assertCount(0, $files);
}
public function testGetFile()
{
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'get_file.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$file = $client->getFile([
'FileId' => 'fileId',
]);
$this->assertInstanceOf(File::class, $file);
}
public function testGettingNonExistentFileThrowsException()
{
$this->expectException(BadJsonException::class);
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(400, [], 'get_file_non_existent.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$client->getFile([
'FileId' => 'fileId',
]);
}
public function testCopyFile()
{
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'list_files_page1.json'),
$this->buildResponseFromStub(200, [], 'copy_file.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$actual = $client->copy([
'BucketId' => 'sourceBucketId',
'FileName' => 'sourceFileName',
'SaveAs' => 'destinationFileName',
]);
$this->assertInstanceOf('BackblazeB2\File', $actual);
$this->assertEquals('4_z4c2b953461da9c825f260e1b_f1114dbf5bg9707e8_d20160206_m012226_c001_v1111017_t0010', $actual->getId());
}
public function testDeleteFile()
{
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'get_file.json'),
$this->buildResponseFromStub(200, [], 'delete_file.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$this->assertTrue($client->deleteFile([
'FileId' => 'fileId',
]));
}
public function testDeleteFileRetrievesFileNameWhenNotProvided()
{
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'get_file.json'),
$this->buildResponseFromStub(200, [], 'delete_file.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$this->assertTrue($client->deleteFile([
'FileId' => 'fileId',
]));
}
public function testDeletingNonExistentFileThrowsException()
{
$this->expectException(BadJsonException::class);
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(400, [], 'delete_file_non_existent.json'),
]);
$client = new Client('testId', 'testKey', ['client' => $guzzle]);
$client->deleteFile([
'FileId' => 'fileId',
'FileName' => 'fileName',
]);
}
public function testAuthenticationTimeout()
{
$reflectionClass = new ReflectionClass('BackblazeB2\Client');
$reflectionProperty = $reflectionClass->getProperty('reAuthTime');
$reflectionProperty->setAccessible(true);
$guzzle = $this->buildGuzzleFromResponses([
$this->buildResponseFromStub(200, [], 'authorize_account.json'),
$this->buildResponseFromStub(200, [], 'create_bucket_public.json'),
]);
$client = new Client(
'testId',
'testKey',
[
'client' => $guzzle,
'auth_timeout_seconds' => 2,
]
);
$curTime = $reflectionProperty->getValue($client);
sleep(5); // let the token timeout
// Something that will reaturhorize
$bucket = $client->createBucket([
'BucketName' => 'Test bucket',
'BucketType' => Bucket::TYPE_PUBLIC,
]);
$newTime = $reflectionProperty->getValue($client);
$this->assertTrue($curTime->timestamp != $newTime->timestamp);
}
}