X7ROOT File Manager
Current Path:
/home/gfecatvj/sites/restate/vendor/aws/aws-sdk-php/src
home
/
gfecatvj
/
sites
/
restate
/
vendor
/
aws
/
aws-sdk-php
/
src
/
📁
..
📁
ACMPCA
📄
AbstractConfigurationProvider.php
(4.46 KB)
📁
AccessAnalyzer
📁
Acm
📁
AlexaForBusiness
📁
Amplify
📁
Api
📁
ApiGateway
📁
ApiGatewayManagementApi
📁
ApiGatewayV2
📁
AppConfig
📁
AppMesh
📁
AppSync
📁
ApplicationAutoScaling
📁
ApplicationDiscoveryService
📁
ApplicationInsights
📁
Appstream
📁
Arn
📁
Athena
📁
AugmentedAIRuntime
📁
AutoScaling
📁
AutoScalingPlans
📄
AwsClient.php
(17.21 KB)
📄
AwsClientInterface.php
(5.4 KB)
📄
AwsClientTrait.php
(2.67 KB)
📁
Backup
📁
Batch
📁
Budgets
📄
CacheInterface.php
(755 B)
📁
Chime
📄
ClientResolver.php
(34.92 KB)
📁
ClientSideMonitoring
📁
Cloud9
📁
CloudDirectory
📁
CloudFormation
📁
CloudFront
📁
CloudHSMV2
📁
CloudHsm
📁
CloudSearch
📁
CloudSearchDomain
📁
CloudTrail
📁
CloudWatch
📁
CloudWatchEvents
📁
CloudWatchLogs
📁
CodeArtifact
📁
CodeBuild
📁
CodeCommit
📁
CodeDeploy
📁
CodeGuruProfiler
📁
CodeGuruReviewer
📁
CodePipeline
📁
CodeStar
📁
CodeStarNotifications
📁
CodeStarconnections
📁
CognitoIdentity
📁
CognitoIdentityProvider
📁
CognitoSync
📄
Command.php
(1.39 KB)
📄
CommandInterface.php
(946 B)
📄
CommandPool.php
(5.2 KB)
📁
Comprehend
📁
ComprehendMedical
📁
ComputeOptimizer
📁
ConfigService
📄
ConfigurationProviderInterface.php
(246 B)
📁
Connect
📁
ConnectParticipant
📁
CostExplorer
📁
CostandUsageReportService
📁
Credentials
📁
Crypto
📁
DAX
📁
DLM
📁
DataExchange
📁
DataPipeline
📁
DataSync
📁
DatabaseMigrationService
📁
Detective
📁
DeviceFarm
📁
DirectConnect
📁
DirectoryService
📁
DocDB
📄
DoctrineCacheAdapter.php
(989 B)
📁
DynamoDb
📁
DynamoDbStreams
📁
EBS
📁
EC2InstanceConnect
📁
EKS
📁
Ec2
📁
Ecr
📁
Ecs
📁
Efs
📁
ElastiCache
📁
ElasticBeanstalk
📁
ElasticInference
📁
ElasticLoadBalancing
📁
ElasticLoadBalancingV2
📁
ElasticTranscoder
📁
ElasticsearchService
📁
Emr
📁
Endpoint
📁
EndpointDiscovery
📄
EndpointParameterMiddleware.php
(2.73 KB)
📁
EventBridge
📁
Exception
📁
FMS
📁
FSx
📁
Firehose
📁
ForecastQueryService
📁
ForecastService
📁
FraudDetector
📁
GameLift
📁
Glacier
📁
GlobalAccelerator
📁
Glue
📁
Greengrass
📁
GroundStation
📁
GuardDuty
📁
Handler
📄
HandlerList.php
(13.18 KB)
📄
HasDataTrait.php
(1.11 KB)
📄
HasMonitoringEventsTrait.php
(869 B)
📄
HashInterface.php
(531 B)
📄
HashingStream.php
(1.5 KB)
📁
Health
📄
History.php
(3.81 KB)
📁
Honeycode
📁
IVS
📁
Iam
📄
IdempotencyTokenMiddleware.php
(3.69 KB)
📁
ImportExport
📁
Inspector
📁
IoT1ClickDevicesService
📁
IoT1ClickProjects
📁
IoTAnalytics
📁
IoTEvents
📁
IoTEventsData
📁
IoTJobsDataPlane
📁
IoTSecureTunneling
📁
IoTSiteWise
📁
IoTThingsGraph
📁
Iot
📁
IotDataPlane
📄
JsonCompiler.php
(478 B)
📁
Kafka
📁
Kinesis
📁
KinesisAnalytics
📁
KinesisAnalyticsV2
📁
KinesisVideo
📁
KinesisVideoArchivedMedia
📁
KinesisVideoMedia
📁
KinesisVideoSignalingChannels
📁
Kms
📁
LakeFormation
📁
Lambda
📁
LexModelBuildingService
📁
LexRuntimeService
📁
LicenseManager
📁
Lightsail
📄
LruArrayCache.php
(2.16 KB)
📁
MQ
📁
MTurk
📁
MachineLearning
📁
Macie
📁
Macie2
📁
ManagedBlockchain
📁
MarketplaceCatalog
📁
MarketplaceCommerceAnalytics
📁
MarketplaceEntitlementService
📁
MarketplaceMetering
📁
MediaConnect
📁
MediaConvert
📁
MediaLive
📁
MediaPackage
📁
MediaPackageVod
📁
MediaStore
📁
MediaStoreData
📁
MediaTailor
📄
Middleware.php
(12.76 KB)
📁
MigrationHub
📁
MigrationHubConfig
📁
Mobile
📄
MockHandler.php
(4.02 KB)
📄
MonitoringEventsInterface.php
(742 B)
📄
MultiRegionClient.php
(7.75 KB)
📁
Multipart
📁
Neptune
📁
NetworkManager
📁
OpsWorks
📁
OpsWorksCM
📁
Organizations
📁
Outposts
📁
PI
📁
Personalize
📁
PersonalizeEvents
📁
PersonalizeRuntime
📄
PhpHash.php
(1.81 KB)
📁
Pinpoint
📁
PinpointEmail
📁
PinpointSMSVoice
📁
Polly
📄
PresignUrlMiddleware.php
(3.28 KB)
📁
Pricing
📄
Psr16CacheAdapter.php
(572 B)
📄
PsrCacheAdapter.php
(742 B)
📁
QLDB
📁
QLDBSession
📁
QuickSight
📁
RAM
📁
RDSDataService
📁
Rds
📁
Redshift
📁
Rekognition
📁
ResourceGroups
📁
ResourceGroupsTaggingAPI
📄
ResponseContainerInterface.php
(246 B)
📄
Result.php
(1.14 KB)
📄
ResultInterface.php
(1.34 KB)
📄
ResultPaginator.php
(5.09 KB)
📁
Retry
📄
RetryMiddleware.php
(8.46 KB)
📄
RetryMiddlewareV2.php
(11.66 KB)
📁
RoboMaker
📁
Route53
📁
Route53Domains
📁
Route53Resolver
📁
S3
📁
S3Control
📁
SSO
📁
SSOOIDC
📁
SageMaker
📁
SageMakerRuntime
📁
SavingsPlans
📁
Schemas
📄
Sdk.php
(39.34 KB)
📁
SecretsManager
📁
SecurityHub
📁
ServerlessApplicationRepository
📁
ServiceCatalog
📁
ServiceDiscovery
📁
ServiceQuotas
📁
Ses
📁
SesV2
📁
Sfn
📁
Shield
📁
Signature
📁
Sms
📁
SnowBall
📁
Sns
📁
Sqs
📁
Ssm
📁
StorageGateway
📄
StreamRequestPayloadMiddleware.php
(2.57 KB)
📁
Sts
📁
Support
📁
Swf
📁
Synthetics
📁
Textract
📄
TraceMiddleware.php
(10.72 KB)
📁
TranscribeService
📁
Transfer
📁
Translate
📁
WAFV2
📁
Waf
📁
WafRegional
📄
Waiter.php
(8.32 KB)
📁
WorkDocs
📁
WorkLink
📁
WorkMail
📁
WorkMailMessageFlow
📁
WorkSpaces
📄
WrappedHttpHandler.php
(6.96 KB)
📁
XRay
📁
data
📄
functions.php
(12.93 KB)
📁
imagebuilder
📁
kendra
📁
signer
Editing: Middleware.php
<?php namespace Aws; use Aws\Api\Service; use Aws\Api\Validator; use Aws\Credentials\CredentialsInterface; use Aws\Exception\AwsException; use GuzzleHttp\Promise; use GuzzleHttp\Psr7; use GuzzleHttp\Psr7\LazyOpenStream; use Psr\Http\Message\RequestInterface; final class Middleware { /** * Middleware used to allow a command parameter (e.g., "SourceFile") to * be used to specify the source of data for an upload operation. * * @param Service $api * @param string $bodyParameter * @param string $sourceParameter * * @return callable */ public static function sourceFile( Service $api, $bodyParameter = 'Body', $sourceParameter = 'SourceFile' ) { return function (callable $handler) use ( $api, $bodyParameter, $sourceParameter ) { return function ( CommandInterface $command, RequestInterface $request = null) use ( $handler, $api, $bodyParameter, $sourceParameter ) { $operation = $api->getOperation($command->getName()); $source = $command[$sourceParameter]; if ($source !== null && $operation->getInput()->hasMember($bodyParameter) ) { $command[$bodyParameter] = new LazyOpenStream($source, 'r'); unset($command[$sourceParameter]); } return $handler($command, $request); }; }; } /** * Adds a middleware that uses client-side validation. * * @param Service $api API being accessed. * * @return callable */ public static function validation(Service $api, Validator $validator = null) { $validator = $validator ?: new Validator(); return function (callable $handler) use ($api, $validator) { return function ( CommandInterface $command, RequestInterface $request = null ) use ($api, $validator, $handler) { $operation = $api->getOperation($command->getName()); $validator->validate( $command->getName(), $operation->getInput(), $command->toArray() ); return $handler($command, $request); }; }; } /** * Builds an HTTP request for a command. * * @param callable $serializer Function used to serialize a request for a * command. * @return callable */ public static function requestBuilder(callable $serializer) { return function (callable $handler) use ($serializer) { return function (CommandInterface $command) use ($serializer, $handler) { return $handler($command, $serializer($command)); }; }; } /** * Creates a middleware that signs requests for a command. * * @param callable $credProvider Credentials provider function that * returns a promise that is resolved * with a CredentialsInterface object. * @param callable $signatureFunction Function that accepts a Command * object and returns a * SignatureInterface. * * @return callable */ public static function signer(callable $credProvider, callable $signatureFunction) { return function (callable $handler) use ($signatureFunction, $credProvider) { return function ( CommandInterface $command, RequestInterface $request ) use ($handler, $signatureFunction, $credProvider) { $signer = $signatureFunction($command); return $credProvider()->then( function (CredentialsInterface $creds) use ($handler, $command, $signer, $request) { return $handler( $command, $signer->signRequest($request, $creds) ); } ); }; }; } /** * Creates a middleware that invokes a callback at a given step. * * The tap callback accepts a CommandInterface and RequestInterface as * arguments but is not expected to return a new value or proxy to * downstream middleware. It's simply a way to "tap" into the handler chain * to debug or get an intermediate value. * * @param callable $fn Tap function * * @return callable */ public static function tap(callable $fn) { return function (callable $handler) use ($fn) { return function ( CommandInterface $command, RequestInterface $request = null ) use ($handler, $fn) { $fn($command, $request); return $handler($command, $request); }; }; } /** * Middleware wrapper function that retries requests based on the boolean * result of invoking the provided "decider" function. * * If no delay function is provided, a simple implementation of exponential * backoff will be utilized. * * @param callable $decider Function that accepts the number of retries, * a request, [result], and [exception] and * returns true if the command is to be retried. * @param callable $delay Function that accepts the number of retries and * returns the number of milliseconds to delay. * @param bool $stats Whether to collect statistics on retries and the * associated delay. * * @return callable */ public static function retry( callable $decider = null, callable $delay = null, $stats = false ) { $decider = $decider ?: RetryMiddleware::createDefaultDecider(); $delay = $delay ?: [RetryMiddleware::class, 'exponentialDelay']; return function (callable $handler) use ($decider, $delay, $stats) { return new RetryMiddleware($decider, $delay, $handler, $stats); }; } /** * Middleware wrapper function that adds an invocation id header to * requests, which is only applied after the build step. * * This is a uniquely generated UUID to identify initial and subsequent * retries as part of a complete request lifecycle. * * @return callable */ public static function invocationId() { return function (callable $handler) { return function ( CommandInterface $command, RequestInterface $request ) use ($handler){ return $handler($command, $request->withHeader( 'aws-sdk-invocation-id', md5(uniqid(gethostname(), true)) )); }; }; } /** * Middleware wrapper function that adds a Content-Type header to requests. * This is only done when the Content-Type has not already been set, and the * request body's URI is available. It then checks the file extension of the * URI to determine the mime-type. * * @param array $operations Operations that Content-Type should be added to. * * @return callable */ public static function contentType(array $operations) { return function (callable $handler) use ($operations) { return function ( CommandInterface $command, RequestInterface $request = null ) use ($handler, $operations) { if (!$request->hasHeader('Content-Type') && in_array($command->getName(), $operations, true) && ($uri = $request->getBody()->getMetadata('uri')) ) { $request = $request->withHeader( 'Content-Type', Psr7\mimetype_from_filename($uri) ?: 'application/octet-stream' ); } return $handler($command, $request); }; }; } /** * Tracks command and request history using a history container. * * This is useful for testing. * * @param History $history History container to store entries. * * @return callable */ public static function history(History $history) { return function (callable $handler) use ($history) { return function ( CommandInterface $command, RequestInterface $request = null ) use ($handler, $history) { $ticket = $history->start($command, $request); return $handler($command, $request) ->then( function ($result) use ($history, $ticket) { $history->finish($ticket, $result); return $result; }, function ($reason) use ($history, $ticket) { $history->finish($ticket, $reason); return Promise\rejection_for($reason); } ); }; }; } /** * Creates a middleware that applies a map function to requests as they * pass through the middleware. * * @param callable $f Map function that accepts a RequestInterface and * returns a RequestInterface. * * @return callable */ public static function mapRequest(callable $f) { return function (callable $handler) use ($f) { return function ( CommandInterface $command, RequestInterface $request = null ) use ($handler, $f) { return $handler($command, $f($request)); }; }; } /** * Creates a middleware that applies a map function to commands as they * pass through the middleware. * * @param callable $f Map function that accepts a command and returns a * command. * * @return callable */ public static function mapCommand(callable $f) { return function (callable $handler) use ($f) { return function ( CommandInterface $command, RequestInterface $request = null ) use ($handler, $f) { return $handler($f($command), $request); }; }; } /** * Creates a middleware that applies a map function to results. * * @param callable $f Map function that accepts an Aws\ResultInterface and * returns an Aws\ResultInterface. * * @return callable */ public static function mapResult(callable $f) { return function (callable $handler) use ($f) { return function ( CommandInterface $command, RequestInterface $request = null ) use ($handler, $f) { return $handler($command, $request)->then($f); }; }; } public static function timer() { return function (callable $handler) { return function ( CommandInterface $command, RequestInterface $request = null ) use ($handler) { $start = microtime(true); return $handler($command, $request) ->then( function (ResultInterface $res) use ($start) { if (!isset($res['@metadata'])) { $res['@metadata'] = []; } if (!isset($res['@metadata']['transferStats'])) { $res['@metadata']['transferStats'] = []; } $res['@metadata']['transferStats']['total_time'] = microtime(true) - $start; return $res; }, function ($err) use ($start) { if ($err instanceof AwsException) { $err->setTransferInfo([ 'total_time' => microtime(true) - $start, ] + $err->getTransferInfo()); } return Promise\rejection_for($err); } ); }; }; } }
Upload File
Create Folder