using Dpz.Core.EnumLibrary;
using Dpz.Core.Public.ViewModel.Request;
using Dpz.Core.Service.ObjectStorage.Services;
using Dpz.Core.Web.Library.Hub;
using Microsoft.AspNetCore.SignalR;

namespace Dpz.Core.Web.Controllers;

public class MumbleController(
    IMumbleService mumbleService,
    IHubContext<Notification> hubContext,
    IObjectStorageOperation objectStorageService
) : Controller
{
    public async Task<IActionResult> Index(int pageIndex = 1, int pageSize = 10)
    {
        this.SetTitle("日常碎碎念");
        ViewBag.Menu = MenuItem.Mumble;
        var list = await mumbleService.GetPagesAsync(pageIndex, pageSize);
        var data = await mumbleService.GetRandomMumblesAsync(5);
        return View(new MumbleIndexModel(list, data));
    }

    [CheckAuthorize]
    [HttpPost]
    public async Task<IActionResult> Publish(string markdown, string id = "")
    {
        var userInfo = User.RequiredUserInfo;

        if (!string.IsNullOrEmpty(id))
        {
            var talk = await mumbleService.FindAsync(id);
            if (userInfo.Id != talk?.Author.Id)
            {
                return Json(new ResultInfo("没有权限修改碎碎念！"));
            }
        }

        if (string.IsNullOrEmpty(id))
        {
            var createRequest = new CreateMumbleRequest
            {
                Author = userInfo,
                CreateTime = DateTime.Now,
                LastUpdateTime = DateTime.Now,
                Markdown = markdown,
            };
            var mumble = await mumbleService.CreateAsync(createRequest);
            await hubContext.Clients.All.SendCoreAsync("pushMessage", [mumble]);
        }
        else
        {
            var editRequest = new EditMumbleRequest { Id = id, Markdown = markdown };
            await mumbleService.EditContentAsync(editRequest);
        }

        return Json(new ResultInfo(true));
    }

    [HttpPost]
    public async Task<IActionResult> Like(string id)
    {
        var talk = await mumbleService.LikeAsync(id);
        return Json(new ResultInfo(talk?.Like));
    }

    [CheckAuthorize]
    [HttpPost]
    public async Task<IActionResult> Upload()
    {
        var file = Request.Form.Files.FirstOrDefault();
        if (file is { Length: > 0 } && file.ContentType.Contains("image"))
        {
            //var userInfo = User.GetIdentity();
            var path = new List<string> { "images", "mumble", DateTime.Now.ToString("yyyy-MM-dd") };
#if DEBUG
            path.Insert(0, "Test");
#endif
            var fileName =
                ObjectId.GenerateNewId() + file.FileName[file.FileName.LastIndexOf('.')..];
            var result = await objectStorageService.UploadAsync(
                file.OpenReadStream(),
                path,
                fileName
            );
            return Json(
                new
                {
                    success = 1,
                    message = "",
                    url = result.AccessUrl,
                }
            );
        }

        return Json(
            new
            {
                success = 0,
                message = "请选择一张图片！",
                url = "",
            }
        );
    }

    [HttpPost, CheckAuthorize]
    public async Task<IActionResult> Delete(string id)
    {
        var talk = await mumbleService.FindAsync(id);
        if (talk == null || User.RequiredUserId != talk.Author.Id)
        {
            return Json(new ResultInfo("碎碎念删除失败，没有权限删除或者不存在！"));
        }

        await mumbleService.DeleteAsync(id);
        return Json(new ResultInfo(true));
    }

    [HttpGet]
    public async Task<IActionResult> Comment(string id = "")
    {
        var talk = await mumbleService.FindAsync(id);
        if (talk == null)
        {
            return NotFound();
        }

        this.SetTitle("碎碎念回复");
        ViewBag.Menu = MenuItem.Mumble;
        return View(talk);
    }
}