using PostSharp.Patterns.Diagnostics;
using System;
using System.Net.Http;
using System.Text;
using System.Threading.Tasks;
 
namespace ClientExample
{
  public class QueueProcessor
  {
    private static readonly LogSource logger = LogSource.Get();
 
    private static readonly HttpClient http = new HttpClient();
 
    static QueueProcessor()
    {
 
    }
 
    public static async Task ProcessQueue(string queuePath)
    {
      await ProcessItem(new QueueItem(1, Verb.Create, "grapefruit"));
      await ProcessItem(new QueueItem(2, Verb.Create, "pear"));
      await ProcessItem(new QueueItem(3, Verb.Create, "grape"));
      await ProcessItem(new QueueItem(1, Verb.Get));
      await ProcessItem(new QueueItem(2, Verb.Get));
      await ProcessItem(new QueueItem(3, Verb.Get));
      await ProcessItem(new QueueItem(3, Verb.Create, "grapefruit"));
      await ProcessItem(new QueueItem(3, Verb.Delete, "grapefruit"));
      await ProcessItem(new QueueItem(3, Verb.Get));
 
    }
 
    private static async Task ProcessItem(QueueItem item)
    {
      try
      {
 
        var url = $"http://localhost:5005/api/values/{item.Id}";
        var stringContent = item.Value == null ? null : new StringContent("\"" + item.Value + "\"", Encoding.UTF8, "application/json");
        HttpResponseMessage response;
 
 
        switch (item.Verb)
        {
          case Verb.Get:
            response = await http.GetAsync(url);
            break;
 
          case Verb.Create:
            response = await http.PostAsync(url, stringContent);
            break;
 
          case Verb.AddOrUpdate:
            response = await http.PutAsync(url, stringContent);
            break;
 
          default:
            throw new NotImplementedException();
        }
 
        response.EnsureSuccessStatusCode();
 
        var responseValue = await response.Content.ReadAsStringAsync();
      }
      catch (Exception e)
      {
        logger.Warning.Write(FormattedMessageBuilder.Formatted("Ignoring exception and continuing."), e);
      }
 
    }
 
  }
}