plexcsharp/PlexAPI/Utils/SpeakeasyHttpClient.cs

//------------------------------------------------------------------------------
// <auto-generated>
// This code was generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
//
// Changes to this file may cause incorrect behavior and will be lost when
// the code is regenerated.
// </auto-generated>
//------------------------------------------------------------------------------
#nullable enable
namespace PlexAPI.Utils
{
    using System;
    using System.Collections.Generic;
    using System.Net.Http;
    using System.Threading.Tasks;

    public interface ISpeakeasyHttpClient
    {
        void AddHeader(string key, string value);
        void AddQueryParam(string key, string value);
        Task<HttpResponseMessage> SendAsync(HttpRequestMessage message);
    }

    public class SpeakeasyHttpClient : ISpeakeasyHttpClient
    {
        private ISpeakeasyHttpClient? client;

        private Dictionary<string, List<string>> headers { get; } =
            new Dictionary<string, List<string>>();

        private Dictionary<string, List<string>> queryParams { get; } =
            new Dictionary<string, List<string>>();

        internal SpeakeasyHttpClient(ISpeakeasyHttpClient? client = null)
        {
            this.client = client;
        }

        public void AddHeader(string key, string value)
        {
            if (headers.ContainsKey(key))
            {
                headers[key].Add(value);
            }
            else
            {
                headers.Add(key, new List<string> { value });
            }
        }

        public void AddQueryParam(string key, string value)
        {
            if (queryParams.ContainsKey(key))
            {
                queryParams[key].Add(value);
            }
            else
            {
                queryParams.Add(key, new List<string> { value });
            }
        }

        public async Task<HttpResponseMessage> SendAsync(HttpRequestMessage message)
        {
            foreach(var hh in headers)
            {
                foreach(var hv in hh.Value)
                {
                    message.Headers.Add(hh.Key, hv);
                }
            }

            /*var qp = URLBuilder.SerializeQueryParams(queryParams);

            if (qp != "")
            {
                if (message.uri.Query == "")
                {
                    message.url += "?" + qp;
                }
                else
                {
                    message.url += "&" + qp;
                }
            }*/

            if (client != null)
            {
                return await client.SendAsync(message);
            }

	    return await new HttpClient().SendAsync(message);
        }
    }
}