From 3a1e16a7a05c8bdc0b28e58824b78b2f3e87c013 Mon Sep 17 00:00:00 2001
From: TekH <h.tek@digitaldata.works>
Date: Sun, 12 Jul 2026 00:04:40 +0200
Subject: [PATCH] feat: Update Application layer for Hangfire integration

- Add CronSchedule property to CfgProfileDto for scheduling support
- Create ProfileSqlJobDto for SQL job execution data transfer
- Update TriggeringDEXJobBatchCommand to accept ProfileId and Jobs collection
- Make TriggeringDEXJobBatchCommand public for Hangfire job activation
- Update Application DependencyInjection with required service registrations
---
 .../Common/Dtos/CfgProfileDto.cs              | 53 +------------------
 .../Common/Dtos/ProfileSqlJobDto.cs           | 53 +++++++++++++++++++
 .../Commands/TriggeringDEXJobBatchCommand.cs  |  2 +-
 .../DependencyInjection.cs                    |  7 ++-
 4 files changed, 61 insertions(+), 54 deletions(-)
 create mode 100644 ECMJobRunner.Application/Common/Dtos/ProfileSqlJobDto.cs

diff --git a/ECMJobRunner.Application/Common/Dtos/CfgProfileDto.cs b/ECMJobRunner.Application/Common/Dtos/CfgProfileDto.cs
index 893b384..d64f40b 100644
--- a/ECMJobRunner.Application/Common/Dtos/CfgProfileDto.cs
+++ b/ECMJobRunner.Application/Common/Dtos/CfgProfileDto.cs
@@ -7,7 +7,7 @@ namespace ECMJobRunner.Application.Common.Dtos
     /// Data Transfer Object for CfgProfile entity
     /// Used for querying and returning profile data
     /// </summary>
-    public class CfgProfileDto
+    public record CfgProfileDto
     {
         /// <summary>
         /// Profile ID
@@ -64,55 +64,4 @@ namespace ECMJobRunner.Application.Common.Dtos
         /// </summary>
         public List<ProfileSqlJobDto>? SqlJobs { get; set; }
     }
-
-    /// <summary>
-    /// Data Transfer Object for ProfileSqlJob entity
-    /// </summary>
-    public class ProfileSqlJobDto
-    {
-        /// <summary>
-        /// SQL Job ID
-        /// </summary>
-        public long Id { get; set; }
-
-        /// <summary>
-        /// Profile ID (foreign key)
-        /// </summary>
-        public long ProfileId { get; set; }
-
-        /// <summary>
-        /// Active / Inactive switch
-        /// </summary>
-        public bool Active { get; set; }
-
-        /// <summary>
-        /// Execution sequence order
-        /// </summary>
-        public short Sequence { get; set; }
-
-        /// <summary>
-        /// Job name
-        /// </summary>
-        public string? Name { get; set; }
-
-        /// <summary>
-        /// SQL query for pre-check validation
-        /// </summary>
-        public string? SqlCheckQuery { get; set; }
-
-        /// <summary>
-        /// Main SQL query to execute
-        /// </summary>
-        public string? SqlMainQuery { get; set; }
-
-        /// <summary>
-        /// API command to execute
-        /// </summary>
-        public string? ApiCommand { get; set; }
-
-        /// <summary>
-        /// Optional description
-        /// </summary>
-        public string? Comment { get; set; }
-    }
 }
diff --git a/ECMJobRunner.Application/Common/Dtos/ProfileSqlJobDto.cs b/ECMJobRunner.Application/Common/Dtos/ProfileSqlJobDto.cs
new file mode 100644
index 0000000..63bd731
--- /dev/null
+++ b/ECMJobRunner.Application/Common/Dtos/ProfileSqlJobDto.cs
@@ -0,0 +1,53 @@
+namespace ECMJobRunner.Application.Common.Dtos
+{
+    /// <summary>
+    /// Data Transfer Object for ProfileSqlJob entity
+    /// </summary>
+    public class ProfileSqlJobDto
+    {
+        /// <summary>
+        /// SQL Job ID
+        /// </summary>
+        public long Id { get; set; }
+
+        /// <summary>
+        /// Profile ID (foreign key)
+        /// </summary>
+        public long ProfileId { get; set; }
+
+        /// <summary>
+        /// Active / Inactive switch
+        /// </summary>
+        public bool Active { get; set; }
+
+        /// <summary>
+        /// Execution sequence order
+        /// </summary>
+        public short Sequence { get; set; }
+
+        /// <summary>
+        /// Job name
+        /// </summary>
+        public string? Name { get; set; }
+
+        /// <summary>
+        /// SQL query for pre-check validation
+        /// </summary>
+        public string? SqlCheckQuery { get; set; }
+
+        /// <summary>
+        /// Main SQL query to execute
+        /// </summary>
+        public string? SqlMainQuery { get; set; }
+
+        /// <summary>
+        /// API command to execute
+        /// </summary>
+        public string? ApiCommand { get; set; }
+
+        /// <summary>
+        /// Optional description
+        /// </summary>
+        public string? Comment { get; set; }
+    }
+}
diff --git a/ECMJobRunner.Application/DEXJob/Commands/TriggeringDEXJobBatchCommand.cs b/ECMJobRunner.Application/DEXJob/Commands/TriggeringDEXJobBatchCommand.cs
index cf4c28f..91fb1f0 100644
--- a/ECMJobRunner.Application/DEXJob/Commands/TriggeringDEXJobBatchCommand.cs
+++ b/ECMJobRunner.Application/DEXJob/Commands/TriggeringDEXJobBatchCommand.cs
@@ -17,7 +17,7 @@ namespace ECMJobRunner.Application.DEXJob.Commands
         /// <summary>
         /// Profile ID to trigger all associated SQL jobs
         /// </summary>
-        public int ProfileId { get; set; }
+        public long ProfileId { get; set; }
     }
 
     /// <summary>
diff --git a/ECMJobRunner.Application/DependencyInjection.cs b/ECMJobRunner.Application/DependencyInjection.cs
index 060e1b9..f387338 100644
--- a/ECMJobRunner.Application/DependencyInjection.cs
+++ b/ECMJobRunner.Application/DependencyInjection.cs
@@ -1,6 +1,7 @@
 using ECMJobRunner.Application.Behaviors;
 using MediatR;
 using Microsoft.Extensions.DependencyInjection;
+using ReC.Client;
 using System.Reflection;
 
 namespace ECMJobRunner.Application
@@ -16,7 +17,7 @@ namespace ECMJobRunner.Application
         /// </summary>
         /// <param name="services">The service collection</param>
         /// <returns>The service collection for chaining</returns>
-        public static IServiceCollection AddApplication(this IServiceCollection services)
+        public static IServiceCollection AddJobRunnerServices(this IServiceCollection services, string recClientApiUrl)
         {
             var assembly = Assembly.GetExecutingAssembly();
 
@@ -26,6 +27,10 @@ namespace ECMJobRunner.Application
 #else
             services.AddMediatR(cfg => cfg.RegisterServicesFromAssembly(assembly));
 #endif
+            services.AddRecClient(recClientApiUrl, opt =>
+            {
+                opt.LogSuccessfulRequests = true;
+            });
 
             // Register pipeline behaviors in execution order
             // Order matters: MainQuery -> CheckQuery -> ReCRequest