SUGCON EU 2019 - The Wheels on the Rebus go Queue, Queue, Queue

0.bounce.json

[
  {
    "campaign_id": "1234",
    "contact_identifier": "1234",
    "email": "pnavarra65456@connectivedx.com",
    "email_address_history_entry_id": "1234",
    "event": "bounce",
    "instance_id": "1234",
    "ip": "167.89.106.58",
    "message_id": "1234",
    "reason": "550 5.4.1 [pnavarra65456@connectivedx.com]: Recipient address rejected: Access denied [BY2NAM05FT005.eop-nam05.prod.protection.outlook.com]",
    "sg_event_id": "K-8dsTHFRqKipipvI40C3g",
    "sg_message_id": "cJzCzytgTeiyRns9uybNaQ.filter0071p3iad2-27823-5C320D7B-2A.0",
    "smtp-id": "<cJzCzytgTeiyRns9uybNaQ@ismtpd0051p1iad1.sendgrid.net>",
    "status": "5.4.1",
    "target_language": "1234",
    "test_value_index": "1234",
    "timestamp": 1546784125,
    "tls": 1,
    "type": "bounce"
  }
]

1.EmailBounceMessageBus.cs

namespace SitecoreHacker.London.Foundation.EmailCampaign.EDS.Messaging.Buses
{
	public sealed class EmailBounceMessageBus
	{
	}
}

2.EmailBounceMessage.cs

using System;
using Newtonsoft.Json;

namespace SitecoreHacker.London.Foundation.EmailCampaign.EDS.Messaging.Model
{
	[Serializable]
	public class EmailBounceMessage : EventMessageBase
	{
		[JsonProperty("ip")]
		public string IPAddress { get; set; }
		[JsonProperty("reason")]
		public string BounceReason { get; set; }
		[JsonProperty("status")]
		public string BounceStatus { get; set; }
		[JsonProperty("type")]
		public string BounceType { get; set; }

	}
}

3.WebhookController.cs

using System;
using System.Threading.Tasks;
using System.Web.Http;
using Newtonsoft.Json;
using Newtonsoft.Json.Converters;
using Newtonsoft.Json.Linq;
using Sitecore.Framework.Messaging;
using Sitecore.Modules.EmailCampaign.Core.Contacts;
using Sitecore.Modules.EmailCampaign.Core.Pipelines.HandleMessageEventBase;
using SitecoreHacker.London.Foundation.EmailCampaign.EDS.Messaging.Buses;
using SitecoreHacker.London.Foundation.EmailCampaign.EDS.Messaging.Model;
using SitecoreHacker.London.Foundation.EmailCampaign.Providers.SendGrid.Models;

namespace SitecoreHacker.London.Foundation.EmailCampaign.EDS.Events
{
	public class WebhookController : ApiController
	{
		private readonly IMessageBus<EmailBounceMessageBus> _emailBounceMessagesBus;
		private readonly IEventDataService _eventDataService;

		public const string Endpoint = "eds/events";
		public const string Keyname = "apikey";

		public WebhookController(IMessageBus<EmailBounceMessageBus> emailBounceMessagesBus, IEventDataService eventDataService)
		{
			_emailBounceMessagesBus = emailBounceMessagesBus;
			_eventDataService = eventDataService;
		}

		[HttpPost]
		[ActionName("DefaultAction")]
		[Route(Endpoint)]
		public async Task<IHttpActionResult> ProcessEvent(string apikey)
		{
			string result = await Request.Content.ReadAsStringAsync();
			var content = JsonConvert.DeserializeObject<ISendGridHook[]>(result, new SendGridHookConverter());
			try
			{
				foreach (var hookMessage in content)
				{
					switch (hookMessage)
					{
						case Bounce b:
							var bounceMessge = new EmailBounceMessage();
							bounceMessge.BounceReason = b.reason;
							bounceMessge.BounceStatus = b.status;
							bounceMessge.BounceType = b.type;
							bounceMessge.ContactIdentifier = _eventDataService.Decrypt(b.contact_identifier)?.ToContactIdentifier();
							bounceMessge.MessageId = Guid.TryParse(_eventDataService.Decrypt(b.message_id), out var messageid) ? messageid : Guid.Empty;
							bounceMessge.CampaignId = Guid.TryParse(b.campaign_id, out var campaignGuid) ? campaignGuid :  Guid.Empty;
							bounceMessge.IPAddress = b.ip;
							bounceMessge.EmailAddressHistoryEntryId = b.email_address_history_entry_id;
							bounceMessge.InstanceId = Guid.TryParse(_eventDataService.Decrypt(b.instance_id), out var instanceId) ? instanceId : Guid.Empty;
							bounceMessge.TargetLanguage = b.target_language;
							bounceMessge.TestValueIndex = byte.TryParse(b.test_value_index.ToString(),out var byteNum) ? byteNum : byte.MaxValue;
							DateTimeOffset dateTimeOffset = DateTimeOffset.FromUnixTimeSeconds(b.timestamp);
							bounceMessge.TimeStamp = dateTimeOffset.DateTime;
							await _emailBounceMessagesBus.SendAsync(bounceMessge);
							break;
						case Complaint c:
							break;
					}
				}

				return Ok(content.Length);
			}
			catch (Exception e)
			{
				return BadRequest(e.Message);
			}
		}
	}
}

