using AsbCloudApp.Data; using AsbCloudApp.Services.Notifications; using AsbCloudInfrastructure.Background; using Microsoft.Extensions.Configuration; using System.Collections.Generic; using System.Linq; using System.Threading; using System.Threading.Tasks; namespace AsbCloudInfrastructure.Services.Email { public class EmailNotificationTransportService : INotificationTransportService { private readonly BackgroundWorker backgroundWorker; private IConfiguration configuration; public EmailNotificationTransportService(BackgroundWorker backgroundWorker, IConfiguration configuration) { this.configuration = configuration; this.backgroundWorker = backgroundWorker; } public int IdTransportType => 1; public Task SendAsync(NotificationDto notification, CancellationToken cancellationToken) { var workId = MakeWorkId(notification.IdUser, notification.Title, notification.Message); if (!backgroundWorker.Works.Any(w => w.Id == workId)) { var work = new WorkToSendEmail(workId, notification, configuration); backgroundWorker.Enqueue(work); } return Task.CompletedTask; } public Task SendRangeAsync(IEnumerable notifications, CancellationToken cancellationToken) { var tasks = notifications .Select(notification => SendAsync(notification, cancellationToken)); return Task.WhenAll(tasks); } private static string MakeWorkId(int idUser, string subject, string content) { var hash = idUser.GetHashCode(); hash ^= subject.GetHashCode(); hash ^= content.GetHashCode(); return hash.ToString("x"); } } }