using Dpz.Core.Public.ViewModel.Request;
using Dpz.Core.Public.ViewModel.Response;

namespace Dpz.Core.WebApi.Controllers;

/// <summary>
/// 录音
/// </summary>
[Route("api/[controller]")]
[ApiController]
public class AudioController(
    IAudioService audioService,
    IObjectStorageOperation objectStorageService,
    IHttpCurrentUserService currentUserService
) : ControllerBase
{
    /// <summary>
    /// 获取录音
    /// </summary>
    /// <returns></returns>
    [HttpGet]
    [Authorize(Policy = "System")]
    [ProducesResponseType(StatusCodes.Status401Unauthorized)]
    [ProducesResponseType<List<AudioResponse>>(StatusCodes.Status200OK)]
    public async Task<IActionResult> GetAudio([FromQuery] QueryDtoBase parameter)
    {
        var list = await audioService.GetPagesAsync(parameter.PageIndex, parameter.PageSize);
        list.AddPaginationMetadata(Response.Headers);
        return Ok(list);
    }

    /// <summary>
    /// 获取我的录音
    /// </summary>
    /// <param name="parameter"></param>
    /// <returns></returns>
    [HttpGet("my"), Authorize]
    [ProducesResponseType(StatusCodes.Status401Unauthorized)]
    [ProducesResponseType<List<AudioResponse>>(StatusCodes.Status200OK)]
    public async Task<IActionResult> GetMyAudio([FromQuery] QueryDtoBase parameter)
    {
        var userInfo = await currentUserService.GetRequiredUserInfoAsync();
        var list = await audioService.GetPagesAsync(
            parameter.PageIndex,
            parameter.PageSize,
            userInfo
        );
        list.AddPaginationMetadata(Response.Headers);
        return Ok(list);
    }

    /// <summary>
    /// 上传录音
    /// </summary>
    /// <param name="audio"></param>
    /// <returns></returns>
    [HttpPost, Authorize]
    [ProducesResponseType(StatusCodes.Status401Unauthorized)]
    [ProducesResponseType(StatusCodes.Status204NoContent)]
    public async Task<IActionResult> Upload([Required] IFormFile audio)
    {
        // var webHost = _configuration.GetSection("WebHost").Get<string>();
        // var audioInfo = await _audioService.UploadAsync(audio, User.GetIdentity());
        // return Created($"{webHost}/Audio/Result/{audioInfo.Id}", audioInfo);
        var stream = audio.OpenReadStream();
        var result = await objectStorageService.UploadAsync(
            stream,
            ["audio", DateTime.Now.ToString("yyyy-MM-dd")],
            $"{ObjectId.GenerateNewId()}.wav"
        );
        var user = await currentUserService.GetRequiredUserInfoAsync();
        var request = new CreateAudioRequest
        {
            AccessUrl = result.Url,
            Duration = TimeSpan.Zero,
            Size = stream.Length,
            Uploader = user,
            UploadTime = DateTime.Now,
        };

        await audioService.AddAsync(request);
        return NoContent();
    }

    /// <summary>
    /// 获取录音
    /// </summary>
    /// <param name="id"></param>
    /// <returns></returns>
    [HttpGet("{id}")]
    [ProducesResponseType<AudioResponse>(StatusCodes.Status200OK)]
    public async Task<ActionResult<AudioResponse>> GetAudio(string id)
    {
        var audio = await audioService.FindAsync(id);
        return Ok(audio);
    }

    /// <summary>
    /// 删除录音
    /// </summary>
    /// <param name="id"></param>
    /// <returns></returns>
    [HttpDelete("{id}"), Authorize(Policy = "System")]
    [ProducesResponseType(StatusCodes.Status401Unauthorized)]
    [ProducesResponseType(StatusCodes.Status204NoContent)]
    public async Task<IActionResult> Delete(string id)
    {
        var audio = await audioService.FindAsync(id);
        if (audio == null)
        {
            return NotFound();
        }
        await audioService.DeleteAsync(id);
        if (!string.IsNullOrWhiteSpace(audio.AccessUrl))
        {
            await objectStorageService.DeleteAsync(audio.AccessUrl);
        }
        return NoContent();
    }
}