Crypto
11 months ago
Exception
11 months ago
RegionalEndpoint
11 months ago
UseArnRegion
11 months ago
AmbiguousSuccessParser.php
11 months ago
ApplyChecksumMiddleware.php
11 months ago
BatchDelete.php
11 months ago
BucketEndpointArnMiddleware.php
11 months ago
BucketEndpointMiddleware.php
11 months ago
CalculatesChecksumTrait.php
11 months ago
EndpointRegionHelperTrait.php
11 months ago
GetBucketLocationParser.php
11 months ago
MultipartCopy.php
11 months ago
MultipartUploader.php
11 months ago
MultipartUploadingTrait.php
11 months ago
ObjectCopier.php
11 months ago
ObjectUploader.php
11 months ago
PermanentRedirectMiddleware.php
11 months ago
PostObject.php
11 months ago
PostObjectV4.php
11 months ago
PutObjectUrlMiddleware.php
11 months ago
RetryableMalformedResponseParser.php
11 months ago
S3Client.php
11 months ago
S3ClientInterface.php
11 months ago
S3ClientTrait.php
11 months ago
S3EndpointMiddleware.php
11 months ago
S3MultiRegionClient.php
11 months ago
S3UriParser.php
11 months ago
SSECMiddleware.php
11 months ago
StreamWrapper.php
11 months ago
Transfer.php
11 months ago
ValidateResponseChecksumParser.php
11 months ago
S3MultiRegionClient.php
362 lines
| 1 | <?php |
| 2 | namespace Aws\S3; |
| 3 | |
| 4 | use Aws\CacheInterface; |
| 5 | use Aws\CommandInterface; |
| 6 | use Aws\LruArrayCache; |
| 7 | use Aws\MultiRegionClient as BaseClient; |
| 8 | use Aws\Exception\AwsException; |
| 9 | use Aws\S3\Exception\PermanentRedirectException; |
| 10 | use GuzzleHttp\Promise; |
| 11 | |
| 12 | /** |
| 13 | * **Amazon Simple Storage Service** multi-region client. |
| 14 | * |
| 15 | * @method \Aws\Result abortMultipartUpload(array $args = []) |
| 16 | * @method \GuzzleHttp\Promise\Promise abortMultipartUploadAsync(array $args = []) |
| 17 | * @method \Aws\Result completeMultipartUpload(array $args = []) |
| 18 | * @method \GuzzleHttp\Promise\Promise completeMultipartUploadAsync(array $args = []) |
| 19 | * @method \Aws\Result copyObject(array $args = []) |
| 20 | * @method \GuzzleHttp\Promise\Promise copyObjectAsync(array $args = []) |
| 21 | * @method \Aws\Result createBucket(array $args = []) |
| 22 | * @method \GuzzleHttp\Promise\Promise createBucketAsync(array $args = []) |
| 23 | * @method \Aws\Result createMultipartUpload(array $args = []) |
| 24 | * @method \GuzzleHttp\Promise\Promise createMultipartUploadAsync(array $args = []) |
| 25 | * @method \Aws\Result createSession(array $args = []) |
| 26 | * @method \GuzzleHttp\Promise\Promise createSessionAsync(array $args = []) |
| 27 | * @method \Aws\Result deleteBucket(array $args = []) |
| 28 | * @method \GuzzleHttp\Promise\Promise deleteBucketAsync(array $args = []) |
| 29 | * @method \Aws\Result deleteBucketAnalyticsConfiguration(array $args = []) |
| 30 | * @method \GuzzleHttp\Promise\Promise deleteBucketAnalyticsConfigurationAsync(array $args = []) |
| 31 | * @method \Aws\Result deleteBucketCors(array $args = []) |
| 32 | * @method \GuzzleHttp\Promise\Promise deleteBucketCorsAsync(array $args = []) |
| 33 | * @method \Aws\Result deleteBucketEncryption(array $args = []) |
| 34 | * @method \GuzzleHttp\Promise\Promise deleteBucketEncryptionAsync(array $args = []) |
| 35 | * @method \Aws\Result deleteBucketIntelligentTieringConfiguration(array $args = []) |
| 36 | * @method \GuzzleHttp\Promise\Promise deleteBucketIntelligentTieringConfigurationAsync(array $args = []) |
| 37 | * @method \Aws\Result deleteBucketInventoryConfiguration(array $args = []) |
| 38 | * @method \GuzzleHttp\Promise\Promise deleteBucketInventoryConfigurationAsync(array $args = []) |
| 39 | * @method \Aws\Result deleteBucketLifecycle(array $args = []) |
| 40 | * @method \GuzzleHttp\Promise\Promise deleteBucketLifecycleAsync(array $args = []) |
| 41 | * @method \Aws\Result deleteBucketMetricsConfiguration(array $args = []) |
| 42 | * @method \GuzzleHttp\Promise\Promise deleteBucketMetricsConfigurationAsync(array $args = []) |
| 43 | * @method \Aws\Result deleteBucketOwnershipControls(array $args = []) |
| 44 | * @method \GuzzleHttp\Promise\Promise deleteBucketOwnershipControlsAsync(array $args = []) |
| 45 | * @method \Aws\Result deleteBucketPolicy(array $args = []) |
| 46 | * @method \GuzzleHttp\Promise\Promise deleteBucketPolicyAsync(array $args = []) |
| 47 | * @method \Aws\Result deleteBucketReplication(array $args = []) |
| 48 | * @method \GuzzleHttp\Promise\Promise deleteBucketReplicationAsync(array $args = []) |
| 49 | * @method \Aws\Result deleteBucketTagging(array $args = []) |
| 50 | * @method \GuzzleHttp\Promise\Promise deleteBucketTaggingAsync(array $args = []) |
| 51 | * @method \Aws\Result deleteBucketWebsite(array $args = []) |
| 52 | * @method \GuzzleHttp\Promise\Promise deleteBucketWebsiteAsync(array $args = []) |
| 53 | * @method \Aws\Result deleteObject(array $args = []) |
| 54 | * @method \GuzzleHttp\Promise\Promise deleteObjectAsync(array $args = []) |
| 55 | * @method \Aws\Result deleteObjectTagging(array $args = []) |
| 56 | * @method \GuzzleHttp\Promise\Promise deleteObjectTaggingAsync(array $args = []) |
| 57 | * @method \Aws\Result deleteObjects(array $args = []) |
| 58 | * @method \GuzzleHttp\Promise\Promise deleteObjectsAsync(array $args = []) |
| 59 | * @method \Aws\Result deletePublicAccessBlock(array $args = []) |
| 60 | * @method \GuzzleHttp\Promise\Promise deletePublicAccessBlockAsync(array $args = []) |
| 61 | * @method \Aws\Result getBucketAccelerateConfiguration(array $args = []) |
| 62 | * @method \GuzzleHttp\Promise\Promise getBucketAccelerateConfigurationAsync(array $args = []) |
| 63 | * @method \Aws\Result getBucketAcl(array $args = []) |
| 64 | * @method \GuzzleHttp\Promise\Promise getBucketAclAsync(array $args = []) |
| 65 | * @method \Aws\Result getBucketAnalyticsConfiguration(array $args = []) |
| 66 | * @method \GuzzleHttp\Promise\Promise getBucketAnalyticsConfigurationAsync(array $args = []) |
| 67 | * @method \Aws\Result getBucketCors(array $args = []) |
| 68 | * @method \GuzzleHttp\Promise\Promise getBucketCorsAsync(array $args = []) |
| 69 | * @method \Aws\Result getBucketEncryption(array $args = []) |
| 70 | * @method \GuzzleHttp\Promise\Promise getBucketEncryptionAsync(array $args = []) |
| 71 | * @method \Aws\Result getBucketIntelligentTieringConfiguration(array $args = []) |
| 72 | * @method \GuzzleHttp\Promise\Promise getBucketIntelligentTieringConfigurationAsync(array $args = []) |
| 73 | * @method \Aws\Result getBucketInventoryConfiguration(array $args = []) |
| 74 | * @method \GuzzleHttp\Promise\Promise getBucketInventoryConfigurationAsync(array $args = []) |
| 75 | * @method \Aws\Result getBucketLifecycle(array $args = []) |
| 76 | * @method \GuzzleHttp\Promise\Promise getBucketLifecycleAsync(array $args = []) |
| 77 | * @method \Aws\Result getBucketLifecycleConfiguration(array $args = []) |
| 78 | * @method \GuzzleHttp\Promise\Promise getBucketLifecycleConfigurationAsync(array $args = []) |
| 79 | * @method \Aws\Result getBucketLocation(array $args = []) |
| 80 | * @method \GuzzleHttp\Promise\Promise getBucketLocationAsync(array $args = []) |
| 81 | * @method \Aws\Result getBucketLogging(array $args = []) |
| 82 | * @method \GuzzleHttp\Promise\Promise getBucketLoggingAsync(array $args = []) |
| 83 | * @method \Aws\Result getBucketMetricsConfiguration(array $args = []) |
| 84 | * @method \GuzzleHttp\Promise\Promise getBucketMetricsConfigurationAsync(array $args = []) |
| 85 | * @method \Aws\Result getBucketNotification(array $args = []) |
| 86 | * @method \GuzzleHttp\Promise\Promise getBucketNotificationAsync(array $args = []) |
| 87 | * @method \Aws\Result getBucketNotificationConfiguration(array $args = []) |
| 88 | * @method \GuzzleHttp\Promise\Promise getBucketNotificationConfigurationAsync(array $args = []) |
| 89 | * @method \Aws\Result getBucketOwnershipControls(array $args = []) |
| 90 | * @method \GuzzleHttp\Promise\Promise getBucketOwnershipControlsAsync(array $args = []) |
| 91 | * @method \Aws\Result getBucketPolicy(array $args = []) |
| 92 | * @method \GuzzleHttp\Promise\Promise getBucketPolicyAsync(array $args = []) |
| 93 | * @method \Aws\Result getBucketPolicyStatus(array $args = []) |
| 94 | * @method \GuzzleHttp\Promise\Promise getBucketPolicyStatusAsync(array $args = []) |
| 95 | * @method \Aws\Result getBucketReplication(array $args = []) |
| 96 | * @method \GuzzleHttp\Promise\Promise getBucketReplicationAsync(array $args = []) |
| 97 | * @method \Aws\Result getBucketRequestPayment(array $args = []) |
| 98 | * @method \GuzzleHttp\Promise\Promise getBucketRequestPaymentAsync(array $args = []) |
| 99 | * @method \Aws\Result getBucketTagging(array $args = []) |
| 100 | * @method \GuzzleHttp\Promise\Promise getBucketTaggingAsync(array $args = []) |
| 101 | * @method \Aws\Result getBucketVersioning(array $args = []) |
| 102 | * @method \GuzzleHttp\Promise\Promise getBucketVersioningAsync(array $args = []) |
| 103 | * @method \Aws\Result getBucketWebsite(array $args = []) |
| 104 | * @method \GuzzleHttp\Promise\Promise getBucketWebsiteAsync(array $args = []) |
| 105 | * @method \Aws\Result getObject(array $args = []) |
| 106 | * @method \GuzzleHttp\Promise\Promise getObjectAsync(array $args = []) |
| 107 | * @method \Aws\Result getObjectAcl(array $args = []) |
| 108 | * @method \GuzzleHttp\Promise\Promise getObjectAclAsync(array $args = []) |
| 109 | * @method \Aws\Result getObjectAttributes(array $args = []) |
| 110 | * @method \GuzzleHttp\Promise\Promise getObjectAttributesAsync(array $args = []) |
| 111 | * @method \Aws\Result getObjectLegalHold(array $args = []) |
| 112 | * @method \GuzzleHttp\Promise\Promise getObjectLegalHoldAsync(array $args = []) |
| 113 | * @method \Aws\Result getObjectLockConfiguration(array $args = []) |
| 114 | * @method \GuzzleHttp\Promise\Promise getObjectLockConfigurationAsync(array $args = []) |
| 115 | * @method \Aws\Result getObjectRetention(array $args = []) |
| 116 | * @method \GuzzleHttp\Promise\Promise getObjectRetentionAsync(array $args = []) |
| 117 | * @method \Aws\Result getObjectTagging(array $args = []) |
| 118 | * @method \GuzzleHttp\Promise\Promise getObjectTaggingAsync(array $args = []) |
| 119 | * @method \Aws\Result getObjectTorrent(array $args = []) |
| 120 | * @method \GuzzleHttp\Promise\Promise getObjectTorrentAsync(array $args = []) |
| 121 | * @method \Aws\Result getPublicAccessBlock(array $args = []) |
| 122 | * @method \GuzzleHttp\Promise\Promise getPublicAccessBlockAsync(array $args = []) |
| 123 | * @method \Aws\Result headBucket(array $args = []) |
| 124 | * @method \GuzzleHttp\Promise\Promise headBucketAsync(array $args = []) |
| 125 | * @method \Aws\Result headObject(array $args = []) |
| 126 | * @method \GuzzleHttp\Promise\Promise headObjectAsync(array $args = []) |
| 127 | * @method \Aws\Result listBucketAnalyticsConfigurations(array $args = []) |
| 128 | * @method \GuzzleHttp\Promise\Promise listBucketAnalyticsConfigurationsAsync(array $args = []) |
| 129 | * @method \Aws\Result listBucketIntelligentTieringConfigurations(array $args = []) |
| 130 | * @method \GuzzleHttp\Promise\Promise listBucketIntelligentTieringConfigurationsAsync(array $args = []) |
| 131 | * @method \Aws\Result listBucketInventoryConfigurations(array $args = []) |
| 132 | * @method \GuzzleHttp\Promise\Promise listBucketInventoryConfigurationsAsync(array $args = []) |
| 133 | * @method \Aws\Result listBucketMetricsConfigurations(array $args = []) |
| 134 | * @method \GuzzleHttp\Promise\Promise listBucketMetricsConfigurationsAsync(array $args = []) |
| 135 | * @method \Aws\Result listBuckets(array $args = []) |
| 136 | * @method \GuzzleHttp\Promise\Promise listBucketsAsync(array $args = []) |
| 137 | * @method \Aws\Result listDirectoryBuckets(array $args = []) |
| 138 | * @method \GuzzleHttp\Promise\Promise listDirectoryBucketsAsync(array $args = []) |
| 139 | * @method \Aws\Result listMultipartUploads(array $args = []) |
| 140 | * @method \GuzzleHttp\Promise\Promise listMultipartUploadsAsync(array $args = []) |
| 141 | * @method \Aws\Result listObjectVersions(array $args = []) |
| 142 | * @method \GuzzleHttp\Promise\Promise listObjectVersionsAsync(array $args = []) |
| 143 | * @method \Aws\Result listObjects(array $args = []) |
| 144 | * @method \GuzzleHttp\Promise\Promise listObjectsAsync(array $args = []) |
| 145 | * @method \Aws\Result listObjectsV2(array $args = []) |
| 146 | * @method \GuzzleHttp\Promise\Promise listObjectsV2Async(array $args = []) |
| 147 | * @method \Aws\Result listParts(array $args = []) |
| 148 | * @method \GuzzleHttp\Promise\Promise listPartsAsync(array $args = []) |
| 149 | * @method \Aws\Result putBucketAccelerateConfiguration(array $args = []) |
| 150 | * @method \GuzzleHttp\Promise\Promise putBucketAccelerateConfigurationAsync(array $args = []) |
| 151 | * @method \Aws\Result putBucketAcl(array $args = []) |
| 152 | * @method \GuzzleHttp\Promise\Promise putBucketAclAsync(array $args = []) |
| 153 | * @method \Aws\Result putBucketAnalyticsConfiguration(array $args = []) |
| 154 | * @method \GuzzleHttp\Promise\Promise putBucketAnalyticsConfigurationAsync(array $args = []) |
| 155 | * @method \Aws\Result putBucketCors(array $args = []) |
| 156 | * @method \GuzzleHttp\Promise\Promise putBucketCorsAsync(array $args = []) |
| 157 | * @method \Aws\Result putBucketEncryption(array $args = []) |
| 158 | * @method \GuzzleHttp\Promise\Promise putBucketEncryptionAsync(array $args = []) |
| 159 | * @method \Aws\Result putBucketIntelligentTieringConfiguration(array $args = []) |
| 160 | * @method \GuzzleHttp\Promise\Promise putBucketIntelligentTieringConfigurationAsync(array $args = []) |
| 161 | * @method \Aws\Result putBucketInventoryConfiguration(array $args = []) |
| 162 | * @method \GuzzleHttp\Promise\Promise putBucketInventoryConfigurationAsync(array $args = []) |
| 163 | * @method \Aws\Result putBucketLifecycle(array $args = []) |
| 164 | * @method \GuzzleHttp\Promise\Promise putBucketLifecycleAsync(array $args = []) |
| 165 | * @method \Aws\Result putBucketLifecycleConfiguration(array $args = []) |
| 166 | * @method \GuzzleHttp\Promise\Promise putBucketLifecycleConfigurationAsync(array $args = []) |
| 167 | * @method \Aws\Result putBucketLogging(array $args = []) |
| 168 | * @method \GuzzleHttp\Promise\Promise putBucketLoggingAsync(array $args = []) |
| 169 | * @method \Aws\Result putBucketMetricsConfiguration(array $args = []) |
| 170 | * @method \GuzzleHttp\Promise\Promise putBucketMetricsConfigurationAsync(array $args = []) |
| 171 | * @method \Aws\Result putBucketNotification(array $args = []) |
| 172 | * @method \GuzzleHttp\Promise\Promise putBucketNotificationAsync(array $args = []) |
| 173 | * @method \Aws\Result putBucketNotificationConfiguration(array $args = []) |
| 174 | * @method \GuzzleHttp\Promise\Promise putBucketNotificationConfigurationAsync(array $args = []) |
| 175 | * @method \Aws\Result putBucketOwnershipControls(array $args = []) |
| 176 | * @method \GuzzleHttp\Promise\Promise putBucketOwnershipControlsAsync(array $args = []) |
| 177 | * @method \Aws\Result putBucketPolicy(array $args = []) |
| 178 | * @method \GuzzleHttp\Promise\Promise putBucketPolicyAsync(array $args = []) |
| 179 | * @method \Aws\Result putBucketReplication(array $args = []) |
| 180 | * @method \GuzzleHttp\Promise\Promise putBucketReplicationAsync(array $args = []) |
| 181 | * @method \Aws\Result putBucketRequestPayment(array $args = []) |
| 182 | * @method \GuzzleHttp\Promise\Promise putBucketRequestPaymentAsync(array $args = []) |
| 183 | * @method \Aws\Result putBucketTagging(array $args = []) |
| 184 | * @method \GuzzleHttp\Promise\Promise putBucketTaggingAsync(array $args = []) |
| 185 | * @method \Aws\Result putBucketVersioning(array $args = []) |
| 186 | * @method \GuzzleHttp\Promise\Promise putBucketVersioningAsync(array $args = []) |
| 187 | * @method \Aws\Result putBucketWebsite(array $args = []) |
| 188 | * @method \GuzzleHttp\Promise\Promise putBucketWebsiteAsync(array $args = []) |
| 189 | * @method \Aws\Result putObject(array $args = []) |
| 190 | * @method \GuzzleHttp\Promise\Promise putObjectAsync(array $args = []) |
| 191 | * @method \Aws\Result putObjectAcl(array $args = []) |
| 192 | * @method \GuzzleHttp\Promise\Promise putObjectAclAsync(array $args = []) |
| 193 | * @method \Aws\Result putObjectLegalHold(array $args = []) |
| 194 | * @method \GuzzleHttp\Promise\Promise putObjectLegalHoldAsync(array $args = []) |
| 195 | * @method \Aws\Result putObjectLockConfiguration(array $args = []) |
| 196 | * @method \GuzzleHttp\Promise\Promise putObjectLockConfigurationAsync(array $args = []) |
| 197 | * @method \Aws\Result putObjectRetention(array $args = []) |
| 198 | * @method \GuzzleHttp\Promise\Promise putObjectRetentionAsync(array $args = []) |
| 199 | * @method \Aws\Result putObjectTagging(array $args = []) |
| 200 | * @method \GuzzleHttp\Promise\Promise putObjectTaggingAsync(array $args = []) |
| 201 | * @method \Aws\Result putPublicAccessBlock(array $args = []) |
| 202 | * @method \GuzzleHttp\Promise\Promise putPublicAccessBlockAsync(array $args = []) |
| 203 | * @method \Aws\Result restoreObject(array $args = []) |
| 204 | * @method \GuzzleHttp\Promise\Promise restoreObjectAsync(array $args = []) |
| 205 | * @method \Aws\Result selectObjectContent(array $args = []) |
| 206 | * @method \GuzzleHttp\Promise\Promise selectObjectContentAsync(array $args = []) |
| 207 | * @method \Aws\Result uploadPart(array $args = []) |
| 208 | * @method \GuzzleHttp\Promise\Promise uploadPartAsync(array $args = []) |
| 209 | * @method \Aws\Result uploadPartCopy(array $args = []) |
| 210 | * @method \GuzzleHttp\Promise\Promise uploadPartCopyAsync(array $args = []) |
| 211 | * @method \Aws\Result writeGetObjectResponse(array $args = []) |
| 212 | * @method \GuzzleHttp\Promise\Promise writeGetObjectResponseAsync(array $args = []) |
| 213 | */ |
| 214 | class S3MultiRegionClient extends BaseClient implements S3ClientInterface |
| 215 | { |
| 216 | use S3ClientTrait; |
| 217 | |
| 218 | /** @var CacheInterface */ |
| 219 | private $cache; |
| 220 | |
| 221 | public static function getArguments() |
| 222 | { |
| 223 | $args = parent::getArguments(); |
| 224 | $regionDef = $args['region'] + ['default' => function (array &$args) { |
| 225 | $availableRegions = array_keys($args['partition']['regions']); |
| 226 | return end($availableRegions); |
| 227 | }]; |
| 228 | unset($args['region']); |
| 229 | |
| 230 | return $args + [ |
| 231 | 'bucket_region_cache' => [ |
| 232 | 'type' => 'config', |
| 233 | 'valid' => [CacheInterface::class], |
| 234 | 'doc' => 'Cache of regions in which given buckets are located.', |
| 235 | 'default' => function () { return new LruArrayCache; }, |
| 236 | ], |
| 237 | 'region' => $regionDef, |
| 238 | ]; |
| 239 | } |
| 240 | |
| 241 | public function __construct(array $args) |
| 242 | { |
| 243 | parent::__construct($args); |
| 244 | $this->cache = $this->getConfig('bucket_region_cache'); |
| 245 | |
| 246 | $this->getHandlerList()->prependInit( |
| 247 | $this->determineRegionMiddleware(), |
| 248 | 'determine_region' |
| 249 | ); |
| 250 | } |
| 251 | |
| 252 | private function determineRegionMiddleware() |
| 253 | { |
| 254 | return function (callable $handler) { |
| 255 | return function (CommandInterface $command) use ($handler) { |
| 256 | $cacheKey = $this->getCacheKey($command['Bucket']); |
| 257 | if ( |
| 258 | empty($command['@region']) && |
| 259 | $region = $this->cache->get($cacheKey) |
| 260 | ) { |
| 261 | $command['@region'] = $region; |
| 262 | } |
| 263 | |
| 264 | return Promise\Coroutine::of(function () use ( |
| 265 | $handler, |
| 266 | $command, |
| 267 | $cacheKey |
| 268 | ) { |
| 269 | try { |
| 270 | yield $handler($command); |
| 271 | } catch (PermanentRedirectException $e) { |
| 272 | if (empty($command['Bucket'])) { |
| 273 | throw $e; |
| 274 | } |
| 275 | $result = $e->getResult(); |
| 276 | $region = null; |
| 277 | if (isset($result['@metadata']['headers']['x-amz-bucket-region'])) { |
| 278 | $region = $result['@metadata']['headers']['x-amz-bucket-region']; |
| 279 | $this->cache->set($cacheKey, $region); |
| 280 | } else { |
| 281 | $region = (yield $this->determineBucketRegionAsync( |
| 282 | $command['Bucket'] |
| 283 | )); |
| 284 | } |
| 285 | |
| 286 | $command['@region'] = $region; |
| 287 | yield $handler($command); |
| 288 | } catch (AwsException $e) { |
| 289 | if ($e->getAwsErrorCode() === 'AuthorizationHeaderMalformed') { |
| 290 | $region = $this->determineBucketRegionFromExceptionBody( |
| 291 | $e->getResponse() |
| 292 | ); |
| 293 | if (!empty($region)) { |
| 294 | $this->cache->set($cacheKey, $region); |
| 295 | |
| 296 | $command['@region'] = $region; |
| 297 | yield $handler($command); |
| 298 | } else { |
| 299 | throw $e; |
| 300 | } |
| 301 | } else { |
| 302 | throw $e; |
| 303 | } |
| 304 | } |
| 305 | }); |
| 306 | }; |
| 307 | }; |
| 308 | } |
| 309 | |
| 310 | public function createPresignedRequest(CommandInterface $command, $expires, array $options = []) |
| 311 | { |
| 312 | if (empty($command['Bucket'])) { |
| 313 | throw new \InvalidArgumentException('The S3\\MultiRegionClient' |
| 314 | . ' cannot create presigned requests for commands without a' |
| 315 | . ' specified bucket.'); |
| 316 | } |
| 317 | |
| 318 | /** @var S3ClientInterface $client */ |
| 319 | $client = $this->getClientFromPool( |
| 320 | $this->determineBucketRegion($command['Bucket']) |
| 321 | ); |
| 322 | return $client->createPresignedRequest( |
| 323 | $client->getCommand($command->getName(), $command->toArray()), |
| 324 | $expires |
| 325 | ); |
| 326 | } |
| 327 | |
| 328 | public function getObjectUrl($bucket, $key) |
| 329 | { |
| 330 | /** @var S3Client $regionalClient */ |
| 331 | $regionalClient = $this->getClientFromPool( |
| 332 | $this->determineBucketRegion($bucket) |
| 333 | ); |
| 334 | |
| 335 | return $regionalClient->getObjectUrl($bucket, $key); |
| 336 | } |
| 337 | |
| 338 | public function determineBucketRegionAsync($bucketName) |
| 339 | { |
| 340 | $cacheKey = $this->getCacheKey($bucketName); |
| 341 | if ($cached = $this->cache->get($cacheKey)) { |
| 342 | return Promise\Create::promiseFor($cached); |
| 343 | } |
| 344 | |
| 345 | /** @var S3ClientInterface $regionalClient */ |
| 346 | $regionalClient = $this->getClientFromPool(); |
| 347 | return $regionalClient->determineBucketRegionAsync($bucketName) |
| 348 | ->then( |
| 349 | function ($region) use ($cacheKey) { |
| 350 | $this->cache->set($cacheKey, $region); |
| 351 | |
| 352 | return $region; |
| 353 | } |
| 354 | ); |
| 355 | } |
| 356 | |
| 357 | private function getCacheKey($bucketName) |
| 358 | { |
| 359 | return "aws:s3:{$bucketName}:location"; |
| 360 | } |
| 361 | } |
| 362 |