diff --git a/code/backend/Cleanuparr.Infrastructure.Tests/Services/JobManagementServiceTests.cs b/code/backend/Cleanuparr.Infrastructure.Tests/Services/JobManagementServiceTests.cs index 5e2a48f9..ebb127e9 100644 --- a/code/backend/Cleanuparr.Infrastructure.Tests/Services/JobManagementServiceTests.cs +++ b/code/backend/Cleanuparr.Infrastructure.Tests/Services/JobManagementServiceTests.cs @@ -512,63 +512,4 @@ public class JobManagementServiceTests } #endregion - - #region GetMainTrigger Tests - - [Fact] - public async Task GetMainTrigger_JobDoesNotExist_ReturnsNull() - { - // Arrange - var jobType = JobType.QueueCleaner; - - _scheduler.CheckExists(Arg.Any(), Arg.Any()) - .Returns(false); - - // Act - var result = await _service.GetMainTrigger(jobType); - - // Assert - result.ShouldBeNull(); - } - - [Fact] - public async Task GetMainTrigger_TriggerExists_ReturnsTrigger() - { - // Arrange - var jobType = JobType.MalwareBlocker; - var expectedTriggerKey = new TriggerKey("MalwareBlocker-trigger"); - - var trigger = Substitute.For(); - trigger.Key.Returns(expectedTriggerKey); - - _scheduler.CheckExists(Arg.Any(), Arg.Any()) - .Returns(true); - _scheduler.GetTrigger(expectedTriggerKey, Arg.Any()) - .Returns(trigger); - - // Act - var result = await _service.GetMainTrigger(jobType); - - // Assert - result.ShouldNotBeNull(); - result.Key.ShouldBe(expectedTriggerKey); - } - - [Fact] - public async Task GetMainTrigger_WhenSchedulerThrows_ReturnsNull() - { - // Arrange - var jobType = JobType.QueueCleaner; - - _scheduler.CheckExists(Arg.Any(), Arg.Any()) - .ThrowsAsync(new Exception("Scheduler error")); - - // Act - var result = await _service.GetMainTrigger(jobType); - - // Assert - result.ShouldBeNull(); - } - - #endregion } diff --git a/code/backend/Cleanuparr.Infrastructure/Services/Interfaces/IJobManagementService.cs b/code/backend/Cleanuparr.Infrastructure/Services/Interfaces/IJobManagementService.cs index f82a3394..1828e693 100644 --- a/code/backend/Cleanuparr.Infrastructure/Services/Interfaces/IJobManagementService.cs +++ b/code/backend/Cleanuparr.Infrastructure/Services/Interfaces/IJobManagementService.cs @@ -25,5 +25,4 @@ public interface IJobManagementService Task> GetAllJobs(IScheduler? scheduler = null); Task GetJob(JobType jobType); Task UpdateJobSchedule(JobType jobType, JobSchedule schedule); - Task GetMainTrigger(JobType jobType); } \ No newline at end of file diff --git a/code/backend/Cleanuparr.Infrastructure/Services/JobManagementService.cs b/code/backend/Cleanuparr.Infrastructure/Services/JobManagementService.cs index da752fa6..4a8906c9 100644 --- a/code/backend/Cleanuparr.Infrastructure/Services/JobManagementService.cs +++ b/code/backend/Cleanuparr.Infrastructure/Services/JobManagementService.cs @@ -170,34 +170,6 @@ public class JobManagementService : IJobManagementService _logger.LogWarning(ex, "Failed to trigger job {jobName} immediately", jobKey.Name); } } - - /// - /// Gets the main scheduled trigger for a job (excludes one-time triggers) - /// - public async Task GetMainTrigger(JobType jobType) - { - string jobName = jobType.ToString(); - try - { - var scheduler = await _schedulerFactory.GetScheduler(); - var jobKey = new JobKey(jobName); - - if (!await scheduler.CheckExists(jobKey)) - { - return null; - } - - // Look for the main trigger (follows our naming convention) - var mainTriggerKey = new TriggerKey($"{jobName}-trigger"); - return await scheduler.GetTrigger(mainTriggerKey); - } - catch (Exception ex) - { - _logger.LogError(ex, "Error getting main trigger for job {jobName}", jobName); - return null; - } - } - public async Task StopJob(JobType jobType) {