Finalized SNS subscription support (SQS only)

Author: Visual-Vincent

GuiStack/Controllers/SNS/SubscriptionsController.cs

@@ -0,0 +1,97 @@
+/*
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at https://mozilla.org/MPL/2.0/.
+ * 
+ * Copyright © Vincent Bengtsson & Contributors 2022-2024
+ * https://github.com/Visual-Vincent/GuiStack
+ */
+
+using System;
+using System.Net;
+using System.Threading.Tasks;
+using Amazon.SimpleNotificationService;
+using GuiStack.Extensions;
+using GuiStack.Models;
+using GuiStack.Repositories;
+using Microsoft.AspNetCore.Mvc;
+
+namespace GuiStack.Controllers.SNS
+{
+    [ApiController]
+    [Route("api/" + nameof(SNS) + "/[controller]")]
+    public class SubscriptionsController : Controller
+    {
+        private ISNSRepository snsRepository;
+
+        public SubscriptionsController(ISNSRepository snsRepository)
+        {
+            this.snsRepository = snsRepository;
+        }
+
+        private ActionResult HandleException(Exception ex)
+        {
+            if(ex == null)
+                throw new ArgumentNullException(nameof(ex));
+
+            if(ex is AmazonSimpleNotificationServiceException snsEx)
+            {
+                if(snsEx.StatusCode == HttpStatusCode.NotFound)
+                    return StatusCode((int)snsEx.StatusCode, new { error = snsEx.Message });
+
+                Console.Error.WriteLine(snsEx);
+                return StatusCode((int)HttpStatusCode.InternalServerError, new { error = ex.Message });
+            }
+
+            Console.Error.WriteLine(ex);
+            return StatusCode((int)HttpStatusCode.InternalServerError);
+        }
+
+        [HttpPost]
+        [Consumes("application/json")]
+        [Produces("application/json")]
+        public async Task<ActionResult> CreateSubscription([FromBody] SNSCreateSubscriptionModel model)
+        {
+            if(string.IsNullOrWhiteSpace(model.TopicArn))
+                return StatusCode((int)HttpStatusCode.BadRequest, new { error = "'topicArn' cannot be empty" });
+
+            if(string.IsNullOrWhiteSpace(model.Protocol))
+                return StatusCode((int)HttpStatusCode.BadRequest, new { error = "'protocol' cannot be empty" });
+
+            if(string.IsNullOrWhiteSpace(model.Endpoint))
+                return StatusCode((int)HttpStatusCode.BadRequest, new { error = "'endpoint' cannot be empty" });
+
+            if(!model.Protocol.Equals("sqs", StringComparison.OrdinalIgnoreCase))
+                return StatusCode((int)HttpStatusCode.BadRequest, new { error = $"Protocol '{model.Protocol}' is not supported. Supported protocols are: sqs" });
+
+            try
+            {
+                await snsRepository.CreateTopicSubscriptionAsync(model.TopicArn, model.Endpoint);
+                return Ok();
+            }
+            catch(Exception ex)
+            {
+                return HandleException(ex);
+            }
+        }
+
+        [HttpDelete("{subscriptionArn}")]
+        public async Task<ActionResult> DeleteSubscription(string subscriptionArn)
+        {
+            if(string.IsNullOrWhiteSpace(subscriptionArn))
+                return StatusCode((int)HttpStatusCode.BadRequest);
+
+            subscriptionArn = subscriptionArn.DecodeRouteParameter();
+
+            try
+            {
+                await snsRepository.DeleteSubscriptionAsync(subscriptionArn);
+                return Ok();
+            }
+            catch(Exception ex)
+            {
+                return HandleException(ex);
+            }
+        }
+    }
+}

GuiStack/Controllers/SNS/TopicsController.cs

@@ -3,7 +3,7 @@
  * License, v. 2.0. If a copy of the MPL was not distributed with this
  * file, You can obtain one at https://mozilla.org/MPL/2.0/.
  * 
- * Copyright © Vincent Bengtsson & Contributors 2022-2023
+ * Copyright © Vincent Bengtsson & Contributors 2022-2024
  * https://github.com/Visual-Vincent/GuiStack
  */
 
@@ -47,7 +47,7 @@ private ActionResult HandleException(Exception ex)
             return StatusCode((int)HttpStatusCode.InternalServerError);
         }
 
