using AvaskTest2.Shared.Models;
using AvaskTest2.Shared.Models.Cdiscount;
using Microsoft.AspNetCore.Mvc;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net.Http;
using System.Net.Http.Json;
using System.Threading.Tasks;

// For more information on enabling Web API for empty projects, visit https://go.microsoft.com/fwlink/?LinkID=397860

namespace AvaskTest2.Server.Controllers
{
    [Route("api/[controller]")]
    [ApiController]
    public class CdiscountController : ControllerBase
    {
        private readonly HttpClient httpClient;

        public CdiscountController() => httpClient = new HttpClient();


        // GET api/<CdiscountController>/cdiscountgetsellerinfo
        [HttpGet("cdiscountgetsellerinfo")] //
        public async Task<JsonResult> CdiscountGetSellerInfo() // Get
        { // pass-through call
            try
            {
                var request = new CdiscountSellerInfoRequest(new User { CompanyId = "AVASK-SOFTWARE" }, "infiniti-system-client");
                //string sTemp = JsonConvert.SerializeObject(request); //### test only
                var response = await httpClient.PostAsJsonAsync("http://localhost:7071/api/cdiscountsellerinfo", request);
                var content = await response.Content.ReadAsStringAsync();
                var cdisResp = JsonConvert.DeserializeObject<CdiscountSellerInfoResponse>(content);
                return new JsonResult(cdisResp?.SellerInfo);
            }
            catch (Exception ex)
            {
                return new JsonResult(ex.Message);
            }
        }

        // POST api/<CdiscountController>/cdiscountgetsellerinfo
        [HttpPost("cdiscountgetsellerinfohead")] //
        public async Task<JsonResult> CdiscountGetSellerInfoHead() // post
        { // pass-through call
            try
            {
                var requestBody = await new StreamReader(Request.Body).ReadToEndAsync();
                var request = JsonConvert.DeserializeObject<CdiscountSellerInfoRequest>(requestBody);
                //string sTemp = JsonConvert.SerializeObject(request); //### test only
                var response = await httpClient.PostAsJsonAsync("http://localhost:7071/api/cdiscountsellerinfo", request);
                var content = await response.Content.ReadAsStringAsync();
                var cdisResp = JsonConvert.DeserializeObject<CdiscountSellerInfoResponse>(content);
                return new JsonResult(cdisResp);
                //return new JsonResult(content);
            }
            catch (Exception ex)
            {
                return new JsonResult(ex.Message);
            }
        }

        // POST api/<CdiscountController>/cdiscountfetchsales
        [HttpPost("cdiscountfetchsales")] //
        public async Task<JsonResult> CdiscountFetchSales([FromBody] SalesDatespan datespan) // Get
        { // pass-through call
            try
            {
                var request = new CdiscountFetchSalesRequest(new User { CompanyId = "AVASK-SOFTWARE" }, "infiniti-system-client", datespan);
                //string sTemp = JsonConvert.SerializeObject(request); //### test only
                var response = await httpClient.PostAsJsonAsync("http://localhost:7071/api/cdiscountfetchsales", request);
                var content = await response.Content.ReadAsStringAsync();
                var uaURL = JsonConvert.DeserializeObject<CdiscountFetchSalesResponse>(content);
                return new JsonResult(uaURL?.SalesResponse);
            }
            catch (Exception ex)
            {
                return new JsonResult(ex.Message);
            }
        }

        // POST api/<CdiscountController>/cdiscountgettrans
        [HttpPost("cdiscountgettrans")] //
        public async Task<JsonResult> CdiscountGetTrans([FromBody] SalesDatespan datespan) // Get
        { // pass-through call
            try
            {
                var request = new CdiscountGetTransRequest(new User { CompanyId = "AVASK-SOFTWARE" }, "infiniti-system-client", datespan);
                //string sTemp = JsonConvert.SerializeObject(request); //### test only
                var response = await httpClient.PostAsJsonAsync("http://localhost:7071/api/cdiscountgettransaction", request);
                var content = await response.Content.ReadAsStringAsync();
                var uaURL = JsonConvert.DeserializeObject<CdiscountGetTransResponse>(content);
                return new JsonResult(uaURL?.TransactionResponse);
            }
            catch (Exception ex)
            {
                return new JsonResult(ex.Message);
            }
        }

        // POST api/<CdiscountController>/cdiscountauthcred
        [HttpPost("cdiscountauthcred")] //
        public async Task<JsonResult> CdiscountAuthCred() // Post
        { // pass-through call
            try
            {
                var requestBody = await new StreamReader(Request.Body).ReadToEndAsync();
                var request = JsonConvert.DeserializeObject<CdiscountAuthCredentialsRequest>(requestBody);
                //var request = new CdiscountAuthCredentialsRequest(new User { CompanyId = "AVASK-SOFTWARE" }, "infiniti-system-client", authCred);
                //string sTemp = JsonConvert.SerializeObject(request); //### test only
                var response = await httpClient.PostAsJsonAsync("http://localhost:7071/api/cdiscountauthcredentials", request);
                var content = await response.Content.ReadAsStringAsync();
                var cdisResp = JsonConvert.DeserializeObject<CdiscountAuthCredentialsResponse>(content);
                return new JsonResult(cdisResp);
            }
            catch (Exception ex)
            {
                return new JsonResult(ex.Message);
            }
        }


    }
}