4.EmailBounceMessageHandler.cs

using System;
using System.Threading.Tasks;
using Sitecore.EmailCampaign.Cm.Pipelines.HandleBounce;
using Sitecore.EmailCampaign.Model.Messaging;
using Sitecore.EmailCampaign.Model.XConnect.Events;
using Sitecore.ExM.Framework.Diagnostics;
using Sitecore.Framework.Messaging;
using Sitecore.Framework.Messaging.DeferStrategies;
using Sitecore.Modules.EmailCampaign.Core;
using Sitecore.Modules.EmailCampaign.Core.Contacts;
using SitecoreHacker.London.Foundation.EmailCampaign.EDS.Messaging.Buses;
using SitecoreHacker.London.Foundation.EmailCampaign.EDS.Messaging.Model;


namespace SitecoreHacker.London.Foundation.EmailCampaign.EDS.Messaging.Handlers
{
	public class EmailBounceMessageHandler : IMessageHandler<EmailBounceMessage>
	{
		private readonly ILogger _logger;
		private readonly PipelineHelper _pipelineHelper;
		private readonly IDeferStrategy<DeferDetectionByResultBase<HandlerResult>> _deferStrategy;
		private readonly IMessageBus<EmailBounceMessageBus> _bus;

		public EmailBounceMessageHandler(ILogger logger, PipelineHelper pipelineHelper, IDeferStrategy<DeferDetectionByResultBase<HandlerResult>> deferStrategy, IMessageBus<EmailBounceMessageBus> bus)
		{
			_logger = logger;
			_pipelineHelper = pipelineHelper;
			_deferStrategy = deferStrategy;
			_bus = bus;
		}
		public async Task Handle(EmailBounceMessage message, IMessageReceiveContext receiveContext, IMessageReplyContext replyContext)
		{
			var result = await _deferStrategy
				.ExecuteAsync(_bus, message, receiveContext, () => RegisterBounce(message));

			_logger.LogInfo(
				result.Deferred
					? $"[EmailBounceMessageHandler] defered message \'{message.MessageId}\' to \'{message.ContactIdentifier.ToLogFile()}\'."
					: $"[EmailBounceMessageHandler] processed message \'{message.MessageId}\' to \'{message.ContactIdentifier.ToLogFile()}\'");
		}

		private HandlerResult RegisterBounce(EmailBounceMessage message)
		{
			try
			{
				var contactIdentifier = message.ContactIdentifier;
				var emailOpenedEvent = new BounceEvent(message.TimeStamp);
				var messageId = message.MessageId;
				emailOpenedEvent.MessageId = messageId;
				var instanceId = message.InstanceId;
				emailOpenedEvent.InstanceId = instanceId;
				var targetLanguage = message.TargetLanguage;
				emailOpenedEvent.MessageLanguage = targetLanguage;
				var testValueIndex = message.TestValueIndex;
				emailOpenedEvent.TestValueIndex = testValueIndex;
				var addressHistoryEntryId = message.EmailAddressHistoryEntryId;
				emailOpenedEvent.EmailAddressHistoryEntryId = addressHistoryEntryId;
				_pipelineHelper.RunPipeline("handleUndeliveredMessage", new HandleBounceArgs(new EventData(contactIdentifier, emailOpenedEvent), true));
			}
			catch (Exception ex)
			{
				_logger.LogError("Failed to process an email opened task", ex);
				return new HandlerResult(HandlerResultType.Error);
			}
			return new HandlerResult(HandlerResultType.Successful);
		}
	}
}

