HRCenter/Diligent.WebAPI.Business/Services/Emailer.cs

using System.Net.Mail;
using System.Net;
using Diligent.WebAPI.Contracts.Models;

namespace Diligent.WebAPI.Business.Services
{
    /// <summary>
    /// Provieds an API for sending emails in both sync & async fashion, as well as sending emails with delays.
    /// </summary>
    public class Emailer : IEmailer
    {
        private readonly AuthorizationSettings _settings;

        public Emailer()
        {
            _settings = new AuthorizationSettings
            {
                SmtpServer = "smtp.mailtrap.io",
                SmtpPort = 2525,
                SmtpUseSSL = true,
                SmtpUsername = "460e3c49f02e37",
                SmtpPassword = "66443869eaad55",
                SmtpFrom = "noreply@hrcenter.net",
                SmtpFromName = "HRCenter Team"
            };
        }

        /// <summary>
        /// Sends an email asynchronously and inserts a new <see cref="DiligEmail"/> record to the underlying database.
        /// </summary>
        /// <param name="to"></param>
        /// <param name="subject"></param>
        /// <param name="body"></param>
        /// <param name="isHtml"></param>
        /// <param name="attachments"></param>
        /// <param name="cc"></param>
        /// <exception cref="ArgumentException"></exception>
        /// <see cref="ArgumentNullException"/>
        /// <exception cref="Exception"></exception>
        /// <returns></returns>
        public async Task<bool> SendEmailAndWriteToDbAsync(List<string> to, string subject, string body, bool isHtml = false, List<string> cc = null)
        {
            var emailResult = await SendEmailAsync(to, subject, body, isHtml, cc);

            var email = CreateEmail(to, subject, body, isHtml);

            if (emailResult)
            {
                email.SentTime = DateTime.UtcNow;
            }

            //var dbResult = await WriteEmailToDbAsync(email);

            return emailResult; // && dbResult > 0;
        }

        public async Task<bool> SendEmailAndWriteToDbAsync(string to, string subject, string body, bool isHtml = false, List<string> cc = null)
        {
            return await SendEmailAndWriteToDbAsync(new List<string> { to }, subject, body, isHtml, cc);
        }

        /// <summary>
        /// Sends an email synchronously and inserts a new <see cref="DiligEmail"/> record to the underlying database.
        /// </summary>
        /// <param name="to"></param>
        /// <param name="subject"></param>
        /// <param name="body"></param>
        /// <param name="isHtml"></param>
        /// <param name="attachments"></param>
        /// <param name="cc"></param>
        /// <exception cref="ArgumentException"></exception>
        /// <see cref="ArgumentNullException"/>
        /// <exception cref="Exception"></exception>
        /// <returns></returns>
        public bool SendEmailAndWriteToDb(List<string> to, string subject, string body, bool isHtml = false,
           List<string> cc = null)
        {
            var emailResult = SendEmail(to, subject, body, isHtml, cc);

            var email = CreateEmail(to, subject, body, isHtml);

            if (emailResult)
            {
                email.SentTime = DateTime.UtcNow;
            }

            //var dbResult = WriteEmailToDb(email);

            return emailResult; // && dbResult > 0;
        }

        public bool SendEmailAndWriteToDb(string to, string subject, string body, bool isHtml = false,
            List<string> cc = null)
        {
            return SendEmailAndWriteToDb(new List<string> { to }, subject, body, isHtml, cc);
        }

        /// <summary>
        /// Sends an email synchronously.
        /// </summary>
        /// <param name="to"></param>
        /// <param name="subject"></param>
        /// <param name="body"></param>
        /// <param name="isHtml"></param>
        /// <param name="attachments"></param>
        /// <param name="cc"></param>
        /// <exception cref="ArgumentException"></exception>
        /// <see cref="ArgumentNullException"/>
        /// <exception cref="Exception"></exception>
        /// <returns></returns>
        public bool SendEmail(List<string> to, string subject, string body, bool isHtml = false,
             List<string> cc = null)
        {
            try
            {
                using (var smtp = GetSmtpClient())
                {
                    var message = GetMailMessage(to, subject, body, isHtml, cc);

                    smtp.Send(message);

                    return true;
                }
            }
            catch (ArgumentException)
            {
                throw;
            }
            catch (Exception e)
            {
                throw new Exception("Failed to send email message.", e);
            }
        }

