using System;
using System.Collections.Generic;
using System.Net;
using System.Text.Json;
using Amazon.CloudWatchLogs;
using Amazon.CloudWatchLogs.Model;
using GetProducts;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using Shared;
using Shared.DataAccess;
using Shared.Models;

var app = Startup.Build(args);

var dataAccess = app.Services.GetRequiredService<ProductsDAO>();

var cloudWatchClient = new AmazonCloudWatchLogsClient();

app.MapGet("/", async (HttpContext context) =>
{
    app.Logger.LogInformation("Received request to list all products");

    var products = await dataAccess.GetAllProducts();

    app.Logger.LogInformation($"Found {products.Products.Count} products(s)");

    context.Response.StatusCode = (int) HttpStatusCode.OK;
    await context.Response.WriteAsJsonAsync(products);
});

app.MapDelete("/{id}", async (HttpContext context) =>
{
    try
    {
        var id = context.Request.RouteValues["id"].ToString();

        app.Logger.LogInformation($"Received request to delete {id}");

        var product = await dataAccess.GetProduct(id);

        if (product == null)
        {
            app.Logger.LogWarning($"Id {id} not found.");

            context.Response.StatusCode = (int) HttpStatusCode.NotFound;
            Results.NotFound();
            return;
        }

        app.Logger.LogInformation($"Deleting {product.Name}");

        await dataAccess.DeleteProduct(product.Id);

        app.Logger.LogInformation("Delete complete");

        context.Response.StatusCode = (int) HttpStatusCode.OK;
        await context.Response.WriteAsJsonAsync($"Product with id {id} deleted");
    }
    catch (Exception e)
    {
        app.Logger.LogError(e, "Failure deleting product");

        context.Response.StatusCode = (int) HttpStatusCode.NotFound;
    }
});

app.MapPut("/{id}", async (HttpContext context) =>
{
    try
    {
        var id = context.Request.RouteValues["id"].ToString();

        app.Logger.LogInformation($"Received request to put {id}");

        var product = await JsonSerializer.DeserializeAsync<Product>(context.Request.Body);

        if (product == null || id != product.Id)
        {
            app.Logger.LogWarning("Product ID in the body does not match path parameter");

            context.Response.StatusCode = (int) HttpStatusCode.BadRequest;
            await context.Response.WriteAsJsonAsync("Product ID in the body does not match path parameter");
            return;
        }

        app.Logger.LogInformation("Putting product");

        await dataAccess.PutProduct(product);

        app.Logger.LogTrace("Done");

        context.Response.StatusCode = (int) HttpStatusCode.OK;
        await context.Response.WriteAsJsonAsync($"Created product with id {id}");
    }
    catch (Exception e)
    {
        app.Logger.LogError(e, "Failure deleting product");

        context.Response.StatusCode = (int) HttpStatusCode.BadRequest;
    }
});

app.MapGet("/{id}", async (HttpContext context) =>
{
    var id = context.Request.RouteValues["id"].ToString();

    app.Logger.LogInformation($"Received request to get {id}");

    var product = await dataAccess.GetProduct(id);

    if (product == null)
    {
        app.Logger.LogWarning($"{id} not found");
        context.Response.StatusCode = (int) HttpStatusCode.NotFound;
        Results.NotFound();
        return;
    }

    context.Response.StatusCode = (int) HttpStatusCode.OK;
    await context.Response.WriteAsJsonAsync(product);
});

app.MapGet("/test-results", async (HttpContext context) =>
{
    var resultRows = 0;
    var queryCount = 0;

    List<List<ResultField>> finalResults = new List<List<ResultField>>();

    while (resultRows < 2 || queryCount >= 3)
    {
        finalResults = await CloudWatchQueryExecution.RunQuery(cloudWatchClient);

        resultRows = finalResults.Count;
        queryCount++;
    }

    var wrapper = new QueryResultWrapper()
    {
        LoadTestType =
            $"{Environment.GetEnvironmentVariable("LOAD_TEST_TYPE")} ({Environment.GetEnvironmentVariable("LAMBDA_ARCHITECTURE")})",
        WarmStart = new QueryResult()
        {
            Count = finalResults[0][1].Value,
            P50 = finalResults[0][2].Value,
            P90 = finalResults[0][3].Value,
            P99 = finalResults[0][4].Value,
            Max = finalResults[0][5].Value,
        },
        ColdStart = new QueryResult()
        {
            Count = finalResults[1][1].Value,
            P50 = finalResults[1][2].Value,
            P90 = finalResults[1][3].Value,
            P99 = finalResults[1][4].Value,
            Max = finalResults[1][5].Value,
        }
    };

    context.Response.StatusCode = (int) HttpStatusCode.OK;
    await context.Response.WriteAsync(wrapper.AsMarkdownTableRow());
});

app.Run();