Added getters to notifications

sinemacula · Aug 9, 2024 · 76177e9 · 76177e9
1 parent 1d8caa8
commit 76177e9
Show file tree

Hide file tree

Showing 6 changed files with 66 additions and 1 deletion.
diff --git a/.github/workflows/tests.yml b/.github/workflows/tests.yml
@@ -19,7 +19,7 @@ jobs:
 
         steps:
             -   name: Checkout code
-                uses: actions/checkout@v3
+                uses: actions/checkout@v4
 
             -   name: Setup PHP
                 uses: shivammathur/setup-php@v2

diff --git a/src/Events/CloudWatchNotificationReceived.php b/src/Events/CloudWatchNotificationReceived.php
@@ -2,6 +2,7 @@
 
 namespace SineMacula\Aws\Sns\Events;
 
+use InvalidArgumentException;
 use SineMacula\Aws\Sns\Entities\Messages\Contracts\CloudWatchNotificationInterface;
 
 /**
@@ -21,4 +22,18 @@ public function __construct(CloudWatchNotificationInterface $notification)
     {
         parent::__construct($notification);
     }
+
+    /**
+     * Return the notification.
+     *
+     * @return \SineMacula\Aws\Sns\Entities\Messages\Contracts\CloudWatchNotificationInterface
+     */
+    public function getNotification(): CloudWatchNotificationInterface
+    {
+        if (!$this->notification instanceof CloudWatchNotificationInterface) {
+            throw new InvalidArgumentException('Invalid notification type');
+        }
+
+        return $this->notification;
+    }
 }
diff --git a/src/Events/NotificationReceived.php b/src/Events/NotificationReceived.php
@@ -23,4 +23,14 @@ public function __construct(
         protected NotificationInterface $notification
 
     ) {}
+
+    /**
+     * Return the notification.
+     *
+     * @return \SineMacula\Aws\Sns\Entities\Messages\Contracts\NotificationInterface
+     */
+    public function getNotification(): NotificationInterface
+    {
+        return $this->notification;
+    }
 }
diff --git a/src/Events/S3NotificationReceived.php b/src/Events/S3NotificationReceived.php
@@ -2,6 +2,7 @@
 
 namespace SineMacula\Aws\Sns\Events;
 
+use InvalidArgumentException;
 use SineMacula\Aws\Sns\Entities\Messages\Contracts\S3NotificationInterface;
 
 /**
@@ -21,4 +22,18 @@ public function __construct(S3NotificationInterface $notification)
     {
         parent::__construct($notification);
     }
+
+    /**
+     * Return the notification.
+     *
+     * @return \SineMacula\Aws\Sns\Entities\Messages\Contracts\S3NotificationInterface
+     */
+    public function getNotification(): S3NotificationInterface
+    {
+        if (!$this->notification instanceof S3NotificationInterface) {
+            throw new InvalidArgumentException('Invalid notification type');
+        }
+
+        return $this->notification;
+    }
 }
diff --git a/src/Events/SesNotificationReceived.php b/src/Events/SesNotificationReceived.php
@@ -2,6 +2,7 @@
 
 namespace SineMacula\Aws\Sns\Events;
 
+use InvalidArgumentException;
 use SineMacula\Aws\Sns\Entities\Messages\Contracts\SesNotificationInterface;
 
 /**
@@ -21,4 +22,18 @@ public function __construct(SesNotificationInterface $notification)
     {
         parent::__construct($notification);
     }
+
+    /**
+     * Return the notification.
+     *
+     * @return \SineMacula\Aws\Sns\Entities\Messages\Contracts\SesNotificationInterface
+     */
+    public function getNotification(): SesNotificationInterface
+    {
+        if (!$this->notification instanceof SesNotificationInterface) {
+            throw new InvalidArgumentException('Invalid notification type');
+        }
+
+        return $this->notification;
+    }
 }
diff --git a/src/Events/SubscriptionConfirmed.php b/src/Events/SubscriptionConfirmed.php
@@ -23,4 +23,14 @@ public function __construct(
         protected SubscriptionConfirmationInterface $message
 
     ) {}
+
+    /**
+     * Return the message.
+     *
+     * @return \SineMacula\Aws\Sns\Entities\Messages\Contracts\SubscriptionConfirmationInterface
+     */
+    public function getMessage(): SubscriptionConfirmationInterface
+    {
+        return $this->message;
+    }
 }