feat: Add endpoint for updating conversation state (#124)

equinor · Nov 14, 2023 · 988c0df · 988c0df
1 parent 6162ee1
commit 988c0df
Show file tree

Hide file tree

Showing 7 changed files with 45 additions and 2 deletions.
diff --git a/datasheetapi/Adapters/ConversationAdapter.cs b/datasheetapi/Adapters/ConversationAdapter.cs
@@ -87,7 +87,7 @@ private static ConversationLevel MapConversationLevelDTOToModel(ConversationLeve
         };
     }
 
-    private static ConversationStatus MapConversationStatusDTOToModel(ConversationStatusDto dto)
+    public static ConversationStatus MapConversationStatusDTOToModel(ConversationStatusDto dto)
     {
         return dto switch
         {

diff --git a/datasheetapi/Controllers/ConversationsController.cs b/datasheetapi/Controllers/ConversationsController.cs
@@ -62,6 +62,21 @@ public async Task<ActionResult<GetConversationDto>> CreateConversation(
         return savedConversation.ToDto(userIdNameMap);
     }
 
+    [HttpPut("{conversationId}", Name = "UpdateConversation")]
+    public async Task<ActionResult<GetConversationDto>> UpdateConversation(
+        Guid projectId,
+        [Required] string tagNo,
+        Guid conversationId,
+        [Required] UpdateConversationDto conversation)
+    {
+        var savedConversation = await _conversationService.UpdateConversation(conversationId, ConversationAdapter.MapConversationStatusDTOToModel(conversation.ConversationStatus));
+
+        var userIdNameMap = await _userService.GetDisplayNames(
+            savedConversation.Participants.Select(p => p.UserId).ToList());
+
+        return savedConversation.ToDto(userIdNameMap);
+    }
+
     [HttpGet("{conversationId}", Name = "GetConversation")]
     public async Task<ActionResult<GetConversationDto>> GetConversation(
         [NotEmptyGuid] Guid projectId, [Required] string tagNo, [NotEmptyGuid] Guid conversationId)

diff --git a/datasheetapi/Dtos/Conversation/UpdateConversationDto.cs b/datasheetapi/Dtos/Conversation/UpdateConversationDto.cs
@@ -0,0 +1,7 @@
+using System.ComponentModel.DataAnnotations;
+
+namespace datasheetapi.Dtos.Conversation;
+public record UpdateConversationDto
+{
+    public ConversationStatusDto ConversationStatus { get; set; }
+}
diff --git a/datasheetapi/Repositories/ConversationRepository.cs b/datasheetapi/Repositories/ConversationRepository.cs
@@ -86,6 +86,16 @@ public async Task<Conversation> CreateConversation(Conversation conversation)
         return savedConversation.Entity;
     }
 
+    public async Task<Conversation> UpdateConversation(Conversation entity)
+    {
+        entity.ModifiedDate = DateTime.UtcNow;
+
+        var updatedConversation = _context.Conversations.Update(entity);
+        await _context.SaveChangesAsync();
+
+        return updatedConversation.Entity;
+    }
+
     public async Task<Conversation?> GetConversation(Guid conversationId)
     {
         return await _context.Conversations

diff --git a/datasheetapi/Repositories/IConversationRepository.cs b/datasheetapi/Repositories/IConversationRepository.cs
@@ -3,6 +3,7 @@ namespace datasheetapi.Repositories;
 public interface IConversationRepository
 {
     Task<Conversation> CreateConversation(Conversation conversation);
+    Task<Conversation> UpdateConversation(Conversation entity);
     Task<Conversation?> GetConversation(Guid conversationId);
     Task<List<Conversation>> GetConversationsForTagNos(ICollection<string> tagNos);
     Task<List<Conversation>> GetConversationsWithLatestMessage(Guid projectId,

diff --git a/datasheetapi/Services/ConversationService.cs b/datasheetapi/Services/ConversationService.cs
@@ -21,12 +21,21 @@ public ConversationService(ILoggerFactory loggerFactory,
     public async Task<Conversation> CreateConversation(Conversation conversation)
     {
         // TODO: Not sure, how to verify the project from the tag.
-        // This needs to be relook when we have integration to FAM
+        // This needs to be looked at when we have integration to FAM
         _ = await _famService.GetTagData(conversation.TagNo)
             ?? throw new NotFoundException("Invalid tag data");
         return await _conversationRepository.CreateConversation(conversation);
     }
 
+    public async Task<Conversation> UpdateConversation(Guid conversationId, ConversationStatus status)
+    {
+        var existingConversation = await _conversationRepository.GetConversation(conversationId)
+                              ?? throw new NotFoundException($"Conversation with id {conversationId} not found");
+
+        existingConversation.ConversationStatus = status;
+        return await _conversationRepository.UpdateConversation(existingConversation);
+    }
+
     public async Task<Conversation> GetConversation(Guid conversationId)
     {
         var conversation = await _conversationRepository.GetConversation(conversationId);

diff --git a/datasheetapi/Services/IConversationService.cs b/datasheetapi/Services/IConversationService.cs
@@ -3,6 +3,7 @@ namespace datasheetapi.Services
     public interface IConversationService
     {
         Task<Conversation> CreateConversation(Conversation conversation);
+        Task<Conversation> UpdateConversation(Guid conversationId, ConversationStatus status);
         Task<Conversation> GetConversation(Guid conversationId);
         Task<List<Conversation>> GetConversations(Guid projectId, string tagNo, bool includeLatestMessage);
         Task<List<Conversation>> GetConversationsForTagNos(ICollection<string> tagNos);