conflicts fixed

server/api/v1/conversations/conversations.py

@@ -45,3 +45,19 @@ async def conversation_messages(
     return APIResponse(
         data=response, message="User conversation messages returned successfully!"
     )
+
+@conversation_router.delete("/{conv_id}")
+async def delete_conversation(
+    conv_id: UUID = Path(..., description="ID of the conversation"),
+    conversation_controller: ConversationController = Depends(
+        Factory().get_conversation_controller
+    ),
+    user: UserInfo = Depends(get_current_user),
+
+):
+    response = await conversation_controller.archive_conversation(
+        conv_id, user.id
+    )
+    return APIResponse(
+        data=response, message="Conversation archived successfully"
+    )

server/app/controllers/conversation.py

@@ -1,3 +1,4 @@
+from fastapi import status, HTTPException
 from app.models import User, UserConversation
 from app.repositories import UserRepository
 from app.repositories.conversation import ConversationRepository
@@ -38,3 +39,18 @@ async def get_conversation_messages(
         count = await self.conversation_repository.get_messages_count(conversation_id)
 
         return ConversationMessageList(count=count, messages=conversation_messages)
+
+    async def archive_conversation(
+        self, conversation_id: str, user_id: str
+    ):
+        user_conversation = (
+            await self.conversation_repository.get_by_id(conversation_id)
+        )
+        if not user_conversation:
+            raise HTTPException(status_code=status.HTTP_404_NOT_FOUND,
+                            message=f"conversation with id: {conversation_id} was not found")
+        if user_conversation.user_id != user_id:
+            raise HTTPException(status_code=status.HTTP_401_UNAUTHORIZED,
+                            message="Unauthorized to update conversation for this user")
+        user_conversation.valid = False
+        await self.conversation_repository.session.commit()