summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat
-rw-r--r--SendGrid/SendGrid/Client.cs370
-rw-r--r--SendGrid/SendGrid/SendGrid.csproj4
-rw-r--r--SendGrid/SendGrid/packages.config1
3 files changed, 368 insertions, 7 deletions
diff --git a/SendGrid/SendGrid/Client.cs b/SendGrid/SendGrid/Client.cs
index be986cb..e4e4d8c 100644
--- a/SendGrid/SendGrid/Client.cs
+++ b/SendGrid/SendGrid/Client.cs
@@ -1,7 +1,15 @@
using System;
-using System.Reflection;
using System.Collections.Generic;
-using SendGrid.CSharp.HTTP.Client;
+using System.Dynamic;
+using System.Linq;
+using System.Net;
+using System.Net.Http;
+using System.Net.Http.Headers;
+using System.Text;
+using System.Threading.Tasks;
+using System.Web.Script.Serialization;
+using System.Web;
+using System.Reflection;
namespace SendGrid
{
@@ -34,4 +42,362 @@ namespace SendGrid
client = new Client(host: baseUri, requestHeaders: requestHeaders, version: version);
}
}
+
+ public class Response
+ {
+ public HttpStatusCode StatusCode;
+ public HttpContent Body;
+ public HttpResponseHeaders Headers;
+
+ /// <summary>
+ /// Holds the response from an API call.
+ /// </summary>
+ /// <param name="statusCode">https://msdn.microsoft.com/en-us/library/system.net.httpstatuscode(v=vs.110).aspx</param>
+ /// <param name="responseBody">https://msdn.microsoft.com/en-us/library/system.net.http.httpcontent(v=vs.118).aspx</param>
+ /// <param name="responseHeaders">https://msdn.microsoft.com/en-us/library/system.net.http.headers.httpresponseheaders(v=vs.118).aspx</param>
+ public Response(HttpStatusCode statusCode, HttpContent responseBody, HttpResponseHeaders responseHeaders)
+ {
+ StatusCode = statusCode;
+ Body = responseBody;
+ Headers = responseHeaders;
+ }
+
+ /// <summary>
+ /// Converts string formatted response body to a Dictionary.
+ /// </summary>
+ /// <param name="content">https://msdn.microsoft.com/en-us/library/system.net.http.httpcontent(v=vs.118).aspx</param>
+ /// <returns>Dictionary object representation of HttpContent</returns>
+ public virtual Dictionary<string, dynamic> DeserializeResponseBody(HttpContent content)
+ {
+ JavaScriptSerializer jss = new JavaScriptSerializer();
+ var dsContent = jss.Deserialize<Dictionary<string, dynamic>>(content.ReadAsStringAsync().Result);
+ return dsContent;
+ }
+
+ /// <summary>
+ /// Converts string formatted response headers to a Dictionary.
+ /// </summary>
+ /// <param name="content">https://msdn.microsoft.com/en-us/library/system.net.http.headers.httpresponseheaders(v=vs.118).aspx</param>
+ /// <returns>Dictionary object representation of HttpRepsonseHeaders</returns>
+ public virtual Dictionary<string, string> DeserializeResponseHeaders(HttpResponseHeaders content)
+ {
+ var dsContent = new Dictionary<string, string>();
+ foreach (var pair in content)
+ {
+ dsContent.Add(pair.Key, pair.Value.First());
+ }
+ return dsContent;
+ }
+ }
+
+ public class Client : DynamicObject
+ {
+ public string Host;
+ public Dictionary<string, string> RequestHeaders;
+ public string Version;
+ public string UrlPath;
+ public string MediaType;
+ public WebProxy WebProxy;
+ public enum Methods
+ {
+ DELETE, GET, PATCH, POST, PUT
+ }
+
+
+ /// <summary>
+ /// REST API client.
+ /// </summary>
+ /// <param name="host">Base url (e.g. https://api.sendgrid.com)</param>
+ /// <param name="requestHeaders">A dictionary of request headers</param>
+ /// <param name="version">API version, override AddVersion to customize</param>
+ /// <param name="urlPath">Path to endpoint (e.g. /path/to/endpoint)</param>
+ /// <returns>Fluent interface to a REST API</returns>
+ public Client(WebProxy webProxy, string host, Dictionary<string, string> requestHeaders = null, string version = null, string urlPath = null)
+ : this(host, requestHeaders, version, urlPath)
+ {
+ WebProxy = webProxy;
+ }
+
+ /// <summary>
+ /// REST API client.
+ /// </summary>
+ /// <param name="host">Base url (e.g. https://api.sendgrid.com)</param>
+ /// <param name="requestHeaders">A dictionary of request headers</param>
+ /// <param name="version">API version, override AddVersion to customize</param>
+ /// <param name="urlPath">Path to endpoint (e.g. /path/to/endpoint)</param>
+ /// <returns>Fluent interface to a REST API</returns>
+ public Client(string host, Dictionary<string, string> requestHeaders = null, string version = null, string urlPath = null)
+ {
+ Host = host;
+ if (requestHeaders != null)
+ {
+ AddRequestHeader(requestHeaders);
+ }
+ Version = (version != null) ? version : null;
+ UrlPath = (urlPath != null) ? urlPath : null;
+ }
+
+ /// <summary>
+ /// Add requestHeaders to the API call
+ /// </summary>
+ /// <param name="requestHeaders">A dictionary of request headers</param>
+ public void AddRequestHeader(Dictionary<string, string> requestHeaders)
+ {
+ RequestHeaders = (RequestHeaders != null)
+ ? RequestHeaders.Union(requestHeaders).ToDictionary(pair => pair.Key, pair => pair.Value) : requestHeaders;
+ }
+
+ /// <summary>
+ /// Build the final URL
+ /// </summary>
+ /// <param name="queryParams">A string of JSON formatted query parameters (e.g {'param': 'param_value'})</param>
+ /// <returns>Final URL</returns>
+ private string BuildUrl(string queryParams = null)
+ {
+ string endpoint = null;
+
+ if (Version != null)
+ {
+ endpoint = Host + "/" + Version + UrlPath;
+ }
+ else
+ {
+ endpoint = Host + UrlPath;
+ }
+
+ if (queryParams != null)
+ {
+ JavaScriptSerializer jss = new JavaScriptSerializer();
+ var ds_query_params = jss.Deserialize<Dictionary<string, dynamic>>(queryParams);
+ var query = HttpUtility.ParseQueryString(string.Empty);
+ foreach (var pair in ds_query_params)
+ {
+ query[pair.Key] = pair.Value.ToString();
+ }
+ string queryString = query.ToString();
+ endpoint = endpoint + "?" + queryString;
+ }
+
+ return endpoint;
+ }
+
+ /// <summary>
+ /// Create a new Client object for method chaining
+ /// </summary>
+ /// <param name="name">Name of url segment to add to the URL</param>
+ /// <returns>A new client object with "name" added to the URL</returns>
+ private Client BuildClient(string name = null)
+ {
+ string endpoint;
+
+ if (name != null)
+ {
+ endpoint = UrlPath + "/" + name;
+ }
+ else
+ {
+ endpoint = UrlPath;
+ }
+
+ UrlPath = null; // Reset the current object's state before we return a new one
+ return new Client(Host, RequestHeaders, Version, endpoint);
+
+ }
+
+ /// <summary>
+ /// Factory method to return the right HttpClient settings.
+ /// </summary>
+ /// <returns>Instance of HttpClient</returns>
+ private HttpClient BuildHttpClient()
+ {
+ // Add the WebProxy if set
+ if (WebProxy != null)
+ {
+ var httpClientHandler = new HttpClientHandler()
+ {
+ Proxy = WebProxy,
+ PreAuthenticate = true,
+ UseDefaultCredentials = false,
+ };
+
+ return new HttpClient(httpClientHandler);
+ }
+
+ return new HttpClient();
+ }
+
+ /// <summary>
+ /// Add the authorization header, override to customize
+ /// </summary>
+ /// <param name="header">Authorization header</param>
+ /// <returns>Authorization value to add to the header</returns>
+ public virtual AuthenticationHeaderValue AddAuthorization(KeyValuePair<string, string> header)
+ {
+ string[] split = header.Value.Split(new char[0]);
+ return new AuthenticationHeaderValue(split[0], split[1]);
+ }
+
+ /// <summary>
+ /// Add the version of the API, override to customize
+ /// </summary>
+ /// <param name="version">Version string to add to the URL</param>
+ public virtual void AddVersion(string version)
+ {
+ Version = version;
+ }
+
+ /// <summary>
+ /// Deal with special cases and URL parameters
+ /// </summary>
+ /// <param name="name">Name of URL segment</param>
+ /// <returns>A new client object with "name" added to the URL</returns>
+ public Client _(string name)
+ {
+ return BuildClient(name);
+ }
+
+ /// <summary>
+ /// Reflection. We capture undefined variable access here
+ /// </summary>
+ /// <param name="binder">The calling object properties</param>
+ /// <param name="result">The callback</param>
+ /// <returns>The callback returns a new client object with "name" added to the URL</returns>
+ public override bool TryGetMember(GetMemberBinder binder, out object result)
+ {
+ result = BuildClient(binder.Name);
+ return true;
+ }
+
+ /// <summary>
+ /// Reflection. We capture the final method call here
+ /// </summary>
+ /// <param name="binder">The calling object properties</param>
+ /// <param name="args">The calling object's arguements</param>
+ /// <param name="result">If "version", returns new client with version attached
+ /// If "method", returns a Response object</param>
+ /// <returns>The callback is described in "result"</returns>
+ public override bool TryInvokeMember(InvokeMemberBinder binder, object[] args, out object result)
+ {
+ if (binder.Name == "version")
+ {
+ AddVersion(args[0].ToString());
+ result = BuildClient();
+ return true;
+ }
+
+ if (Enum.IsDefined(typeof(Methods), binder.Name.ToUpper()))
+ {
+ string queryParams = null;
+ string requestBody = null;
+ int i = 0;
+
+ foreach (object obj in args)
+ {
+ string name = binder.CallInfo.ArgumentNames.Count > i ?
+ binder.CallInfo.ArgumentNames[i] : null;
+ if (name == "queryParams")
+ {
+ queryParams = obj.ToString();
+ }
+ else if (name == "requestBody")
+ {
+ requestBody = obj.ToString();
+ }
+ else if (name == "requestHeaders")
+ {
+ AddRequestHeader((Dictionary<string, string>)obj);
+ }
+ i++;
+ }
+ result = RequestAsync(binder.Name.ToUpper(), requestBody: requestBody, queryParams: queryParams).ConfigureAwait(false);
+ return true;
+ }
+ else
+ {
+ result = null;
+ return false;
+ }
+
+ }
+
+ /// <summary>
+ /// Make the call to the API server, override for testing or customization
+ /// </summary>
+ /// <param name="client">Client object ready for communication with API</param>
+ /// <param name="request">The parameters for the API call</param>
+ /// <returns>Response object</returns>
+ public async virtual Task<Response> MakeRequest(HttpClient client, HttpRequestMessage request)
+ {
+ HttpResponseMessage response = await client.SendAsync(request).ConfigureAwait(false);
+ return new Response(response.StatusCode, response.Content, response.Headers);
+ }
+
+ /// <summary>
+ /// Prepare for async call to the API server
+ /// </summary>
+ /// <param name="method">HTTP verb</param>
+ /// <param name="requestBody">JSON formatted string</param>
+ /// <param name="queryParams">JSON formatted queary paramaters</param>
+ /// <returns>Response object</returns>
+ private async Task<Response> RequestAsync(string method, string requestBody = null, string queryParams = null)
+ {
+ using (var client = BuildHttpClient())
+ {
+ try
+ {
+ // Build the URL
+ client.BaseAddress = new Uri(Host);
+ string endpoint = BuildUrl(queryParams);
+
+ // Build the request headers
+ client.DefaultRequestHeaders.Accept.Clear();
+ if (RequestHeaders != null)
+ {
+ foreach (KeyValuePair<string, string> header in RequestHeaders)
+ {
+ if (header.Key == "Authorization")
+ {
+ client.DefaultRequestHeaders.Authorization = AddAuthorization(header);
+ }
+ else if (header.Key == "Content-Type")
+ {
+ MediaType = header.Value;
+ client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue(MediaType));
+ }
+ else
+ {
+ client.DefaultRequestHeaders.Add(header.Key, header.Value);
+ }
+ }
+ }
+
+ // Build the request body
+ StringContent content = null;
+ if (requestBody != null)
+ {
+ content = new StringContent(requestBody, Encoding.UTF8, MediaType);
+ }
+
+ // Build the final request
+ HttpRequestMessage request = new HttpRequestMessage
+ {
+ Method = new HttpMethod(method),
+ RequestUri = new Uri(endpoint),
+ Content = content
+ };
+ return await MakeRequest(client, request).ConfigureAwait(false);
+
+ }
+ catch (Exception ex)
+ {
+ HttpResponseMessage response = new HttpResponseMessage();
+ string message;
+ message = (ex is HttpRequestException) ? ".NET HttpRequestException" : ".NET Exception";
+ message = message + ", raw message: \n\n";
+ response.Content = new StringContent(message + ex.Message);
+ return new Response(response.StatusCode, response.Content, response.Headers);
+ }
+ }
+ }
+ }
}
diff --git a/SendGrid/SendGrid/SendGrid.csproj b/SendGrid/SendGrid/SendGrid.csproj
index cba6595..0edef5d 100644
--- a/SendGrid/SendGrid/SendGrid.csproj
+++ b/SendGrid/SendGrid/SendGrid.csproj
@@ -47,10 +47,6 @@
<HintPath>..\packages\Newtonsoft.Json.9.0.1\lib\net45\Newtonsoft.Json.dll</HintPath>
<Private>True</Private>
</Reference>
- <Reference Include="SendGrid.CSharp.HTTP.Client, Version=3.0.0.0, Culture=neutral, PublicKeyToken=79219bf4e5ecaaca, processorArchitecture=MSIL">
- <HintPath>..\packages\SendGrid.CSharp.HTTP.Client.3.0.0\lib\SendGrid.CSharp.HTTP.Client.dll</HintPath>
- <Private>True</Private>
- </Reference>
<Reference Include="System" />
<Reference Include="System.Core" />
<Reference Include="System.Net.Http.Formatting, Version=5.2.3.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35, processorArchitecture=MSIL">
diff --git a/SendGrid/SendGrid/packages.config b/SendGrid/SendGrid/packages.config
index e83b5f0..d0f35fb 100644
--- a/SendGrid/SendGrid/packages.config
+++ b/SendGrid/SendGrid/packages.config
@@ -2,5 +2,4 @@
<packages>
<package id="Microsoft.AspNet.WebApi.Client" version="5.2.3" targetFramework="net452" />
<package id="Newtonsoft.Json" version="9.0.1" targetFramework="net452" />
- <package id="SendGrid.CSharp.HTTP.Client" version="3.0.0" targetFramework="net452" />
</packages> \ No newline at end of file
generated by cgit v1.1 at 2025-05-16 20:33:08 +0000