        /// <summary>
        /// Sends an email asynchronously.
        /// </summary>
        /// <param name="to"></param>
        /// <param name="subject"></param>
        /// <param name="body"></param>
        /// <param name="isHtml"></param>
        /// <param name="attachments"></param>
        /// <param name="cc"></param>
        /// <exception cref="ArgumentException"></exception>
        /// <see cref="ArgumentNullException"/>
        /// <exception cref="Exception"></exception>
        /// <returns></returns>
        public async Task<bool> SendEmailAsync(List<string> to, string subject, string body, bool isHtml = false, List<string> cc = null)
        {
            try
            {
                using (var smtp = GetSmtpClient())
                {
                    var message = GetMailMessage(to, subject, body, isHtml, cc);

                    await smtp.SendMailAsync(message);

                    return true;
                }
            }
            catch (ArgumentException)
            {
                throw;
            }
            catch (Exception e)
            {
                throw new Exception("Failed to send email message.", e);
            }
        }

        /// <summary>
        /// Creates a <see cref="SmtpClient"/> object and configures it.
        /// </summary>
        /// <returns></returns>
        public SmtpClient GetSmtpClient()
        {
            var smtp = new SmtpClient(_settings.SmtpServer) { Timeout = 1000000 };

            if (!string.IsNullOrWhiteSpace(_settings.SmtpUsername))
            {
                smtp.UseDefaultCredentials = false;
                smtp.Credentials = new NetworkCredential(
                    _settings.SmtpUsername,
                    _settings.SmtpPassword);
                smtp.EnableSsl = _settings.SmtpUseSSL;
                smtp.Port = _settings.SmtpPort;
            }

            return smtp;
        }

        /// <summary>
        /// Creates a new <see cref="MailMessage"/> from the specified arguments.
        /// </summary>
        /// <param name="to"></param>
        /// <param name="subject"></param>
        /// <param name="body"></param>
        /// <param name="isHtml"></param>
        /// <param name="attachments"></param>
        /// <param name="cc"></param>
        /// <exception cref="ArgumentException"></exception>
        /// <returns></returns>
        public MailMessage GetMailMessage(List<string> to, string subject, string body, bool isHtml = false, List<string> cc = null)
        {
            var message = new MailMessage
            {
                Sender = new MailAddress(_settings.SmtpFrom, _settings.SmtpFromName),
                From = new MailAddress(_settings.SmtpFrom),
                Subject = subject,
                Body = body,
                IsBodyHtml = isHtml
            };



            if (to.Any())
            {
                message.To.Add(string.Join(",", to.Where(email => !string.IsNullOrWhiteSpace(email))));
            }
            else
            {
                throw new ArgumentException("The list of recipient emails can not be empty");
            }

            if (cc != null && cc.Any())
            {
                message.CC.Add(string.Join(",", cc.Where(email => !string.IsNullOrWhiteSpace(email))));
            }

            return message;
        }

        /// <summary>
        /// Sends an email aysnchronously. If the "dont send before" argument is specified, then the email will be sent with a delay - after the specified time.
        /// </summary>
        /// <param name="to"></param>
        /// <param name="subject"></param>
        /// <param name="body"></param>
        /// <param name="isHtml"></param>
        /// <param name="attachments"></param>
        /// <param name="dontSendBefore"></param>
        /// <exception cref="ArgumentException"></exception>
        /// <exception cref="Exception"></exception>
        /// <returns></returns>
        public async Task<bool> SendEmailWithDelayAsync(List<string> to, string subject, string body, bool isHtml = false, DateTime? dontSendBefore = null)
        {
            try
            {
                var email = CreateEmail(to, subject, body, isHtml, dontSendBefore);

                //var result = await WriteEmailToDbAsync(email);

                return true;
            }
            catch (ArgumentException)
            {
                throw;
            }
            catch (Exception e)
            {
                throw new Exception("Error while attempting to send an email with delay.", e);
            }
        }

