88 lines
3.3 KiB
C#
88 lines
3.3 KiB
C#
using Microsoft.AspNetCore.Authorization;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using RSecurityBackend.Models.Auth.Memory;
|
|
using RSecurityBackend.Models.Generic.Db;
|
|
using RSecurityBackend.Services;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Net;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace RSecurityBackend.Controllers
|
|
{
|
|
/// <summary>
|
|
/// Long Running Jobs
|
|
/// </summary>
|
|
[Produces("application/json")]
|
|
[Route("api/rjobs")]
|
|
public abstract class RLongRunningJobsControllerBase : Controller
|
|
{
|
|
/// <summary>
|
|
/// get long running jobs
|
|
/// </summary>
|
|
/// <param name="succeeded"></param>
|
|
/// <param name="failed"></param>
|
|
/// <returns></returns>
|
|
[HttpGet]
|
|
[Authorize(Policy = SecurableItem.AuditLogEntityShortName + ":" + SecurableItem.ViewOperationShortName)]
|
|
[ProducesResponseType((int)HttpStatusCode.OK, Type = typeof(IEnumerable<RLongRunningJobStatus>))]
|
|
[ProducesResponseType((int)HttpStatusCode.BadRequest, Type = typeof(string))]
|
|
public async Task<IActionResult> Get(bool succeeded = true, bool failed = true)
|
|
{
|
|
var res = await _jobService.GetJobs(succeeded, failed);
|
|
if (!string.IsNullOrEmpty(res.ExceptionString))
|
|
return BadRequest(res.ExceptionString);
|
|
return Ok(res.Result);
|
|
}
|
|
|
|
/// <summary>
|
|
/// clean up old jobs
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
[HttpDelete("cleanup")]
|
|
[Authorize(Policy = SecurableItem.AuditLogEntityShortName + ":" + SecurableItem.ViewOperationShortName)]
|
|
[ProducesResponseType((int)HttpStatusCode.OK, Type = typeof(IEnumerable<RLongRunningJobStatus>))]
|
|
[ProducesResponseType((int)HttpStatusCode.BadRequest, Type = typeof(string))]
|
|
public async Task<IActionResult> CleanUp()
|
|
{
|
|
var res = await _jobService.CleanUp(true, true);
|
|
if (!string.IsNullOrEmpty(res.ExceptionString))
|
|
return BadRequest(res.ExceptionString);
|
|
return Ok();
|
|
}
|
|
|
|
/// <summary>
|
|
/// delete a specific job record, this could be used for deleting records which are not cleanable using the "cleanup" method
|
|
/// </summary>
|
|
/// <param name="id"></param>
|
|
/// <returns></returns>
|
|
[HttpDelete]
|
|
[Route("{id}")]
|
|
[Authorize(Policy = SecurableItem.AuditLogEntityShortName + ":" + SecurableItem.ViewOperationShortName)]
|
|
[ProducesResponseType((int)HttpStatusCode.OK)]
|
|
[ProducesResponseType((int)HttpStatusCode.BadRequest, Type = typeof(string))]
|
|
public async Task<IActionResult> DeleteJob(Guid id)
|
|
{
|
|
var res = await _jobService.DeleteJob(id);
|
|
if (!string.IsNullOrEmpty(res.ExceptionString))
|
|
return BadRequest(res.ExceptionString);
|
|
return Ok();
|
|
}
|
|
|
|
/// <summary>
|
|
/// constructor
|
|
/// </summary>
|
|
/// <param name="jobService">
|
|
/// </param>
|
|
public RLongRunningJobsControllerBase(ILongRunningJobProgressService jobService)
|
|
{
|
|
_jobService = jobService;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Jobs Service
|
|
/// </summary>
|
|
protected readonly ILongRunningJobProgressService _jobService;
|
|
}
|
|
}
|