public sealed class RunCommand()

in Tools/LambdaTestTool-v2/src/Amazon.Lambda.TestTool/Commands/RunCommand.cs [20:163]
121 lines of code
21 McCabe index (conditional complexity)

public sealed class RunCommand(
    IToolInteractiveService toolInteractiveService, IEnvironmentManager environmentManager) : CancellableAsyncCommand<RunCommandSettings>
{
    public const string LAMBDA_RUNTIME_API_PORT = "LAMBDA_RUNTIME_API_PORT";
    public const string API_GATEWAY_EMULATOR_PORT = "API_GATEWAY_EMULATOR_PORT";

    /// <summary>
    /// Task for the Lambda Runtime API.
    /// </summary>
    public Task LambdRuntimeApiTask { get; private set; }

    /// <summary>
    /// The method responsible for executing the <see cref="RunCommand"/>.
    /// </summary>
    public override async Task<int> ExecuteAsync(CommandContext context, RunCommandSettings settings, CancellationTokenSource cancellationTokenSource)
    {
        try
        {
            EvaluateEnvironmentVariables(settings);

            if (!settings.LambdaEmulatorPort.HasValue && !settings.ApiGatewayEmulatorPort.HasValue && string.IsNullOrEmpty(settings.SQSEventSourceConfig))
            {
                throw new ArgumentException("At least one of the following parameters must be set: " +
                                            "--lambda-emulator-port, --api-gateway-emulator-port or --sqs-eventsource-config");
            }

            var tasks = new List<Task>();

            if (settings.LambdaEmulatorPort.HasValue)
            {
                var testToolProcess = TestToolProcess.Startup(settings, cancellationTokenSource.Token);
                LambdRuntimeApiTask = testToolProcess.RunningTask;
                tasks.Add(testToolProcess.RunningTask);

                if (!settings.NoLaunchWindow)
                {
                    try
                    {
                        var info = new ProcessStartInfo
                        {
                            UseShellExecute = true,
                            FileName = testToolProcess.ServiceUrl
                        };
                        Process.Start(info);
                    }
                    catch (Exception e)
                    {
                        toolInteractiveService.WriteErrorLine($"Error launching browser: {e.Message}");
                    }
                }
            }

            if (settings.ApiGatewayEmulatorPort.HasValue)
            {
                if (settings.ApiGatewayEmulatorMode is null)
                {
                    throw new ArgumentException("When --api-gateway-emulator-port is set the --api-gateway-emulator-mode must be set to configure the mode for the API Gateway emulator.");
                }

                var apiGatewayEmulatorProcess =
                    ApiGatewayEmulatorProcess.Startup(settings, cancellationTokenSource.Token);
                tasks.Add(apiGatewayEmulatorProcess.RunningTask);
            }

            if (!string.IsNullOrEmpty(settings.SQSEventSourceConfig))
            {
                var sqsEventSourceProcess = SQSEventSourceProcess.Startup(settings, cancellationTokenSource.Token);
                tasks.Add(sqsEventSourceProcess.RunningTask);
            }

            await Task.Run(() => Task.WaitAny(tasks.ToArray(), cancellationTokenSource.Token));

            return CommandReturnCodes.Success;
        }
        catch (OperationCanceledException) when (cancellationTokenSource.IsCancellationRequested)
        {
            return CommandReturnCodes.Success;
        }
        catch (Exception e) when (e.IsExpectedException())
        {
            toolInteractiveService.WriteErrorLine(string.Empty);
            toolInteractiveService.WriteErrorLine(e.Message);

            return CommandReturnCodes.UserError;
        }
        catch (Exception e)
        {
            // This is a bug
            toolInteractiveService.WriteErrorLine(
                $"Unhandled exception.{Environment.NewLine}" +
                $"This is a bug.{Environment.NewLine}" +
                $"Please copy the stack trace below and file a bug at {Constants.LinkGithubRepo}. " +
                e.PrettyPrint());

            return CommandReturnCodes.UnhandledException;
        }
        finally
        {
            await cancellationTokenSource.CancelAsync();
        }
    }

    private void EvaluateEnvironmentVariables(RunCommandSettings settings)
    {
        var environmentVariables = environmentManager.GetEnvironmentVariables();
        if (environmentVariables == null)
            return;

        if (environmentVariables.Contains(LAMBDA_RUNTIME_API_PORT))
        {
            var envValue = environmentVariables[LAMBDA_RUNTIME_API_PORT]?.ToString();
            if (int.TryParse(envValue, out var port))
            {
                settings.LambdaEmulatorPort = port;
            }
            else
            {
                throw new ArgumentException($"Value for {LAMBDA_RUNTIME_API_PORT} environment variable was not a valid port number");
            }
        }
        if (environmentVariables.Contains(API_GATEWAY_EMULATOR_PORT))
        {
            var envValue = environmentVariables[API_GATEWAY_EMULATOR_PORT]?.ToString();
            if (int.TryParse(envValue, out var port))
            {
                settings.ApiGatewayEmulatorPort = port;
            }
            else
            {
                throw new ArgumentException($"Value for {API_GATEWAY_EMULATOR_PORT} environment variable was not a valid port number");
            }
        }

        if (settings.SQSEventSourceConfig != null && settings.SQSEventSourceConfig.StartsWith(Constants.ArgumentEnvironmentVariablePrefix, StringComparison.CurrentCultureIgnoreCase))
        {
            var envVariable = settings.SQSEventSourceConfig.Substring(Constants.ArgumentEnvironmentVariablePrefix.Length);
            if (!environmentVariables.Contains(envVariable))
            {
                throw new InvalidOperationException($"Environment variable {envVariable} for the SQS event source config was empty");
            }
            settings.SQSEventSourceConfig = environmentVariables[envVariable]?.ToString();
        }
    }
}