using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Threading.Tasks;
using EasyCode.EventBus.Abstractions;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;

namespace EasyCode.WebApi
{
 public class RequestHandlerService
 {
 private ICommandBusClient _client;
 private ILogger _logger;
 public RequestHandlerService(ICommandBusClient client,ILogger<RequestHandlerService> logger)
 {
 _client = client;
 _logger = logger;
 }

 public async Task<TResponse> GetResponseAsync<TRequest, TResponse>(string requestType, TRequest request) where TResponse:new()
 {
 JsonSerializer serializer=new JsonSerializer();
 using (MemoryStream ms = new MemoryStream())
 {
 using (StreamWriter sw = new StreamWriter(ms))
 {
 serializer.Serialize(sw, request);
 sw.Flush();
 var requestBuffer = ms.ToArray();
 try
 {
 var responseBuffer = await _client.GetResponseAsync(requestType, requestBuffer);
 using (MemoryStream msb = new MemoryStream(responseBuffer))
 {
 StreamReader reader = new StreamReader(msb);
 TResponse res= (TResponse)serializer.Deserialize(reader, typeof(TResponse));
 return res;
 }
 }
 catch (Exception e)
 {
 _logger.LogError($"{e.Message},{e.Source}");
 }
 
 }
 
 }

 return default(TResponse);

 }
 }
}