using System.ComponentModel.DataAnnotations;
using Dpz.Core.EnumLibrary;
using Dpz.Core.Public.ViewModel.Request;
using Dpz.Core.Service.ObjectStorage.Services;

namespace Dpz.Core.Web.Controllers;

public class AudioController(
    IAudioService audioService,
    IObjectStorageOperation objectStorageService,
    IHttpCurrentUserService currentUserService
) : Controller
{
    [CheckAuthorize]
    public async Task<IActionResult> Upload(
        [FromForm, Required] IFormFile? record,
        [FromForm, Required] double duration
    )
    {
        if (record == null || record.Length == 0)
        {
            return Json(new ResultInfo("请上传音乐！"));
        }

        var audioExtensions = new[] { ".mp3", ".flac", ".wav", ".webm" };
        if (!audioExtensions.Contains(Path.GetExtension(record.FileName).ToLower()))
        {
            return Json(
                new ResultInfo($"目前只支持{string.Join("、", audioExtensions)}格式的音频！")
            );
        }

        var stream = record.OpenReadStream();
        var result = await objectStorageService.UploadAsync(
            stream,
            ["audio", DateTime.Now.ToString("yyyyMMdd")],
            $"{ObjectId.GenerateNewId()}.webm"
        );
        var request = new CreateAudioRequest
        {
            AccessUrl = result.Url,
            Duration = TimeSpan.FromSeconds(duration),
            Size = stream.Length,
            Uploader = await currentUserService.GetRequiredUserInfoAsync(),
            UploadTime = DateTime.Now,
        };

        var added = await audioService.AddAsync(request);
        return Json(new ResultInfo(added));
    }

    [CheckAuthorize, HttpPost]
    public async Task<IActionResult> Delete(string id)
    {
        var audio = await audioService.FindAsync(id);
        if (audio == null || User.RequiredNameIdentifier != audio.Uploader.Id)
        {
            return Json(new ResultInfo("未知音频或没有权限删除！"));
        }

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

    [CheckAuthorize]
    public async Task<IActionResult> MyAudio(int pageIndex, int pageSize = 20)
    {
        var user = await currentUserService.GetRequiredUserInfoAsync();
        var source = await audioService.GetPagesAsync(pageIndex, pageSize, user);
        return Json(source);
    }

    [CheckAuthorize(Permissions = Permissions.System)]
    public async Task<IActionResult> AudioPager(int pageIndex, int pageSize)
    {
        var source = await audioService.GetPagesAsync(pageIndex, pageSize);
        return Json(source);
    }
}