CU-8687aj3gt Updated angular, fixed build and added novu

Author: ucswift

Core/Resgrid.Config/ChatConfig.cs

@@ -4,5 +4,10 @@ public static class ChatConfig
 	{
 		public static string DepartmentChatPrefix = "D1_";
 		public static string DepartmentGroupChatPrefix = "DG1_";
+		public static string NovuBackendUrl = "";
+		public static string NovuSocketUrl = "";
+		public static string NovuEnvironmentId = "";
+		public static string NovuApplicationId = "";
+		public static string NovuSecretKey = "";
 	}
 }

Core/Resgrid.Model/Providers/Models/INovuProvider.cs

@@ -0,0 +1,8 @@
+using System.Threading.Tasks;
+
+namespace Resgrid.Model.Providers;
+
+public interface INovuProvider
+{
+	Task<bool> CreateSubscriber(string userId, int departmentId, string email, string firstName, string lastName);
+}

Providers/Resgrid.Providers.Messaging/Class1.cs

@@ -0,0 +1,13 @@
+using Autofac;
+using Resgrid.Model.Providers;
+
+namespace Resgrid.Providers.Messaging
+{
+	public class MessagingProviderModule : Module
+	{
+		protected override void Load(ContainerBuilder builder)
+		{
+			builder.RegisterType<NovuProvider>().As<INovuProvider>().InstancePerLifetimeScope();
+		}
+	}
+}

Providers/Resgrid.Providers.Messaging/MessagingProviderModule.cs

@@ -0,0 +1,50 @@
+using Novu;
+using Novu.Domain.Models.Subscribers;
+using Resgrid.Framework;
+using Resgrid.Model.Providers;
+
+namespace Resgrid.Providers.Messaging
+{
+	public class NovuProvider: INovuProvider
+	{
+		public async Task<bool> CreateSubscriber(string userId, int departmentId, string email, string firstName, string lastName)
+		{
+			try
+			{
+				var novuConfiguration = new NovuClientConfiguration
+				{
+					Url = Config.ChatConfig.NovuBackendUrl, //"https://novu-api.my-domain.com/v1",
+					ApiKey = Config.ChatConfig.NovuSecretKey //"12345",
+				};
+
+				var novu = new NovuClient(novuConfiguration);
+
+				var subscriberCreateData = new SubscriberCreateData();
+				subscriberCreateData.SubscriberId = userId;
+				subscriberCreateData.FirstName = firstName;
+				subscriberCreateData.LastName = lastName;
+				subscriberCreateData.Email = email;
+				subscriberCreateData.Data = new List<AdditionalData>();
+				subscriberCreateData.Data.Add(new AdditionalData
+				{
+					Key = "DepartmentId",
+					Value = departmentId.ToString()
+				});
+
+				var subscriber = await novu.Subscriber.Create(subscriberCreateData);
+
+				if (subscriber != null && subscriber.Data != null)
+					return true;
+
+				return false;
+			}
+			catch (Exception e)
+			{
+				Logging.LogException(e, "Failed to create novu subscriber");
+				return false;
+			}
+		}
+
+
+	}
+}

Providers/Resgrid.Providers.Messaging/NovuProvider.cs

@@ -7,11 +7,18 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="Autofac" Version="8.0.0" />
+    <PackageReference Include="Novu" Version="0.6.0" />
     <PackageReference Include="WhatsappBusiness.CloudApi" Version="1.0.35" />
   </ItemGroup>
 
   <ItemGroup>
     <Folder Include="Whatsapp\" />
   </ItemGroup>
 
+  <ItemGroup>
+    <ProjectReference Include="..\..\Core\Resgrid.Config\Resgrid.Config.csproj" />
+    <ProjectReference Include="..\..\Core\Resgrid.Model\Resgrid.Model.csproj" />
+  </ItemGroup>
+
 </Project>

Providers/Resgrid.Providers.Messaging/Resgrid.Providers.Messaging.csproj

@@ -61,6 +61,7 @@
     <ProjectReference Include="..\..\Providers\Resgrid.Providers.Firebase\Resgrid.Providers.Firebase.csproj" />
     <ProjectReference Include="..\..\Providers\Resgrid.Providers.Geo\Resgrid.Providers.Geo.csproj" />
     <ProjectReference Include="..\..\Providers\Resgrid.Providers.Marketing\Resgrid.Providers.Marketing.csproj" />
+    <ProjectReference Include="..\..\Providers\Resgrid.Providers.Messaging\Resgrid.Providers.Messaging.csproj" />
     <ProjectReference Include="..\..\Providers\Resgrid.Providers.Migrations\Resgrid.Providers.Migrations.csproj" />
     <ProjectReference Include="..\..\Providers\Resgrid.Providers.Number\Resgrid.Providers.Number.csproj" />
     <ProjectReference Include="..\..\Providers\Resgrid.Providers.Pdf\Resgrid.Providers.Pdf.csproj" />

Web/Resgrid.Web.Eventing/Resgrid.Web.Eventing.csproj

