Add MailPace Sender

FluentEmail.sln

@@ -43,6 +43,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FluentEmail.Liquid", "src\R
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FluentEmail.Liquid.Tests", "test\FluentEmail.Liquid.Tests\FluentEmail.Liquid.Tests.csproj", "{C8063CBA-D8F3-467A-A75C-63843F0DE862}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "FluentEmail.MailPace", "src\Senders\FluentEmail.MailPace\FluentEmail.MailPace.csproj", "{B7A5D5CF-9804-41CA-BF0A-16D5252CE7A9}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -97,6 +99,10 @@ Global
 		{C8063CBA-D8F3-467A-A75C-63843F0DE862}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{C8063CBA-D8F3-467A-A75C-63843F0DE862}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{C8063CBA-D8F3-467A-A75C-63843F0DE862}.Release|Any CPU.Build.0 = Release|Any CPU
+		{B7A5D5CF-9804-41CA-BF0A-16D5252CE7A9}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{B7A5D5CF-9804-41CA-BF0A-16D5252CE7A9}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{B7A5D5CF-9804-41CA-BF0A-16D5252CE7A9}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{B7A5D5CF-9804-41CA-BF0A-16D5252CE7A9}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -117,6 +123,7 @@ Global
 		{0C7819AD-BC76-465D-9B2A-BE2DA75042F2} = {926C0980-31D9-4449-903F-3C756044C28A}
 		{17100F47-A555-4756-A25F-4F05EDAFA74E} = {12F031E5-8DDC-40A0-9862-8764A6E190C0}
 		{C8063CBA-D8F3-467A-A75C-63843F0DE862} = {47CB89AC-9615-4FA8-90DE-2D849935C36D}
+		{B7A5D5CF-9804-41CA-BF0A-16D5252CE7A9} = {926C0980-31D9-4449-903F-3C756044C28A}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {23736554-5288-4B30-9710-B4D9880BCF0B}

README.markdown

