Merge pull request #1690 from vmiguellima/add-get-queue-name-to-sqs-r…

…ecord

Add ability to get queue name from sqs event

src/Event/Sqs/SqsRecord.php

@@ -57,6 +57,17 @@ public function getReceiptHandle(): string
         return $this->record['receiptHandle'];
     }
 
+    /**
+     * Returns the name of the SQS queue that contains the message.
+     * Queue naming constraints: https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/quotas-queues.html
+     */
+    public function getQueueName(): string
+    {
+        $parts = explode(':', $this->record['eventSourceARN']);
+
+        return $parts[count($parts) - 1];
+    }
+
     /**
      * Returns the record original data as an array.
      *

tests/Event/Sqs/SqsRecordTest.php

@@ -0,0 +1,18 @@
+<?php declare(strict_types=1);
+
+namespace Bref\Test\Event\Sqs;
+
+use Bref\Event\Sqs\SqsRecord;
+use PHPUnit\Framework\TestCase;
+
+class SqsRecordTest extends TestCase
+{
+    public function test_it_can_get_queue_name_from_sqs_event()
+    {
+        $event = json_decode(file_get_contents(__DIR__ . '/sqs.json'), true);
+
+        $sqsRecord = new SqsRecord($event['Records'][0]);
+
+        $this->assertSame($sqsRecord->getQueueName(), 'my-queue');
+    }
+}