5.InitializeMessageBus.cs

using System;
using Sitecore.Framework.Messaging;
using Sitecore.Pipelines;
using SitecoreHacker.London.Foundation.EmailCampaign.EDS.Messaging.Buses;

namespace SitecoreHacker.London.Foundation.EmailCampaign.EDS.Messaging.Pipelines.Initialize
{
	public class InitializeMessageBus
	{
		private readonly IServiceProvider _serviceProvider;

		public InitializeMessageBus(IServiceProvider serviceProvider)
		{
			_serviceProvider = serviceProvider;
		}

		public void Process(PipelineArgs args)
		{
			_serviceProvider.StartMessageBus<EmailBounceMessageBus>();
		}
	}
}

6.WebhookConfigurator.cs

using Microsoft.Extensions.DependencyInjection;
using Sitecore.DependencyInjection;
using Sitecore.Framework.Messaging;
using SitecoreHacker.London.Foundation.EmailCampaign.EDS.Messaging.Handlers;
using SitecoreHacker.London.Foundation.EmailCampaign.EDS.Messaging.Model;

namespace SitecoreHacker.London.Foundation.DependencyInjection
{
	public class WebhookConfigurator : IServicesConfigurator
	{
		public void Configure(IServiceCollection serviceCollection)
		{
			// configurator per project? Use this:
			serviceCollection.AddMvcControllersInCurrentAssembly();

			serviceCollection.AddTransient<IMessageHandler<EmailBounceMessage>, EmailBounceMessageHandler>();
		}
	}
}

7.Configuration.config

<?xml version="1.0" encoding="utf-8" ?>
<configuration xmlns:x="http://www.sitecore.net/xmlconfig/" xmlns:role="http://www.sitecore.net/xmlconfig/role/" xmlns:eds="http://www.sitecore.net/xmlconfig/eds/" xmlns:exmEnabled="http://www.sitecore.net/xmlconfig/exmEnabled/">
	<sitecore exmEnabled:require="yes">
		<pipelines>
			<initialize>
				<processor type="SitecoreHacker.London.Foundation.DependencyInjection.Initialize.RegisterWebhookRoute, SitecoreHacker.London" />
				<processor type="SitecoreHacker.London.Foundation.EmailCampaign.EDS.Messaging.Pipelines.Initialize.InitializeMessageBus, SitecoreHacker.London" resolve="true" />
			</initialize>
		</pipelines>
		<services>
			<configurator type="SitecoreHacker.London.Foundation.DependencyInjection.WebhookConfigurator, SitecoreHacker.London" />
		</services>

		<Messaging>
			<Rebus>
				<SitecoreHacker.London.Foundation.EmailCampaign.EDS.Messaging.Buses.EmailBounceMessageBus>
					<Transport>
						<SqlServer>
							<OneWay role:require="(Standalone or ContentManagement) and !ContentDelivery">false</OneWay>
							<OneWay role:require="ContentDelivery">true</OneWay>
							<ConnectionStringOrName>messaging</ConnectionStringOrName>
							<TableName>Sitecore_Transport</TableName>
							<InputQueueName>EmailBounceMessageQueue</InputQueueName>
						</SqlServer>
					</Transport>
					<Routing>
						<TypeBasedMappings>
							<TypeMappings>
								<EmailBounceMapping>
									<Type>SitecoreHacker.London.Foundation.EmailCampaign.EDS.Messaging.Model.EmailBounceMessage, SitecoreHacker.London</Type>
									<DestinationQueue>EmailBounceMessageQueue</DestinationQueue>
								</EmailBounceMapping>
							</TypeMappings>
						</TypeBasedMappings>
					</Routing>
					<Options role:require="Standalone or ContentManagement">
						<SetNumberOfWorkers>1</SetNumberOfWorkers>
						<SimpleRetryStrategy>
							<ErrorQueueAddress>Error</ErrorQueueAddress>
							<MaxDeliveryAttempts>1</MaxDeliveryAttempts>
							<SecondLevelRetriesEnabled>false</SecondLevelRetriesEnabled>
						</SimpleRetryStrategy>
					</Options>
					<Logging Type="Sitecore.Messaging.SitecoreLoggerFactory,Sitecore.Messaging"/>
				</SitecoreHacker.London.Foundation.EmailCampaign.EDS.Messaging.Buses.EmailBounceMessageBus>
			</Rebus>
		</Messaging>

	</sitecore>
</configuration>