Add tests to cover basic Topic to Event mapping

Author: tepeds

src/SnsBroker.php

@@ -8,6 +8,8 @@
 use Illuminate\Support\Facades\Log;
 use Nipwaayoni\SnsHandler\Events\SnsConfirmationRequestReceived;
 use Nipwaayoni\SnsHandler\Events\SnsMessageReceived;
+use Nipwaayoni\Tests\SnsHandler\Events\SnsMessageAlphaReceived;
+use Nipwaayoni\Tests\SnsHandler\Events\SnsMessageBetaReceived;
 
 class SnsBroker
 {
@@ -74,7 +76,11 @@ private function getSubscriptionEvent(string $arn)
 
     private function getNotificationEvent(string $arn)
     {
-        $map = [SnsMessageReceived::class => ['*']];
+        $map = [
+            SnsMessageAlphaReceived::class => ['arn:aws:sns:us-west-2:123456789012:AlphaTopic'],
+            SnsMessageBetaReceived::class => ['arn:aws:sns:us-west-2:123456789012:AlphaTopic'],
+            SnsMessageReceived::class => ['*'],
+        ];
         return $this->arnMap($arn, $map);
     }
 

tests/Events/SnsMessageAlphaReceived.php

@@ -0,0 +1,25 @@
+<?php
+
+
+namespace Nipwaayoni\Tests\SnsHandler\Events;
+
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Foundation\Events\Dispatchable;
+use Nipwaayoni\SnsHandler\SnsMessage;
+
+class SnsMessageAlphaReceived
+{
+    use Dispatchable, InteractsWithSockets;
+
+    private $message;
+
+    public function __construct(SnsMessage $message)
+    {
+        $this->message = $message;
+    }
+
+    public function message(): SnsMessage
+    {
+        return $this->message;
+    }
+}

tests/Events/SnsMessageBetaReceived.php

@@ -0,0 +1,25 @@
+<?php
+
+
+namespace Nipwaayoni\Tests\SnsHandler\Events;
+
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Foundation\Events\Dispatchable;
+use Nipwaayoni\SnsHandler\SnsMessage;
+
+class SnsMessageBetaReceived
+{
+    use Dispatchable, InteractsWithSockets;
+
+    private $message;
+
+    public function __construct(SnsMessage $message)
+    {
+        $this->message = $message;
+    }
+
+    public function message(): SnsMessage
+    {
+        return $this->message;
+    }
+}

tests/Unit/SnsBrokerTest.php

@@ -11,6 +11,8 @@
 use Nipwaayoni\SnsHandler\SnsHttpRequest;
 use Nipwaayoni\SnsHandler\SnsMessage;
 use Nipwaayoni\SnsHandler\SnsUnknownTopicArnException;
+use Nipwaayoni\Tests\SnsHandler\Events\SnsMessageAlphaReceived;
+use Nipwaayoni\Tests\SnsHandler\Events\SnsMessageBetaReceived;
 use PHPUnit\Framework\MockObject\MockObject;
 use Nipwaayoni\Tests\SnsHandler\MakesSnsTests;
 use Nipwaayoni\Tests\SnsHandler\TestCase;
@@ -112,4 +114,33 @@ public function testValidatesSnsMessage(): void
 
         $this->broker->handleRequest($request);
     }
+
+    public function testDispatchMappedNotificationMessage(): void
+    {
+        $request = $this->createMock(SnsHttpRequest::class);
+        $request->expects($this->once())->method('jsonContent')
+            ->willReturn($this->makeSnsMessageJson([
+                'MessageId' => 'abc123',
+                'TopicArn' => 'arn:aws:sns:us-west-2:123456789012:AlphaTopic'
+            ]));
+
+        $this->broker->handleRequest($request);
+        Event::assertDispatched(SnsMessageAlphaReceived::class);
+        Event::assertNotDispatched(SnsMessageReceived::class);
+    }
+
+    public function testDispatchFirstMappedNotificationMessage(): void
+    {
+        $request = $this->createMock(SnsHttpRequest::class);
+        $request->expects($this->once())->method('jsonContent')
+            ->willReturn($this->makeSnsMessageJson([
+                'MessageId' => 'abc123',
+                'TopicArn' => 'arn:aws:sns:us-west-2:123456789012:AlphaTopic'
+            ]));
+
+        $this->broker->handleRequest($request);
+        Event::assertDispatched(SnsMessageAlphaReceived::class);
+        Event::assertNotDispatched(SnsMessageBetaReceived::class);
+        Event::assertNotDispatched(SnsMessageReceived::class);
+    }
 }