add sns driver + use profile to establish connection

Author: fbaudry

pkg/enqueue/Resources.php

@@ -14,6 +14,7 @@
 use Enqueue\Pheanstalk\PheanstalkConnectionFactory;
 use Enqueue\RdKafka\RdKafkaConnectionFactory;
 use Enqueue\Redis\RedisConnectionFactory;
+use Enqueue\Sns\SnsConnectionFactory;
 use Enqueue\SnsQs\SnsQsConnectionFactory;
 use Enqueue\Sqs\SqsConnectionFactory;
 use Enqueue\Stomp\StompConnectionFactory;
@@ -42,7 +43,7 @@ public static function getAvailableConnections(): array
 
         $availableMap = [];
         foreach ($map as $connectionClass => $item) {
-            if (class_exists($connectionClass)) {
+            if (\class_exists($connectionClass)) {
                 $availableMap[$connectionClass] = $item;
             }
         }
@@ -156,6 +157,10 @@ public static function getKnownConnections(): array
                 'schemes' => ['sqs'],
                 'supportedSchemeExtensions' => [],
                 'package' => 'enqueue/sqs', ];
+            $map[SnsConnectionFactory::class] = [
+                'schemes' => ['sns'],
+                'supportedSchemeExtensions' => [],
+                'package' => 'enqueue/sns', ];
             $map[SnsQsConnectionFactory::class] = [
                 'schemes' => ['snsqs'],
                 'supportedSchemeExtensions' => [],
@@ -183,9 +188,9 @@ public static function getKnownConnections(): array
 
     public static function addConnection(string $connectionFactoryClass, array $schemes, array $extensions, string $package): void
     {
-        if (class_exists($connectionFactoryClass)) {
+        if (\class_exists($connectionFactoryClass)) {
             if (false == (new \ReflectionClass($connectionFactoryClass))->implementsInterface(ConnectionFactory::class)) {
-                throw new \InvalidArgumentException(sprintf('The connection factory class "%s" must implement "%s" interface.', $connectionFactoryClass, ConnectionFactory::class));
+                throw new \InvalidArgumentException(\sprintf('The connection factory class "%s" must implement "%s" interface.', $connectionFactoryClass, ConnectionFactory::class));
             }
         }
 

pkg/sns/SnsConnectionFactory.php

@@ -89,6 +89,10 @@ private function establishConnection(): SnsClient
             $config['endpoint'] = $this->config['endpoint'];
         }
 
+        if (isset($this->config['profile'])) {
+            $config['profile'] = $this->config['profile'];
+        }
+
         if ($this->config['key'] && $this->config['secret']) {
             $config['credentials'] = [
                 'key' => $this->config['key'],