change how scanner and main process communicate (#2555)

* report scanner progress using api

* process scanner search index updates through api

* update changelog

* update dependencies
This commit is contained in:
Jason Dove
2025-10-21 15:08:49 -05:00
committed by GitHub
parent 2ef2b0299a
commit 626048f9c3
64 changed files with 1173 additions and 885 deletions
@@ -0,0 +1,53 @@
using System.Threading.Channels;
using ErsatzTV.Application;
using ErsatzTV.Application.Search;
using ErsatzTV.Core.Interfaces.Metadata;
using Microsoft.AspNetCore.Mvc;
namespace ErsatzTV.Controllers.Api;
[ApiController]
[ApiExplorerSettings(IgnoreApi = true)]
[Route("api/scan/{scanId:guid}")]
public class ScannerController(
IScannerProxyService scannerProxyService,
ChannelWriter<ISearchIndexBackgroundServiceRequest> channelWriter)
{
[HttpPost("progress")]
[EndpointSummary("Scanner progress update")]
public async Task<IActionResult> Progress(Guid scanId, [FromBody] decimal percentComplete)
{
await scannerProxyService.Progress(scanId, percentComplete);
return new OkResult();
}
[HttpPost("items/reindex")]
[EndpointSummary("Scanner reindex items in search index")]
public async Task<IActionResult> UpdateItems(
Guid scanId,
[FromBody] List<int> itemsToUpdate,
CancellationToken cancellationToken)
{
if (scannerProxyService.IsActive(scanId))
{
await channelWriter.WriteAsync(new ReindexMediaItems(itemsToUpdate), cancellationToken);
}
return new OkResult();
}
[HttpPost("items/remove")]
[EndpointSummary("Scanner remove items from search index")]
public async Task<IActionResult> RemoveItems(
Guid scanId,
[FromBody] List<int> itemsToRemove,
CancellationToken cancellationToken)
{
if (scannerProxyService.IsActive(scanId))
{
await channelWriter.WriteAsync(new RemoveMediaItems(itemsToRemove), cancellationToken);
}
return new OkResult();
}
}