Add setting subscription attributes to Sns and SnsQs

Author: andrewmy

pkg/sns/SnsClient.php

@@ -60,6 +60,11 @@ public function unsubscribe(array $args): Result
         return $this->callApi('unsubscribe', $args);
     }
 
+    public function setSubscriptionAttributes(array $args): Result
+    {
+        return $this->callApi('setSubscriptionAttributes', $args);
+    }
+
     public function listSubscriptionsByTopic(array $args): Result
     {
         return $this->callApi('ListSubscriptionsByTopic', $args);

pkg/sns/SnsContext.php

@@ -145,6 +145,16 @@ public function getSubscriptions(SnsDestination $destination): array
         return $subscriptions;
     }
 
+    public function setSubscriptionAttributes(SnsSubscribe $subscribe): void
+    {
+        foreach ($this->getSubscriptions($subscribe->getTopic()) as $subscription) {
+            $this->client->setSubscriptionAttributes(array_merge(
+                $subscribe->getAttributes(),
+                ['SubscriptionArn' => $subscription['SubscriptionArn']],
+            ));
+        }
+    }
+
     public function getTopicArn(SnsDestination $destination): string
     {
         if (false == array_key_exists($destination->getTopicName(), $this->topicArns)) {

pkg/snsqs/SnsQsContext.php

@@ -173,6 +173,17 @@ public function close(): void
         $this->getSqsContext()->close();
     }
 
+    public function setSubscriptionAttributes(SnsQsTopic $topic, SnsQsQueue $queue, array $attributes): void
+    {
+        $this->getSnsContext()->setSubscriptionAttributes(new SnsSubscribe(
+            $topic,
+            $this->getSqsContext()->getQueueArn($queue),
+            SnsSubscribe::PROTOCOL_SQS,
+            false,
+            $attributes,
+        ));
+    }
+
     private function getSnsContext(): SnsContext
     {
         if (null === $this->snsContext) {