@@ -22,6 +22,7 @@ Maintained by Luke Lowrey - follow me  on twitter **[@lukencode](https://twitter
 
 * [FluentEmail.Mailgun](src/Senders/FluentEmail.Mailgun) - Send emails via MailGun's REST API.
 * [FluentEmail.SendGrid](src/Senders/FluentEmail.SendGrid) - Send email via the SendGrid API.
+* [FluentEmail.MailPace](src/Senders/FluentEmail.MailPace) - Send emails via the [MailPace](https://www.mailpace.com/) REST API.
 * [FluentEmail.Mailtrap](src/Senders/FluentEmail.Mailtrap) - Send emails to Mailtrap. Uses [FluentEmail.Smtp](src/Senders/FluentEmail.Smtp) for delivery.
 * [FluentEmail.MailKit](src/Senders/FluentEmail.MailKit) - Send emails using the [MailKit](https://github.com/jstedfast/MailKit) email library.
 
@@ -159,5 +160,4 @@ var email = new Email("[email protected]")
 	.UsingTemplateFromEmbedded("Example.Project.Namespace.template-name.cshtml", 
 		new { Name = "Bob" }, 
 		TypeFromYourEmbeddedAssembly.GetType().GetTypeInfo().Assembly);
-```
-
+```

src/Senders/FluentEmail.MailPace/FluentEmail.MailPace.csproj

@@ -0,0 +1,19 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+    <PropertyGroup>
+        <Description>Send emails via MailPace using their REST API</Description>
+        <AssemblyTitle>Fluent Email - MailPace</AssemblyTitle>
+        <Authors>Luke Lowrey;Ben Cull;Github Contributors</Authors>
+        <PackageTags>$(PackageTags);smtp</PackageTags>
+        <TargetFramework>netstandard2.0</TargetFramework>
+    </PropertyGroup>
+
+    <ItemGroup>
+        <PackageReference Include="Newtonsoft.Json" Version="13.0.2" />
+    </ItemGroup>
+
+    <ItemGroup>
+        <ProjectReference Include="..\..\FluentEmail.Core\FluentEmail.Core.csproj" />
+    </ItemGroup>
+
+</Project>

src/Senders/FluentEmail.MailPace/FluentEmailMailPaceBuilderExtensions.cs

@@ -0,0 +1,18 @@
+using FluentEmail.Core.Interfaces;
+using FluentEmail.MailPace;
+using Microsoft.Extensions.DependencyInjection.Extensions;
+
+// ReSharper disable once CheckNamespace
+namespace Microsoft.Extensions.DependencyInjection
+{
+    public static class FluentEmailMailPaceBuilderExtensions
+    {
+        public static FluentEmailServicesBuilder AddMailPaceSender(
+            this FluentEmailServicesBuilder builder,
+            string serverToken)
+        {
+            builder.Services.TryAdd(ServiceDescriptor.Scoped<ISender>(_ => new MailPaceSender(serverToken)));
+            return builder;
+        }
+    }
+}

src/Senders/FluentEmail.MailPace/MailPaceAttachment.cs

@@ -0,0 +1,11 @@
+using Newtonsoft.Json;
+
+namespace FluentEmail.MailPace;
+
+public class MailPaceAttachment
+{
+    [JsonProperty("name")] public string Name { get; set; }
+    [JsonProperty("content")] public string Content { get; set; }
+    [JsonProperty("content_type")] public string ContentType { get; set; }
+    [JsonProperty("cid", NullValueHandling = NullValueHandling.Ignore)] public string Cid { get; set; }
+}

src/Senders/FluentEmail.MailPace/MailPaceResponse.cs

@@ -0,0 +1,12 @@
+using System.Collections.Generic;
+using Newtonsoft.Json;
+
+namespace FluentEmail.MailPace;
+
+public class MailPaceResponse
+{
+    [JsonProperty("id", NullValueHandling = NullValueHandling.Ignore)] public string Id { get; set; }
+    [JsonProperty("status", NullValueHandling = NullValueHandling.Ignore)] public string Status { get; set; }
+    [JsonProperty("error")] public string Error { get; set; }
+    [JsonProperty("errors")] public Dictionary<string, List<string>> Errors { get; set; } = new();
+}

src/Senders/FluentEmail.MailPace/MailPaceSendRequest.cs

@@ -0,0 +1,18 @@
+using System.Collections.Generic;
+using Newtonsoft.Json;
+
+namespace FluentEmail.MailPace;
+
+public class MailPaceSendRequest
+{
+    [JsonProperty("from")] public string From { get; set; }
+    [JsonProperty("to")] public string To { get; set; }
+    [JsonProperty("cc", NullValueHandling = NullValueHandling.Ignore)] public string Cc { get; set; }
+    [JsonProperty("bcc", NullValueHandling = NullValueHandling.Ignore)] public string Bcc { get; set; }
+    [JsonProperty("subject")] public string Subject { get; set; }
+    [JsonProperty("htmlbody", NullValueHandling = NullValueHandling.Ignore)] public string HtmlBody { get; set; }
+    [JsonProperty("textbody", NullValueHandling = NullValueHandling.Ignore)] public string TextBody { get; set; }
+    [JsonProperty("replyto", NullValueHandling = NullValueHandling.Ignore)] public string ReplyTo { get; set; }
+    [JsonProperty("attachments")] public List<MailPaceAttachment> Attachments { get; set; } = new(0);
+    [JsonProperty("tags")] public List<string> Tags { get; set; } = new(0);
+}

src/Senders/FluentEmail.MailPace/MailPaceSender.cs

@@ -0,0 +1,143 @@
+using System;
+using System.IO;
+using System.Linq;
+using System.Net.Http;
+using System.Net.Http.Headers;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+using FluentEmail.Core;
+using FluentEmail.Core.Interfaces;
+using FluentEmail.Core.Models;
+using Newtonsoft.Json;
+
+namespace FluentEmail.MailPace;
+
+public class MailPaceSender : ISender, IDisposable
+{
+    private readonly HttpClient _httpClient;
+
+    public MailPaceSender(string serverToken)
+    {
+        _httpClient = new HttpClient();
+        _httpClient.DefaultRequestHeaders.Add("MailPace-Server-Token", serverToken);
+        _httpClient.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
+    }
+
+    public SendResponse Send(IFluentEmail email, CancellationToken? token = null) =>
+        SendAsync(email, token).GetAwaiter().GetResult();
+
+    public async Task<SendResponse> SendAsync(IFluentEmail email, CancellationToken? token = null)
+    {
+        var sendRequest = BuildSendRequestFor(email);
+
+        var content = new StringContent(JsonConvert.SerializeObject(sendRequest), Encoding.UTF8, "application/json");
+
+        var response = await _httpClient.PostAsync("https://app.mailpace.com/api/v1/send", content)
+            .ConfigureAwait(false);
+
+        var mailPaceResponse = await TryOrNull(async () => JsonConvert.DeserializeObject<MailPaceResponse>(
+            await response.Content.ReadAsStringAsync())) ?? new MailPaceResponse();
+
+        if (response.IsSuccessStatusCode)
+        {
+            return new SendResponse { MessageId = mailPaceResponse.Id };
+        }
+        else
+        {
+            var result = new SendResponse();
+
+            if (!string.IsNullOrEmpty(mailPaceResponse.Error))
+            {
+                result.ErrorMessages.Add(mailPaceResponse.Error);
+            }
+
+            if (mailPaceResponse.Errors != null && mailPaceResponse.Errors.Count != 0)
+            {
+                result.ErrorMessages.AddRange(mailPaceResponse.Errors
+                    .Select(it => $"{it.Key}: {string.Join("; ", it.Value)}"));
+            }
+
+            if (!result.ErrorMessages.Any())
+            {
+                result.ErrorMessages.Add(response.ReasonPhrase ?? "An unknown error has occurred.");
+            }
+
+            return result;
+        }
+    }
+
+    private static MailPaceSendRequest BuildSendRequestFor(IFluentEmail email)
+    {
+        var sendRequest = new MailPaceSendRequest
+        {
+            From = $"{email.Data.FromAddress.Name} <{email.Data.FromAddress.EmailAddress}>",
+            To = string.Join(",", email.Data.ToAddresses.Select(it => !string.IsNullOrEmpty(it.Name) ? $"{it.Name} <{it.EmailAddress}>" : it.EmailAddress)),
+            Subject = email.Data.Subject
+        };
+
+        if (email.Data.CcAddresses.Any())
+        {
+            sendRequest.Cc = string.Join(",", email.Data.CcAddresses.Select(it => !string.IsNullOrEmpty(it.Name) ? $"{it.Name} <{it.EmailAddress}>" : it.EmailAddress));
+        }
+
+        if (email.Data.BccAddresses.Any())
+        {
+            sendRequest.Bcc = string.Join(",", email.Data.BccAddresses.Select(it => !string.IsNullOrEmpty(it.Name) ? $"{it.Name} <{it.EmailAddress}>" : it.EmailAddress));
+        }
+
+        if (email.Data.ReplyToAddresses.Any())
+        {
+            sendRequest.ReplyTo = string.Join(",", email.Data.ReplyToAddresses.Select(it => !string.IsNullOrEmpty(it.Name) ? $"{it.Name} <{it.EmailAddress}>" : it.EmailAddress));
+        }
+
+        if (email.Data.IsHtml)
+        {
+            sendRequest.HtmlBody = email.Data.Body;
+            if (!string.IsNullOrEmpty(email.Data.PlaintextAlternativeBody))
+            {
+                sendRequest.TextBody = email.Data.PlaintextAlternativeBody;
+            }
+        }
+        else
+        {
+            sendRequest.TextBody = email.Data.Body;
+        }
+
+        if (email.Data.Tags.Any())
+        {
+            sendRequest.Tags.AddRange(email.Data.Tags);
+        }
+
+        if (email.Data.Attachments.Any())
+        {
+            sendRequest.Attachments.AddRange(
+                email.Data.Attachments.Select(it => new MailPaceAttachment
+                {
+                    Name = it.Filename,
+                    Content = it.Data.ConvertToBase64(),
+                    ContentType = it.ContentType ?? Path.GetExtension(it.Filename), // jpeg, jpg, png, gif, txt, pdf, docx, xlsx, pptx, csv, att, ics, ical, html, zip
+                    Cid = it.IsInline ? it.ContentId : null
+                }));
+        }
+
+        return sendRequest;
+    }
+
+    private async Task<T> TryOrNull<T>(Func<Task<T>> method)
+    {
+        try
+        {
+            return await method();
+        }
+        catch
+        {
+            return default;
+        }
+    }
+
+    public void Dispose()
+    {
+        _httpClient.Dispose();
+    }
+}

src/Senders/FluentEmail.MailPace/StreamExtensions.cs

@@ -0,0 +1,23 @@
+using System;
+using System.IO;
+
+namespace FluentEmail.MailPace;
+
+public static class StreamExtensions
+{
+    public static string ConvertToBase64(this Stream stream)
+    {
+        if (stream is MemoryStream memoryStream)
+        {
+            return Convert.ToBase64String(memoryStream.ToArray());
+        }
+
+        var bytes = new Byte[(int)stream.Length];
+
+        stream.Seek(0, SeekOrigin.Begin);
+        // ReSharper disable once MustUseReturnValue
+        stream.Read(bytes, 0, (int)stream.Length);
+
+        return Convert.ToBase64String(bytes);
+    }
+}