reorganize core

see Sockseek.Core/README.md

Author: fiso64

Sockseek.Cli/Program.cs

@@ -419,6 +419,7 @@ await backend.SubmitExtractJobAsync(
         {
             SockseekLog.Trace("Main: Entered finally block. Disposing clientManager...");
             engine.Cancel();
+            await engine.DisposeAsync();
             await cts.CancelAsync();
             cliReporter?.Stop();
             clientManager.Dispose();

Sockseek.Cli/Services/LocalCliBackend.cs

@@ -37,7 +37,7 @@ public LocalCliBackend(
         stateStore.JobUpserted += summary => Publish("job.upserted", summary);
         stateStore.WorkflowUpserted += summary => Publish("workflow.upserted", summary);
         stateStore.SearchUpdated += update => Publish("search.updated", update);
-        new EngineEventDtoAdapter(GetSummary, Publish).Attach(engine.Events);
+        new EngineEventDtoAdapter(GetSummary, Publish).Attach(engine.Events, engine.SearchEvents);
     }
 
     public Task<JobSummaryDto> SubmitExtractJobAsync(SubmitExtractJobRequestDto request, CancellationToken ct = default)
@@ -519,24 +519,14 @@ public Task<bool> CancelJobAsync(Guid jobId, CancellationToken ct = default)
     {
         ct.ThrowIfCancellationRequested();
 
-        var job = engine.GetJob(jobId);
-        if (job == null)
-            return Task.FromResult(false);
-
-        job.Cancel(JobCancellationSource.UserRequestedJob);
-        return Task.FromResult(true);
+        return Task.FromResult(engine.CancelJob(jobId));
     }
 
     public async Task<bool> CancelJobByDisplayIdAsync(int displayId, Guid? workflowId = null, CancellationToken ct = default)
     {
         ct.ThrowIfCancellationRequested();
 
-        var job = engine.GetJob(displayId);
-        if (job == null || (workflowId.HasValue && job.WorkflowId != workflowId.Value))
-            return false;
-
-        job.Cancel(JobCancellationSource.UserRequestedJob);
-        return await Task.FromResult(true);
+        return await Task.FromResult(engine.CancelJobByDisplayId(displayId, workflowId));
     }
 
     public Task<int> CancelWorkflowAsync(Guid workflowId, CancellationToken ct = default)
@@ -554,11 +544,7 @@ public Task<bool> TryNextCandidateAsync(Guid jobId, CancellationToken ct = defau
     public Task<bool> TryNextCandidateByDisplayIdAsync(int displayId, Guid? workflowId = null, CancellationToken ct = default)
     {
         ct.ThrowIfCancellationRequested();
-        var job = engine.GetJob(displayId);
-        if (job == null || (workflowId.HasValue && job.WorkflowId != workflowId.Value))
-            return Task.FromResult(false);
-
-        return Task.FromResult(engine.TryNextCandidate(job.Id));
+        return Task.FromResult(engine.TryNextCandidateByDisplayId(displayId, workflowId));
     }
 
     private void Publish(string type, object payload)

Sockseek.Cli/Settings/CliSettings.cs

@@ -3,7 +3,7 @@ namespace Sockseek.Cli;
 /// CLI-only settings — control presentation and UI behavior.
 /// Not passed to the engine; consumed by the CLI layer before/when constructing the engine.
 ///
-/// The engine interacts with UI through EngineEvents only.
+/// The engine interacts with UI through Core event surfaces such as DownloadEvents and SearchEvents.
 /// These settings tell the CLI which presentation/orchestration layers to wire up.
 ///
 public class CliSettings

Sockseek.Cli/Utilities/JsonStreamProgressReporter.cs

@@ -31,7 +31,7 @@ public JsonStreamProgressReporter(TextWriter writer)
         };
     }
 
-    public void Attach(EngineEvents events)
+    public void Attach(DownloadEvents events)
     {
         events.TrackListReady     += songs => ReportTrackList(songs);
         events.JobStateChanged    += job =>