Add AWS check for topic existence

uecode · Feb 10, 2015 · deb9137 · deb9137
1 parent 0fad2ed
commit deb9137
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/src/Provider/AwsProvider.php b/src/Provider/AwsProvider.php
@@ -23,6 +23,7 @@
 namespace Uecode\Bundle\QPushBundle\Provider;
 
 use Aws\Common\Aws;
+use Aws\Sns\Exception\NotFoundException;
 use Aws\Sqs\SqsClient;
 use Aws\Sqs\Exception\SqsException;
 use Doctrine\Common\Cache\Cache;
@@ -411,6 +412,21 @@ public function topicExists()
             return true;
         }
 
+        if (!empty($this->queueUrl)) {
+            $queueArn = $this->sqs->getQueueArn($this->queueUrl);
+            $topicArn = str_replace('sqs', 'sns', $queueArn);
+            try {
+                $result   = $this->sns->getTopicAttributes([
+                    'TopicArn' => $topicArn
+                ]);
+            } catch (NotFoundException $e) {
+                return false;
+            }
+            $this->topicArn = $topicArn;
+            $this->cache->save($key, $this->topicArn);
+            return true;
+        }
+
         return false;
     }