public record BicepDeploymentStartParams()

in src/Bicep.LangServer/Handlers/BicepDeploymentStartCommandHandler.cs [24:203]
147 lines of code
10 McCabe index (conditional complexity)

    public record BicepDeploymentStartParams(
        string documentPath,
        string? parametersFilePath,
        string id,
        string deploymentScope,
        string location,
        string template,
        string token,
        string expiresOnTimestamp,
        string deployId,
        string deploymentName,
        string portalUrl,
        bool parametersFileExists,
        string? parametersFileName,
        ParametersFileUpdateOption parametersFileUpdateOption,
        List<BicepUpdatedDeploymentParameter> updatedDeploymentParameters,
        string resourceManagerEndpointUrl,
        string audience) : IRequest<string>;

    public record BicepDeploymentStartResponse(bool isSuccess, string outputMessage, string? viewDeploymentInPortalMessage);

    public record BicepparamCompilationResult(bool isSuccess, string compilationResult);

    public class BicepDeploymentStartCommandHandler : ExecuteTypedResponseCommandHandlerBase<BicepDeploymentStartParams, BicepDeploymentStartResponse>
    {
        private readonly IDeploymentCollectionProvider deploymentCollectionProvider;
        private readonly IDeploymentOperationsCache deploymentOperationsCache;
        private readonly ITelemetryProvider telemetryProvider;
        private readonly BicepCompiler bicepCompiler;
        private readonly ICompilationManager compilationManager;
        private readonly IArmClientProvider armClientProvider;
        private readonly IDeploymentHelper deploymentHelper;

        public BicepDeploymentStartCommandHandler(IDeploymentCollectionProvider deploymentCollectionProvider, IDeploymentOperationsCache deploymentOperationsCache, BicepCompiler bicepCompiler, ICompilationManager compilationManager, ISerializer serializer, ITelemetryProvider telemetryProvider, IArmClientProvider armClientProvider, IDeploymentHelper deploymentHelper)
            : base(LangServerConstants.DeployStartCommand, serializer)
        {
            this.deploymentCollectionProvider = deploymentCollectionProvider;
            this.deploymentOperationsCache = deploymentOperationsCache;
            this.telemetryProvider = telemetryProvider;
            this.bicepCompiler = bicepCompiler;
            this.compilationManager = compilationManager;
            this.armClientProvider = armClientProvider;
            this.deploymentHelper = deploymentHelper;
        }

        public override async Task<BicepDeploymentStartResponse> Handle(BicepDeploymentStartParams request, CancellationToken cancellationToken)
        {
            PostDeployStartTelemetryEvent(request.deployId);

            var options = new ArmClientOptions();
            options.Diagnostics.ApplySharedResourceManagerSettings();
            options.Environment = new ArmEnvironment(new Uri(request.resourceManagerEndpointUrl), request.audience);

            var credential = new CredentialFromTokenAndTimeStamp(request.token, request.expiresOnTimestamp);
            var armClient = armClientProvider.createArmClient(credential, default, options);

            //starting with empty valid json (that can be parsed) for deployments with no parameters
            string parametersFileJson = "{}";

            if (request.parametersFilePath is { })
            {
                if (PathHelper.HasBicepparamsExtension(DocumentUri.FromFileSystemPath(request.parametersFilePath).ToUriEncoded()))
                {
                    //params file validation
                    if (request.parametersFileUpdateOption != ParametersFileUpdateOption.None)
                    {
                        return new BicepDeploymentStartResponse(false, "Cannot create/overwrite/update parameter files when using a bicep parameters file", null);
                    }

                    if (request.updatedDeploymentParameters.Any())
                    {
                        return new BicepDeploymentStartResponse(false, "Cannot update parameters for bicep parameter file", null);
                    }

                    //params file compilation
                    var bicepparamCompilationResult = await TryCompileBicepparamFile(request.parametersFilePath);

                    if (!bicepparamCompilationResult.isSuccess)
                    {
                        return new BicepDeploymentStartResponse(false, bicepparamCompilationResult.compilationResult, null);
                    }
                    else
                    {
                        parametersFileJson = ExtractParametersObjectValue(bicepparamCompilationResult.compilationResult);
                    }
                }
                else
                {
                    //request.parametersFileName only exists for a json parameter file
                    //as it maybe need to create a file if none exits on disk
                    if (request.parametersFileName is { })
                    {
                        try
                        {
                            parametersFileJson = DeploymentParametersHelper.GetUpdatedParametersFileContents(
                                request.documentPath,
                                request.parametersFileName,
                                request.parametersFilePath,
                                request.parametersFileUpdateOption,
                                request.updatedDeploymentParameters);
                        }
                        catch (Exception e)
                        {
                            return new BicepDeploymentStartResponse(false, e.Message, null);
                        }
                    }
                    else
                    {
                        return new BicepDeploymentStartResponse(false, "ParametersFileName must be provided with JSON parameters file", null);
                    }
                }
            }

            //stringified json for params passed here
            var bicepDeploymentStartResponse = await deploymentHelper.StartDeploymentAsync(
                deploymentCollectionProvider,
                armClient,
                request.documentPath,
                request.template,
                request.id,
                request.deploymentScope,
                request.location,
                request.deployId,
                request.portalUrl,
                request.deploymentName,
                JsonElementFactory.CreateElement(parametersFileJson),
                deploymentOperationsCache);

            PostDeployStartResultTelemetryEvent(request.deployId, bicepDeploymentStartResponse.isSuccess);

            return bicepDeploymentStartResponse;
        }

        private void PostDeployStartTelemetryEvent(string deployId)
        {
            var telemetryEvent = BicepTelemetryEvent.CreateDeployStart(deployId);

            telemetryProvider.PostEvent(telemetryEvent);
        }

        private void PostDeployStartResultTelemetryEvent(string deployId, bool isSuccess)
        {
            var telemetryEvent = BicepTelemetryEvent.CreateDeployStartOrWaitForCompletionResult(
                TelemetryConstants.EventNames.DeployStartResult,
                deployId,
                isSuccess);

            telemetryProvider.PostEvent(telemetryEvent);
        }

        public async Task<BicepparamCompilationResult> TryCompileBicepparamFile(string parametersFilePath)
        {
            var documentUri = DocumentUri.FromFileSystemPath(parametersFilePath);
            var compilation = await new CompilationHelper(bicepCompiler, compilationManager).GetRefreshedCompilation(documentUri);

            var paramsResult = compilation.Emitter.Parameters();

            if (paramsResult.Parameters is null)
            {
                var fileDiagnosticPair = KeyValuePair.Create(compilation.SourceFileGrouping.EntryPoint, paramsResult.Diagnostics[compilation.SourceFileGrouping.EntryPoint]);
                return new BicepparamCompilationResult(false, DiagnosticsHelper.GetDiagnosticsMessage(fileDiagnosticPair));
            }

            return new BicepparamCompilationResult(true, paramsResult.Parameters);
        }

        public string ExtractParametersObjectValue(string JsonParametersContent)
        {
            var jObject = JObject.Parse(JsonParametersContent);
            var parameters = jObject["parameters"];

            if (parameters is not null)
            {
                return parameters.ToString();
            }

            //return original JSON if no "parameters" property found
            return jObject.ToString();
        }
    }