EWatch/Actions/ActionSmtp.cs

/*
 * Created by SharpDevelop.
 * User: banana
 * Date: 2013/10/04
 * Time: 17:25
 * 
 * To change this template use Tools | Options | Coding | Edit Standard Headers.
 */
using System;
using System.Linq;
using System.Net;
using System.Net.Mail;
using System.Text;
using EWatch.Models;
using EWatch.Utils;

namespace EWatch.Actions
{
        /// <summary>
        /// SMTPサーバーにメール配信を要求するアクションです。
        /// </summary>
        public class ActionSmtp : BaseAction
        {
                public const string Name = "smtp";
                
                private string _serverHost;
                private int _serverPort;
                
                private object lockObject = new object();

                public string ServerHost {
                        get {
                                return string.Format("{0}:{1}", _serverHost, _serverPort);
                        }
                        set {
                                string[] hostAndPort = value.Split(new char[]{ ':' });
                                _serverHost = hostAndPort[0];
                                _serverPort = 25;
                                if (hostAndPort.Length >= 2) {
                                        int.TryParse(hostAndPort[1], out _serverPort);
                                }
                        }
                }
                public string ToAddress { get; set; }
                public string FromAddress { get; set; }
                public EMailSender.Protections Protection { get; set; }
                public EMailSender.AuthenticateMethods AuthMethod { get; set; }
                public string UserID { get; set; }
                public string Password { get; set; }
                
                public ActionSmtp()
                {
                        Protection = EMailSender.Protections.None;
                        AuthMethod = EMailSender.AuthenticateMethods.None;
                }
                
                public override bool Validate()
                {
                        if (Util.IsNullOrEmpty(_serverHost)) {
                                log.Error("ServerHost is not specified.");
                                return false;
                        }
                        if (Util.IsNullOrEmpty(FromAddress)) {
                                log.Error("FromAddress is not specified.");
                                return false;
                        }
                        if (Util.IsNullOrEmpty(ToAddress)) {
                                log.Error("ToAddress is not specified.");
                                return false;
                        }
                        return true;
                }
                
                public override void Execute(LogData data)
                {
                        lock (lockObject) {
                                StringBuilder body = new StringBuilder();
                                body.AppendFormat("Time:   {0}\r\n", data.TimeStamp.Value.ToString("yyyy-MM-dd HH:mm:ss.fff"));
                                if (!Util.IsNullOrEmpty(data.Level)) {
                                        body.AppendFormat("level:  {0}\r\n", data.Level);
                                        body.AppendFormat("code:   {0}\r\n", data.Code);
                                }
                                if (!Util.IsNullOrEmpty(data.Name)) {
                                        body.AppendFormat("name:   {0}\r\n", data.Name);
                                }
                                if (!Util.IsNullOrEmpty(data.HostName)) {
                                        body.AppendFormat("host:   {0}\r\n", data.HostName);
                                }
                                if (!Util.IsNullOrEmpty(data.Source)) {
                                        body.AppendFormat("source: {0}\r\n", data.Source);
                                }
                                body.AppendFormat("{0}\r\n", data.Message);
                                var subject = string.Format("[{0}] {1}", data.HostName, data.Message);
                                if (!string.IsNullOrEmpty(data.Name))
                                        subject = string.Format("[{0}]{1}", data.Name, subject);
                                Send(GetSubject(subject),
                                        body.ToString(),
                                        data.Level == "E");
                        }
                }
                
                private string GetSubject(string value)
                {
                        if (!string.IsNullOrEmpty(value)) {
                                // 改行があればそこで区切る
                                var array = value.Split('\n');
                                value = array[0];
                                // 76文字以上ならそこで区切る
                                if (value.Length > 76)
                                        value = value.Substring(0, 76);
                        }
                        return value;
                }
                
                private void Send(string subject, string body, bool urgent)
                {
                        var pw = DecryptPassword(Password);
                        using (var sender = new EMailSender(_serverHost, _serverPort,
                                                    Protection, AuthMethod,
                                                    UserID, pw, null)) {
                                sender.Send(subject, body,
                                        new MailAddress(FromAddress),
                                        ToAddress.Split(',').Select(x => new MailAddress(x)).ToArray(),
                                        null, null, urgent);
                        }
                }

        private string DecryptPassword(string value)
        {
            if (!Util.IsNullOrEmpty(value)) {
                try {
                    return CryptUtil.Decrypt(value, Dns.GetHostName(), null);
                } catch (FormatException e) {
                }
            }
            return value;
        }
    }
}