DocSpace-buildtools/common/ASC.Core.Common/Notify/Senders/SmtpSender.cs

353 lines
13 KiB
C#
Raw Normal View History

2019-05-15 14:56:09 +00:00
/*
*
* (c) Copyright Ascensio System Limited 2010-2018
*
* This program is freeware. You can redistribute it and/or modify it under the terms of the GNU
* General Public License (GPL) version 3 as published by the Free Software Foundation (https://www.gnu.org/copyleft/gpl.html).
* In accordance with Section 7(a) of the GNU GPL its Section 15 shall be amended to the effect that
* Ascensio System SIA expressly excludes the warranty of non-infringement of any third-party rights.
*
* THIS PROGRAM IS DISTRIBUTED WITHOUT ANY WARRANTY; WITHOUT EVEN THE IMPLIED WARRANTY OF MERCHANTABILITY OR
* FITNESS FOR A PARTICULAR PURPOSE. For more details, see GNU GPL at https://www.gnu.org/copyleft/gpl.html
*
* You can contact Ascensio System SIA by email at sales@onlyoffice.com
*
* The interactive user interfaces in modified source and object code versions of ONLYOFFICE must display
* Appropriate Legal Notices, as required under Section 5 of the GNU GPL version 3.
*
* Pursuant to Section 7 § 3(b) of the GNU GPL you must retain the original ONLYOFFICE logo which contains
* relevant author attributions when distributing the software. If the display of the logo in its graphic
* form is not reasonably feasible for technical reasons, you must include the words "Powered by ONLYOFFICE"
* in every copy of the program you distribute.
* Pursuant to Section 7 § 3(e) we decline to grant you any rights under trademark law for use of our trademarks.
*
*/
using System;
using System.Collections.Generic;
using System.IO;
2019-11-06 15:03:09 +00:00
using System.Net;
2020-02-17 08:58:14 +00:00
using ASC.Common;
2019-05-15 14:56:09 +00:00
using ASC.Common.Logging;
using ASC.Common.Utils;
using ASC.Notify.Messages;
2019-11-06 15:03:09 +00:00
using ASC.Notify.Patterns;
2020-02-17 08:58:14 +00:00
2019-05-15 14:56:09 +00:00
using MailKit;
2019-11-06 15:03:09 +00:00
using MailKit.Security;
2020-02-17 08:58:14 +00:00
2019-11-06 15:03:09 +00:00
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Options;
2020-02-17 08:58:14 +00:00
2019-05-15 14:56:09 +00:00
using MimeKit;
namespace ASC.Core.Notify.Senders
{
internal class SmtpSender : INotifySender
{
private const string HTML_FORMAT =
@"<!DOCTYPE html PUBLIC ""-//W3C//DTD HTML 4.01 Transitional//EN"">
<html>
<head>
<meta content=""text/html;charset=UTF-8"" http-equiv=""Content-Type"">
</head>
<body>{0}</body>
</html>";
2019-11-06 15:03:09 +00:00
protected ILog Log { get; set; }
2020-08-12 09:58:08 +00:00
protected IConfiguration Configuration { get; }
protected IServiceProvider ServiceProvider { get; }
2019-11-06 15:03:09 +00:00
2020-07-28 14:24:21 +00:00
private string Host { get; set; }
private int Port { get; set; }
private bool Ssl { get; set; }
private ICredentials Credentials { get; set; }
2020-09-29 12:27:28 +00:00
protected bool UseCoreSettings { get; set; }
2019-11-06 15:03:09 +00:00
const int NETWORK_TIMEOUT = 30000;
public SmtpSender(
IServiceProvider serviceProvider,
IOptionsMonitor<ILog> options)
2019-05-15 14:56:09 +00:00
{
2019-11-06 15:03:09 +00:00
Log = options.Get("ASC.Notify");
Configuration = serviceProvider.GetService<IConfiguration>();
ServiceProvider = serviceProvider;
2019-05-15 14:56:09 +00:00
}
public virtual void Init(IDictionary<string, string> properties)
{
if (properties.ContainsKey("useCoreSettings") && bool.Parse(properties["useCoreSettings"]))
{
2020-09-29 12:27:28 +00:00
UseCoreSettings = true;
2019-05-15 14:56:09 +00:00
}
else
{
2020-07-28 14:24:21 +00:00
Host = properties["host"];
Port = properties.ContainsKey("port") ? int.Parse(properties["port"]) : 25;
Ssl = properties.ContainsKey("enableSsl") && bool.Parse(properties["enableSsl"]);
2019-05-15 14:56:09 +00:00
if (properties.ContainsKey("userName"))
{
2020-07-28 14:24:21 +00:00
Credentials = new NetworkCredential(
2019-05-15 14:56:09 +00:00
properties["userName"],
properties["password"]);
}
}
}
2019-10-10 13:18:12 +00:00
private void InitUseCoreSettings(CoreConfiguration configuration)
2019-05-15 14:56:09 +00:00
{
2019-11-06 15:03:09 +00:00
var s = configuration.SmtpSettings;
2019-10-10 13:18:12 +00:00
2020-07-28 14:24:21 +00:00
Host = s.Host;
Port = s.Port;
Ssl = s.EnableSSL;
Credentials = !string.IsNullOrEmpty(s.CredentialsUserName)
2019-05-15 14:56:09 +00:00
? new NetworkCredential(s.CredentialsUserName, s.CredentialsUserPassword)
: null;
}
public virtual NoticeSendResult Send(NotifyMessage m)
2019-11-06 15:03:09 +00:00
{
using var scope = ServiceProvider.CreateScope();
2020-08-24 18:41:06 +00:00
var scopeClass = scope.ServiceProvider.GetService<SmtpSenderScope>();
2020-09-04 09:06:30 +00:00
var (tenantManager, configuration) = scopeClass;
2020-10-12 19:39:23 +00:00
tenantManager.SetCurrentTenant(m.Tenant);
2019-10-10 13:18:12 +00:00
2019-05-15 14:56:09 +00:00
var smtpClient = GetSmtpClient();
var result = NoticeSendResult.TryOnceAgain;
try
{
try
{
2020-09-29 12:27:28 +00:00
if (UseCoreSettings)
2020-09-04 09:06:30 +00:00
InitUseCoreSettings(configuration);
2019-05-15 14:56:09 +00:00
var mail = BuildMailMessage(m);
2020-07-28 14:24:21 +00:00
Log.DebugFormat("SmtpSender - host={0}; port={1}; enableSsl={2} enableAuth={3}", Host, Port, Ssl, Credentials != null);
2019-05-15 14:56:09 +00:00
2020-07-28 14:24:21 +00:00
smtpClient.Connect(Host, Port,
Ssl ? SecureSocketOptions.Auto : SecureSocketOptions.None);
2019-05-15 14:56:09 +00:00
2020-07-28 14:24:21 +00:00
if (Credentials != null)
2019-05-15 14:56:09 +00:00
{
2020-07-28 14:24:21 +00:00
smtpClient.Authenticate(Credentials);
2019-05-15 14:56:09 +00:00
}
smtpClient.Send(mail);
result = NoticeSendResult.OK;
}
catch (Exception e)
{
Log.ErrorFormat("Tenant: {0}, To: {1} - {2}", m.Tenant, m.To, e);
throw;
}
}
catch (ObjectDisposedException)
{
result = NoticeSendResult.SendingImpossible;
}
catch (InvalidOperationException)
{
2020-07-28 14:24:21 +00:00
result = string.IsNullOrEmpty(Host) || Port == 0
2019-05-15 14:56:09 +00:00
? NoticeSendResult.SendingImpossible
: NoticeSendResult.TryOnceAgain;
}
catch (IOException)
{
result = NoticeSendResult.TryOnceAgain;
}
catch (MailKit.Net.Smtp.SmtpProtocolException)
{
result = NoticeSendResult.SendingImpossible;
}
catch (MailKit.Net.Smtp.SmtpCommandException e)
{
switch (e.StatusCode)
{
case MailKit.Net.Smtp.SmtpStatusCode.MailboxBusy:
case MailKit.Net.Smtp.SmtpStatusCode.MailboxUnavailable:
case MailKit.Net.Smtp.SmtpStatusCode.ExceededStorageAllocation:
result = NoticeSendResult.TryOnceAgain;
break;
case MailKit.Net.Smtp.SmtpStatusCode.MailboxNameNotAllowed:
case MailKit.Net.Smtp.SmtpStatusCode.UserNotLocalWillForward:
case MailKit.Net.Smtp.SmtpStatusCode.UserNotLocalTryAlternatePath:
result = NoticeSendResult.MessageIncorrect;
break;
default:
if (e.StatusCode != MailKit.Net.Smtp.SmtpStatusCode.Ok)
{
result = NoticeSendResult.TryOnceAgain;
}
break;
}
}
catch (Exception)
{
result = NoticeSendResult.SendingImpossible;
}
finally
{
if (smtpClient.IsConnected)
smtpClient.Disconnect(true);
smtpClient.Dispose();
}
return result;
}
private MimeMessage BuildMailMessage(NotifyMessage m)
{
var mimeMessage = new MimeMessage
{
Subject = m.Subject
};
var fromAddress = MailboxAddress.Parse(ParserOptions.Default, m.From);
mimeMessage.From.Add(fromAddress);
foreach (var to in m.To.Split(new[] { '|' }, StringSplitOptions.RemoveEmptyEntries))
{
mimeMessage.To.Add(MailboxAddress.Parse(ParserOptions.Default, to));
}
if (m.ContentType == Pattern.HTMLContentType)
{
var textPart = new TextPart("plain")
{
Text = HtmlUtil.GetText(m.Content),
ContentTransferEncoding = ContentEncoding.QuotedPrintable
};
var multipartAlternative = new MultipartAlternative { textPart };
var htmlPart = new TextPart("html")
{
Text = GetHtmlView(m.Content),
ContentTransferEncoding = ContentEncoding.QuotedPrintable
};
2019-08-01 08:47:15 +00:00
if (m.EmbeddedAttachments != null && m.EmbeddedAttachments.Count > 0)
2019-05-15 14:56:09 +00:00
{
2019-11-06 15:03:09 +00:00
var multipartRelated = new MultipartRelated
{
Root = htmlPart
2019-08-15 12:04:42 +00:00
};
2019-05-15 14:56:09 +00:00
foreach (var attachment in m.EmbeddedAttachments)
{
var mimeEntity = ConvertAttachmentToMimePart(attachment);
2019-08-15 12:04:42 +00:00
if (mimeEntity != null)
2019-05-15 14:56:09 +00:00
multipartRelated.Add(mimeEntity);
}
multipartAlternative.Add(multipartRelated);
}
else
{
multipartAlternative.Add(htmlPart);
}
mimeMessage.Body = multipartAlternative;
}
else
{
2019-11-06 15:03:09 +00:00
mimeMessage.Body = new TextPart("plain")
{
Text = m.Content,
ContentTransferEncoding = ContentEncoding.QuotedPrintable
2019-08-15 12:04:42 +00:00
};
2019-05-15 14:56:09 +00:00
}
if (!string.IsNullOrEmpty(m.ReplyTo))
{
mimeMessage.ReplyTo.Add(MailboxAddress.Parse(ParserOptions.Default, m.ReplyTo));
}
mimeMessage.Headers.Add("Auto-Submitted", string.IsNullOrEmpty(m.AutoSubmitted) ? "auto-generated" : m.AutoSubmitted);
2019-05-15 14:56:09 +00:00
return mimeMessage;
}
protected string GetHtmlView(string body)
{
return string.Format(HTML_FORMAT, body);
}
private MailKit.Net.Smtp.SmtpClient GetSmtpClient()
{
2019-09-24 10:32:12 +00:00
var sslCertificatePermit = Configuration["mail:certificate-permit"] != null &&
Convert.ToBoolean(Configuration["mail:certificate-permit"]);
2019-05-15 14:56:09 +00:00
var smtpClient = new MailKit.Net.Smtp.SmtpClient
{
ServerCertificateValidationCallback = (sender, certificate, chain, errors) =>
sslCertificatePermit || MailService.DefaultServerCertificateValidationCallback(sender, certificate, chain, errors),
Timeout = NETWORK_TIMEOUT
};
return smtpClient;
}
private static MimePart ConvertAttachmentToMimePart(NotifyMessageAttachment attachment)
{
try
{
if (attachment == null || string.IsNullOrEmpty(attachment.FileName) || string.IsNullOrEmpty(attachment.ContentId) || attachment.Content == null)
return null;
var extension = Path.GetExtension(attachment.FileName);
if (string.IsNullOrEmpty(extension))
return null;
return new MimePart("image", extension.TrimStart('.'))
{
ContentId = attachment.ContentId,
2019-08-01 08:47:15 +00:00
Content = new MimeContent(new MemoryStream(attachment.Content.ToByteArray())),
2019-05-15 14:56:09 +00:00
ContentDisposition = new ContentDisposition(ContentDisposition.Attachment),
ContentTransferEncoding = ContentEncoding.Base64,
FileName = attachment.FileName
};
}
catch (Exception)
{
return null;
}
2020-08-24 18:41:06 +00:00
}
}
public class SmtpSenderScope
{
2020-08-31 08:18:07 +00:00
private TenantManager TenantManager { get; }
private CoreConfiguration CoreConfiguration { get; }
2020-07-28 14:24:21 +00:00
2020-08-24 18:41:06 +00:00
public SmtpSenderScope(TenantManager tenantManager, CoreConfiguration coreConfiguration)
2020-07-28 14:24:21 +00:00
{
2020-08-24 18:41:06 +00:00
TenantManager = tenantManager;
CoreConfiguration = coreConfiguration;
}
2020-08-31 08:18:07 +00:00
public void Deconstruct(out TenantManager tenantManager, out CoreConfiguration coreConfiguration)
2020-09-30 14:47:42 +00:00
{
(tenantManager, coreConfiguration) = (TenantManager, CoreConfiguration);
}
2019-11-06 15:03:09 +00:00
}
public static class SmtpSenderExtension
{
2020-02-17 08:58:14 +00:00
public static DIHelper AddSmtpSenderService(this DIHelper services)
2019-11-06 15:03:09 +00:00
{
2020-10-12 19:39:23 +00:00
services.TryAddSingleton<SmtpSender>();
services.TryAddScoped<SmtpSenderScope>();
2019-11-06 15:03:09 +00:00
return services
.AddTenantManagerService()
.AddCoreSettingsService();
}
2019-05-15 14:56:09 +00:00
}
}