mirror/Cleanuparr
1
0
Fork 0
mirror of https://github.com/Cleanuparr/Cleanuparr.git synced 2026-06-29 07:45:53 -04:00
Code Issues Packages Projects Releases Wiki Activity

removed unused method

Browse Source
This commit is contained in:
Flaminel
2026-06-16 23:21:40 +03:00
parent 614e97313e
commit 9a31e86ad8
3 changed files with 0 additions and 88 deletions
Download Patch File Download Diff File Expand all files Collapse all files

59
code/backend/Cleanuparr.Infrastructure.Tests/Services/JobManagementServiceTests.cs
View File

@@ -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<JobKey>(), Arg.Any<CancellationToken>())
.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<ITrigger>();
trigger.Key.Returns(expectedTriggerKey);
_scheduler.CheckExists(Arg.Any<JobKey>(), Arg.Any<CancellationToken>())
.Returns(true);
_scheduler.GetTrigger(expectedTriggerKey, Arg.Any<CancellationToken>())
.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<JobKey>(), Arg.Any<CancellationToken>())
.ThrowsAsync(new Exception("Scheduler error"));
// Act
var result = await _service.GetMainTrigger(jobType);
// Assert
result.ShouldBeNull();
}
#endregion
}

1
code/backend/Cleanuparr.Infrastructure/Services/Interfaces/IJobManagementService.cs
View File

@@ -25,5 +25,4 @@ public interface IJobManagementService
Task<IReadOnlyList<JobInfo>> GetAllJobs(IScheduler? scheduler = null);
Task<JobInfo> GetJob(JobType jobType);
Task<bool> UpdateJobSchedule(JobType jobType, JobSchedule schedule);
Task<ITrigger?> GetMainTrigger(JobType jobType);
}

28
code/backend/Cleanuparr.Infrastructure/Services/JobManagementService.cs
View File

@@ -170,34 +170,6 @@ public class JobManagementService : IJobManagementService
_logger.LogWarning(ex, "Failed to trigger job {jobName} immediately", jobKey.Name);
}
}
/// <summary>
/// Gets the main scheduled trigger for a job (excludes one-time triggers)
/// </summary>
public async Task<ITrigger?> 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<bool> StopJob(JobType jobType)
{