add email notification when new video available solve

src/DevBetterWeb.Infrastructure/Handlers/SendEmailVideoAddedHandler.cs

@@ -0,0 +1,35 @@
+using System.Threading.Tasks;
+using DevBetterWeb.Core.Events;
+using DevBetterWeb.Core.Interfaces;
+using DevBetterWeb.Infrastructure.Interfaces;
+
+namespace DevBetterWeb.Core.Handlers;
+
+public class SendEmailVideoAddedHandler : IHandle<VideoAddedEvent>
+{
+	private readonly IGetUsersHaveRolesService _getUsersHaveRolesService;
+	private readonly IEmailService _emailService;
+
+	public SendEmailVideoAddedHandler(IGetUsersHaveRolesService getUsersHaveRolesService, IEmailService emailService)
+	{
+		_getUsersHaveRolesService = getUsersHaveRolesService;
+		_emailService = emailService;
+	}
+
+  public static string ReturnMessageString(VideoAddedEvent domainEvent)
+  {
+    return $"Video {domainEvent.Video.Title} is added! " +
+        $"Check out the video here: https://devbetter.com/Videos/Details/{domainEvent.Video.VideoId}.";
+  }
+
+  public async Task Handle(VideoAddedEvent domainEvent)
+  {
+		var message = ReturnMessageString(domainEvent);
+    var activeUsers = await _getUsersHaveRolesService.ExecuteAsync();
+
+    foreach (var activeUser in activeUsers)
+    {
+			await _emailService.SendEmailAsync(activeUser.UserName!, "DevBetter New Video", message);
+		}
+  }
+}

src/DevBetterWeb.Infrastructure/Interfaces/IGetUsersHaveRolesService.cs

@@ -0,0 +1,9 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Identity;
+
+namespace DevBetterWeb.Infrastructure.Interfaces;
+public interface IGetUsersHaveRolesService
+{
+	Task<List<IdentityUser>> ExecuteAsync();
+}

src/DevBetterWeb.Infrastructure/Services/GetUsersHaveRolesService.cs

@@ -0,0 +1,41 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using DevBetterWeb.Infrastructure.Interfaces;
+using Microsoft.AspNetCore.Identity;
+
+namespace DevBetterWeb.Infrastructure.Services;
+
+public class GetUsersHaveRolesService : IGetUsersHaveRolesService
+{
+	private readonly UserManager<IdentityUser> _userManager;
+
+	public GetUsersHaveRolesService(UserManager<IdentityUser> userManager)
+	{
+		_userManager = userManager;
+	}
+
+	public async Task<List<IdentityUser>> ExecuteAsync()
+	{
+		var usersWithRoles = new List<IdentityUser>();
+
+		var allUsers = _userManager.Users.ToList();
+		foreach (var user in allUsers)
+		{
+			if (user.UserName == null)
+			{
+				continue;
+			}
+			var roles = await _userManager.GetRolesAsync(user);
+
+			if (roles.Any())
+			{
+				usersWithRoles.Add(user);
+			}
+		}
+
+		return usersWithRoles;
+	}
+}

src/DevBetterWeb.Web/Program.cs

@@ -31,6 +31,7 @@
 using DevBetterWeb.Infrastructure;
 using Microsoft.Extensions.Configuration;
 using NimblePros.Vimeo.Extensions;
+using DevBetterWeb.Infrastructure.Interfaces;
 
 // 29 Aug 2023 - Getting a nullref in here somewhere maybe? Also a stack overflow during startup somewhere.
 
@@ -122,6 +123,7 @@
 builder.Services.AddScoped<ILeaderboardService, LeaderboardService>();
 builder.Services.AddScoped<IAddCreatedVideoToFolderService, AddCreatedVideoToFolderService>();
 builder.Services.AddScoped<ICreateVideoService, CreateVideoService>();
+builder.Services.AddScoped<IGetUsersHaveRolesService, GetUsersHaveRolesService>();
 builder.Services.AddScoped(typeof(ILocalMigrationService<>), typeof(MigrationService<>));
 
 VimeoSettings vimeoSettings = builder.Configuration.GetSection(Constants.ConfigKeys.VimeoSettings)!.Get<VimeoSettings>()!;