using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Shared;
using Shared.Engine;
using System.IO.Compression;
using System.Threading.Tasks;

namespace Lampac.Controllers
{
    public class RchBaseApi : BaseController
    {
        [HttpGet]
        [Route("rch/check/connected")]
        public ActionResult СheckСonnected()
        {
            var rch = new RchClient(HttpContext, host, new Shared.Models.Base.BaseSettings() { rhub = true }, requestInfo);
            if (rch.IsNotConnected())
                return ContentTo(rch.connectionMsg);

            var info = rch.InfoConnected() ?? new RchClientInfo();
            return Json(new { info.version, info.apkVersion, info.rchtype });
        }
    }

    public class RchApi : Controller
    {
        [HttpPost]
        [AllowAnonymous]
        [Route("rch/result")]
        async public Task<ActionResult> WriteResult([FromQuery] string id)
        {
            if (string.IsNullOrEmpty(id))
                return BadRequest(401);

            if (!RchClient.rchIds.TryGetValue(id, out var rchHub))
                return BadRequest(400);

            try
            {
                await Request.Body.CopyToAsync(rchHub.ms, PoolInvk.bufferSize, HttpContext.RequestAborted);
                rchHub.ms.Position = 0;

                rchHub.tcs.TrySetResult(null);
            }
            catch
            {
                rchHub.tcs.TrySetResult(null);
                return BadRequest(400);
            }

            return Ok();
        }

        [HttpPost]
        [AllowAnonymous]
        [Route("rch/gzresult")]
        async public Task<ActionResult> WriteZipResult([FromQuery] string id)
        {
            if (string.IsNullOrEmpty(id))
                return BadRequest(401);

            if (!RchClient.rchIds.TryGetValue(id, out var rchHub))
                return BadRequest(400);

            try
            {
                using (var gzip = new GZipStream(Request.Body, CompressionMode.Decompress, leaveOpen: true))
                {
                    await gzip.CopyToAsync(rchHub.ms, PoolInvk.bufferSize, HttpContext.RequestAborted);
                    rchHub.ms.Position = 0;

                    rchHub.tcs.TrySetResult(null);
                }
            }
            catch 
            {
                rchHub.tcs.TrySetResult(null);
                return BadRequest(400);
            }

            return Ok();
        }
    }
}