@@ -49,6 +49,7 @@
 using Org.BouncyCastle.Asn1.Ess;
 using IPNetwork = Microsoft.AspNetCore.HttpOverrides.IPNetwork;
 using System.Net.Http;
+using Resgrid.Providers.Messaging;
 
 namespace Resgrid.Web.Eventing
 {
@@ -75,7 +76,7 @@ public Startup(IHostingEnvironment env)
 		public void ConfigureServices(IServiceCollection services)
 		{
 			IdentityModelEventSource.ShowPII = true;
-			
+
 			bool configResult = ConfigProcessor.LoadAndProcessConfig(Configuration["AppOptions:ConfigPath"]);
 			bool envConfigResult = ConfigProcessor.LoadAndProcessEnvVariables(Configuration.AsEnumerable());
 
@@ -284,10 +285,10 @@ public void ConfigureServices(IServiceCollection services)
 				options.RequireHttpsMetadata = false;
 				options.Audience = JwtConfig.Audience;
 				options.TokenValidationParameters = tokenValidationParameters;
-				
+
 				// We have to hook the OnMessageReceived event in order to
 				// allow the JWT authentication handler to read the access
-				// token from the query string when a WebSocket or 
+				// token from the query string when a WebSocket or
 				// Server-Sent Events request comes in.
 
 				// Sending the access token in the query string is required due to
@@ -337,6 +338,7 @@ public void ConfigureContainer(ContainerBuilder builder)
 			builder.RegisterModule(new MarketingModule());
 			builder.RegisterModule(new PdfProviderModule());
 			builder.RegisterModule(new FirebaseProviderModule());
+			builder.RegisterModule(new MessagingProviderModule());
 
 			builder.RegisterType<IdentityUserStore>().As<IUserStore<Model.Identity.IdentityUser>>().InstancePerLifetimeScope();
 			builder.RegisterType<IdentityRoleStore>().As<IRoleStore<Model.Identity.IdentityRole>>().InstancePerLifetimeScope();

Web/Resgrid.Web.Eventing/Startup.cs

@@ -73,6 +73,11 @@ public async Task<ActionResult<GetConfigResult>> GetConfig(string key)
 			result.Data.PersonnelLocationMinMeters = MappingConfig.PersonnelLocationMinMeters;
 			result.Data.UnitLocationMinMeters = MappingConfig.UnitLocationMinMeters;
 
+			result.Data.NovuEnvironmentId = ChatConfig.NovuEnvironmentId;
+			result.Data.NovuApplicationId = ChatConfig.NovuApplicationId;
+			result.Data.NovuBackendApiUrl = ChatConfig.NovuBackendUrl;
+			result.Data.NovuSocketUrl = ChatConfig.NovuSocketUrl;
+
 			result.PageSize = 1;
 			result.Status = ResponseHelper.Success;
 			ResponseHelper.PopulateV4ResponseData(result);

Web/Resgrid.Web.ServicesCore/Controllers/v4/ConfigController.cs

@@ -6,6 +6,7 @@
 using Resgrid.Web.Services.Helpers;
 using Resgrid.Web.Services.Models.v4.Security;
 using Resgrid.Model;
+using Resgrid.Model.Providers;
 
 namespace Resgrid.Web.Services.Controllers.v4
 {
@@ -23,18 +24,21 @@ public class SecurityController : V4AuthenticatedApiControllerbase
 		private readonly IPermissionsService _permissionsService;
 		private readonly IPersonnelRolesService _personnelRolesService;
 		private readonly IUserProfileService _userProfileService;
+		private readonly INovuProvider _novuProvider;
 
 		/// <summary>
 		/// Operations to perform against the security sub-system
 		/// </summary>
 		public SecurityController(IDepartmentsService departmentsService, IDepartmentGroupsService departmentGroupsService,
-			IPermissionsService permissionsService, IPersonnelRolesService personnelRolesService, IUserProfileService userProfileService)
+			IPermissionsService permissionsService, IPersonnelRolesService personnelRolesService, IUserProfileService userProfileService,
+			INovuProvider novuProvider)
 		{
 			_departmentsService = departmentsService;
 			_departmentGroupsService = departmentGroupsService;
 			_permissionsService = permissionsService;
 			_personnelRolesService = personnelRolesService;
 			_userProfileService = userProfileService;
+			_novuProvider = novuProvider;
 		}
 		#endregion Members and Constructors
 
@@ -95,6 +99,8 @@ public async Task<ActionResult<DepartmentRightsResult>> GetCurrentUsersRights()
 			result.Data.CanAddNote = _permissionsService.IsUserAllowed(createNotePermission, result.Data.IsAdmin, isGroupAdmin, roles);
 			result.Data.CanCreateMessage = _permissionsService.IsUserAllowed(createMessagePermission, result.Data.IsAdmin, isGroupAdmin, roles);
 
+			var novuSuccess = await _novuProvider.CreateSubscriber(UserId, DepartmentId, profile.MembershipEmail, profile.FirstName, profile.LastName);
+
 			result.PageSize = 1;
 			result.Status = ResponseHelper.Success;
 			ResponseHelper.PopulateV4ResponseData(result);