using KB.SpeeDing.Common;

​

using KB.SpeeDing.Common.Contracts;

​

using KB.SpeeDing.Common.Notification;

​

using Microsoft.Extensions.Configuration;

​

using Microsoft.Extensions.Logging;

​

using System.Net.Mail;

​

using System.Threading.Tasks;

​

using System.Threading;

​

using MimeKit;

​

using MailKit;

​

using MailKit.Net.Smtp;

​

​

namespace KB.SpeeDing.Notification.Services

​

{

​

    public class SmtpNotificationDestinationService : ICommonConnectedService<NotificationMessage>

​

    {

​

        protected ILogger Logger { get; set; }

​

        private SmtpClient client { get; set; }

​

        private IConfiguration Configuration { get; set; }

​

​

        public SmtpNotificationDestinationService(ILogger<SmtpNotificationDestinationService> logger, SmtpClient client, IConfiguration Configuration)

​

        {

​

            Logger = logger;

​

            this.client = client;

​

            this.Configuration = Configuration;

​

        }

​

​

        protected virtual string GetName()

​

        {

​

            return "Smtp Notification";

​

        }

​

​

​

        /// <summary>

​

        /// not used on producer side

​

        /// </summary>

​

        /// <param name="message"></param>

​

        /// <param name="cancellationToken"></param>

​

        /// <returns></returns>

​

        /// <exception cref="System.NotImplementedException"></exception>

​

        public async Task<bool> ProcessBegin(NotificationMessage message, CancellationToken cancellationToken)

​

        {

​

            await Task.Run(() => { }, cancellationToken);

​

            throw new System.NotImplementedException();

​

        }

​

​

        public async Task<bool> Process(NotificationMessage message, CancellationToken cancellationToken)

​

        {

​

            Logger.LogInformation(message.DestinationHeader, $"{GetName()} notification service. Only logging. Message: {message?.SourceData?.Subject}, type: {message?.SourceData?.NotificationType}");

​

            await Task.Run(() => { }, cancellationToken);

​

            return true;

​

        }

​

​

        private void SendEmail(NotificationData Data)

​

        {

​

            var message = new MimeMessage();

​

            message.From.Add(new MailboxAddress("Joey Tribbiani", "joey@friends.com")); //?

​

            message.To.Add(new MailboxAddress("Mrs. Chanandler Bong", "chandler@friends.com")); //typ zpravy, podle toho adresy

​

            message.Subject = "How you doin'?";

​

            message.Body = new TextPart("plain") //message

​

            {

​

                Text = @"Hey Chandler,..."

​

            };

​

            using (var client = new SmtpClient())

​

            {

​

                client.Connect("smtp.friends.com", 587, false); //server, port, ?

​

​

                // Note: only needed if the SMTP server requires authentication

​

                client.Authenticate("joey", "password");

​

​

                client.Send(message);

​

                client.Disconnect(true);

​

            }

​

        }

​

​

        /// <summary>

​

        /// not used on producer side

​

        /// </summary>

​

        /// <param name="message"></param>

​

        /// <param name="cancellationToken"></param>

​

        /// <returns></returns>

​

        /// <exception cref="System.NotImplementedException"></exception>

​

        public async Task<bool> ProcessEnd(NotificationMessage message, CancellationToken cancellationToken)

​

        {

​

            await Task.Run(() => { }, cancellationToken);

​

            throw new System.NotImplementedException();

​

        }

​

    }

​

}

///////////////////////////////////////////////////////////////////////// v jinym namespace:

    public class NotificationMessage: CommonProcessMessage<NotificationData, DirectResult, ConsumeResult<string, byte[]>>

​

    {

​

    }

​

 public enum Classification { C0, C1, C2, C3}; 

​

    public class NotificationData

​

    {

​

        public string NotificationType { get; set; }

​

        public string Subject { get; set; }

blabla

        public string Message { get; set; }

​

        public Classification Classification {get; set;} = Classification.C1;

        public string Source { get; set; }//directApi, service

​

        public string DestinationType { get; set; } //email, log

​

        public CommunicationHeader CommunicationHeader { get; set; }

​

​

    }