littleshop/LittleShop/Areas/Admin/Controllers/MessagesController.cs

using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using LittleShop.DTOs;
using LittleShop.Services;
using LittleShop.Models;

namespace LittleShop.Areas.Admin.Controllers;

[Area("Admin")]
[Authorize(Policy = "AdminOnly")]
public class MessagesController : Controller
{
    private readonly ICustomerMessageService _messageService;
    private readonly ICustomerService _customerService;
    private readonly ILogger<MessagesController> _logger;

    public MessagesController(ICustomerMessageService messageService, ICustomerService customerService, ILogger<MessagesController> logger)
    {
        _messageService = messageService;
        _customerService = customerService;
        _logger = logger;
    }

    public async Task<IActionResult> Index()
    {
        var threads = await _messageService.GetActiveThreadsAsync();
        return View(threads);
    }

    public async Task<IActionResult> Customer(Guid id)
    {
        var conversation = await _messageService.GetMessageThreadAsync(id);
        
        // If no conversation exists yet, create an empty one for this customer
        if (conversation == null)
        {
            // Check if customer exists
            var customerExists = await _messageService.ValidateCustomerExistsAsync(id);
            if (!customerExists)
            {
                TempData["Error"] = "Customer not found.";
                return RedirectToAction("Index");
            }

            // Get customer information
            var customer = await _customerService.GetCustomerByIdAsync(id);
            if (customer == null)
            {
                TempData["Error"] = "Customer information not available.";
                return RedirectToAction("Index");
            }

            // Create empty conversation structure for new conversation
            conversation = new MessageThreadDto
            {
                ThreadId = id,
                Subject = customer.DisplayName,
                CustomerId = id,
                CustomerName = customer.DisplayName,
                OrderId = null,
                OrderReference = null,
                StartedAt = DateTime.UtcNow,
                LastMessageAt = DateTime.UtcNow,
                MessageCount = 0,
                HasUnreadMessages = false,
                RequiresResponse = false,
                Messages = new List<CustomerMessageDto>()
            };
        }

        return View(conversation);
    }

    [HttpPost]
    [ValidateAntiForgeryToken]
    public async Task<IActionResult> Reply(Guid customerId, string content, bool isUrgent = false)
    {
        try
        {
            var createMessageDto = new CreateCustomerMessageDto
            {
                CustomerId = customerId,
                Type = MessageType.CustomerService,
                Subject = "Support Reply", // Simple subject for admin replies
                Content = content,
                IsUrgent = isUrgent,
                Priority = isUrgent ? 1 : 5
            };

            var message = await _messageService.CreateMessageAsync(createMessageDto);
            if (message != null)
            {
                TempData["Success"] = "Reply sent successfully!";
            }
            else
            {
                TempData["Error"] = "Failed to send reply.";
            }
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "Error sending reply");
            TempData["Error"] = "An error occurred sending the reply.";
        }

        return RedirectToAction("Customer", new { id = customerId });
    }
}