View source
<?php
namespace NoDrupal\Tests\flysystem_s3\Unit\Flysystem;
use Aws\Credentials\Credentials;
use Aws\S3\S3Client;
use Aws\S3\S3ClientInterface;
use Drupal\Core\Cache\MemoryBackend;
use Drupal\Core\DependencyInjection\ContainerBuilder;
use Drupal\Core\Logger\RfcLogLevel;
use Drupal\Tests\UnitTestCase;
use Drupal\flysystem_s3\Flysystem\S3;
use League\Flysystem\AdapterInterface;
use League\Flysystem\Config;
use Prophecy\Argument;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\RequestStack;
class S3Test extends UnitTestCase {
public function test() {
$configuration = [
'bucket' => 'example-bucket',
'prefix' => 'test prefix',
'cname' => 'example.com',
];
$client = new S3Client([
'version' => 'latest',
'region' => 'beep',
'credentials' => new Credentials('fsdf', 'sfsdf'),
]);
$plugin = new S3($client, new Config($configuration));
$this
->assertInstanceOf(AdapterInterface::class, $plugin
->getAdapter());
$this
->assertSame('http://example.com/test%20prefix/foo%201.html', $plugin
->getExternalUrl('s3://foo 1.html'));
$configuration['prefix'] = '';
$plugin = new S3($client, new Config($configuration));
$this
->assertSame('http://example.com/foo%201.html', $plugin
->getExternalUrl('s3://foo 1.html'));
}
public function testMergeConfiguration() {
$container = new ContainerBuilder();
$container
->set('request_stack', new RequestStack());
$container
->get('request_stack')
->push(Request::create('https://example.com/'));
$configuration = [
'key' => 'fee',
'secret' => 'fo',
'region' => 'eu-west-1',
'bucket' => 'example-bucket',
];
$configuration = S3::mergeConfiguration($container, $configuration);
$this
->assertSame('https', $configuration['protocol']);
$client_config = S3::mergeClientConfiguration($container, $configuration);
$this
->assertSame('eu-west-1', $client_config['region']);
$this
->assertNull($client_config['endpoint']);
$this
->assertInstanceOf(Credentials::class, $client_config['credentials']);
}
public function testCreate() {
$container = new ContainerBuilder();
$container
->set('request_stack', new RequestStack());
$container
->get('request_stack')
->push(Request::create('https://example.com/'));
$configuration = [
'key' => 'fee',
'secret' => 'fo',
'region' => 'eu-west-1',
'bucket' => 'example-bucket',
];
$plugin = S3::create($container, $configuration, '', '');
$this
->assertInstanceOf(S3::class, $plugin);
}
public function testCreateUsingNonAwsConfiguration() {
$container = new ContainerBuilder();
$container
->set('request_stack', new RequestStack());
$container
->get('request_stack')
->push(Request::create('https://example.com/'));
$configuration = [
'key' => 'fee',
'secret' => 'fo',
'region' => 'eu-west-1',
'cname' => 'something.somewhere.tld',
'endpoint' => 'https://api.somewhere.tld',
];
$plugin = S3::create($container, $configuration, '', '');
$this
->assertSame('https://something.somewhere.tld/foo%201.html', $plugin
->getExternalUrl('s3://foo 1.html'));
$this
->assertSame('https://api.somewhere.tld', (string) $plugin
->getAdapter()
->getClient()
->getEndpoint());
}
public function testCreateUsingNonAwsConfigurationWithBucket() {
$container = new ContainerBuilder();
$container
->set('request_stack', new RequestStack());
$container
->get('request_stack')
->push(Request::create('http://example.com/'));
$configuration = [
'key' => 'foo',
'secret' => 'bar',
'cname' => 'storage.example.com',
'cname_is_bucket' => FALSE,
'bucket' => 'my-bucket',
'endpoint' => 'https://api.somewhere.tld',
];
$plugin = S3::create($container, $configuration, '', '');
$this
->assertSame('http://storage.example.com/my-bucket/foo%201.html', $plugin
->getExternalUrl('s3://foo 1.html'));
$this
->assertSame('https://api.somewhere.tld', (string) $plugin
->getAdapter()
->getClient()
->getEndpoint());
}
public function testEmptyCnameDoesNotBreakConfiguration() {
$configuration = [
'cname' => NULL,
'bucket' => 'my-bucket',
];
$plugin = new S3($this
->createMock(S3ClientInterface::class), new Config($configuration));
$this
->assertSame('http://s3.amazonaws.com/my-bucket/foo.html', $plugin
->getExternalUrl('s3://foo.html'));
}
public function testEnsure() {
$client = $this
->prophesize(S3ClientInterface::class);
$client
->doesBucketExist(Argument::type('string'))
->willReturn(TRUE);
$plugin = new S3($client
->reveal(), new Config([
'bucket' => 'example-bucket',
]));
$this
->assertSame([], $plugin
->ensure());
$client
->doesBucketExist(Argument::type('string'))
->willReturn(FALSE);
$plugin = new S3($client
->reveal(), new Config([
'bucket' => 'example-bucket',
]));
$result = $plugin
->ensure();
$this
->assertSame(1, count($result));
$this
->assertSame(RfcLogLevel::ERROR, $result[0]['severity']);
}
public function testIamAuth() {
$container = new ContainerBuilder();
$container
->set('request_stack', new RequestStack());
$container
->get('request_stack')
->push(Request::create('https://example.com/'));
$container
->set('cache.default', new MemoryBackend('bin'));
$configuration = [
'bucket' => 'example-bucket',
];
$plugin = S3::create($container, $configuration, '', '');
}
}
