AddResourceUseCase.cs 1.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142
  1. using RackPeek.Domain.Helpers;
  2. using RackPeek.Domain.Persistence;
  3. using RackPeek.Domain.Resources;
  4. namespace RackPeek.Domain.UseCases;
  5. public interface IAddResourceUseCase<T> : IResourceUseCase<T>
  6. where T : Resource
  7. {
  8. Task ExecuteAsync(string name, string? runsOn = null);
  9. }
  10. public class AddResourceUseCase<T>(IResourceCollection repo) : IAddResourceUseCase<T> where T : Resource
  11. {
  12. public async Task ExecuteAsync(string name, string? runsOn = null)
  13. {
  14. name = Normalize.HardwareName(name);
  15. ThrowIfInvalid.ResourceName(name);
  16. var existingResource = await repo.GetByNameAsync(name);
  17. if (existingResource != null)
  18. throw new ConflictException($"Resource '{name}' ({existingResource.Kind}) already exists.");
  19. if (runsOn != null)
  20. {
  21. runsOn = Normalize.HardwareName(runsOn);
  22. ThrowIfInvalid.ResourceName(runsOn);
  23. var parentResource = await repo.GetByNameAsync(runsOn);
  24. if (parentResource == null) throw new NotFoundException($"Resource '{runsOn}' not found.");
  25. if (!Resource.CanRunOn<T>(parentResource))
  26. throw new InvalidOperationException(
  27. $" {Resource.GetKind<T>()} cannot run on {parentResource.Kind} '{runsOn}'.");
  28. }
  29. var resource = Activator.CreateInstance<T>();
  30. resource.Name = name;
  31. resource.RunsOn = runsOn;
  32. await repo.AddAsync(resource);
  33. }
  34. }