nona-config/cli/src/Nona.Cli/Migrate/MigrateCommands.cs at 3294293a78a32c03f9cae4528ca7079913bec628 · Ryware/nona-config · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
using System.CommandLine;
using System.CommandLine.Invocation;
using System.CommandLine.NamingConventionBinder;
using Nona.Cli.Migrate.Commands;

namespace Nona.Cli.Migrate;

internal sealed class MigrateCommands(CliContext ctx) : ICliCommandGroup
{
    public Command Build()
    {
        var migrate = new Command("migrate", "Run migration commands.");
        migrate.AddCommand(BuildFirebase());
        migrate.AddCommand(BuildParameterStore());
        return migrate;
    }

    private Command BuildFirebase()
    {
        var configOpt = new Option<string?>("--config", "Migration config file path.");
        var dryRunOpt = new Option<bool>("--dry-run", "Preview changes without applying them.");
        var baseUrlOpt = new Option<string?>(["--base-url", "--api-url"], "Nona base URL.");
        var projectOpt = new Option<string?>(["--project", "--project-name"], "Nona project name.");
        var tokenOpt = new Option<string?>(["--token", "--bearer-token"], "Admin bearer token.");
        var emailOpt = new Option<string?>("--email", "Admin email used by the migrator when no token is supplied.");
        var passwordOpt = new Option<string?>("--password", "Admin password used by the migrator when no token is supplied.");

        var handler = new FirebaseMigrateCommandHandler();
        var cmd = new Command("firebase", "Import Firebase Remote Config into Nona.");
        cmd.AddOption(configOpt);
        cmd.AddOption(dryRunOpt);
        cmd.AddOption(baseUrlOpt);
        cmd.AddOption(projectOpt);
        cmd.AddOption(tokenOpt);
        cmd.AddOption(emailOpt);
        cmd.AddOption(passwordOpt);
        cmd.Handler = CommandHandler.Create(async (InvocationContext ic) =>
        {
            var connection = ctx.Resolver.ResolveMigrationConnection(
                ic.ParseResult.GetValueForOption(baseUrlOpt),
                ic.ParseResult.GetValueForOption(tokenOpt),
                ic.ParseResult.GetValueForOption(emailOpt),
                ic.ParseResult.GetValueForOption(passwordOpt));
            var project = ctx.Resolver.Project(ic.ParseResult.GetValueForOption(projectOpt));

            var args = ctx.Resolver.BuildFirebaseArgs(
                ic.ParseResult.GetValueForOption(configOpt),
                ic.ParseResult.GetValueForOption(dryRunOpt),
                connection.BaseUrl,
                project,
                connection.Token,
                connection.Email,
                connection.Password);

            ic.ExitCode = await handler.HandleAsync(new FirebaseMigrateCommand(args), ic.GetCancellationToken());
        });

        return cmd;
    }

    private Command BuildParameterStore()
    {
        var taskDefinitionOpt = new Option<string>(
            "--task-definition",
            "Local ECS task definition JSON path.")
        {
            IsRequired = true
        };
        var environmentOpt = new Option<string>(
            "--environment",
            "Target Nona environment.")
        {
            IsRequired = true
        };
        var regionOpt = new Option<string?>("--region", "AWS region for non-ARN Parameter Store references.");
        var profileOpt = new Option<string?>("--profile", "AWS shared credentials profile.");
        var dryRunOpt = new Option<bool>("--dry-run", "Preview changes without applying them.");
        var baseUrlOpt = new Option<string?>(["--base-url", "--api-url"], "Nona base URL.");
        var projectOpt = new Option<string?>(["--project", "--project-name"], "Nona project name.");
        var tokenOpt = new Option<string?>(["--token", "--bearer-token"], "Admin bearer token.");
        var emailOpt = new Option<string?>("--email", "Admin email used by the migrator when no token is supplied.");
        var passwordOpt = new Option<string?>("--password", "Admin password used by the migrator when no token is supplied.");

        var handler = new ParameterStoreMigrateCommandHandler();
        var cmd = new Command("parameter-store", "Import AWS Parameter Store values referenced by an ECS task definition into Nona.");
        cmd.AddOption(taskDefinitionOpt);
        cmd.AddOption(environmentOpt);
        cmd.AddOption(regionOpt);
        cmd.AddOption(profileOpt);
        cmd.AddOption(dryRunOpt);
        cmd.AddOption(baseUrlOpt);
        cmd.AddOption(projectOpt);
        cmd.AddOption(tokenOpt);
        cmd.AddOption(emailOpt);
        cmd.AddOption(passwordOpt);
        cmd.Handler = CommandHandler.Create(async (InvocationContext ic) =>
        {
            var connection = ctx.Resolver.ResolveMigrationConnection(
                ic.ParseResult.GetValueForOption(baseUrlOpt),
                ic.ParseResult.GetValueForOption(tokenOpt),
                ic.ParseResult.GetValueForOption(emailOpt),
                ic.ParseResult.GetValueForOption(passwordOpt));
            var project = ctx.Resolver.Project(ic.ParseResult.GetValueForOption(projectOpt));

            var args = ctx.Resolver.BuildParameterStoreArgs(
                ic.ParseResult.GetValueForOption(taskDefinitionOpt)!,
                ic.ParseResult.GetValueForOption(environmentOpt)!,
                ic.ParseResult.GetValueForOption(regionOpt),
                ic.ParseResult.GetValueForOption(profileOpt),
                ic.ParseResult.GetValueForOption(dryRunOpt),
                connection.BaseUrl,
                project,
                connection.Token,
                connection.Email,
                connection.Password);

            ic.ExitCode = await handler.HandleAsync(
                new ParameterStoreMigrateCommand(args),
                ic.GetCancellationToken());
        });

        return cmd;
    }
}