// Licensed to the .NET Foundation under one or more agreements.
// The .NET Foundation licenses this file to you under the MIT license.
 
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Http;
using Microsoft.AspNetCore.Connections;
using Microsoft.AspNetCore.Http.Connections;
using Newtonsoft.Json;
 
namespace Microsoft.AspNetCore.SignalR.Client.Tests;
 
internal static class ResponseUtils
{
    public static HttpResponseMessage CreateResponse(HttpStatusCode statusCode) =>
        CreateResponse(statusCode, string.Empty);
 
    public static HttpResponseMessage CreateResponse(HttpStatusCode statusCode, string payload) =>
        CreateResponse(statusCode, new StringContent(payload));
 
    public static HttpResponseMessage CreateResponse(HttpStatusCode statusCode, byte[] payload) =>
        CreateResponse(statusCode, new ByteArrayContent(payload));
 
    public static HttpResponseMessage CreateResponse(HttpStatusCode statusCode, HttpContent payload)
    {
        return new HttpResponseMessage(statusCode)
        {
            Content = payload
        };
    }
 
    public static bool IsNegotiateRequest(HttpRequestMessage request)
    {
        return request.Method == HttpMethod.Post &&
               new UriBuilder(request.RequestUri).Path.EndsWith("/negotiate", StringComparison.Ordinal);
    }
 
    public static bool IsLongPollRequest(HttpRequestMessage request)
    {
        return request.Method == HttpMethod.Get &&
               !IsServerSentEventsRequest(request) &&
               (request.RequestUri.PathAndQuery.Contains("?id=") || request.RequestUri.PathAndQuery.Contains("&id="));
    }
 
    public static bool IsLongPollDeleteRequest(HttpRequestMessage request)
    {
        return request.Method == HttpMethod.Delete &&
               (request.RequestUri.PathAndQuery.Contains("?id=") || request.RequestUri.PathAndQuery.Contains("&id="));
    }
 
    public static bool IsServerSentEventsRequest(HttpRequestMessage request)
    {
        return request.Method == HttpMethod.Get && request.Headers.Accept.Any(h => h.MediaType == "text/event-stream");
    }
 
    public static bool IsSocketSendRequest(HttpRequestMessage request)
    {
        return request.Method == HttpMethod.Post &&
               (request.RequestUri.PathAndQuery.Contains("?id=") || request.RequestUri.PathAndQuery.Contains("&id="));
    }
 
    public static string CreateNegotiationContent(string connectionId = "00000000-0000-0000-0000-000000000000",
        HttpTransportType? transportTypes = null, string connectionToken = "connection-token", int negotiateVersion = 0)
    {
        var availableTransports = new List<object>();
 
        transportTypes = transportTypes ?? HttpTransports.All;
        if ((transportTypes & HttpTransportType.WebSockets) != 0)
        {
            availableTransports.Add(new
            {
                transport = nameof(HttpTransportType.WebSockets),
                transferFormats = new[] { nameof(TransferFormat.Text), nameof(TransferFormat.Binary) }
            });
        }
        if ((transportTypes & HttpTransportType.ServerSentEvents) != 0)
        {
            availableTransports.Add(new
            {
                transport = nameof(HttpTransportType.ServerSentEvents),
                transferFormats = new[] { nameof(TransferFormat.Text) }
            });
        }
        if ((transportTypes & HttpTransportType.LongPolling) != 0)
        {
            availableTransports.Add(new
            {
                transport = nameof(HttpTransportType.LongPolling),
                transferFormats = new[] { nameof(TransferFormat.Text), nameof(TransferFormat.Binary) }
            });
        }
 
        return JsonConvert.SerializeObject(new { connectionId, availableTransports, connectionToken, negotiateVersion });
    }
}