mirror of
https://github.com/fergalmoran/podnoms.git
synced 2025-12-23 01:40:26 +00:00
46 lines
1.7 KiB
C#
46 lines
1.7 KiB
C#
using System.Threading.Tasks;
|
|
using AutoMapper;
|
|
using Hangfire;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using Microsoft.Extensions.Logging;
|
|
using PodNoms.Api.Models;
|
|
using PodNoms.Api.Models.ViewModels;
|
|
using PodNoms.Api.Persistence;
|
|
using PodNoms.Api.Services.Jobs;
|
|
|
|
namespace PodNoms.Api.Controllers {
|
|
[Route("[controller]")]
|
|
public class PlaylistController : Controller {
|
|
private readonly IPlaylistRepository _playlistRepository;
|
|
private readonly IPodcastRepository _podcastRepository;
|
|
private readonly IUnitOfWork _unitOfWork;
|
|
private readonly IMapper _mapper;
|
|
private readonly ILogger _logger;
|
|
|
|
public PlaylistController(IPlaylistRepository playlistRepository, IPodcastRepository podcastRepository,
|
|
IUnitOfWork unitOfWork, IMapper mapper, ILoggerFactory logger) {
|
|
this._logger = logger.CreateLogger<EntryController>();
|
|
this._playlistRepository = playlistRepository;
|
|
this._podcastRepository = podcastRepository;
|
|
this._unitOfWork = unitOfWork;
|
|
this._mapper = mapper;
|
|
}
|
|
|
|
[HttpPost]
|
|
public async Task<ActionResult<Playlist>> Post([FromBody] PodcastEntryViewModel entry) {
|
|
var podcast = await _podcastRepository.GetAsync(entry.PodcastId);
|
|
if (podcast != null) {
|
|
var playlist = new Playlist() {
|
|
Podcast = podcast,
|
|
SourceUrl = entry.SourceUrl
|
|
};
|
|
_playlistRepository.AddOrUpdate(playlist);
|
|
await _unitOfWork.CompleteAsync();
|
|
BackgroundJob.Enqueue<ProcessPlaylistsJob>(job => job.Execute(playlist.Id));
|
|
return Ok(playlist);
|
|
}
|
|
return NotFound();
|
|
}
|
|
}
|
|
}
|