monorepo/LCU.API.Internal.FileOperations/LCU.Api.Internal.FileOperations/Services/FileActionServices/DeleteDirectoryService.cs

using System;
using System.IO;
using System.Collections.Generic;
using Newtonsoft.Json;
using LCU.Library.Internal.FileOperationsModels.Models;
using LCU.Library.Internal.FileOperationsModels.Shared;
using LCU.Api.Internal.FileOperations.Validations;
using LCU.Library.Internal.LCUServiceFactory.Configurations;
namespace LCU.Api.Internal.FileOperations.Services.FileActionServices;

public class DeleteDirectoryService : FileActionService, IFileActionService, IActionService<DeleteDirectoryRequest>
{
	public DeleteDirectoryService(ServicesFactoryConfiguration servicesFactoryConfiguration)
        : base(servicesFactoryConfiguration)
	{
	}

	public RequestResponse ExecuteAction(QueueRequest queueRequest)
    {
        var requestResponse = new RequestResponse();
        try
        {
            var directoryRequest = JsonConvert.DeserializeObject<DeleteDirectoryRequest>(queueRequest.Request);

            var requests = BuildListOfRequest(directoryRequest);
            requestResponse = DirectoryValidation.ValidateDirectoryRequestsWithinLimit(requests,
                                                                                     directoryRequest.MaxAmountOfDirectories,
                                                                                     requestResponse);
            if (!requestResponse.IsSuccessful)
            {
                return requestResponse;
            }

            foreach (var request in requests)
            {
                var temporaryRequestResponse = PerformRequest(request);
                if (!temporaryRequestResponse.IsSuccessful)
                {
                    requestResponse.IsSuccessful = temporaryRequestResponse.IsSuccessful;
                    requestResponse.MessageStack.AddRange(temporaryRequestResponse.MessageStack);
                }
            }

            requestResponse.ReturnResponse = directoryRequest;
            return requestResponse;
        }
        catch (Exception exception)
        {
            return RequestResponseHelper.ExceptionUpdateRequestResponse(requestResponse,
                                                                        queueRequest.FileOperationType,
                                                                        exception.Message);
        }
    }

    public RequestResponse PerformRequest(DeleteDirectoryRequest request)
    {
        return OperationService.PerformOperation(request, IsRequestValid, DeleteDirectory);
    }

    private void DeleteDirectory(DeleteDirectoryRequest request)
    {
        try
        {
            Directory.Delete(request.FinalDirectoryPath, request.Recursive);
        }
        catch (Exception exception)
        {
            throw new Exception($"Exception thrown while trying to ExecuteRequestAction. " +
                                $"Request: {JsonConvert.SerializeObject(request)}" +
                                $"ExceptionMessage: {exception.Message}");
        }
    }

    public RequestResponse PreQueueValidation(DeleteDirectoryRequest originalRequest)
    {
        var requestResponse = new RequestResponse();
        requestResponse = DirectoryValidation.ValidateDirectoryExists(originalRequest.DirectoryRootPath, requestResponse);
        if (!requestResponse.IsSuccessful)
        {
            return requestResponse;
        }

        var requestList = BuildListOfRequest(originalRequest);
        requestResponse = DirectoryValidation.ValidateDirectoryRequestsWithinLimit(requestList, 
                                                                                 originalRequest.MaxAmountOfDirectories, 
                                                                                 requestResponse);
        if (!requestResponse.IsSuccessful)
        {
            return requestResponse;
        }

        foreach (var request in requestList)
        {
            requestResponse = IsRequestValid(request, requestResponse);
        }

        return requestResponse;
    }

    public List<DeleteDirectoryRequest> BuildListOfRequest(DeleteDirectoryRequest originalRequest)
    {
        var nameList = RegexNameHandler.BuildDirectoryList(originalRequest.DirectoryRootPath,
                                                           originalRequest.FinalDirectoryName,
                                                           originalRequest.DirectoryNameSettings);
        var requests = new List<DeleteDirectoryRequest>();

        foreach (var name in nameList)
        {
            var newRequest = Clone.DeepClone(originalRequest);
            newRequest.DirectoryName = name;

            requests.Add(newRequest);
        }

        return requests;
    }

    public RequestResponse IsRequestValid(DeleteDirectoryRequest request, RequestResponse requestResponse)
    {
        requestResponse = DirectoryValidation.ValidateDirectoryExists(request.FinalDirectoryPath, requestResponse);
        return requestResponse;
    }
}