using ErsatzTV.Core; using ErsatzTV.Core.Domain.Scheduling; using ErsatzTV.Infrastructure.Data; using Microsoft.EntityFrameworkCore; namespace ErsatzTV.Application.Scheduling; public class CreateTemplateGroupHandler(IDbContextFactory dbContextFactory) : IRequestHandler> { public async Task> Handle( CreateTemplateGroup request, CancellationToken cancellationToken) { await using TvContext dbContext = await dbContextFactory.CreateDbContextAsync(cancellationToken); Validation validation = await Validate(dbContext, request); return await validation.Apply(profile => PersistTemplateGroup(dbContext, profile)); } private static async Task PersistTemplateGroup( TvContext dbContext, TemplateGroup templateGroup) { await dbContext.TemplateGroups.AddAsync(templateGroup); await dbContext.SaveChangesAsync(); return Mapper.ProjectToViewModel(templateGroup); } private static Task> Validate( TvContext dbContext, CreateTemplateGroup request) => ValidateName(dbContext, request).MapT(name => new TemplateGroup { Name = name, Templates = [] }); private static async Task> ValidateName( TvContext dbContext, CreateTemplateGroup createTemplateGroup) { Validation result1 = createTemplateGroup.NotEmpty(c => c.Name) .Bind(_ => createTemplateGroup.NotLongerThan(50)(c => c.Name)); bool duplicateName = await dbContext.TemplateGroups .AnyAsync(ps => ps.Name == createTemplateGroup.Name); Validation result2 = duplicateName ? Fail("Template group name must be unique") : Success(Unit.Default); return (result1, result2).Apply((_, _) => createTemplateGroup.Name); } }