37 lines
885 B
C#
37 lines
885 B
C#
|
using MongoDB.Driver;
|
||
|
|
using MongoDB.Driver.Linq;
|
||
|
|
using server.Models;
|
||
|
|
|
||
|
|
namespace server.Persistence.Repositories
|
||
|
|
{
|
||
|
|
public class EpisodeRepository : IEpisodeRepository
|
||
|
|
{
|
||
|
|
private readonly IDbContext _context;
|
||
|
|
|
||
|
|
public EpisodeRepository(IDbContext context)
|
||
|
|
{
|
||
|
|
_context = context;
|
||
|
|
}
|
||
|
|
|
||
|
|
public async Task<List<Episode>> GetEpisodesAsync(EpisodeFilter? filter)
|
||
|
|
{
|
||
|
|
try
|
||
|
|
{
|
||
|
|
var query = _context.Episodes.AsQueryable();
|
||
|
|
|
||
|
|
if (filter?.Season != null)
|
||
|
|
{
|
||
|
|
query = query.Where(episode => episode.Season == filter.Season);
|
||
|
|
}
|
||
|
|
|
||
|
|
return await query.ToListAsync();
|
||
|
|
}
|
||
|
|
catch (Exception e)
|
||
|
|
{
|
||
|
|
Console.WriteLine(e);
|
||
|
|
throw;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|