AutomaticAnnouncements/EmailService.cs at master · TorN-dev/AutomaticAnnouncements · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
using System;
using System.Collections.Generic;
using System.Text;
using MailKit.Net.Smtp;
using MailKit;
using MimeKit;
using System.Linq;
using MimeKit.Text;
using MailKit.Net.Pop3;
using MailKit.Security;
using System.Net.Mail;
using System.Reflection;
using System.Diagnostics;
using System.Threading;

namespace AutomaticAnnouncements
{
	public interface IEmailService
	{
		//void Send(EmailMessage emailMessage);
		//List<EmailMessage> ReceiveEmail(int maxCount = 10);
		List<EmailMessage> ReceiveLatestEmail(int maxCount = 10);
	}

	// Everything to do with the emails
	public class EmailService : IEmailService
	{
		private readonly IEmailConfiguration _emailConfiguration;

		public EmailService(IEmailConfiguration emailConfiguration)
		{
			_emailConfiguration = emailConfiguration;
		}

		// Function for sending emails, currently unused
		//public void Send(EmailMessage emailMessage)
		//{
		//	var message = new MimeMessage();
		//	message.To.AddRange(emailMessage.ToAddresses.Select(x => new MailboxAddress(x.Name, x.Address)));
		//	message.From.AddRange(emailMessage.FromAddresses.Select(x => new MailboxAddress(x.Name, x.Address)));

		//	message.Subject = emailMessage.Subject;			message.Body = new TextPart(TextFormat.Html)
		//	{
		//		Text = emailMessage.Content
		//	};

		//	using SmtpClient emailClient = new SmtpClient();

		//	//The last parameter is to use SSL
		//	emailClient.Connect(_emailConfiguration.SmtpServer, _emailConfiguration.SmtpPort, true);

		//	//Remove OAuth functionality as it's not needed
		//	emailClient.AuthenticationMechanisms.Remove("XOAUTH2");

		//	emailClient.Authenticate(_emailConfiguration.SmtpUsername, _emailConfiguration.SmtpPassword);
		//	emailClient.Send(message);
		//	emailClient.Disconnect(true);
		//}

		// Retrieves the least recent emails, currently unsused
		//public List<EmailMessage> ReceiveEmail(int maxCount = 10)
		//{
		//	using Pop3Client emailClient = new Pop3Client();
		//	emailClient.Connect(_emailConfiguration.PopServer, _emailConfiguration.PopPort, true);

		//	//Remove any OAuth functionality, then authenticate
		//	emailClient.AuthenticationMechanisms.Remove("XOAUTH2");
		//	emailClient.Authenticate(_emailConfiguration.PopUsername, _emailConfiguration.PopPassword);

		//	List<EmailMessage> emails = new List<EmailMessage>();
		//	for (int i = 0; i < emailClient.Count && i < maxCount; i++)
		//	{
		//		var message = emailClient.GetMessage(i);
		//		var emailMessage = new EmailMessage
		//		{
		//			Content = !string.IsNullOrEmpty(message.HtmlBody) ? message.HtmlBody : message.TextBody,
		//			Subject = message.Subject
		//		};
		//		emailMessage.ToAddresses.AddRange(message.To.Select(x => (MailboxAddress)x).Select(x => new EmailAddress { Address = x.Address, Name = x.Name }));
		//		emailMessage.FromAddresses.AddRange(message.From.Select(x => (MailboxAddress)x).Select(x => new EmailAddress { Address = x.Address, Name = x.Name }));
		//		emails.Add(emailMessage);
		//	}

		//	return emails;
		//}

		// Retrieves the most recent emails
		public List<EmailMessage> ReceiveLatestEmail(int maxCount = 10)
		{
			using Pop3Client emailClient = new Pop3Client();

			bool connected = false;
			for (int i = 0; i < 10; i++)
			{
				try
				{
					emailClient.Connect(_emailConfiguration.PopServer, _emailConfiguration.PopPort, true);
					connected = true;
					break;
				}
				catch (Exception e)
				{
					Thread.Sleep(10000);
					Console.WriteLine(e);
				}
			}
			if(!connected) //Restart application
			{
				Console.WriteLine("Restarting...");

				// Get file path of current process
				var filePath = Assembly.GetExecutingAssembly().Location;

				// Start program
				Process.Start(filePath);

				// For all Windows application but typically for Console app.
				Environment.Exit(0);
			}

			//emailClient.Connect("pop.gmail.com", 995, SecureSocketOptions.SslOnConnect);

			////Remove any OAuth functionality, then authenticate
			emailClient.AuthenticationMechanisms.Remove("XOAUTH2");
			emailClient.Authenticate(_emailConfiguration.PopUsername, _emailConfiguration.PopPassword);

			List<EmailMessage> emails = new List<EmailMessage>();
			for (int i = emailClient.Count - 1; i >= 0 && i >= emailClient.Count - maxCount; i--)
			//for (int i = 0; i < emailClient.Count && i < maxCount; i++)
			{
				var message = emailClient.GetMessage(i);

				var emailMessage = new EmailMessage
				{
					Content = !string.IsNullOrEmpty(message.HtmlBody) ? message.HtmlBody : message.TextBody,
					Subject = message.Subject
				};
				emailMessage.ToAddresses.AddRange(message.To.Select(x => (MailboxAddress)x).Select(x => new EmailAddress { Address = x.Address, Name = x.Name }));
				emailMessage.FromAddresses.AddRange(message.From.Select(x => (MailboxAddress)x).Select(x => new EmailAddress { Address = x.Address, Name = x.Name }));
				emails.Add(emailMessage);
			}

			emailClient.Disconnect(true);
			return emails;
		}
	}
}