DD.WellWorkover.Cloud/AsbCloudWebApi/Controllers/ReduceSamplingController.cs

using AsbCloudApp.Services;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using System.Collections.Generic;
using System.Threading.Tasks;
using AsbCloudApp.Data;
using System.Linq;
using AsbCloudWebApi.SignalR;
using Microsoft.AspNetCore.SignalR;

namespace AsbCloudWebApi.Controllers;

/// <summary>
/// Редактор кустов для админки
/// </summary>
[Route("api/admin/[controller]")]
[ApiController]
[Authorize]
public class ReduceSamplingController: ControllerBase
{
    private readonly IReduceSamplingService service;
    private readonly IHubContext<TelemetryHub> telemetryHubContext;
    private const string sirnalRGroupName = "ReduceSampling";
    private const string sirnalRMethodOnProgress = "OnProgress";

    public ReduceSamplingController(
        IReduceSamplingService service,
        IHubContext<TelemetryHub> telemetryHubContext )
    {
        this.service = service;
        this.telemetryHubContext = telemetryHubContext;
    }

    /// <summary>
    /// Получить все задания. Задания удаляются минимум через 10 сек после выполнения, возможно позднее.
    /// </summary>
    /// <param name="idTelemetry"></param>
    /// <returns></returns>
    [HttpGet]
    public virtual ActionResult<IEnumerable<JobDto>> GetAll(int idTelemetry)
    {
        var result = service.GetJobs();
        if (result.Any())
            return Ok(result);
        else
            return NoContent();
    }

    /// <summary>
    /// Получить состояние определенной задачи
    /// </summary>
    /// <param name="idTelemetry"></param>
    /// <returns></returns>
    [HttpGet("{idTelemetry}")]
    public virtual ActionResult<JobDto> GetOrDefault(int idTelemetry)
    {
        var result = service.GetOrDefaultState(idTelemetry);
        return Ok(result);
    }

    /// <summary>
    /// Создать задачу прореживанию архива и добавить её в очередь на выполнение.
    /// Если задача есть в очереди, она же и возвращается, но подписка не происходит.
    /// </summary>
    [HttpPost]
    [Permission]
    public virtual ActionResult<JobDto> Enqueue(int idTelemetry)
    {
        void onProgress(JobDto job) =>
            Task.Run(async () =>
                await telemetryHubContext.Clients.Group(sirnalRGroupName)
                  .SendAsync(sirnalRMethodOnProgress, job));

        service.TryEnqueueRediceSamplingJob(idTelemetry, onProgress, out JobDto job);
        return Ok(job);
    }
}