ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: home / lab2454c / vaultchip.com / vendor / aws / aws-sdk-php / src

<?php
namespace Aws;

use Aws\Api\Service;
use Aws\Exception\AwsException;
use GuzzleHttp\Promise\RejectedPromise;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\StreamInterface;
use RecursiveArrayIterator;
use RecursiveIteratorIterator;

/**
 * Traces state changes between middlewares.
 */
class TraceMiddleware
{
    private $prevOutput;
    private $prevInput;
    private $config;

/** @var Service */
    private $service;

private static $authHeaders = [
        'X-Amz-Security-Token' => '[TOKEN]',
    ];

private static $authStrings = [
        // S3Signature
        '/AWSAccessKeyId=[A-Z0-9]{20}&/i' => 'AWSAccessKeyId=[KEY]&',
        // SignatureV4 Signature and S3Signature
        '/Signature=.+/i' => 'Signature=[SIGNATURE]',
        // SignatureV4 access key ID
        '/Credential=[A-Z0-9]{20}\//i' => 'Credential=[KEY]/',
        // S3 signatures
        '/AWS [A-Z0-9]{20}:.+/' => 'AWS AKI[KEY]:[SIGNATURE]',
        // STS Presigned URLs
        '/X-Amz-Security-Token=[^&]+/i' => 'X-Amz-Security-Token=[TOKEN]',
        // Crypto *Stream Keys
        '/\["key.{27,36}Stream.{9}\]=>\s+.{7}\d{2}\) "\X{16,64}"/U' => '["key":[CONTENT KEY]]',
    ];

/**
     * Configuration array can contain the following key value pairs.
     *
     * - logfn: (callable) Function that is invoked with log messages. By
     *   default, PHP's "echo" function will be utilized.
     * - stream_size: (int) When the size of a stream is greater than this
     *   number, the stream data will not be logged. Set to "0" to not log any
     *   stream data.
     * - scrub_auth: (bool) Set to false to disable the scrubbing of auth data
     *   from the logged messages.
     * - http: (bool) Set to false to disable the "debug" feature of lower
     *   level HTTP adapters (e.g., verbose curl output).
     * - auth_strings: (array) A mapping of authentication string regular
     *   expressions to scrubbed strings. These mappings are passed directly to
     *   preg_replace (e.g., preg_replace($key, $value, $debugOutput) if
     *   "scrub_auth" is set to true.
     * - auth_headers: (array) A mapping of header names known to contain
     *   sensitive data to what the scrubbed value should be. The value of any
     *   headers contained in this array will be replaced with the if
     *   "scrub_auth" is set to true.
     */
    public function __construct(array $config = [], Service $service = null)
    {
        $this->config = $config + [
            'logfn'        => function ($value) { echo $value; },
            'stream_size'  => 524288,
            'scrub_auth'   => true,
            'http'         => true,
            'auth_strings' => [],
            'auth_headers' => [],
        ];

$this->config['auth_strings'] += self::$authStrings;
        $this->config['auth_headers'] += self::$authHeaders;
        $this->service = $service;
    }

public function __invoke($step, $name)
    {
        $this->prevOutput = $this->prevInput = [];

return function (callable $next) use ($step, $name) {
            return function (
                CommandInterface $command,
                RequestInterface $request = null
            ) use ($next, $step, $name) {
                $this->createHttpDebug($command);
                $start = microtime(true);
                $this->stepInput([
                    'step'    => $step,
                    'name'    => $name,
                    'request' => $this->requestArray($request),
                    'command' => $this->commandArray($command)
                ]);

return $next($command, $request)->then(
                    function ($value) use ($step, $name, $command, $start) {
                        $this->flushHttpDebug($command);
                        $this->stepOutput($start, [
                            'step'   => $step,
                            'name'   => $name,
                            'result' => $this->resultArray($value),
                            'error'  => null
                        ]);
                        return $value;
                    },
                    function ($reason) use ($step, $name, $start, $command) {
                        $this->flushHttpDebug($command);
                        $this->stepOutput($start, [
                            'step'   => $step,
                            'name'   => $name,
                            'result' => null,
                            'error'  => $this->exceptionArray($reason)
                        ]);
                        return new RejectedPromise($reason);
                    }
                );
            };
        };
    }

private function stepInput($entry)
    {
        static $keys = ['command', 'request'];
        $this->compareStep($this->prevInput, $entry, '-> Entering', $keys);
        $this->write("\n");
        $this->prevInput = $entry;
    }

private function stepOutput($start, $entry)
    {
        static $keys = ['result', 'error'];
        $this->compareStep($this->prevOutput, $entry, '<- Leaving', $keys);
        $totalTime = microtime(true) - $start;
        $this->write("  Inclusive step time: " . $totalTime . "\n\n");
        $this->prevOutput = $entry;
    }

private function compareStep(array $a, array $b, $title, array $keys)
    {
        $changes = [];
        foreach ($keys as $key) {
            $av = isset($a[$key]) ? $a[$key] : null;
            $bv = isset($b[$key]) ? $b[$key] : null;
            $this->compareArray($av, $bv, $key, $changes);
        }
        $str = "\n{$title} step {$b['step']}, name '{$b['name']}'";
        $str .= "\n" . str_repeat('-', strlen($str) - 1) . "\n\n  ";
        $str .= $changes
            ? implode("\n  ", str_replace("\n", "\n  ", $changes))
            : 'no changes';
        $this->write($str . "\n");
    }

private function commandArray(CommandInterface $cmd)
    {
        return [
            'instance' => spl_object_hash($cmd),
            'name'     => $cmd->getName(),
            'params'   => $this->getRedactedArray($cmd)
        ];
    }

private function requestArray(RequestInterface $request = null)
    {
        return !$request ? [] : array_filter([
            'instance' => spl_object_hash($request),
            'method'   => $request->getMethod(),
            'headers'  => $this->redactHeaders($request->getHeaders()),
            'body'     => $this->streamStr($request->getBody()),
            'scheme'   => $request->getUri()->getScheme(),
            'port'     => $request->getUri()->getPort(),
            'path'     => $request->getUri()->getPath(),
            'query'    => $request->getUri()->getQuery(),
        ]);
    }

private function responseArray(ResponseInterface $response = null)
    {
        return !$response ? [] : [
            'instance'   => spl_object_hash($response),
            'statusCode' => $response->getStatusCode(),
            'headers'    => $this->redactHeaders($response->getHeaders()),
            'body'       => $this->streamStr($response->getBody())
        ];
    }

private function resultArray($value)
    {
        return $value instanceof ResultInterface
            ? [
                'instance' => spl_object_hash($value),
                'data'     => $value->toArray()
            ] : $value;
    }

private function exceptionArray($e)
    {
        if (!($e instanceof \Exception)) {
            return $e;
        }

$result = [
            'instance'   => spl_object_hash($e),
            'class'      => get_class($e),
            'message'    => $e->getMessage(),
            'file'       => $e->getFile(),
            'line'       => $e->getLine(),
            'trace'      => $e->getTraceAsString(),
        ];

if ($e instanceof AwsException) {
            $result += [
                'type'       => $e->getAwsErrorType(),
                'code'       => $e->getAwsErrorCode(),
                'requestId'  => $e->getAwsRequestId(),
                'statusCode' => $e->getStatusCode(),
                'result'     => $this->resultArray($e->getResult()),
                'request'    => $this->requestArray($e->getRequest()),
                'response'   => $this->responseArray($e->getResponse()),
            ];
        }

return $result;
    }

private function compareArray($a, $b, $path, array &$diff)
    {
        if ($a === $b) {
            return;
        }

if (is_array($a)) {
            $b = (array) $b;
            $keys = array_unique(array_merge(array_keys($a), array_keys($b)));
            foreach ($keys as $k) {
                if (!array_key_exists($k, $a)) {
                    $this->compareArray(null, $b[$k], "{$path}.{$k}", $diff);
                } elseif (!array_key_exists($k, $b)) {
                    $this->compareArray($a[$k], null, "{$path}.{$k}", $diff);
                } else {
                    $this->compareArray($a[$k], $b[$k], "{$path}.{$k}", $diff);
                }
            }
        } elseif ($a !== null && $b === null) {
            $diff[] = "{$path} was unset";
        } elseif ($a === null && $b !== null) {
            $diff[] = sprintf("%s was set to %s", $path, $this->str($b));
        } else {
            $diff[] = sprintf("%s changed from %s to %s", $path, $this->str($a), $this->str($b));
        }
    }

private function str($value)
    {
        if (is_scalar($value)) {
            return (string) $value;
        }

if ($value instanceof \Exception) {
            $value = $this->exceptionArray($value);
        }

ob_start();
        var_dump($value);
        return ob_get_clean();
    }

private function streamStr(StreamInterface $body)
    {
        return $body->getSize() < $this->config['stream_size']
            ? (string) $body
            : 'stream(size=' . $body->getSize() . ')';
    }

private function createHttpDebug(CommandInterface $command)
    {
        if ($this->config['http'] && !isset($command['@http']['debug'])) {
            $command['@http']['debug'] = fopen('php://temp', 'w+');
        }
    }

private function flushHttpDebug(CommandInterface $command)
    {
        if ($res = $command['@http']['debug']) {
            rewind($res);
            $this->write(stream_get_contents($res));
            fclose($res);
            $command['@http']['debug'] = null;
        }
    }

private function write($value)
    {
        if ($this->config['scrub_auth']) {
            foreach ($this->config['auth_strings'] as $pattern => $replacement) {
                $value = preg_replace_callback(
                    $pattern,
                    function ($matches) use ($replacement) {
                        return $replacement;
                    },
                    $value
                );
            }
        }

call_user_func($this->config['logfn'], $value);
    }

private function redactHeaders(array $headers)
    {
        if ($this->config['scrub_auth']) {
            $headers = $this->config['auth_headers'] + $headers;
        }

return $headers;
    }

/**
     * @param CommandInterface $cmd
     * @return array
     */
    private function getRedactedArray(CommandInterface $cmd)
    {
        if (!isset($this->service["shapes"])) {
            return $cmd->toArray();
        }
        $shapes = $this->service["shapes"];
        $cmdArray = $cmd->toArray();
        $iterator = new RecursiveIteratorIterator(
            new RecursiveArrayIterator($cmdArray),
            RecursiveIteratorIterator::SELF_FIRST
        );
        foreach ($iterator as $parameter => $value) {
           if (isset($shapes[$parameter]['sensitive']) &&
               $shapes[$parameter]['sensitive'] === true
           ) {
               $redactedValue = is_string($value) ? "[{$parameter}]" : ["[{$parameter}]"];
               $currentDepth = $iterator->getDepth();
               for ($subDepth = $currentDepth; $subDepth >= 0; $subDepth--) {
                   $subIterator = $iterator->getSubIterator($subDepth);
                   $subIterator->offsetSet(
                       $subIterator->key(),
                       ($subDepth === $currentDepth
                           ? $redactedValue
                           : $iterator->getSubIterator(($subDepth+1))->getArrayCopy()
                       )
                   );
               }
           }
        }
        return $iterator->getArrayCopy();
    }
}

