From 0c8af4992cb0f7589dcafaad65ada12753c64594 Mon Sep 17 00:00:00 2001
From: Andrew Dolgov <noreply@fakecake.org>
Date: Wed, 23 Nov 2022 21:14:33 +0300
Subject: initial

---
 .../aws-sdk-php/src/Sqs/Exception/SqsException.php |   9 +
 vendor/aws/aws-sdk-php/src/Sqs/SqsClient.php       | 256 +++++++++++++++++++++
 2 files changed, 265 insertions(+)
 create mode 100644 vendor/aws/aws-sdk-php/src/Sqs/Exception/SqsException.php
 create mode 100644 vendor/aws/aws-sdk-php/src/Sqs/SqsClient.php

(limited to 'vendor/aws/aws-sdk-php/src/Sqs')

diff --git a/vendor/aws/aws-sdk-php/src/Sqs/Exception/SqsException.php b/vendor/aws/aws-sdk-php/src/Sqs/Exception/SqsException.php
new file mode 100644
index 0000000..e122c0d
--- /dev/null
+++ b/vendor/aws/aws-sdk-php/src/Sqs/Exception/SqsException.php
@@ -0,0 +1,9 @@
+<?php
+namespace Aws\Sqs\Exception;
+
+use Aws\Exception\AwsException;
+
+/**
+ * Represents an error interacting with the Amazon Simple Queue Service.
+ */
+class SqsException extends AwsException {}
diff --git a/vendor/aws/aws-sdk-php/src/Sqs/SqsClient.php b/vendor/aws/aws-sdk-php/src/Sqs/SqsClient.php
new file mode 100644
index 0000000..511d502
--- /dev/null
+++ b/vendor/aws/aws-sdk-php/src/Sqs/SqsClient.php
@@ -0,0 +1,256 @@
+<?php
+namespace Aws\Sqs;
+
+use Aws\AwsClient;
+use Aws\CommandInterface;
+use Aws\Sqs\Exception\SqsException;
+use GuzzleHttp\Psr7\Uri;
+use GuzzleHttp\Psr7\UriResolver;
+use Psr\Http\Message\RequestInterface;
+
+/**
+ * Client used to interact Amazon Simple Queue Service (Amazon SQS)
+ *
+ * @method \Aws\Result addPermission(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise addPermissionAsync(array $args = [])
+ * @method \Aws\Result changeMessageVisibility(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise changeMessageVisibilityAsync(array $args = [])
+ * @method \Aws\Result changeMessageVisibilityBatch(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise changeMessageVisibilityBatchAsync(array $args = [])
+ * @method \Aws\Result createQueue(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise createQueueAsync(array $args = [])
+ * @method \Aws\Result deleteMessage(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise deleteMessageAsync(array $args = [])
+ * @method \Aws\Result deleteMessageBatch(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise deleteMessageBatchAsync(array $args = [])
+ * @method \Aws\Result deleteQueue(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise deleteQueueAsync(array $args = [])
+ * @method \Aws\Result getQueueAttributes(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise getQueueAttributesAsync(array $args = [])
+ * @method \Aws\Result getQueueUrl(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise getQueueUrlAsync(array $args = [])
+ * @method \Aws\Result listDeadLetterSourceQueues(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise listDeadLetterSourceQueuesAsync(array $args = [])
+ * @method \Aws\Result listQueueTags(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise listQueueTagsAsync(array $args = [])
+ * @method \Aws\Result listQueues(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise listQueuesAsync(array $args = [])
+ * @method \Aws\Result purgeQueue(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise purgeQueueAsync(array $args = [])
+ * @method \Aws\Result receiveMessage(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise receiveMessageAsync(array $args = [])
+ * @method \Aws\Result removePermission(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise removePermissionAsync(array $args = [])
+ * @method \Aws\Result sendMessage(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise sendMessageAsync(array $args = [])
+ * @method \Aws\Result sendMessageBatch(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise sendMessageBatchAsync(array $args = [])
+ * @method \Aws\Result setQueueAttributes(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise setQueueAttributesAsync(array $args = [])
+ * @method \Aws\Result tagQueue(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise tagQueueAsync(array $args = [])
+ * @method \Aws\Result untagQueue(array $args = [])
+ * @method \GuzzleHttp\Promise\Promise untagQueueAsync(array $args = [])
+ */
+class SqsClient extends AwsClient
+{
+    public function __construct(array $config)
+    {
+        parent::__construct($config);
+        $list = $this->getHandlerList();
+        $list->appendBuild($this->queueUrl(), 'sqs.queue_url');
+        $list->appendSign($this->validateMd5(), 'sqs.md5');
+    }
+
+    /**
+     * Converts a queue URL into a queue ARN.
+     *
+     * @param string $queueUrl The queue URL to perform the action on.
+     *                         Retrieved when the queue is first created.
+     *
+     * @return string An ARN representation of the queue URL.
+     */
+    public function getQueueArn($queueUrl)
+    {
+        $queueArn = strtr($queueUrl, [
+            'http://'        => 'arn:aws:',
+            'https://'       => 'arn:aws:',
+            '.amazonaws.com' => '',
+            '/'              => ':',
+            '.'              => ':',
+        ]);
+
+        // Cope with SQS' .fifo / :fifo arn inconsistency
+        if (substr($queueArn, -5) === ':fifo') {
+            $queueArn = substr_replace($queueArn, '.fifo', -5);
+        }
+        return $queueArn;
+    }
+
+    /**
+     * Moves the URI of the queue to the URI in the input parameter.
+     *
+     * @return callable
+     */
+    private function queueUrl()
+    {
+        return static function (callable $handler) {
+            return function (
+                CommandInterface $c,
+                RequestInterface $r = null
+            ) use ($handler) {
+                if ($c->hasParam('QueueUrl')) {
+                    $r = $r->withUri(UriResolver::resolve(
+                        $r->getUri(),
+                        new Uri($c['QueueUrl'])
+                    ));
+                }
+                return $handler($c, $r);
+            };
+        };
+    }
+
+    /**
+     * Calculates the expected md5 hash of message attributes according to the encoding
+     * scheme detailed in SQS documentation.
+     *
+     * @param array $message Message containing attributes for validation.
+     *                       Retrieved when using MessageAttributeNames on
+     *                       ReceiveMessage.
+     *
+     * @return string|null The md5 hash of the message attributes according to
+     *                     the encoding scheme. Returns null when there are no
+     *                     attributes.
+     * @link http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-message-attributes.html#message-attributes-items-validation
+     */
+    private static function calculateMessageAttributesMd5($message)
+    {
+        if (empty($message['MessageAttributes'])
+            || !is_array($message['MessageAttributes'])
+        ) {
+            return null;
+        }
+
+        ksort($message['MessageAttributes']);
+        $attributeValues = "";
+        foreach ($message['MessageAttributes'] as $name => $details) {
+            $attributeValues .= self::getEncodedStringPiece($name);
+            $attributeValues .= self::getEncodedStringPiece($details['DataType']);
+            if (substr($details['DataType'], 0, 6) === 'Binary') {
+                $attributeValues .= pack('c', 0x02);
+                $attributeValues .= self::getEncodedBinaryPiece(
+                    $details['BinaryValue']
+                );
+            } else {
+                $attributeValues .= pack('c', 0x01);
+                $attributeValues .= self::getEncodedStringPiece(
+                    $details['StringValue']
+                );
+            }
+        }
+
+        return md5($attributeValues);
+    }
+
+    private static function calculateBodyMd5($message)
+    {
+        return md5($message['Body']);
+    }
+
+    private static function getEncodedStringPiece($piece)
+    {
+        $utf8Piece = iconv(
+            mb_detect_encoding($piece, mb_detect_order(), true),
+            "UTF-8",
+            $piece
+        );
+        return self::getFourBytePieceLength($utf8Piece) . $utf8Piece;
+    }
+
+    private static function getEncodedBinaryPiece($piece)
+    {
+        return self::getFourBytePieceLength($piece) . $piece;
+    }
+
+    private static function getFourBytePieceLength($piece)
+    {
+        return pack('N', (int)strlen($piece));
+    }
+
+    /**
+     * Validates ReceiveMessage body and message attribute MD5s.
+     *
+     * @return callable
+     */
+    private function validateMd5()
+    {
+        return static function (callable $handler) {
+            return function (
+                CommandInterface $c,
+                RequestInterface $r = null
+            ) use ($handler) {
+                if ($c->getName() !== 'ReceiveMessage') {
+                    return $handler($c, $r);
+                }
+
+                return $handler($c, $r)
+                    ->then(
+                        function ($result) use ($c, $r) {
+                            foreach ((array) $result['Messages'] as $msg) {
+                                $bodyMd5 = self::calculateBodyMd5($msg);
+                                if (isset($msg['MD5OfBody'])
+                                    && $bodyMd5 !== $msg['MD5OfBody']
+                                ) {
+                                    throw new SqsException(
+                                        sprintf(
+                                            'MD5 mismatch. Expected %s, found %s',
+                                            $msg['MD5OfBody'],
+                                            $bodyMd5
+                                        ),
+                                        $c,
+                                        [
+                                            'code' => 'ClientChecksumMismatch',
+                                            'request' => $r
+                                        ]
+                                    );
+                                }
+
+                                if (isset($msg['MD5OfMessageAttributes'])) {
+                                    $messageAttributesMd5 = self::calculateMessageAttributesMd5($msg);
+                                    if ($messageAttributesMd5 !== $msg['MD5OfMessageAttributes']) {
+                                        throw new SqsException(
+                                            sprintf(
+                                                'Attribute MD5 mismatch. Expected %s, found %s',
+                                                $msg['MD5OfMessageAttributes'],
+                                                $messageAttributesMd5
+                                                    ? $messageAttributesMd5
+                                                    : 'No Attributes'
+                                            ),
+                                            $c,
+                                            [
+                                                'code' => 'ClientChecksumMismatch',
+                                                'request' => $r
+                                            ]
+                                        );
+                                    }
+                                } else if (isset($msg['MessageAttributes'])) {
+                                    throw new SqsException(
+                                        sprintf(
+                                            'No Attribute MD5 found. Expected %s',
+                                            self::calculateMessageAttributesMd5($msg)
+                                        ),
+                                        $c,
+                                        [
+                                            'code' => 'ClientChecksumMismatch',
+                                            'request' => $r
+                                        ]
+                                    );
+                                }
+                            }
+                            return $result;
+                        }
+                    );
+            };
+        };
+    }
+}
-- 
cgit v1.2.3