FileFlowsPlugins/EmailNodes/Communication/SendEmail.cs

using System.ComponentModel.DataAnnotations;
using MailKit.Net.Smtp;
using MimeKit;

namespace FileFlows.Communication
{
    public class SendEmail:Node
    {
        public override int Inputs => 1;
        public override int Outputs => 2;
        public override string Icon => "fas fa-envelope";

        public override FlowElementType Type => FlowElementType.Communication;
        public override bool FailureNode => true;

        [StringArray(1)]
        public string[] Recipients { get; set; }

        [TextVariable(2)]
        public string Subject { get; set; }

        /// <summary>
        /// Gets or sets the message
        /// </summary>
        [Required]
        [Template(3, nameof(BodyTemplates))]
        public string Body { get; set; }

        private static List<ListOption> _BodyTemplates;
        public static List<ListOption> BodyTemplates
        {
            get
            {
                if (_BodyTemplates == null)
                {
                    _BodyTemplates = new List<ListOption>
                    {
                        new () { Label = "Basic", Value = @"File: {{ file.Orig.FullName }}
Size: {{ file.Size }}" },
                        new () { Label = "File Size Changes", Value = @"
{{ difference = file.Size - file.Orig.Size }}
{{ percent = (difference / file.Orig.Size) * 100 | math.round 2 }}

Input File: {{ file.Orig.FullName }}
Output File: {{ file.FullName }}
Original Size: {{ file.Orig.Size | file_size }}
Final Size: {{ file.Size | file_size }}

{{- if difference > 0 }}
File grew in size: {{ difference | math.abs | file_size }}
{{ else }}
File shrunk in size by: {{ difference | file_size }} / {{ percent }}%
{{ end }}"}
                    };
                }
                return _BodyTemplates;
            }
        }

        public override int Execute(NodeParameters args)
        {
            try
            {
                var settings = args.GetPluginSettings<PluginSettings>();

                if (string.IsNullOrEmpty(settings?.SmtpServer))
                {
                    args.Logger?.ELog(
                        "No SMTP Server configured, configure this under the 'Plugins > Email > Edit' page.");
                    return -1;
                }

                args.Logger?.ILog($"Got SMTP Server: {settings.SmtpServer} [{settings.SmtpPort}]");

                string body = RenderBody(args);

                string sender = settings.Sender ?? "fileflows@" + Environment.MachineName;
                string subject = args.ReplaceVariables(this.Subject ?? String.Empty)?.EmptyAsNull() ??
                                 "Email from FileFlows";

                SendMailKit(args, settings, sender, subject, body);

                //SendDotNet(args, settings, sender, subject, body);

                return 1;
            }
            catch (Exception ex)
            {
                args.Logger?.WLog("Error sending message: " + ex.Message);
                return 2;
            }
        }

        internal string RenderBody(NodeParameters args)
        {
            if (string.IsNullOrEmpty(this.Body))
                return string.Empty;

            return args.RenderTemplate!(this.Body);
        }

        private void SendDotNet(NodeParameters args, PluginSettings settings, string sender, string subject, string body)
        {
            args.Logger?.ILog($"Send using .NET internal mail library");
            System.Net.Mail.MailMessage message = new ();
            message.From = new System.Net.Mail.MailAddress(sender);
            foreach (var recipient in Recipients)
                message.To.Add(recipient);
            message.Subject = subject;
            message.Body = args.ReplaceVariables(body);


            System.Net.Mail.SmtpClient smtp = new ();
            smtp.Port = settings.SmtpPort;
            smtp.Host = settings.SmtpServer;
            if (string.IsNullOrEmpty(settings.SmtpUsername) == false)
            {
                args.Logger?.ILog("Sending using credientials");
                smtp.EnableSsl = true;
                smtp.UseDefaultCredentials = false;
                smtp.Credentials = new System.Net.NetworkCredential(settings.SmtpUsername, settings.SmtpPassword);
                //smtp.DeliveryMethod = SmtpDeliveryMethod.Network;
            }
            args.Logger?.ILog("About to send email");
            smtp.Send(message);
            args.Logger?.ILog("Email sent!");
        }

        private void SendMailKit(NodeParameters args, PluginSettings settings, string sender, string subject, string body)
        {
            var message = new MimeMessage();
            message.From.Add(new MailboxAddress(sender, sender));
            foreach (var recipient in Recipients)
                message.To.Add(new MailboxAddress(recipient, recipient));
            message.Subject = subject;
            message.Body = new TextPart("plain")
            {
                Text = body
            };

            args.Logger?.ILog($"About to construct SmtpClient");
            using (var client = new SmtpClient())
            {
                args.Logger?.ILog($"Connecting to SMTP Server: {settings.SmtpServer}:{settings.SmtpPort}");
                client.Connect(settings.SmtpServer, settings.SmtpPort);

                if (string.IsNullOrEmpty(settings.SmtpUsername) == false)
                {
                    args.Logger?.ILog("Sending using credientials");
                    client.AuthenticationMechanisms.Remove("XOAUTH2");
                    client.Authenticate(settings.SmtpUsername, settings.SmtpPassword);
                }
                args.Logger?.ILog($"About to send message");
                client.Send(message);
                args.Logger?.ILog($"Message sent");
                client.Disconnect(true);
            }
        }
    }
}