[+] ..
[+] ServiceQuotas
[+] Crypto
[+] ForecastService
[+] EBS
[+] CloudFormation
[+] Sts
[+] Athena
[-] RetryMiddleware.php [edit]
[+] WorkDocs
[+] ClientSideMonitoring
[+] DeviceFarm
[+] ComprehendMedical
[+] Rekognition
[+] FIS
[+] DAX
[+] SageMaker
[+] MTurk
[+] ElasticLoadBalancing
[+] Ecs
[+] IdentityStore
[+] LookoutEquipment
[-] StreamRequestPayloadMiddleware.php [edit]
[+] WellArchitected
[+] Health
[-] HasDataTrait.php [edit]
[+] Ses
[+] Schemas
[+] MachineLearning
[+] Route53RecoveryControlConfig
[+] WorkMail
[-] ConfigurationProviderInterface.php [edit]
[+] IoTWireless
[+] data
[-] HasMonitoringEventsTrait.php [edit]
[+] KinesisVideoMedia
[+] Pinpoint
[+] AppMesh
[+] IoTFleetHub
[+] AutoScaling
[+] CodeGuruProfiler
[+] MediaTailor
[+] CodeCommit
[+] GlueDataBrew
[-] CacheInterface.php [edit]
[+] Sqs
[+] AutoScalingPlans
[+] IoTEvents
[+] MediaPackage
[+] Budgets
[+] IVS
[+] ForecastQueryService
[+] MarketplaceEntitlementService
[+] AmplifyBackend
[+] LicenseManager
[+] CloudTrail
[+] IoT1ClickProjects
[+] IoTThingsGraph
[+] SavingsPlans
[+] CloudFront
[+] ServerlessApplicationRepository
[+] ElasticsearchService
[+] DynamoDbStreams
[+] DLM
[-] Sdk.php [edit]
[+] XRay
[+] CloudSearchDomain
[+] MarketplaceCatalog
[+] CostExplorer
[+] Chime
[-] MockHandler.php [edit]
[-] JsonCompiler.php [edit]
[+] IoTJobsDataPlane
[-] HashingStream.php [edit]
[+] SSOAdmin
[+] NimbleStudio
[+] ResourceGroupsTaggingAPI
[-] PsrCacheAdapter.php [edit]
[+] LakeFormation
[+] ChimeSDKMessaging
[+] Iot
[+] NetworkFirewall
[+] Synthetics
[+] IoTSecureTunneling
[+] Glue
[+] signer
[+] kendra
[+] CodeArtifact
[+] OpenSearchService
[+] LocationService
[+] Sns
[+] WorkLink
[+] Api
[+] MQ
[+] Exception
[+] WafRegional
[+] ResourceGroups
[+] S3Control
[+] EventBridge
[+] Appstream
[+] CodeBuild
[+] MediaLive
[+] SesV2
[+] Kinesis
[+] MediaStoreData
[-] CommandInterface.php [edit]
[+] KafkaConnect
[+] Kafka
[+] EC2InstanceConnect
[+] CodeGuruReviewer
[+] CloudHsm
[+] MarketplaceMetering
[+] CloudDirectory
[+] ImportExport
[+] Route53RecoveryCluster
[+] Route53Resolver
[+] ChimeSDKIdentity
[+] KinesisVideoSignalingChannels
[+] ConfigService
[-] HandlerList.php [edit]
[+] KinesisAnalyticsV2
[+] ElasticBeanstalk
[-] Waiter.php [edit]
[+] GroundStation
[+] ElastiCache
[+] KinesisVideoArchivedMedia
[+] mgn
[+] Efs
[+] imagebuilder
[+] AppConfig
[+] QLDB
[+] WAFV2
[+] CloudSearch
[+] Redshift
[+] PinpointSMSVoice
[+] QLDBSession
[+] SecretsManager
[+] EMRContainers
[+] SSMIncidents
[+] Lambda
[+] Multipart
[+] DatabaseMigrationService
[+] AugmentedAIRuntime
[+] DataExchange
[-] AbstractConfigurationProvider.php [edit]
[+] Proton
[+] RedshiftDataAPIService
[-] InputValidationMiddleware.php [edit]
[+] CustomerProfiles
[+] WorkMailMessageFlow
[-] ResultPaginator.php [edit]
[+] Route53Domains
[+] CloudHSMV2
[-] RetryMiddlewareV2.php [edit]
[+] ApplicationDiscoveryService
[+] Ec2
[+] Shield
[+] LexModelBuildingService
[+] ElasticTranscoder
[+] Handler
[+] EndpointDiscovery
[+] DynamoDb
[+] CloudWatchLogs
[-] ResponseContainerInterface.php [edit]
[+] Inspector
[+] Ecr
[+] RDSDataService
[+] DirectoryService
[+] IoTAnalytics
[+] CloudWatchEvents
[+] RAM
[+] FMS
[-] ClientResolver.php [edit]
[+] Signature
[+] AccessAnalyzer
[-] Command.php [edit]
[+] PrometheusService
[+] ConnectParticipant
[+] ServiceCatalog
[+] Ssm
[+] IoT1ClickDevicesService
[+] TimestreamWrite
[+] ApplicationAutoScaling
[+] CodePipeline
[-] History.php [edit]
[+] FSx
[+] Batch
[+] AlexaForBusiness
[+] Braket
[+] ACMPCA
[-] Middleware.php [edit]
[+] Personalize
[+] Detective
[+] ManagedBlockchain
[+] SSOOIDC
[+] Endpoint
[+] SnowBall
[+] Acm
[-] AwsClientInterface.php [edit]
[+] Kms
[+] Iam
[+] SSMContacts
[+] AppIntegrationsService
[+] ElasticInference
[-] Psr16CacheAdapter.php [edit]
[+] HealthLake
[+] StorageGateway
[+] Polly
[-] MultiRegionClient.php [edit]
[+] Honeycode
[+] MediaStore
[+] MWAA
[-] CommandPool.php [edit]
[+] S3Outposts
[+] Swf
[+] Mobile
[+] ECRPublic
[+] CognitoIdentityProvider
[+] ApiGatewayV2
[+] Backup
[+] Route53RecoveryReadiness
[+] IotDataPlane
[+] CognitoSync
[+] SnowDeviceManagement
[+] LookoutMetrics
[-] HashInterface.php [edit]
[+] TranscribeService
[-] IdempotencyTokenMiddleware.php [edit]
[+] GlobalAccelerator
[+] LookoutforVision
[+] ApiGatewayManagementApi
[+] SageMakerFeatureStoreRuntime
[+] Cloud9
[+] MemoryDB
[-] AwsClientTrait.php [edit]
[+] Macie2
[-] MonitoringEventsInterface.php [edit]
[+] AppRunner
[+] OpsWorks
[+] OpsWorksCM
[+] AuditManager
[+] Support
[-] TraceMiddleware.php [edit]
[+] Lightsail
[-] EndpointParameterMiddleware.php [edit]
[+] Arn
[+] MigrationHub
[+] Firehose
[+] CostandUsageReportService
[+] Credentials
[+] Sms
[+] DataPipeline
[+] QuickSight
[+] PI
[+] Outposts
[+] NetworkManager
[+] RoboMaker
[+] FinSpaceData
[+] MarketplaceCommerceAnalytics
[+] AppSync
[+] CodeDeploy
[-] functions.php [edit]
[+] TimestreamQuery
[+] ConnectContactLens
[+] DirectConnect
[+] CodeStarconnections
[+] GuardDuty
[+] LexRuntimeService
[+] CognitoIdentity
[+] ApplicationInsights
[+] GreengrassV2
[+] IoTDeviceAdvisor
[+] WorkSpaces
[+] ComputeOptimizer
[+] Comprehend
[+] Emr
[+] CloudWatch
[+] finspace
[+] DocDB
[+] IoTSiteWise
[+] ApiGateway
[+] Amplify
[+] Greengrass
[+] Connect
[+] ApplicationCostProfiler
[-] PresignUrlMiddleware.php [edit]
[-] AwsClient.php [edit]
[+] Macie
[+] SagemakerEdgeManager
[+] CodeStar
[+] Appflow
[+] Organizations
[+] PersonalizeEvents
[+] GameLift
[+] KinesisVideo
[+] Pricing
[+] PinpointEmail
[-] Result.php [edit]
[+] Rds
[-] ResultInterface.php [edit]
[+] SageMakerRuntime
[+] Waf
[+] MigrationHubConfig
[+] Translate
[-] WrappedHttpHandler.php [edit]
[+] Glacier
[+] Retry
[+] Neptune
[+] AppRegistry
[+] LexRuntimeV2
[+] MediaConnect
[+] SSO
[+] IoTEventsData
[-] PhpHash.php [edit]
[+] CodeStarNotifications
[+] SecurityHub
[+] FraudDetector
[+] Route53
[+] PersonalizeRuntime
[+] DataSync
[+] Textract
[+] MediaConvert
[+] Transfer
[+] LexModelsV2
[-] LruArrayCache.php [edit]
[-] DoctrineCacheAdapter.php [edit]
[+] MediaPackageVod
[+] S3
[+] KinesisAnalytics
[+] ServiceDiscovery
[+] EKS
[+] ElasticLoadBalancingV2
[+] DevOpsGuru
[+] Sfn