        /// <summary>
        /// Creates a <see cref="DiligEmail"/> object with specified arguments.
        /// </summary>
        /// <param name="to"></param>
        /// <param name="subject"></param>
        /// <param name="body"></param>
        /// <param name="isHtml"></param>
        /// <param name="attachments"></param>
        /// <param name="dontSendBefore"></param>
        /// <exception cref="ArgumentException"></exception>
        /// <returns></returns>
        public DiligEmail CreateEmail(List<string> to, string subject, string body, bool isHtml = false,
            DateTime? dontSendBefore = null)
        {
            if (!to.Any())
            {
                throw new ArgumentException("The list of recipient emails can not be empty");
            }
            var email = new DiligEmail
            {
                To = to.Aggregate((previous, next) => previous + ";" + next),
                Subject = subject,
                Body = body,
                IsHtml = isHtml,
                DontSendBefore = dontSendBefore,
                CreateTime = DateTime.UtcNow
            };



            return email;
        }

        /// <summary>
        /// Fills the specified <see cref="DiligEmail"/> object with the specified <see cref="EmailAttachment"/> list.
        /// </summary>
        /// <param name="email"></param>
        /// <param name="attachments"></param>
        /// <exception cref="ArgumentException"></exception>
        /// <returns></returns>
        //public DiligEmail FillEmailAttachments(DiligEmail email)
        //{
        //    if (email == null)
        //    {
        //        throw new ArgumentNullException(nameof(email), "Email can not be null");
        //    }

        //    if (attachments != null && attachments.Any())
        //    {
        //        attachments.ForEach(attachment =>
        //        {
        //            email.DiligEmailAttachments.Add(new DiligEmailAttachment
        //            {
        //                FileName = attachment.FileName,
        //                SourceFileName = attachment.SourceFileName,
        //                Type = attachment.Type,
        //                Disposition = attachment.Disposition
        //            });
        //        });
        //    }

        //    return email;
        //}

        /// <summary>
        /// Writes the specified <see cref="DiligEmail"/> object to the underlying database.
        /// </summary>
        /// <param name="email"></param>
        /// <exception cref="ArgumentException"></exception>
        /// <exception cref="Exception"></exception>
        /// <returns></returns>
        //public async Task<int> WriteEmailToDbAsync(DiligEmail email)
        //{
        //    try
        //    {
        //        if (email == null)
        //        {
        //            throw new ArgumentNullException(nameof(email), "Email can not be null");
        //        }
        //        _entities.DiligEmails.Add(email);

        //        var result = await _entities.SaveChangesAsync();

        //        return result;
        //    }
        //    catch (Exception e)
        //    {
        //        throw new Exception("Failed to write entry into the database", e);
        //    }
        //}

        /// <summary>
        /// Writes the specified <see cref="DiligEmail"/> object to the underlying database.
        /// </summary>
        /// <param name="email"></param>
        /// <exception cref="ArgumentNullException"></exception>
        /// <exception cref="Exception"></exception>
        /// <returns></returns>
        //public int WriteEmailToDb(DiligEmail email)
        //{
        //    try
        //    {
        //        if (email == null)
        //        {
        //            throw new ArgumentNullException(nameof(email), "Email can not be null");
        //        }
        //        _entities.DiligEmails.Add(email);

        //        var result = _entities.SaveChanges();

        //        return result;
        //    }
        //    catch (ArgumentException)
        //    {
        //        throw;
        //    }
        //    catch (Exception e)
        //    {
        //        throw new Exception("Failed to write entry into the database", e);
        //    }
        //}
    }
}