-        [HttpPut]
+        [HttpPost]
         [Consumes("application/json")]
         public async Task<ActionResult> CreateTopic([FromBody] SNSCreateTopicModel model)
         {

GuiStack/Controllers/SQS/QueuesController.cs

@@ -3,7 +3,7 @@
  * License, v. 2.0. If a copy of the MPL was not distributed with this
  * file, You can obtain one at https://mozilla.org/MPL/2.0/.
  * 
- * Copyright © Vincent Bengtsson & Contributors 2022
+ * Copyright © Vincent Bengtsson & Contributors 2022-2024
  * https://github.com/Visual-Vincent/GuiStack
  */
 
@@ -121,7 +121,7 @@ public async Task<ActionResult> SendMessage([FromRoute] string queueName, [FromB
 
                     // This re-encoding to Base64 is intentional, as I want to rely on .NET's Base64 implementation to ensure that
                     // in the event that encoding isn't properly performed by the client, we don't send incorrectly encoded messages.
-                    // (Insead, the decoding above will likely throw an error)
+                    // (Instead, the decoding above will likely throw an error)
 
                     if(message.Base64Encode)
                         body = Convert.ToBase64String(protoData);

GuiStack/Models/SNSCreateSubscriptionModel.cs

@@ -0,0 +1,20 @@
+/*
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at https://mozilla.org/MPL/2.0/.
+ * 
+ * Copyright © Vincent Bengtsson & Contributors 2022-2024
+ * https://github.com/Visual-Vincent/GuiStack
+ */
+
+using System;
+
+namespace GuiStack.Models
+{
+    public class SNSCreateSubscriptionModel
+    {
+        public string TopicArn { get; set; }
+        public string Protocol { get; set; }
+        public string Endpoint { get; set; }
+    }
+}

GuiStack/Pages/SNS/Index.cshtml

@@ -129,7 +129,7 @@ else
                 var dedupe = document.getElementById("new-sns-topic-dedupe-checkbox").checked;
 
                 var response = await fetch("@Url.Action("CreateTopic", "Topics")", {
-                    method: "PUT",
+                    method: "POST",
                     headers: new Headers({ "Content-Type": "application/json" }),
                     body: JSON.stringify({
                         topicName: topicName,

GuiStack/Pages/SNS/_TopicInfo.cshtml

@@ -7,6 +7,7 @@
  * https://github.com/Visual-Vincent/GuiStack
  *@
 
+@using Amazon;
 @using GuiStack.Models
 @using GuiStack.Extensions
 @using GuiStack.Repositories
@@ -15,7 +16,7 @@
 <div id="sns-subscribe-to-sqs-modal" class="cssWindow dark backdropblur text-center">
     <div class="closeWindowButton"><a no-href onclick="closeParentWindow(event)">×</a></div>
 
-    <h2 class="title">Subscribe to SQS queue</h2>
+    <h2 class="title">Subscribe SQS queue to Topic</h2>
     <div class="queue-selector-container text-left" style="margin-top: 16px; margin-bottom: 16px">
         Loading queues...
     </div>
@@ -25,6 +26,10 @@
     </div>
 </div>
 
+@{
+    await Html.RenderPartialAsync("~/Pages/Shared/_DeleteModal.cshtml", new DeleteModalModel("delete-sns-subscription-modal"));
+}
+
 <table class="gs-info-table colored">
     <tbody>
         <tr>
@@ -85,22 +90,45 @@
 <table class="gs-list padded autosize-all-cols-but-first">
     <thead>
         <tr>
-            <th>Protocol</th>
             <th>Endpoint</th>
+            <th>Protocol</th>
             <th>Owner</th>
             <th>Actions</th>
         </tr>
     </thead>
     <tbody>
-        @foreach(var subscription in Model.Subscriptions)
+        @foreach(var subscription in Model.Subscriptions.OrderBy(s => s.Protocol).ThenBy(s => s.Endpoint))
         {
-            <tr>
+            <tr data-arn="@subscription.Arn" data-endpoint="@subscription.Endpoint">
+                @if(subscription.Protocol == null)
+                {
+                    <td>@subscription.Endpoint</td>
+                }
+                else
+                {
+                    <td>
+                        @switch(subscription.Protocol.ToLower())
+                        {
+                            case "sqs":
+                            {
+                                if (Arn.TryParse(subscription.Endpoint, out var arn))
+                                {
+                                    <a href="/SQS/@arn.Resource"><i class="fa-solid fa-database gs-rotate-270" style="margin-right: 2px"></i> @arn.Resource</a>
+                                }
+                                else
+                                {
+                                    <td>@subscription.Endpoint</td>
+                                }
+                                break;
+                            }
+                        }
+                    </td>
+                }
                 <td>@subscription.Protocol</td>
-                <td>@subscription.Endpoint</td>
-                <td>@subscription.Owner</td>
+                <td>@(!string.IsNullOrWhiteSpace(subscription.Owner) ? subscription.Owner : "(unknown)")</td>
                 <td>
                     <div class="gs-icons">
-                        <a no-href class="purple lnk-sns-sub-copyarn" title="Copy ARN">
+                        <a no-href class="purple lnk-sns-sub-copyarn" title="Copy Endpoint address/ARN">
                             <i class="fa-solid fa-link"></i>
                         </a>
                         <a no-href class="red lnk-sns-sub-delete" title="Delete">
@@ -117,6 +145,14 @@
     var subscribeToSqsModal = document.getElementById("sns-subscribe-to-sqs-modal");
     var queueSelectorContainer = $("#sns-subscribe-to-sqs-modal .queue-selector-container");
 
+    $(".lnk-sns-sub-copyarn").click(sns_CopySubscriptionArn);
+    $(".lnk-sns-sub-delete").click(sns_DeleteSubscriptionPrompt);
+    $("#delete-sns-subscription-modal .yes-button").click(sns_DeleteSubscription);
+
+    const SNS_URL_DELETE_SUBSCRIPTION = "@Url.Action("DeleteSubscription", "Subscriptions", new { subscriptionArn = "__SUBSCRIPTIONARN__" })";
+
+    var prompt_SubscriptionArn;
+
     subscribeToSqsModal.addEventListener("windowopened", function() {
         $.ajax({
             type: "GET",
@@ -136,7 +172,7 @@
         queueSelectorContainer.html("Loading queues...");
     });
 
-    function sns_CreateSubscription_Click()
+    async function sns_CreateSubscription_Click()
     {
         var selectedItem = gs_GetSelectedTableItem(queueSelectorContainer[0]);
 
@@ -146,7 +182,88 @@
             return;
         }
 
-        // TODO: Create subscription
-        alert(selectedItem.getAttribute("data-queue-name"));
+        var queueUrl = selectedItem.getAttribute("data-url");
+
+        try
+        {
+            var response = await fetch("@Url.Action("CreateSubscription", "Subscriptions")", {
+                method: "POST",
+                headers: new Headers({ "Content-Type": "application/json" }),
+                body: JSON.stringify({
+                    topicArn: "@Model.Topic.TopicARN",
+                    protocol: "sqs",
+                    endpoint: queueUrl
+                })
+            });
+
+            if(!response.ok) {
+                throw "Failed to create SNS subscription: Server returned HTTP status " + response.status;
+            }
+
+            window.location.reload(true);
+        }
+        catch(error)
+        {
+            gs_DisplayError(error);
+        }
+
+        closeWindow("sns-subscribe-to-sqs-modal");
+    }
+
+    function sns_CopySubscriptionArn(event)
+    {
+        try
+        {
+            var arn = gs_GetParentTableRow(event.currentTarget, true).getAttribute("data-arn");
+            navigator.clipboard.writeText(arn);
+        }
+        catch(error)
+        {
+            gs_DisplayError(error);
+        }
+    }
+
+    function sns_DeleteSubscriptionPrompt(event)
+    {
+        try
+        {
+            var objNameElement = document.querySelector("#delete-sns-subscription-modal .title .object-name");
+            var parentRow = gs_GetParentTableRow(event.currentTarget, true);
+            var endpoint = parentRow.getAttribute("data-endpoint");
+
+            prompt_SubscriptionArn = parentRow.getAttribute("data-arn");
+
+            objNameElement.innerHTML = '<span style="color: #FFFFFF">the subscription</span> ' + endpoint;
+            showWindow("delete-sns-subscription-modal");
+        }
+        catch(error)
+        {
+            gs_DisplayError(error);
+        }
+    }
+
+    async function sns_DeleteSubscription()
+    {
+        try
+        {
+            var subscriptionArn = encodeURIComponent(prompt_SubscriptionArn);
+
+            var url = SNS_URL_DELETE_SUBSCRIPTION
+                .replace("__SUBSCRIPTIONARN__", subscriptionArn);
+
+            var response = await fetch(url, { method: "DELETE" });
+
+            if(!response.ok) {
+                throw "Failed to delete SNS subscription: Server returned HTTP status " + response.status;
+            }
+
+            window.location.reload(true);
+        }
+        catch(error)
+        {
+            gs_DisplayError(error);
+        }
+
+        closeWindow("delete-sns-subscription-modal");
     }
 </script>

GuiStack/Pages/SNS/_TopicsTable.cshtml

@@ -3,14 +3,16 @@
  * License, v. 2.0. If a copy of the MPL was not distributed with this
  * file, You can obtain one at https://mozilla.org/MPL/2.0/.
  * 
- * Copyright © Vincent Bengtsson & Contributors 2022-2023
+ * Copyright © Vincent Bengtsson & Contributors 2022-2024
  * https://github.com/Visual-Vincent/GuiStack
  *@
 
 @using GuiStack.Models; 
 @model IEnumerable<SNSTopic>
 
-@{ await Html.RenderPartialAsync("~/Pages/Shared/_DeleteModal.cshtml", new DeleteModalModel("deleteSNSTopicModal")); }
+@{
+    await Html.RenderPartialAsync("~/Pages/Shared/_DeleteModal.cshtml", new DeleteModalModel("deleteSNSTopicModal"));
+}
 
 <table class="gs-list padded autosize-all-cols-but-first">
     <thead>