squidex/backend/extensions/Squidex.Extensions/Actions/Email/EmailFlowStep.cs

// ==========================================================================
//  Squidex Headless CMS
// ==========================================================================
//  Copyright (c) Squidex UG (haftungsbeschraenkt)
//  All rights reserved. Licensed under the MIT license.
// ==========================================================================

using System.ComponentModel.DataAnnotations;
using MailKit.Net.Smtp;
using MimeKit;
using MimeKit.Text;
using Squidex.Domain.Apps.Core.Rules.Deprecated;
using Squidex.Flows;
using Squidex.Infrastructure.Reflection;
using Squidex.Infrastructure.Validation;

namespace Squidex.Extensions.Actions.Email;

[FlowStep(
    Title = "Email",
    IconImage = "<svg xmlns='http://www.w3.org/2000/svg' viewBox='0 0 32 32'><path d='M28 5h-24c-2.209 0-4 1.792-4 4v13c0 2.209 1.791 4 4 4h24c2.209 0 4-1.791 4-4v-13c0-2.208-1.791-4-4-4zM2 10.25l6.999 5.25-6.999 5.25v-10.5zM30 22c0 1.104-0.898 2-2 2h-24c-1.103 0-2-0.896-2-2l7.832-5.875 4.368 3.277c0.533 0.398 1.166 0.6 1.8 0.6 0.633 0 1.266-0.201 1.799-0.6l4.369-3.277 7.832 5.875zM30 20.75l-7-5.25 7-5.25v10.5zM17.199 18.602c-0.349 0.262-0.763 0.4-1.199 0.4s-0.851-0.139-1.2-0.4l-12.8-9.602c0-1.103 0.897-2 2-2h24c1.102 0 2 0.897 2 2l-12.801 9.602z'/></svg>",
    IconColor = "#333300",
    Display = "Send an email",
    Description = "Send an email with a custom SMTP server.",
    ReadMore = "https://en.wikipedia.org/wiki/Email")]
#pragma warning disable CS0618 // Type or member is obsolete
internal sealed record EmailFlowStep : FlowStep, IConvertibleToAction
#pragma warning restore CS0618 // Type or member is obsolete
{
    [LocalizedRequired]
    [Display(Name = "Server Host", Description = "The IP address or host to the SMTP server.")]
    [Editor(FlowStepEditor.Text)]
    public string ServerHost { get; set; }

    [LocalizedRequired]
    [Display(Name = "Server Port", Description = "The port to the SMTP server.")]
    [Editor(FlowStepEditor.Text)]
    public int ServerPort { get; set; }

    [Display(Name = "Username", Description = "The username for the SMTP server.")]
    [Editor(FlowStepEditor.Text)]
    [Expression]
    public string ServerUsername { get; set; }

    [Display(Name = "Password", Description = "The password for the SMTP server.")]
    [Editor(FlowStepEditor.Password)]
    public string ServerPassword { get; set; }

    [LocalizedRequired]
    [Display(Name = "From Address", Description = "The email sending address.")]
    [Editor(FlowStepEditor.Text)]
    [Expression]
    public string MessageFrom { get; set; }

    [LocalizedRequired]
    [Display(Name = "To Address", Description = "The email message will be sent to.")]
    [Editor(FlowStepEditor.Text)]
    [Expression]
    public string MessageTo { get; set; }

    [LocalizedRequired]
    [Display(Name = "Subject", Description = "The subject line for this email message.")]
    [Editor(FlowStepEditor.Text)]
    [Expression]
    public string MessageSubject { get; set; }

    [LocalizedRequired]
    [Display(Name = "Body", Description = "The message body.")]
    [Editor(FlowStepEditor.TextArea)]
    [Expression]
    public string MessageBody { get; set; }

    public override async ValueTask<FlowStepResult> ExecuteAsync(FlowExecutionContext executionContext,
        CancellationToken ct)
    {
        if (executionContext.IsSimulation)
        {
            executionContext.LogSkipSimulation();
            return Next();
        }

        using var smtpClient = new SmtpClient();

        await smtpClient.ConnectAsync(ServerHost, ServerPort, cancellationToken: ct);

        if (!string.IsNullOrWhiteSpace(ServerUsername) && !string.IsNullOrWhiteSpace(ServerPassword))
        {
            await smtpClient.AuthenticateAsync(ServerUsername, ServerPassword, ct);
        }

        var smtpMessage = new MimeMessage
        {
            Body = new TextPart(TextFormat.Html)
            {
                Text = MessageBody,
            },
            Subject = MessageSubject,
        };

        smtpMessage.From.Add(MailboxAddress.Parse(
            MessageFrom));

        smtpMessage.To.Add(MailboxAddress.Parse(
            MessageTo));

        await smtpClient.SendAsync(smtpMessage, ct);

        executionContext.Log($"Email sent to {MessageTo}");
        return Next();
    }

#pragma warning disable CS0618 // Type or member is obsolete
    public RuleAction ToAction()
    {
        return SimpleMapper.Map(this, new EmailAction());
    }
#pragma warning restore CS0618 // Type or member is obsolete
}