feat: ensure/automatically confirm the SNS subscription

README.md

@@ -192,11 +192,11 @@ Finally, we need to confirm the subscription which is easily done by navigating
 
 ![AWS SNS Subscription Confirmation Screenshot](https://i.imgur.com/qzLZJAD.png)
 
-By default, AWS will have sent a post request to URL you defined in your "Subscription" setup. You can view request in the Expose interface, by visiting the "Dashboard Url", which should be similar to: `http://127.0.0.1:4040`
+By default, AWS will have sent a post request to URL you defined in your "Subscription" setup. This package automatically handles the "confirmation" part. In case there is an issue and it is not confirmed yet, please click on the "Request confirmation" button as seen in the screenshot above.
 
-Once you are in the Expose dashboard, you need to locate the `SubscribeURL` value. Once located, copy it and use it to confirm your SNS Topic Subscription.
+You can also view the request in the Expose interface, by visiting the "Dashboard Url", which should be similar to: `http://127.0.0.1:4040`
 
-![AWS SNS Subscription Confirmation Screenshot](https://i.imgur.com/ECGIBUY.png)
+Once the status reflects "Confirmed", your API will receive webhooks as AWS provides updates.
 
 #### Create CloudWatch Event
 

src/Http/Controllers/IncomingWebhookController.php

@@ -4,6 +4,7 @@
 
 use Aws\Sns\Message;
 use Illuminate\Routing\Controller;
+use Illuminate\Support\Facades\Http;
 use Meema\MediaConverter\Events\ConversionHasCompleted;
 use Meema\MediaConverter\Events\ConversionHasError;
 use Meema\MediaConverter\Events\ConversionHasInputInformation;
@@ -25,7 +26,8 @@ public function __construct()
     public function __invoke()
     {
         try {
-            $message = json_decode(Message::fromRawPostData()['Message'] ?? '', true);
+            $message = $this->ensureSubscriptionIsConfirmed();
+
             $detail = $message['detail'];
             $status = $detail['status'];
 
@@ -68,4 +70,18 @@ public function fireEventFor($status, $message)
                 throw new \Exception();
         }
     }
+
+    /**
+     * @return array
+     */
+    public function ensureSubscriptionIsConfirmed(): array
+    {
+        $message = Message::fromRawPostData()->toArray();
+
+        if (array_key_exists('SubscribeURL', $message)) {
+            Http::get($message['SubscribeURL']);
+        }
+
+        return $message;
+    }
 }