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

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

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

	public RequestResponse ExecuteAction(QueueRequest queueRequest)
    {
        var requestResponse = new RequestResponse();
        try
        {
            var directoryRequest = JsonConvert.DeserializeObject<CreateDirectoryRequest>(queueRequest.Request);
            requestResponse = PerformRequest(directoryRequest);
            requestResponse.ReturnResponse = directoryRequest;
            return requestResponse;
        }
        catch (Exception exception)
        {
            return RequestResponseHelper.ExceptionUpdateRequestResponse(requestResponse,
                                                                   queueRequest.FileOperationType,
                                                                   exception.Message);
        }
    }

    public RequestResponse PerformRequest(CreateDirectoryRequest request)
    {
        return OperationService.PerformOperation(request, IsRequestValid, CreateDirectory);
    }

    private void CreateDirectory(CreateDirectoryRequest request)
    {
        try
        {
            Directory.CreateDirectory(request.DirectoryDestination);
        }
        catch (Exception exception)
        {
            throw new Exception($"Exception thrown while trying to ExecuteRequestAction. " +
                                 $"Request: {JsonConvert.SerializeObject(request)}" +
                                 $"ExceptionMessage: {exception.Message}");
        }
    }

    public RequestResponse PreQueueValidation(CreateDirectoryRequest originalRequest)
    {
        var requestResponse = new RequestResponse();
        requestResponse = IsRequestValid(originalRequest, requestResponse);
        return requestResponse;
    }

    public RequestResponse IsRequestValid(CreateDirectoryRequest request, RequestResponse requestResponse)
    {
        requestResponse = FileValidation.ValidateDirectoryExists(request.DirectoryPath, requestResponse);
        requestResponse = FileValidation.ValidateDirectoryNotExists(request.DirectoryDestination, requestResponse);
        return requestResponse;
    }
}