smsapi/ProxyHTTP.cs

   1 using System;
   2 using System.Collections.Generic;
   3 using System.Collections.Specialized;
   4 using System.IO;
   5 using System.Net;
   6 using System.Net.Http;
   7 using System.Threading;
   8 using System.Threading.Tasks;
   9
  10 namespace SMSApi.Api
  11 {
  12     public class ProxyHTTP : Proxy
  13     {
  14         private readonly string baseUrl;
  15         private IClient authentication;
  16
  17         public ProxyHTTP(string baseUrl)
  18         {
  19             this.baseUrl = baseUrl;
  20         }
  21
  22         public void Authentication(IClient client)
  23         {
  24             authentication = client;
  25         }
  26
  27         public HttpResponseEntity Execute(string uri, NameValueCollection data, RequestMethod method)
  28         {
  29             return Execute(uri, data, new Dictionary<string, Stream>(), method);
  30         }
  31
  32         public HttpResponseEntity Execute(
  33             string uri,
  34             NameValueCollection data,
  35             Stream file,
  36             RequestMethod method)
  37         {
  38             return Execute(uri, data, new Dictionary<string, Stream> { { "file", file } }, method);
  39         }
  40
  41         public HttpResponseEntity Execute(
  42             string uri,
  43             NameValueCollection data,
  44             Dictionary<string, Stream> files,
  45             RequestMethod method)
  46         {
  47             ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
  48
  49             HttpClient client = CreateClient();
  50
  51             try
  52             {
  53                 return client.SendRequest(method, uri, data, files).Result;
  54             }
  55             catch (System.Exception e)
  56             {
  57                 throw new ProxyException("Failed to get response from " + uri, e);
  58             }
  59         }
  60
  61         public async Task<HttpResponseEntity> ExecuteAsync(
  62             string uri,
  63             NameValueCollection data,
  64             RequestMethod method,
  65             CancellationToken cancellationToken = default
  66             )
  67         {
  68             return await ExecuteAsync(uri, data, new Dictionary<string, Stream>(), method);
  69         }
  70
  71         public async Task<HttpResponseEntity> ExecuteAsync(
  72             string uri,
  73             NameValueCollection data,
  74             Stream file,
  75             RequestMethod method,
  76             CancellationToken cancellationToken = default
  77             )
  78         {
  79             return await ExecuteAsync(uri, data, new Dictionary<string, Stream> { { "file", file } }, method);
  80         }
  81
  82         public async Task<HttpResponseEntity> ExecuteAsync(
  83             string uri,
  84             NameValueCollection data,
  85             Dictionary<string, Stream> files,
  86             RequestMethod method,
  87             CancellationToken cancellationToken = default
  88             )
  89         {
  90             ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
  91
  92             HttpClient client = CreateClient();
  93
  94             try
  95             {
  96                 return await client.SendRequest(method, uri, data, files, cancellationToken);
  97             }
  98             catch (System.Exception e)
  99             {
 100                 throw new ProxyException("Failed to get response from " + uri, e);
 101             }
 102         }
 103
 104         private HttpClient CreateClient()
 105         {
 106             var client = new HttpClient();
 107             client.BaseAddress = new Uri(baseUrl);
 108             client.DefaultRequestHeaders.TryAddWithoutValidation("User-Agent", authentication.GetClientAgent());
 109
 110             if (authentication == null) return client;
 111
 112             var authHeader = authentication.DefaultRequestHeaders;
 113
 114             client.DefaultRequestHeaders.Add(authHeader.Key, authHeader.Value);
 115
 116             return client;
 117         }
 118     }
 119 }