Merge pull request #120 from FromDoppler/add-get-message-status

Add get message status
FromDoppler · Oct 4, 2024 · 26382ce · 26382ce
2 parents f54f1fc + 605ee93
commit 26382ce
Show file tree

Hide file tree

Showing 7 changed files with 136 additions and 0 deletions.
diff --git a/DopplerBeplic.Tests/GetTemplateMessageStatusTests.cs b/DopplerBeplic.Tests/GetTemplateMessageStatusTests.cs
@@ -0,0 +1,66 @@
+using DopplerBeplic.Models.Responses;
+using DopplerBeplic.Services.Interfaces;
+using Newtonsoft.Json;
+
+namespace DopplerBeplic.Tests
+{
+    public class GetTemplateMessageStatusTests
+    {
+        [Fact]
+        public async Task GET_get_message_status_should_not_authorize_without_token()
+        {
+            var application = new PlaygroundApplication();
+            var client = application.CreateClient();
+
+            var response = await client.GetAsync("/customer/messages/xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx");
+
+            Assert.Equal(HttpStatusCode.Unauthorized, response.StatusCode);
+            Assert.Equal("Bearer", response.Headers.WwwAuthenticate.ToString());
+        }
+
+        [Fact]
+        public async Task GET_get_message_status_should_authorize_super_user_and_returns_status()
+        {
+            var bodyParams = new { };
+
+            var application = new PlaygroundApplication();
+
+            var messageId = Guid.NewGuid().ToString();
+
+            var expectedResponse = new TemplateMessageResponse()
+            {
+                MessageId = messageId,
+                Status = new List<TemplateMessageStatusResponse>()
+                {
+                    new TemplateMessageStatusResponse()
+                    {
+                        Status = "READ",
+                        StatusDate = DateTime.UtcNow
+                    }
+                }
+            };
+
+            var beplicServiceMock = new Mock<IBeplicService>();
+            beplicServiceMock.Setup(x => x.GetMessageStatus(messageId)).ReturnsAsync(expectedResponse);
+
+            application.ConfigureServices(services => services.AddSingleton(beplicServiceMock.Object));
+
+            var client = application.CreateClient();
+            client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", TestUsersData.Token_Superuser_Expire2033_05_18);
+
+            var response = await client.GetAsync($"/customer/messages/{messageId}");
+
+            Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+
+            beplicServiceMock.Verify(x => x.GetMessageStatus(messageId), Times.Once);
+
+            var content = await response.Content.ReadAsStringAsync();
+
+            var messageResponse = JsonConvert.DeserializeObject<TemplateMessageResponse>(content);
+
+            Assert.Equal(messageResponse?.MessageId, expectedResponse.MessageId);
+            Assert.Equal("READ", messageResponse?.Status?[0].Status);
+        }
+
+    }
+}
diff --git a/doppler-beplic/Models/Responses/BeplicResponses/BeplicTemplateMessageStatusResponse.cs b/doppler-beplic/Models/Responses/BeplicResponses/BeplicTemplateMessageStatusResponse.cs
@@ -0,0 +1,8 @@
+namespace DopplerBeplic.Models.Responses.BeplicResponses
+{
+    public class BeplicTemplateMessageStatusResponse
+    {
+        public string? Status { get; set; }
+        public DateTime StatusDate { get; set; }
+    }
+}
diff --git a/doppler-beplic/Models/Responses/TemplateMessageResponse.cs b/doppler-beplic/Models/Responses/TemplateMessageResponse.cs
@@ -3,5 +3,6 @@ namespace DopplerBeplic.Models.Responses
     public class TemplateMessageResponse
     {
         public string? MessageId { get; set; }
+        public List<TemplateMessageStatusResponse>? Status { get; set; }
     }
 }
diff --git a/doppler-beplic/Models/Responses/TemplateMessageStatusResponse.cs b/doppler-beplic/Models/Responses/TemplateMessageStatusResponse.cs
@@ -0,0 +1,8 @@
+namespace DopplerBeplic.Models.Responses
+{
+    public class TemplateMessageStatusResponse
+    {
+        public string? Status { get; set; }
+        public DateTime StatusDate { get; set; }
+    }
+}
diff --git a/doppler-beplic/Program.cs b/doppler-beplic/Program.cs
@@ -267,6 +267,23 @@
 .RequireAuthorization(Policies.OnlySuperuser);
 
 
+app.MapGet("/customer/messages/{messageId}", async Task<Results<Ok<TemplateMessageResponse>, BadRequest<string>>> (string messageId, IBeplicService beplicService) =>
+{
+    try
+    {
+        var response = await beplicService.GetMessageStatus(messageId);
+
+        return TypedResults.Ok(response);
+    }
+    catch (Exception e)
+    {
+        return TypedResults.BadRequest(e.Message);
+    }
+})
+.WithName("MessageStatus")
+.WithOpenApi()
+.RequireAuthorization(Policies.OnlySuperuser);
+
 app.MapGet("/customer/rooms/{roomId}/templates", async Task<Results<Ok<IEnumerable<TemplateResponse>>, BadRequest<string>>> (int roomId, IBeplicService beplicService) =>
 {
     try

diff --git a/doppler-beplic/Services/Classes/BeplicService.cs b/doppler-beplic/Services/Classes/BeplicService.cs
@@ -330,6 +330,41 @@ public async Task<PlanAssignResponse> PlanAssign(PlanAssignmentDTO planAssignDat
             return result;
         }
 
+        public async Task<TemplateMessageResponse> GetMessageStatus(string messageId)
+        {
+            var parameters = new Parameter[]
+            {
+                Parameter.CreateParameter("messageId",messageId,ParameterType.UrlSegment)
+            };
+            var response = await _sdk.ExecuteServiceResource("/services/partner/messages/{messageId}", parameters, Method.Get);
+
+            if (response.IsSuccessStatusCode)
+            {
+                var result = JsonConvert.DeserializeObject<BeplicServiceResponse<List<BeplicTemplateMessageStatusResponse>>>(response.Content ?? string.Empty);
+
+                return new TemplateMessageResponse()
+                {
+                    MessageId = messageId,
+                    Status = result?.Data?.Select(x => new TemplateMessageStatusResponse()
+                    {
+                        Status = x.Status,
+                        StatusDate = x.StatusDate,
+                    }).ToList(),
+                };
+            }
+            else
+            {
+                var errorResponse = JsonConvert.DeserializeObject<BeplicServiceResponse<dynamic>>(response.Content ?? string.Empty);
+
+                var message = errorResponse?.Message ?? string.Empty;
+                var statusCode = errorResponse?.HttpStatusCode ?? (int)HttpStatusCode.InternalServerError;
+
+                LogErrorMethod("GetMessageStatus", response.Content ?? message);
+
+                throw new BadHttpRequestException(message, statusCode);
+            }
+        }
+
         public async Task<TemplateMessageResponse> SendTemplateMessage(int roomId, int templateId, TemplateMessageDTO messageDTO)
         {
             var bodyParams = new

diff --git a/doppler-beplic/Services/Interfaces/IBeplicService.cs b/doppler-beplic/Services/Interfaces/IBeplicService.cs
@@ -28,5 +28,6 @@ public interface IBeplicService
         Task<PlanCancellationResponse> CancelPlan(string idExternal);
 
         Task<UserPlanResponse> GetUserPlan(int idExternal);
+        Task<TemplateMessageResponse> GetMessageStatus(string messageId);
     }
 }