Drop unused code

Author: nulltoken

src/NCronJob/Execution/StartupJobManager.cs

@@ -5,8 +5,6 @@ internal class StartupJobManager(
     JobProcessor jobProcessor,
     JobExecutionProgressObserver observer)
 {
-    private readonly AsyncManualResetEvent startupJobsCompleted = new();
-
     public async Task ProcessStartupJobs(CancellationToken stopToken)
     {
         var startupJobs = jobRegistry.GetAllOneTimeJobs();
@@ -16,22 +14,8 @@ public async Task ProcessStartupJobs(CancellationToken stopToken)
         {
             await Task.WhenAll(startupTasks).ConfigureAwait(false);
         }
-
-        startupJobsCompleted.Set();
     }
 
     private async Task CreateExecutionTask(JobRun job, CancellationToken stopToken) =>
         await jobProcessor.ProcessJobAsync(job, stopToken).ConfigureAwait(false);
-
-    public Task WaitForStartupJobsCompletion() => startupJobsCompleted.WaitAsync();
 }
-
-internal class AsyncManualResetEvent
-{
-    private readonly TaskCompletionSource tcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
-
-    public Task WaitAsync() => tcs.Task;
-
-    public void Set() => tcs.TrySetResult();
-}
-

src/NCronJob/Registry/JobDefinition.cs

@@ -45,9 +45,4 @@ internal sealed record JobDefinition(
     private JobExecutionAttributes JobPolicyMetadata { get; } = JobPolicyMetadata ?? new JobExecutionAttributes(Type);
     public RetryPolicyAttribute? RetryPolicy => JobPolicyMetadata.RetryPolicy;
     public SupportsConcurrencyAttribute? ConcurrencyPolicy => JobPolicyMetadata.ConcurrencyPolicy;
-
-    // Hooks for specific state changes
-    public Action<JobDefinition>? OnCompletion { get; set; }
-    public Action<JobDefinition, string?>? OnFailure { get; set; }
-    public Action<JobDefinition>? OnRunning { get; set; }
 }

src/NCronJob/Registry/JobRun.cs

@@ -95,32 +95,6 @@ private void Initialize()
     {
         OnStateChanged += (jr, state) =>
         {
-            switch (state.Type)
-            {
-                case JobStateType.Completed:
-                    jr.JobDefinition.OnCompletion?.Invoke(jr.JobDefinition);
-                    break;
-                case JobStateType.Faulted:
-                    jr.JobDefinition.OnFailure?.Invoke(jr.JobDefinition, state.Message);
-                    break;
-                case JobStateType.Running:
-                    jr.JobDefinition.OnRunning?.Invoke(jr.JobDefinition);
-                    break;
-                case JobStateType.Retrying:
-                case JobStateType.Scheduled:
-                case JobStateType.Cancelled:
-                case JobStateType.Expired:
-                case JobStateType.Skipped:
-                case JobStateType.Crashed:
-                case JobStateType.Completing:
-                case JobStateType.Initializing:
-                case JobStateType.WaitingForDependency:
-                case JobStateType.NotStarted:
-                    break;
-                default:
-                    throw new ArgumentOutOfRangeException(nameof(state), state.Type, "Unexpected JobStateType value");
-            }
-
             progressReporter(jr);
         };