using Dpz.Core.Entity.Base.Image;
using Dpz.Core.Infrastructure.Imaging;
using Dpz.Core.MessageQueue.Abstractions;
using Dpz.Core.Public.ViewModel.Messages;
using Dpz.Core.Public.ViewModel.Request;
using Dpz.Core.Public.ViewModel.Response;

namespace Dpz.Core.WebApi.Controllers;

/// <summary>
/// 碎碎念管理
/// </summary>
[ApiController, Route(("api/[controller]"))]
public class MumbleController(
    IMumbleService mumbleService,
    IObjectStorageOperation objectStorageService,
    IHttpCurrentUserService currentUserService,
    IImageFormatDetector imageFormatDetector,
    IMessagePublisher<RemoveImagesMessage> publisher
) : ControllerBase
{
    /// <summary>
    /// 获取碎碎念
    /// </summary>
    /// <returns></returns>
    [HttpGet]
    [ProducesResponseType<List<MumbleResponse>>(StatusCodes.Status200OK)]
    public async Task<IActionResult> GetMumbles(
        [FromQuery] MumbleQueryParameterDto parameter,
        CancellationToken cancellationToken
    )
    {
        var list = await mumbleService.GetPagesAsync(
            parameter.PageIndex,
            parameter.PageSize,
            parameter.Content,
            cancellationToken: cancellationToken
        );
        //list.ForEach(async x => await HandleImageHostAsync(x));
        list.AddPaginationMetadata(Response.Headers);
        return Ok(list);
    }

    /// <summary>
    /// 根据ID获取碎碎念
    /// </summary>
    /// <param name="id"></param>
    /// <param name="cancellationToken">取消令牌</param>
    /// <returns></returns>
    [HttpGet("{id}")]
    [ProducesResponseType<MumbleResponse>(StatusCodes.Status200OK)]
    public async Task<IActionResult> GetMumble(string id, CancellationToken cancellationToken)
    {
        var mumble = await mumbleService.FindAsync(id, cancellationToken);
        //await HandleImageHostAsync(mumble);
        return Ok(mumble);
    }

    /// <summary>
    /// 新建碎碎念
    /// </summary>
    /// <param name="model"></param>
    /// <param name="cancellationToken">取消令牌</param>
    /// <returns></returns>
    [HttpPost, Authorize]
    [ProducesResponseType(StatusCodes.Status204NoContent)]
    [ProducesResponseType(StatusCodes.Status401Unauthorized)]
    public async Task<IActionResult> Create(
        [FromBody] MumbleCreateDto model,
        CancellationToken cancellationToken
    )
    {
        var user = await currentUserService.GetRequiredUserInfoAsync(cancellationToken);
        var request = new CreateMumbleRequest
        {
            Author = user,
            CommentCount = 0,
            Like = 0,
            CreateTime = DateTime.Now,
            LastUpdateTime = DateTime.Now,
            Markdown = model.Markdown,
            Images = model.Images,
        };
        await mumbleService.CreateAsync(request, cancellationToken);

        return NoContent();
    }

    /// <summary>
    /// 编辑碎碎念内容
    /// </summary>
    /// <param name="model"></param>
    /// <param name="cancellationToken">取消令牌</param>
    /// <returns></returns>
    [HttpPatch, Authorize(Policy = "System")]
    [ProducesResponseType(StatusCodes.Status204NoContent)]
    [ProducesResponseType(StatusCodes.Status401Unauthorized)]
    public async Task<IActionResult> EditContent(
        [FromBody] MumbleEditContentDto model,
        CancellationToken cancellationToken
    )
    {
        var request = new EditMumbleRequest
        {
            Id = model.Id,
            Markdown = model.Markdown,
            Images = model.Images,
        };
        await mumbleService.EditContentAsync(request, cancellationToken);
        return NoContent();
    }

    /// <summary>
    /// 删除碎碎念
    /// </summary>
    /// <param name="id"></param>
    /// <param name="cancellationToken">取消令牌</param>
    /// <returns></returns>
    [HttpDelete("{id}"), Authorize(Policy = "System")]
    [ProducesResponseType(StatusCodes.Status204NoContent)]
    [ProducesResponseType(StatusCodes.Status401Unauthorized)]
    public async Task<IActionResult> Delete(string id, CancellationToken cancellationToken)
    {
        await mumbleService.DeleteAsync([id], cancellationToken);
        return NoContent();
    }

    /// <summary>
    /// 点赞
    /// </summary>
    /// <param name="id"></param>
    /// <param name="cancellationToken">取消令牌</param>
    /// <returns></returns>
    [HttpPost("like/{id}")]
    [ProducesResponseType(StatusCodes.Status204NoContent)]
    public async Task<IActionResult> Like(string id, CancellationToken cancellationToken)
    {
        var mumble = await mumbleService.LikeAsync(id, cancellationToken);
        return Ok(mumble);
    }

    /// <summary>
    /// 上传相关的图片
    /// </summary>
    /// <returns></returns>
    [HttpPost("upload"), Authorize]
    [ProducesResponseType<List<ImageMetadata>>(StatusCodes.Status200OK)]
    [ProducesResponseType(StatusCodes.Status400BadRequest)]
    [ProducesResponseType(StatusCodes.Status401Unauthorized)]
    public async Task<ActionResult<List<ImageMetadata>>> Upload(
        CancellationToken cancellationToken = default
    )
    {
        var path = new[] {
#if DEBUG
            "Test",
#endif
            "images", "mumble", DateTime.Now.ToString("yyyy-MM-dd") };
        return await Request.Form.Files.UploadMultipleImagesAsync(
            imageFormatDetector,
            objectStorageService,
            publisher,
            path,
            cancellationToken
        );
    }

    /// <summary>
    /// 历史碎碎念
    /// 如果历史上的当前没有碎碎念，则返回随机碎碎念
    /// </summary>
    /// <returns></returns>
    [HttpGet("history")]
    public async Task<ActionResult<List<MumbleResponse>>> History(
        CancellationToken cancellationToken
    )
    {
        var list = await mumbleService.GetHistoryMumblesAsync(5, cancellationToken);
        return Ok(list);
    }
}