diff --git a/ECMJobRunner.Application/DependencyInjection.cs b/ECMJobRunner.Application/DependencyInjection.cs index e36928d..e52a5b3 100644 --- a/ECMJobRunner.Application/DependencyInjection.cs +++ b/ECMJobRunner.Application/DependencyInjection.cs @@ -1,4 +1,4 @@ -using ECMJobRunner.Application.DEXJob.Commands.Behaviors; +using ECMJobRunner.Application.Profiles.Commands.Behaviors; using MediatR; using Microsoft.Extensions.DependencyInjection; using ReC.Client; diff --git a/ECMJobRunner.Application/DEXJob/Commands/Behaviors/CheckQueryExecutionBehavior.cs b/ECMJobRunner.Application/Profiles/Commands/Behaviors/CheckQueryExecutionBehavior.cs similarity index 94% rename from ECMJobRunner.Application/DEXJob/Commands/Behaviors/CheckQueryExecutionBehavior.cs rename to ECMJobRunner.Application/Profiles/Commands/Behaviors/CheckQueryExecutionBehavior.cs index d0f4f3d..a57f7cf 100644 --- a/ECMJobRunner.Application/DEXJob/Commands/Behaviors/CheckQueryExecutionBehavior.cs +++ b/ECMJobRunner.Application/Profiles/Commands/Behaviors/CheckQueryExecutionBehavior.cs @@ -3,7 +3,7 @@ using ECMJobRunner.Application.Common.Dtos; using ECMJobRunner.Application.Common.Exceptions; using ECMJobRunner.Application.Common.Interfaces; using ECMJobRunner.Application.Common.Options; -using ECMJobRunner.Application.DEXJob.Commands; +using ECMJobRunner.Application.Profiles.Commands; using MediatR; using Microsoft.Extensions.Options; using System; @@ -11,7 +11,7 @@ using System.Text.RegularExpressions; using System.Threading; using System.Threading.Tasks; -namespace ECMJobRunner.Application.DEXJob.Commands.Behaviors +namespace ECMJobRunner.Application.Profiles.Commands.Behaviors { /// /// Pipeline behavior that executes the check SQL query for DEX jobs @@ -46,7 +46,7 @@ namespace ECMJobRunner.Application.DEXJob.Commands.Behaviors public async Task Handle(TRequest request, RequestHandlerDelegate next, CancellationToken cancellationToken) #endif { - if (request is TriggeringDEXJobCommand command) + if (request is TriggeringProfileJobCommand command) { await ExecuteCheckQueryAsync(command, cancellationToken); } @@ -54,7 +54,7 @@ namespace ECMJobRunner.Application.DEXJob.Commands.Behaviors return await next(); } - private async Task ExecuteCheckQueryAsync(TriggeringDEXJobCommand command, CancellationToken cancel) + private async Task ExecuteCheckQueryAsync(TriggeringProfileJobCommand command, CancellationToken cancel) { if (!string.IsNullOrWhiteSpace(command.Job.SqlCheckQuery)) { diff --git a/ECMJobRunner.Application/DEXJob/Commands/Behaviors/MainQueryExecutionBehavior.cs b/ECMJobRunner.Application/Profiles/Commands/Behaviors/MainQueryExecutionBehavior.cs similarity index 94% rename from ECMJobRunner.Application/DEXJob/Commands/Behaviors/MainQueryExecutionBehavior.cs rename to ECMJobRunner.Application/Profiles/Commands/Behaviors/MainQueryExecutionBehavior.cs index 45866c2..c76afd8 100644 --- a/ECMJobRunner.Application/DEXJob/Commands/Behaviors/MainQueryExecutionBehavior.cs +++ b/ECMJobRunner.Application/Profiles/Commands/Behaviors/MainQueryExecutionBehavior.cs @@ -3,7 +3,7 @@ using ECMJobRunner.Application.Common.Dtos; using ECMJobRunner.Application.Common.Exceptions; using ECMJobRunner.Application.Common.Interfaces; using ECMJobRunner.Application.Common.Options; -using ECMJobRunner.Application.DEXJob.Commands; +using ECMJobRunner.Application.Profiles.Commands; using MediatR; using Microsoft.Extensions.Options; using System; @@ -11,7 +11,7 @@ using System.Text.RegularExpressions; using System.Threading; using System.Threading.Tasks; -namespace ECMJobRunner.Application.DEXJob.Commands.Behaviors +namespace ECMJobRunner.Application.Profiles.Commands.Behaviors { /// /// Pipeline behavior that executes the main SQL query for DEX jobs @@ -46,7 +46,7 @@ namespace ECMJobRunner.Application.DEXJob.Commands.Behaviors public async Task Handle(TRequest request, RequestHandlerDelegate next, CancellationToken cancellationToken) #endif { - if (request is TriggeringDEXJobCommand command) + if (request is TriggeringProfileJobCommand command) { await ExecuteMainQueryAsync(command, cancellationToken); } @@ -54,7 +54,7 @@ namespace ECMJobRunner.Application.DEXJob.Commands.Behaviors return await next(); } - private async Task ExecuteMainQueryAsync(TriggeringDEXJobCommand command, CancellationToken cancel) + private async Task ExecuteMainQueryAsync(TriggeringProfileJobCommand command, CancellationToken cancel) { if (!string.IsNullOrWhiteSpace(command.Job.SqlMainQuery)) { diff --git a/ECMJobRunner.Application/DEXJob/Commands/Behaviors/ReCRequestExecutionBehavior.cs b/ECMJobRunner.Application/Profiles/Commands/Behaviors/ReCRequestExecutionBehavior.cs similarity index 90% rename from ECMJobRunner.Application/DEXJob/Commands/Behaviors/ReCRequestExecutionBehavior.cs rename to ECMJobRunner.Application/Profiles/Commands/Behaviors/ReCRequestExecutionBehavior.cs index bfcc7a0..a764ec9 100644 --- a/ECMJobRunner.Application/DEXJob/Commands/Behaviors/ReCRequestExecutionBehavior.cs +++ b/ECMJobRunner.Application/Profiles/Commands/Behaviors/ReCRequestExecutionBehavior.cs @@ -1,7 +1,7 @@ using ECMJobRunner.Application.Common.Constants; using ECMJobRunner.Application.Common.Exceptions; using ECMJobRunner.Application.Common.Options; -using ECMJobRunner.Application.DEXJob.Commands; +using ECMJobRunner.Application.Profiles.Commands; using MediatR; using Microsoft.Extensions.Options; using ReC.Client; @@ -10,7 +10,7 @@ using System; using System.Threading; using System.Threading.Tasks; -namespace ECMJobRunner.Application.DEXJob.Commands.Behaviors +namespace ECMJobRunner.Application.Profiles.Commands.Behaviors { /// /// Pipeline behavior that sends ReC HTTP request for DEX jobs @@ -45,7 +45,7 @@ namespace ECMJobRunner.Application.DEXJob.Commands.Behaviors public async Task Handle(TRequest request, RequestHandlerDelegate next, CancellationToken cancellationToken) #endif { - if (request is TriggeringDEXJobCommand command) + if (request is TriggeringProfileJobCommand command) { await SendReCRequestAsync(command, cancellationToken); } @@ -53,7 +53,7 @@ namespace ECMJobRunner.Application.DEXJob.Commands.Behaviors return await next(); } - private async Task SendReCRequestAsync(TriggeringDEXJobCommand command, CancellationToken cancel) + private async Task SendReCRequestAsync(TriggeringProfileJobCommand command, CancellationToken cancel) { try { diff --git a/ECMJobRunner.Application/DEXJob/Commands/TriggeringDEXJobBatchCommand.cs b/ECMJobRunner.Application/Profiles/Commands/TriggeringProfileJobBatchCommand.cs similarity index 89% rename from ECMJobRunner.Application/DEXJob/Commands/TriggeringDEXJobBatchCommand.cs rename to ECMJobRunner.Application/Profiles/Commands/TriggeringProfileJobBatchCommand.cs index 91fb1f0..a4e78fd 100644 --- a/ECMJobRunner.Application/DEXJob/Commands/TriggeringDEXJobBatchCommand.cs +++ b/ECMJobRunner.Application/Profiles/Commands/TriggeringProfileJobBatchCommand.cs @@ -6,13 +6,13 @@ using System; using System.Threading; using System.Threading.Tasks; -namespace ECMJobRunner.Application.DEXJob.Commands +namespace ECMJobRunner.Application.Profiles.Commands { /// /// Command to trigger DEX job batch for a profile /// Executes all SQL jobs associated with a profile ID /// - public class TriggeringDEXJobBatchCommand : IRequest + public class TriggeringProfileJobBatchCommand : IRequest { /// /// Profile ID to trigger all associated SQL jobs @@ -26,7 +26,7 @@ namespace ECMJobRunner.Application.DEXJob.Commands /// Validates that the profile is active before execution /// public class TriggeringDEXJobBatchCommandHandler(ICfgProfileRepository profileRepo, IProfileSqlJobRepository jobRepo, ISender sender) - : IRequestHandler + : IRequestHandler { /// /// Handles the TriggeringDEXJobBatchCommand @@ -36,7 +36,7 @@ namespace ECMJobRunner.Application.DEXJob.Commands /// Cancellation token /// Unit value indicating completion /// Thrown when the profile is not active - public async Task Handle(TriggeringDEXJobBatchCommand request, CancellationToken cancellationToken) + public async Task Handle(TriggeringProfileJobBatchCommand request, CancellationToken cancellationToken) { var batchId = CreateBatchId(); @@ -59,7 +59,7 @@ namespace ECMJobRunner.Application.DEXJob.Commands foreach (var job in jobs) { - await sender.Send(new TriggeringDEXJobCommand + await sender.Send(new TriggeringProfileJobCommand { Job = job, BatchId = batchId diff --git a/ECMJobRunner.Application/DEXJob/Commands/TriggeringDEXJobCommand.cs b/ECMJobRunner.Application/Profiles/Commands/TriggeringProfileJobCommand.cs similarity index 86% rename from ECMJobRunner.Application/DEXJob/Commands/TriggeringDEXJobCommand.cs rename to ECMJobRunner.Application/Profiles/Commands/TriggeringProfileJobCommand.cs index 218548f..dfb4bdd 100644 --- a/ECMJobRunner.Application/DEXJob/Commands/TriggeringDEXJobCommand.cs +++ b/ECMJobRunner.Application/Profiles/Commands/TriggeringProfileJobCommand.cs @@ -3,7 +3,7 @@ using MediatR; using System.Threading; using System.Threading.Tasks; -namespace ECMJobRunner.Application.DEXJob.Commands +namespace ECMJobRunner.Application.Profiles.Commands { /// /// Command to trigger a single DEX job execution @@ -12,7 +12,7 @@ namespace ECMJobRunner.Application.DEXJob.Commands /// 2. CheckQueryExecutionBehavior - validates with check SQL query /// 3. ReCRequestExecutionBehavior - invokes ReC HTTP request /// - public class TriggeringDEXJobCommand : IRequest + public class TriggeringProfileJobCommand : IRequest { /// /// The SQL job to execute @@ -30,7 +30,7 @@ namespace ECMJobRunner.Application.DEXJob.Commands /// All execution logic is delegated to pipeline behaviors /// This handler simply returns completion after behaviors execute /// - public class TriggeringDEXJobCommandHandler : IRequestHandler + public class TriggeringDEXJobCommandHandler : IRequestHandler { /// /// Handles the TriggeringDEXJobCommand @@ -39,7 +39,7 @@ namespace ECMJobRunner.Application.DEXJob.Commands /// The command containing job and batch ID /// Cancellation token /// Unit value indicating completion - public Task Handle(TriggeringDEXJobCommand request, CancellationToken cancellationToken) + public Task Handle(TriggeringProfileJobCommand request, CancellationToken cancellationToken) { // All execution logic is handled by pipeline behaviors: // - MainQueryExecutionBehavior diff --git a/ECMJobRunner.Application/DEXJob/Queries/GetProfileQuery.cs b/ECMJobRunner.Application/Profiles/Queries/GetProfileQuery.cs similarity index 98% rename from ECMJobRunner.Application/DEXJob/Queries/GetProfileQuery.cs rename to ECMJobRunner.Application/Profiles/Queries/GetProfileQuery.cs index 18566e1..dbd2ca3 100644 --- a/ECMJobRunner.Application/DEXJob/Queries/GetProfileQuery.cs +++ b/ECMJobRunner.Application/Profiles/Queries/GetProfileQuery.cs @@ -7,7 +7,7 @@ using System.Linq; using System.Threading; using System.Threading.Tasks; -namespace ECMJobRunner.Application.DEXJob.Queries +namespace ECMJobRunner.Application.Profiles.Queries { /// /// Query to retrieve profiles with flexible filtering options diff --git a/ECMJobRunner.Tests/Application/CheckQueryExecutionBehaviorTests.cs b/ECMJobRunner.Tests/Application/CheckQueryExecutionBehaviorTests.cs index f14fbb6..fc08ecc 100644 --- a/ECMJobRunner.Tests/Application/CheckQueryExecutionBehaviorTests.cs +++ b/ECMJobRunner.Tests/Application/CheckQueryExecutionBehaviorTests.cs @@ -21,7 +21,7 @@ namespace ECMJobRunner.Tests.Application { private readonly Mock _mockExecutor; private readonly Mock> _mockOptions; - private readonly CheckQueryExecutionBehavior _behavior; + private readonly CheckQueryExecutionBehavior _behavior; private readonly Mock> _mockNext; public CheckQueryExecutionBehaviorTests() @@ -29,7 +29,7 @@ namespace ECMJobRunner.Tests.Application _mockExecutor = new Mock(); _mockOptions = new Mock>(); _mockOptions.Setup(o => o.Value).Returns(new DexJobOptions()); - _behavior = new CheckQueryExecutionBehavior(_mockExecutor.Object, _mockOptions.Object); + _behavior = new CheckQueryExecutionBehavior(_mockExecutor.Object, _mockOptions.Object); _mockNext = new Mock>(); _mockNext.Setup(n => n()).ReturnsAsync(Unit.Value); } @@ -38,7 +38,7 @@ namespace ECMJobRunner.Tests.Application public async Task Handle_WithValidCheckQuery_ExecutesSuccessfully() { // Arrange - var command = new TriggeringDEXJobCommand + var command = new TriggeringProfileJobCommand { Job = new ProfileSqlJob { SqlCheckQuery = "SELECT COUNT(*) AS [Return Value] FROM Table" }, BatchId = "20260711143025123456" @@ -68,7 +68,7 @@ namespace ECMJobRunner.Tests.Application public async Task Handle_WithPositiveReturnValue_DoesNotThrow(int returnValue) { // Arrange - var command = new TriggeringDEXJobCommand + var command = new TriggeringProfileJobCommand { Job = new ProfileSqlJob { SqlCheckQuery = "SELECT COUNT(*) AS [Return Value] FROM Table" }, BatchId = "20260711143025123456" @@ -96,7 +96,7 @@ namespace ECMJobRunner.Tests.Application public async Task Handle_WithZeroOrNegativeReturnValue_ThrowsDEXJobException(int returnValue) { // Arrange - var command = new TriggeringDEXJobCommand + var command = new TriggeringProfileJobCommand { Job = new ProfileSqlJob { SqlCheckQuery = "SELECT COUNT(*) AS [Return Value] FROM Table" }, BatchId = "20260711143025123456" @@ -122,7 +122,7 @@ namespace ECMJobRunner.Tests.Application public async Task Handle_WithNullCheckQuery_IgnoresByDefault() { // Arrange - var command = new TriggeringDEXJobCommand + var command = new TriggeringProfileJobCommand { Job = new ProfileSqlJob { SqlCheckQuery = null }, BatchId = "20260711143025123456" @@ -157,8 +157,8 @@ namespace ECMJobRunner.Tests.Application }; _mockOptions.Setup(o => o.Value).Returns(options); - var behavior = new CheckQueryExecutionBehavior(_mockExecutor.Object, _mockOptions.Object); - var command = new TriggeringDEXJobCommand + var behavior = new CheckQueryExecutionBehavior(_mockExecutor.Object, _mockOptions.Object); + var command = new TriggeringProfileJobCommand { Job = new ProfileSqlJob { SqlCheckQuery = null }, BatchId = "20260711143025123456" @@ -181,7 +181,7 @@ namespace ECMJobRunner.Tests.Application { // Arrange var batchId = "20260711143025123456"; - var command = new TriggeringDEXJobCommand + var command = new TriggeringProfileJobCommand { Job = new ProfileSqlJob { SqlCheckQuery = "SELECT COUNT(*) AS [Return Value] FROM Table WHERE BatchId = '#INT#BATCH_ID'" }, BatchId = batchId @@ -209,7 +209,7 @@ namespace ECMJobRunner.Tests.Application public async Task Handle_WithNullResult_ThrowsDEXJobException() { // Arrange - var command = new TriggeringDEXJobCommand + var command = new TriggeringProfileJobCommand { Job = new ProfileSqlJob { SqlCheckQuery = "SELECT COUNT(*) AS [Return Value] FROM Table" }, BatchId = "20260711143025123456" diff --git a/ECMJobRunner.Tests/Application/MainQueryExecutionBehaviorTests.cs b/ECMJobRunner.Tests/Application/MainQueryExecutionBehaviorTests.cs index 4165c34..b2ee7f2 100644 --- a/ECMJobRunner.Tests/Application/MainQueryExecutionBehaviorTests.cs +++ b/ECMJobRunner.Tests/Application/MainQueryExecutionBehaviorTests.cs @@ -21,7 +21,7 @@ namespace ECMJobRunner.Tests.Application { private readonly Mock _mockExecutor; private readonly Mock> _mockOptions; - private readonly MainQueryExecutionBehavior _behavior; + private readonly MainQueryExecutionBehavior _behavior; private readonly Mock> _mockNext; public MainQueryExecutionBehaviorTests() @@ -29,7 +29,7 @@ namespace ECMJobRunner.Tests.Application _mockExecutor = new Mock(); _mockOptions = new Mock>(); _mockOptions.Setup(o => o.Value).Returns(new DexJobOptions()); - _behavior = new MainQueryExecutionBehavior(_mockExecutor.Object, _mockOptions.Object); + _behavior = new MainQueryExecutionBehavior(_mockExecutor.Object, _mockOptions.Object); _mockNext = new Mock>(); _mockNext.Setup(n => n()).ReturnsAsync(Unit.Value); } @@ -38,7 +38,7 @@ namespace ECMJobRunner.Tests.Application public async Task Handle_WithValidMainQuery_ExecutesSuccessfully() { // Arrange - var command = new TriggeringDEXJobCommand + var command = new TriggeringProfileJobCommand { Job = new ProfileSqlJob { SqlMainQuery = "INSERT INTO Table VALUES (1)" }, BatchId = "20260711143025123456" @@ -65,7 +65,7 @@ namespace ECMJobRunner.Tests.Application public async Task Handle_WithNullReturnValue_DoesNotThrow() { // Arrange - var command = new TriggeringDEXJobCommand + var command = new TriggeringProfileJobCommand { Job = new ProfileSqlJob { SqlMainQuery = "INSERT INTO Table VALUES (1)" }, BatchId = "20260711143025123456" @@ -90,7 +90,7 @@ namespace ECMJobRunner.Tests.Application public async Task Handle_WithNonNullReturnValue_ThrowsDEXJobException() { // Arrange - var command = new TriggeringDEXJobCommand + var command = new TriggeringProfileJobCommand { Job = new ProfileSqlJob { SqlMainQuery = "INSERT INTO Table VALUES (1)" }, BatchId = "20260711143025123456" @@ -116,7 +116,7 @@ namespace ECMJobRunner.Tests.Application public async Task Handle_WithNullMainQuery_IgnoresByDefault() { // Arrange - var command = new TriggeringDEXJobCommand + var command = new TriggeringProfileJobCommand { Job = new ProfileSqlJob { SqlMainQuery = null }, BatchId = "20260711143025123456" @@ -151,8 +151,8 @@ namespace ECMJobRunner.Tests.Application }; _mockOptions.Setup(o => o.Value).Returns(options); - var behavior = new MainQueryExecutionBehavior(_mockExecutor.Object, _mockOptions.Object); - var command = new TriggeringDEXJobCommand + var behavior = new MainQueryExecutionBehavior(_mockExecutor.Object, _mockOptions.Object); + var command = new TriggeringProfileJobCommand { Job = new ProfileSqlJob { SqlMainQuery = null }, BatchId = "20260711143025123456" @@ -175,7 +175,7 @@ namespace ECMJobRunner.Tests.Application { // Arrange var batchId = "20260711143025123456"; - var command = new TriggeringDEXJobCommand + var command = new TriggeringProfileJobCommand { Job = new ProfileSqlJob { SqlMainQuery = "INSERT INTO Table (BatchId) VALUES ('#INT#BATCH_ID')" }, BatchId = batchId @@ -203,7 +203,7 @@ namespace ECMJobRunner.Tests.Application public async Task Handle_WithExecutionError_ThrowsDEXJobException() { // Arrange - var command = new TriggeringDEXJobCommand + var command = new TriggeringProfileJobCommand { Job = new ProfileSqlJob { SqlMainQuery = "INVALID SQL" }, BatchId = "20260711143025123456" diff --git a/ECMJobRunner.Tests/Application/TriggeringDEXJobBatchCommandTests.cs b/ECMJobRunner.Tests/Application/TriggeringDEXJobBatchCommandTests.cs index 937ec4b..019340d 100644 --- a/ECMJobRunner.Tests/Application/TriggeringDEXJobBatchCommandTests.cs +++ b/ECMJobRunner.Tests/Application/TriggeringDEXJobBatchCommandTests.cs @@ -46,7 +46,7 @@ namespace ECMJobRunner.Tests.Application .Setup(r => r.FindAsync(It.IsAny>>(), It.IsAny())) .ReturnsAsync(jobs); - var command = new TriggeringDEXJobBatchCommand { ProfileId = profileId }; + var command = new TriggeringProfileJobBatchCommand { ProfileId = profileId }; // Act var result = await _handler.Handle(command, CancellationToken.None); @@ -54,7 +54,7 @@ namespace ECMJobRunner.Tests.Application // Assert result.Should().Be(Unit.Value); _mockSender.Verify( - s => s.Send(It.IsAny(), It.IsAny()), + s => s.Send(It.IsAny(), It.IsAny()), Times.Exactly(2), "Should send command for each job"); } @@ -68,7 +68,7 @@ namespace ECMJobRunner.Tests.Application .Setup(r => r.FindAsync(It.IsAny>>(), It.IsAny())) .ReturnsAsync(Array.Empty()); - var command = new TriggeringDEXJobBatchCommand { ProfileId = profileId }; + var command = new TriggeringProfileJobBatchCommand { ProfileId = profileId }; // Act var result = await _handler.Handle(command, CancellationToken.None); @@ -76,7 +76,7 @@ namespace ECMJobRunner.Tests.Application // Assert result.Should().Be(Unit.Value); _mockSender.Verify( - s => s.Send(It.IsAny(), It.IsAny()), + s => s.Send(It.IsAny(), It.IsAny()), Times.Never, "Should not send any commands when no jobs found"); } @@ -115,13 +115,13 @@ namespace ECMJobRunner.Tests.Application .Setup(r => r.FindAsync(It.IsAny>>(), It.IsAny())) .ReturnsAsync(new[] { job }); - TriggeringDEXJobCommand? capturedCommand = null; + TriggeringProfileJobCommand? capturedCommand = null; _mockSender - .Setup(s => s.Send(It.IsAny(), It.IsAny())) - .Callback, CancellationToken>((cmd, _) => capturedCommand = cmd as TriggeringDEXJobCommand) + .Setup(s => s.Send(It.IsAny(), It.IsAny())) + .Callback, CancellationToken>((cmd, _) => capturedCommand = cmd as TriggeringProfileJobCommand) .ReturnsAsync(Unit.Value); - var command = new TriggeringDEXJobBatchCommand { ProfileId = profileId }; + var command = new TriggeringProfileJobBatchCommand { ProfileId = profileId }; // Act await _handler.Handle(command, CancellationToken.None); diff --git a/ECMJobRunner.WebCron/Extensions/DtoExtensions.cs b/ECMJobRunner.WebCron/Extensions/DtoExtensions.cs index b2c9676..1196c15 100644 --- a/ECMJobRunner.WebCron/Extensions/DtoExtensions.cs +++ b/ECMJobRunner.WebCron/Extensions/DtoExtensions.cs @@ -1,5 +1,5 @@ using ECMJobRunner.Application.Common.Dtos; -using ECMJobRunner.Application.DEXJob.Commands; +using ECMJobRunner.Application.Profiles.Commands; using MediatR; namespace ECMJobRunner.WebCron.Extensions; @@ -27,10 +27,10 @@ public static class DtoExtensions /// Converts a profile DTO to a DEX job batch command. /// /// The profile configuration DTO. - /// A ready to execute the profile job. - public static TriggeringDEXJobBatchCommand ToJob(this CfgProfileDto profile) + /// A ready to execute the profile job. + public static TriggeringProfileJobBatchCommand ToJob(this CfgProfileDto profile) { - return new TriggeringDEXJobBatchCommand + return new TriggeringProfileJobBatchCommand { ProfileId = profile.Id, }; diff --git a/ECMJobRunner.WebCron/ProfileWorker/ProfileWork.cs b/ECMJobRunner.WebCron/ProfileWorker/ProfileWork.cs index 59e1334..dd79c62 100644 --- a/ECMJobRunner.WebCron/ProfileWorker/ProfileWork.cs +++ b/ECMJobRunner.WebCron/ProfileWorker/ProfileWork.cs @@ -1,4 +1,4 @@ -using ECMJobRunner.Application.DEXJob.Queries; +using ECMJobRunner.Application.Profiles.Queries; using ECMJobRunner.WebCron.Extensions; using Hangfire; using MediatR;