feat(configmanager): add config set and connection update CLI commands
Add missing CLI commands to match UI capabilities: config set commands for all configuration sections (datasync, dataaccess, auth, ldap, search, excelexport) and connection update command. Also adds unit tests for SecretCommands, ValidateCommand, and TestConnectionCommand.
This commit is contained in:
Joseph Doherty
@@ -1,12 +1,13 @@
|
||||
using System.CommandLine;
|
||||
using System.Text.Json;
|
||||
using JdeScoping.ConfigManager.Core.Models;
|
||||
using JdeScoping.ConfigManager.Core.Services;
|
||||
using Microsoft.Extensions.DependencyInjection;
|
||||
|
||||
namespace JdeScoping.ConfigManager.Cli.Commands;
|
||||
|
||||
/// <summary>
|
||||
/// Configuration viewing command implementations.
|
||||
/// Configuration viewing and editing command implementations.
|
||||
/// </summary>
|
||||
public static class ConfigCommands
|
||||
{
|
||||
@@ -432,4 +433,601 @@ public static class ConfigCommands
|
||||
var autoDiscoveryService = serviceProvider.GetRequiredService<IAutoDiscoveryService>();
|
||||
return await autoDiscoveryService.FindConfigFolderAsync();
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Creates the config set command with section subcommands.
|
||||
/// </summary>
|
||||
public static Command CreateSetCommand(
|
||||
IServiceProvider serviceProvider,
|
||||
Option<string?> configPathOption,
|
||||
Option<bool> verboseOption,
|
||||
Option<bool> quietOption)
|
||||
{
|
||||
var command = new Command("set", "Modify configuration settings");
|
||||
|
||||
command.AddCommand(CreateSetDataSyncCommand(serviceProvider, configPathOption, verboseOption, quietOption));
|
||||
command.AddCommand(CreateSetDataAccessCommand(serviceProvider, configPathOption, verboseOption, quietOption));
|
||||
command.AddCommand(CreateSetAuthCommand(serviceProvider, configPathOption, verboseOption, quietOption));
|
||||
command.AddCommand(CreateSetLdapCommand(serviceProvider, configPathOption, verboseOption, quietOption));
|
||||
command.AddCommand(CreateSetSearchCommand(serviceProvider, configPathOption, verboseOption, quietOption));
|
||||
command.AddCommand(CreateSetExcelExportCommand(serviceProvider, configPathOption, verboseOption, quietOption));
|
||||
|
||||
return command;
|
||||
}
|
||||
|
||||
private static Command CreateSetDataSyncCommand(
|
||||
IServiceProvider serviceProvider,
|
||||
Option<string?> configPathOption,
|
||||
Option<bool> verboseOption,
|
||||
Option<bool> quietOption)
|
||||
{
|
||||
var command = new Command("datasync", "Modify DataSync configuration");
|
||||
|
||||
var enabledOption = new Option<bool?>("--enabled", "Enable or disable data synchronization");
|
||||
var checkIntervalOption = new Option<int?>("--check-interval", "Check interval in minutes");
|
||||
var maxParallelismOption = new Option<int?>("--max-parallelism", "Maximum degree of parallelism");
|
||||
var batchSizeOption = new Option<int?>("--batch-size", "Batch size for sync operations");
|
||||
var bulkCopyBatchSizeOption = new Option<int?>("--bulk-copy-batch-size", "Batch size for bulk copy operations");
|
||||
var lookbackMultiplierOption = new Option<double?>("--lookback-multiplier", "Lookback multiplier for delta calculations");
|
||||
var purgeRetentionDaysOption = new Option<int?>("--purge-retention-days", "Days to retain synced data before purging");
|
||||
var syncTimeoutOption = new Option<int?>("--sync-timeout", "Timeout in seconds for sync operations");
|
||||
|
||||
command.AddOption(enabledOption);
|
||||
command.AddOption(checkIntervalOption);
|
||||
command.AddOption(maxParallelismOption);
|
||||
command.AddOption(batchSizeOption);
|
||||
command.AddOption(bulkCopyBatchSizeOption);
|
||||
command.AddOption(lookbackMultiplierOption);
|
||||
command.AddOption(purgeRetentionDaysOption);
|
||||
command.AddOption(syncTimeoutOption);
|
||||
|
||||
command.SetHandler(async (context) =>
|
||||
{
|
||||
var configPath = context.ParseResult.GetValueForOption(configPathOption);
|
||||
var verbose = context.ParseResult.GetValueForOption(verboseOption);
|
||||
var quiet = context.ParseResult.GetValueForOption(quietOption);
|
||||
var enabled = context.ParseResult.GetValueForOption(enabledOption);
|
||||
var checkInterval = context.ParseResult.GetValueForOption(checkIntervalOption);
|
||||
var maxParallelism = context.ParseResult.GetValueForOption(maxParallelismOption);
|
||||
var batchSize = context.ParseResult.GetValueForOption(batchSizeOption);
|
||||
var bulkCopyBatchSize = context.ParseResult.GetValueForOption(bulkCopyBatchSizeOption);
|
||||
var lookbackMultiplier = context.ParseResult.GetValueForOption(lookbackMultiplierOption);
|
||||
var purgeRetentionDays = context.ParseResult.GetValueForOption(purgeRetentionDaysOption);
|
||||
var syncTimeout = context.ParseResult.GetValueForOption(syncTimeoutOption);
|
||||
|
||||
var exitCode = await SetDataSyncAsync(
|
||||
serviceProvider, configPath, verbose, quiet,
|
||||
enabled, checkInterval, maxParallelism, batchSize, bulkCopyBatchSize,
|
||||
lookbackMultiplier, purgeRetentionDays, syncTimeout);
|
||||
Environment.ExitCode = exitCode;
|
||||
});
|
||||
|
||||
return command;
|
||||
}
|
||||
|
||||
private static async Task<int> SetDataSyncAsync(
|
||||
IServiceProvider serviceProvider,
|
||||
string? configPath,
|
||||
bool verbose,
|
||||
bool quiet,
|
||||
bool? enabled,
|
||||
int? checkInterval,
|
||||
int? maxParallelism,
|
||||
int? batchSize,
|
||||
int? bulkCopyBatchSize,
|
||||
double? lookbackMultiplier,
|
||||
int? purgeRetentionDays,
|
||||
int? syncTimeout)
|
||||
{
|
||||
return await ModifyConfigAsync(serviceProvider, configPath, verbose, quiet, "DataSync", config =>
|
||||
{
|
||||
var modified = false;
|
||||
|
||||
if (enabled.HasValue)
|
||||
{
|
||||
config.DataSync.Enabled = enabled.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (checkInterval.HasValue)
|
||||
{
|
||||
config.DataSync.CheckInterval = TimeSpan.FromMinutes(checkInterval.Value);
|
||||
modified = true;
|
||||
}
|
||||
if (maxParallelism.HasValue)
|
||||
{
|
||||
config.DataSync.MaxDegreeOfParallelism = maxParallelism.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (batchSize.HasValue)
|
||||
{
|
||||
config.DataSync.BatchSize = batchSize.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (bulkCopyBatchSize.HasValue)
|
||||
{
|
||||
config.DataSync.BulkCopyBatchSize = bulkCopyBatchSize.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (lookbackMultiplier.HasValue)
|
||||
{
|
||||
config.DataSync.LookbackMultiplier = lookbackMultiplier.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (purgeRetentionDays.HasValue)
|
||||
{
|
||||
config.DataSync.PurgeRetentionDays = purgeRetentionDays.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (syncTimeout.HasValue)
|
||||
{
|
||||
config.DataSync.SyncTimeoutSeconds = syncTimeout.Value;
|
||||
modified = true;
|
||||
}
|
||||
|
||||
return modified;
|
||||
});
|
||||
}
|
||||
|
||||
private static Command CreateSetDataAccessCommand(
|
||||
IServiceProvider serviceProvider,
|
||||
Option<string?> configPathOption,
|
||||
Option<bool> verboseOption,
|
||||
Option<bool> quietOption)
|
||||
{
|
||||
var command = new Command("dataaccess", "Modify DataAccess configuration");
|
||||
|
||||
var defaultTimeoutOption = new Option<int?>("--default-timeout", "Default timeout in seconds for database queries");
|
||||
var lotUsageTimeoutOption = new Option<int?>("--lot-usage-timeout", "Timeout in seconds for lot usage queries");
|
||||
var misDataTimeoutOption = new Option<int?>("--mis-data-timeout", "Timeout in seconds for MIS data queries");
|
||||
var detailedLoggingOption = new Option<bool?>("--detailed-logging", "Enable or disable detailed query logging");
|
||||
var productionSchemaOption = new Option<string?>("--production-schema", "Schema name for production data");
|
||||
var archiveSchemaOption = new Option<string?>("--archive-schema", "Schema name for archive data");
|
||||
var stageSchemaOption = new Option<string?>("--stage-schema", "Schema name for staging data");
|
||||
|
||||
command.AddOption(defaultTimeoutOption);
|
||||
command.AddOption(lotUsageTimeoutOption);
|
||||
command.AddOption(misDataTimeoutOption);
|
||||
command.AddOption(detailedLoggingOption);
|
||||
command.AddOption(productionSchemaOption);
|
||||
command.AddOption(archiveSchemaOption);
|
||||
command.AddOption(stageSchemaOption);
|
||||
|
||||
command.SetHandler(async (context) =>
|
||||
{
|
||||
var configPath = context.ParseResult.GetValueForOption(configPathOption);
|
||||
var verbose = context.ParseResult.GetValueForOption(verboseOption);
|
||||
var quiet = context.ParseResult.GetValueForOption(quietOption);
|
||||
var defaultTimeout = context.ParseResult.GetValueForOption(defaultTimeoutOption);
|
||||
var lotUsageTimeout = context.ParseResult.GetValueForOption(lotUsageTimeoutOption);
|
||||
var misDataTimeout = context.ParseResult.GetValueForOption(misDataTimeoutOption);
|
||||
var detailedLogging = context.ParseResult.GetValueForOption(detailedLoggingOption);
|
||||
var productionSchema = context.ParseResult.GetValueForOption(productionSchemaOption);
|
||||
var archiveSchema = context.ParseResult.GetValueForOption(archiveSchemaOption);
|
||||
var stageSchema = context.ParseResult.GetValueForOption(stageSchemaOption);
|
||||
|
||||
var exitCode = await SetDataAccessAsync(
|
||||
serviceProvider, configPath, verbose, quiet,
|
||||
defaultTimeout, lotUsageTimeout, misDataTimeout, detailedLogging,
|
||||
productionSchema, archiveSchema, stageSchema);
|
||||
Environment.ExitCode = exitCode;
|
||||
});
|
||||
|
||||
return command;
|
||||
}
|
||||
|
||||
private static async Task<int> SetDataAccessAsync(
|
||||
IServiceProvider serviceProvider,
|
||||
string? configPath,
|
||||
bool verbose,
|
||||
bool quiet,
|
||||
int? defaultTimeout,
|
||||
int? lotUsageTimeout,
|
||||
int? misDataTimeout,
|
||||
bool? detailedLogging,
|
||||
string? productionSchema,
|
||||
string? archiveSchema,
|
||||
string? stageSchema)
|
||||
{
|
||||
return await ModifyConfigAsync(serviceProvider, configPath, verbose, quiet, "DataAccess", config =>
|
||||
{
|
||||
var modified = false;
|
||||
|
||||
if (defaultTimeout.HasValue)
|
||||
{
|
||||
config.DataAccess.DefaultTimeoutSeconds = defaultTimeout.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (lotUsageTimeout.HasValue)
|
||||
{
|
||||
config.DataAccess.LotUsageTimeoutSeconds = lotUsageTimeout.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (misDataTimeout.HasValue)
|
||||
{
|
||||
config.DataAccess.MisDataTimeoutSeconds = misDataTimeout.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (detailedLogging.HasValue)
|
||||
{
|
||||
config.DataAccess.EnableDetailedLogging = detailedLogging.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (!string.IsNullOrEmpty(productionSchema))
|
||||
{
|
||||
config.DataAccess.ProductionSchema = productionSchema;
|
||||
modified = true;
|
||||
}
|
||||
if (!string.IsNullOrEmpty(archiveSchema))
|
||||
{
|
||||
config.DataAccess.ArchiveSchema = archiveSchema;
|
||||
modified = true;
|
||||
}
|
||||
if (!string.IsNullOrEmpty(stageSchema))
|
||||
{
|
||||
config.DataAccess.StageSchema = stageSchema;
|
||||
modified = true;
|
||||
}
|
||||
|
||||
return modified;
|
||||
});
|
||||
}
|
||||
|
||||
private static Command CreateSetAuthCommand(
|
||||
IServiceProvider serviceProvider,
|
||||
Option<string?> configPathOption,
|
||||
Option<bool> verboseOption,
|
||||
Option<bool> quietOption)
|
||||
{
|
||||
var command = new Command("auth", "Modify Auth configuration");
|
||||
|
||||
var cookieNameOption = new Option<string?>("--cookie-name", "Name of the authentication cookie");
|
||||
var cookieExpirationOption = new Option<int?>("--cookie-expiration", "Cookie expiration time in minutes");
|
||||
|
||||
command.AddOption(cookieNameOption);
|
||||
command.AddOption(cookieExpirationOption);
|
||||
|
||||
command.SetHandler(async (context) =>
|
||||
{
|
||||
var configPath = context.ParseResult.GetValueForOption(configPathOption);
|
||||
var verbose = context.ParseResult.GetValueForOption(verboseOption);
|
||||
var quiet = context.ParseResult.GetValueForOption(quietOption);
|
||||
var cookieName = context.ParseResult.GetValueForOption(cookieNameOption);
|
||||
var cookieExpiration = context.ParseResult.GetValueForOption(cookieExpirationOption);
|
||||
|
||||
var exitCode = await SetAuthAsync(serviceProvider, configPath, verbose, quiet, cookieName, cookieExpiration);
|
||||
Environment.ExitCode = exitCode;
|
||||
});
|
||||
|
||||
return command;
|
||||
}
|
||||
|
||||
private static async Task<int> SetAuthAsync(
|
||||
IServiceProvider serviceProvider,
|
||||
string? configPath,
|
||||
bool verbose,
|
||||
bool quiet,
|
||||
string? cookieName,
|
||||
int? cookieExpiration)
|
||||
{
|
||||
return await ModifyConfigAsync(serviceProvider, configPath, verbose, quiet, "Auth", config =>
|
||||
{
|
||||
var modified = false;
|
||||
|
||||
if (!string.IsNullOrEmpty(cookieName))
|
||||
{
|
||||
config.Auth.CookieName = cookieName;
|
||||
modified = true;
|
||||
}
|
||||
if (cookieExpiration.HasValue)
|
||||
{
|
||||
config.Auth.CookieExpirationMinutes = cookieExpiration.Value;
|
||||
modified = true;
|
||||
}
|
||||
|
||||
return modified;
|
||||
});
|
||||
}
|
||||
|
||||
private static Command CreateSetLdapCommand(
|
||||
IServiceProvider serviceProvider,
|
||||
Option<string?> configPathOption,
|
||||
Option<bool> verboseOption,
|
||||
Option<bool> quietOption)
|
||||
{
|
||||
var command = new Command("ldap", "Modify LDAP configuration");
|
||||
|
||||
var serverUrlsOption = new Option<string?>("--server-urls", "Comma-separated list of LDAP server URLs");
|
||||
var groupDnOption = new Option<string?>("--group-dn", "Distinguished name of the LDAP group for authorization");
|
||||
var searchBaseOption = new Option<string?>("--search-base", "Base distinguished name for LDAP searches");
|
||||
var connectionTimeoutOption = new Option<int?>("--connection-timeout", "Connection timeout in seconds");
|
||||
var useFakeAuthOption = new Option<bool?>("--use-fake-auth", "Use fake authentication instead of LDAP");
|
||||
var adminBypassUsersOption = new Option<string?>("--admin-bypass-users", "Comma-separated list of users that bypass group membership validation");
|
||||
|
||||
command.AddOption(serverUrlsOption);
|
||||
command.AddOption(groupDnOption);
|
||||
command.AddOption(searchBaseOption);
|
||||
command.AddOption(connectionTimeoutOption);
|
||||
command.AddOption(useFakeAuthOption);
|
||||
command.AddOption(adminBypassUsersOption);
|
||||
|
||||
command.SetHandler(async (context) =>
|
||||
{
|
||||
var configPath = context.ParseResult.GetValueForOption(configPathOption);
|
||||
var verbose = context.ParseResult.GetValueForOption(verboseOption);
|
||||
var quiet = context.ParseResult.GetValueForOption(quietOption);
|
||||
var serverUrls = context.ParseResult.GetValueForOption(serverUrlsOption);
|
||||
var groupDn = context.ParseResult.GetValueForOption(groupDnOption);
|
||||
var searchBase = context.ParseResult.GetValueForOption(searchBaseOption);
|
||||
var connectionTimeout = context.ParseResult.GetValueForOption(connectionTimeoutOption);
|
||||
var useFakeAuth = context.ParseResult.GetValueForOption(useFakeAuthOption);
|
||||
var adminBypassUsers = context.ParseResult.GetValueForOption(adminBypassUsersOption);
|
||||
|
||||
var exitCode = await SetLdapAsync(
|
||||
serviceProvider, configPath, verbose, quiet,
|
||||
serverUrls, groupDn, searchBase, connectionTimeout, useFakeAuth, adminBypassUsers);
|
||||
Environment.ExitCode = exitCode;
|
||||
});
|
||||
|
||||
return command;
|
||||
}
|
||||
|
||||
private static async Task<int> SetLdapAsync(
|
||||
IServiceProvider serviceProvider,
|
||||
string? configPath,
|
||||
bool verbose,
|
||||
bool quiet,
|
||||
string? serverUrls,
|
||||
string? groupDn,
|
||||
string? searchBase,
|
||||
int? connectionTimeout,
|
||||
bool? useFakeAuth,
|
||||
string? adminBypassUsers)
|
||||
{
|
||||
return await ModifyConfigAsync(serviceProvider, configPath, verbose, quiet, "LDAP", config =>
|
||||
{
|
||||
var modified = false;
|
||||
|
||||
if (serverUrls != null)
|
||||
{
|
||||
config.Ldap.ServerUrls = serverUrls.Split(',', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries);
|
||||
modified = true;
|
||||
}
|
||||
if (groupDn != null)
|
||||
{
|
||||
config.Ldap.GroupDn = groupDn;
|
||||
modified = true;
|
||||
}
|
||||
if (searchBase != null)
|
||||
{
|
||||
config.Ldap.SearchBase = searchBase;
|
||||
modified = true;
|
||||
}
|
||||
if (connectionTimeout.HasValue)
|
||||
{
|
||||
config.Ldap.ConnectionTimeoutSeconds = connectionTimeout.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (useFakeAuth.HasValue)
|
||||
{
|
||||
config.Ldap.UseFakeAuth = useFakeAuth.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (adminBypassUsers != null)
|
||||
{
|
||||
config.Ldap.AdminBypassUsers = adminBypassUsers.Split(',', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries);
|
||||
modified = true;
|
||||
}
|
||||
|
||||
return modified;
|
||||
});
|
||||
}
|
||||
|
||||
private static Command CreateSetSearchCommand(
|
||||
IServiceProvider serviceProvider,
|
||||
Option<string?> configPathOption,
|
||||
Option<bool> verboseOption,
|
||||
Option<bool> quietOption)
|
||||
{
|
||||
var command = new Command("search", "Modify Search configuration");
|
||||
|
||||
var maxResultRowsOption = new Option<int?>("--max-result-rows", "Maximum number of result rows returned by a search");
|
||||
var timeoutOption = new Option<int?>("--timeout", "Timeout in seconds for search operations");
|
||||
var maxConcurrentOption = new Option<int?>("--max-concurrent", "Maximum number of concurrent search operations");
|
||||
|
||||
command.AddOption(maxResultRowsOption);
|
||||
command.AddOption(timeoutOption);
|
||||
command.AddOption(maxConcurrentOption);
|
||||
|
||||
command.SetHandler(async (context) =>
|
||||
{
|
||||
var configPath = context.ParseResult.GetValueForOption(configPathOption);
|
||||
var verbose = context.ParseResult.GetValueForOption(verboseOption);
|
||||
var quiet = context.ParseResult.GetValueForOption(quietOption);
|
||||
var maxResultRows = context.ParseResult.GetValueForOption(maxResultRowsOption);
|
||||
var timeout = context.ParseResult.GetValueForOption(timeoutOption);
|
||||
var maxConcurrent = context.ParseResult.GetValueForOption(maxConcurrentOption);
|
||||
|
||||
var exitCode = await SetSearchAsync(serviceProvider, configPath, verbose, quiet, maxResultRows, timeout, maxConcurrent);
|
||||
Environment.ExitCode = exitCode;
|
||||
});
|
||||
|
||||
return command;
|
||||
}
|
||||
|
||||
private static async Task<int> SetSearchAsync(
|
||||
IServiceProvider serviceProvider,
|
||||
string? configPath,
|
||||
bool verbose,
|
||||
bool quiet,
|
||||
int? maxResultRows,
|
||||
int? timeout,
|
||||
int? maxConcurrent)
|
||||
{
|
||||
return await ModifyConfigAsync(serviceProvider, configPath, verbose, quiet, "Search", config =>
|
||||
{
|
||||
var modified = false;
|
||||
|
||||
if (maxResultRows.HasValue)
|
||||
{
|
||||
config.Search.MaxResultRows = maxResultRows.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (timeout.HasValue)
|
||||
{
|
||||
config.Search.TimeoutSeconds = timeout.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (maxConcurrent.HasValue)
|
||||
{
|
||||
config.Search.MaxConcurrentSearches = maxConcurrent.Value;
|
||||
modified = true;
|
||||
}
|
||||
|
||||
return modified;
|
||||
});
|
||||
}
|
||||
|
||||
private static Command CreateSetExcelExportCommand(
|
||||
IServiceProvider serviceProvider,
|
||||
Option<string?> configPathOption,
|
||||
Option<bool> verboseOption,
|
||||
Option<bool> quietOption)
|
||||
{
|
||||
var command = new Command("excelexport", "Modify ExcelExport configuration");
|
||||
|
||||
var maxRowsPerSheetOption = new Option<int?>("--max-rows-per-sheet", "Maximum number of rows per Excel worksheet");
|
||||
var dateFormatOption = new Option<string?>("--date-format", "Default date format for Excel exports");
|
||||
var timezoneIdOption = new Option<string?>("--timezone-id", "Time zone identifier for date/time conversions");
|
||||
var debugWriteToFileOption = new Option<bool?>("--debug-write-to-file", "Write debug output to files");
|
||||
var debugOutputDirOption = new Option<string?>("--debug-output-dir", "Directory path for debug output files");
|
||||
|
||||
command.AddOption(maxRowsPerSheetOption);
|
||||
command.AddOption(dateFormatOption);
|
||||
command.AddOption(timezoneIdOption);
|
||||
command.AddOption(debugWriteToFileOption);
|
||||
command.AddOption(debugOutputDirOption);
|
||||
|
||||
command.SetHandler(async (context) =>
|
||||
{
|
||||
var configPath = context.ParseResult.GetValueForOption(configPathOption);
|
||||
var verbose = context.ParseResult.GetValueForOption(verboseOption);
|
||||
var quiet = context.ParseResult.GetValueForOption(quietOption);
|
||||
var maxRowsPerSheet = context.ParseResult.GetValueForOption(maxRowsPerSheetOption);
|
||||
var dateFormat = context.ParseResult.GetValueForOption(dateFormatOption);
|
||||
var timezoneId = context.ParseResult.GetValueForOption(timezoneIdOption);
|
||||
var debugWriteToFile = context.ParseResult.GetValueForOption(debugWriteToFileOption);
|
||||
var debugOutputDir = context.ParseResult.GetValueForOption(debugOutputDirOption);
|
||||
|
||||
var exitCode = await SetExcelExportAsync(
|
||||
serviceProvider, configPath, verbose, quiet,
|
||||
maxRowsPerSheet, dateFormat, timezoneId, debugWriteToFile, debugOutputDir);
|
||||
Environment.ExitCode = exitCode;
|
||||
});
|
||||
|
||||
return command;
|
||||
}
|
||||
|
||||
private static async Task<int> SetExcelExportAsync(
|
||||
IServiceProvider serviceProvider,
|
||||
string? configPath,
|
||||
bool verbose,
|
||||
bool quiet,
|
||||
int? maxRowsPerSheet,
|
||||
string? dateFormat,
|
||||
string? timezoneId,
|
||||
bool? debugWriteToFile,
|
||||
string? debugOutputDir)
|
||||
{
|
||||
return await ModifyConfigAsync(serviceProvider, configPath, verbose, quiet, "ExcelExport", config =>
|
||||
{
|
||||
var modified = false;
|
||||
|
||||
if (maxRowsPerSheet.HasValue)
|
||||
{
|
||||
config.ExcelExport.MaxRowsPerSheet = maxRowsPerSheet.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (!string.IsNullOrEmpty(dateFormat))
|
||||
{
|
||||
config.ExcelExport.DefaultDateFormat = dateFormat;
|
||||
modified = true;
|
||||
}
|
||||
if (!string.IsNullOrEmpty(timezoneId))
|
||||
{
|
||||
config.ExcelExport.TimezoneId = timezoneId;
|
||||
modified = true;
|
||||
}
|
||||
if (debugWriteToFile.HasValue)
|
||||
{
|
||||
config.ExcelExport.DebugWriteToFile = debugWriteToFile.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (!string.IsNullOrEmpty(debugOutputDir))
|
||||
{
|
||||
config.ExcelExport.DebugOutputDirectory = debugOutputDir;
|
||||
modified = true;
|
||||
}
|
||||
|
||||
return modified;
|
||||
});
|
||||
}
|
||||
|
||||
private static async Task<int> ModifyConfigAsync(
|
||||
IServiceProvider serviceProvider,
|
||||
string? configPath,
|
||||
bool verbose,
|
||||
bool quiet,
|
||||
string sectionName,
|
||||
Func<ConfigModel, bool> modifier)
|
||||
{
|
||||
var folderPath = await GetConfigFolderAsync(serviceProvider, configPath);
|
||||
if (folderPath == null)
|
||||
{
|
||||
Console.Error.WriteLine("Error: Could not find configuration folder. Use --config-path to specify.");
|
||||
return 1;
|
||||
}
|
||||
|
||||
var configFileService = serviceProvider.GetRequiredService<IConfigFileService>();
|
||||
var backupService = serviceProvider.GetRequiredService<IBackupService>();
|
||||
var appSettingsPath = Path.Combine(folderPath, "appsettings.json");
|
||||
|
||||
if (!File.Exists(appSettingsPath))
|
||||
{
|
||||
Console.Error.WriteLine($"Error: appsettings.json not found at {appSettingsPath}");
|
||||
return 1;
|
||||
}
|
||||
|
||||
try
|
||||
{
|
||||
var config = await configFileService.LoadAppSettingsAsync(appSettingsPath);
|
||||
var modified = modifier(config);
|
||||
|
||||
if (!modified)
|
||||
{
|
||||
Console.Error.WriteLine("Error: No changes specified. Use --help to see available options.");
|
||||
return 1;
|
||||
}
|
||||
|
||||
// Create backup before saving
|
||||
var backupPath = await backupService.CreateBackupAsync(appSettingsPath);
|
||||
if (verbose)
|
||||
{
|
||||
Console.WriteLine($"Backup created: {Path.GetFileName(backupPath)}");
|
||||
}
|
||||
|
||||
await configFileService.SaveAppSettingsAsync(appSettingsPath, config);
|
||||
|
||||
if (!quiet)
|
||||
{
|
||||
Console.WriteLine($"{sectionName} configuration updated successfully");
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
Console.Error.WriteLine($"Error: {ex.Message}");
|
||||
return 1;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -155,6 +155,84 @@ public static class ConnectionCommands
|
||||
return command;
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Creates the connection update command.
|
||||
/// </summary>
|
||||
public static Command CreateUpdateCommand(
|
||||
IServiceProvider serviceProvider,
|
||||
Option<string?> configPathOption,
|
||||
Option<bool> verboseOption,
|
||||
Option<bool> quietOption)
|
||||
{
|
||||
var command = new Command("update", "Update an existing connection");
|
||||
|
||||
var nameArgument = new Argument<string>("name", "The connection name to update");
|
||||
command.AddArgument(nameArgument);
|
||||
|
||||
var providerOption = new Option<ConnectionProvider?>(
|
||||
aliases: ["--provider", "-p"],
|
||||
description: "Database provider (SqlServer, Oracle, Generic)");
|
||||
command.AddOption(providerOption);
|
||||
|
||||
var serverOption = new Option<string?>(
|
||||
aliases: ["--server", "-s"],
|
||||
description: "Server name or host");
|
||||
command.AddOption(serverOption);
|
||||
|
||||
var databaseOption = new Option<string?>(
|
||||
aliases: ["--database", "-d"],
|
||||
description: "Database name");
|
||||
command.AddOption(databaseOption);
|
||||
|
||||
var userOption = new Option<string?>(
|
||||
aliases: ["--user", "-u"],
|
||||
description: "User ID");
|
||||
command.AddOption(userOption);
|
||||
|
||||
var passwordOption = new Option<string?>(
|
||||
aliases: ["--password"],
|
||||
description: "Password (will be stored in config)");
|
||||
command.AddOption(passwordOption);
|
||||
|
||||
var portOption = new Option<int?>(
|
||||
aliases: ["--port"],
|
||||
description: "Port number");
|
||||
command.AddOption(portOption);
|
||||
|
||||
var serviceNameOption = new Option<string?>(
|
||||
aliases: ["--service-name"],
|
||||
description: "Oracle service name");
|
||||
command.AddOption(serviceNameOption);
|
||||
|
||||
var rawOption = new Option<string?>(
|
||||
aliases: ["--raw"],
|
||||
description: "Raw connection string (for Generic provider)");
|
||||
command.AddOption(rawOption);
|
||||
|
||||
command.SetHandler(async (context) =>
|
||||
{
|
||||
var configPath = context.ParseResult.GetValueForOption(configPathOption);
|
||||
var verbose = context.ParseResult.GetValueForOption(verboseOption);
|
||||
var quiet = context.ParseResult.GetValueForOption(quietOption);
|
||||
var name = context.ParseResult.GetValueForArgument(nameArgument);
|
||||
var provider = context.ParseResult.GetValueForOption(providerOption);
|
||||
var server = context.ParseResult.GetValueForOption(serverOption);
|
||||
var database = context.ParseResult.GetValueForOption(databaseOption);
|
||||
var user = context.ParseResult.GetValueForOption(userOption);
|
||||
var password = context.ParseResult.GetValueForOption(passwordOption);
|
||||
var port = context.ParseResult.GetValueForOption(portOption);
|
||||
var serviceName = context.ParseResult.GetValueForOption(serviceNameOption);
|
||||
var raw = context.ParseResult.GetValueForOption(rawOption);
|
||||
|
||||
var exitCode = await UpdateConnectionAsync(
|
||||
serviceProvider, configPath, verbose, quiet,
|
||||
name, provider, server, database, user, password, port, serviceName, raw);
|
||||
Environment.ExitCode = exitCode;
|
||||
});
|
||||
|
||||
return command;
|
||||
}
|
||||
|
||||
private static async Task<int> ListConnectionsAsync(
|
||||
IServiceProvider serviceProvider,
|
||||
string? configPath,
|
||||
@@ -438,6 +516,118 @@ public static class ConnectionCommands
|
||||
}
|
||||
}
|
||||
|
||||
private static async Task<int> UpdateConnectionAsync(
|
||||
IServiceProvider serviceProvider,
|
||||
string? configPath,
|
||||
bool verbose,
|
||||
bool quiet,
|
||||
string name,
|
||||
ConnectionProvider? provider,
|
||||
string? server,
|
||||
string? database,
|
||||
string? user,
|
||||
string? password,
|
||||
int? port,
|
||||
string? serviceName,
|
||||
string? raw)
|
||||
{
|
||||
var folderPath = await GetConfigFolderAsync(serviceProvider, configPath);
|
||||
if (folderPath == null)
|
||||
{
|
||||
Console.Error.WriteLine("Error: Could not find configuration folder. Use --config-path to specify.");
|
||||
return 1;
|
||||
}
|
||||
|
||||
var configFileService = serviceProvider.GetRequiredService<IConfigFileService>();
|
||||
var appSettingsPath = Path.Combine(folderPath, "appsettings.json");
|
||||
|
||||
if (!File.Exists(appSettingsPath))
|
||||
{
|
||||
Console.Error.WriteLine($"Error: appsettings.json not found at {appSettingsPath}");
|
||||
return 1;
|
||||
}
|
||||
|
||||
try
|
||||
{
|
||||
var config = await configFileService.LoadAppSettingsAsync(appSettingsPath);
|
||||
var entry = config.ConnectionStrings.Entries.FirstOrDefault(e =>
|
||||
e.Name.Equals(name, StringComparison.OrdinalIgnoreCase));
|
||||
|
||||
if (entry == null)
|
||||
{
|
||||
Console.Error.WriteLine($"Error: Connection '{name}' not found");
|
||||
return 1;
|
||||
}
|
||||
|
||||
var modified = false;
|
||||
|
||||
if (provider.HasValue)
|
||||
{
|
||||
entry.Provider = provider.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (server != null)
|
||||
{
|
||||
entry.Server = server;
|
||||
entry.Host = server; // For Oracle, use server as host
|
||||
modified = true;
|
||||
}
|
||||
if (database != null)
|
||||
{
|
||||
entry.Database = database;
|
||||
modified = true;
|
||||
}
|
||||
if (user != null)
|
||||
{
|
||||
entry.UserId = user;
|
||||
modified = true;
|
||||
}
|
||||
if (password != null)
|
||||
{
|
||||
entry.Password = password;
|
||||
modified = true;
|
||||
}
|
||||
if (port.HasValue)
|
||||
{
|
||||
if (entry.Provider == ConnectionProvider.SqlServer)
|
||||
entry.SqlServerPort = port;
|
||||
else if (entry.Provider == ConnectionProvider.Oracle)
|
||||
entry.Port = port.Value;
|
||||
modified = true;
|
||||
}
|
||||
if (serviceName != null)
|
||||
{
|
||||
entry.ServiceName = serviceName;
|
||||
modified = true;
|
||||
}
|
||||
if (raw != null)
|
||||
{
|
||||
entry.RawConnectionString = raw;
|
||||
modified = true;
|
||||
}
|
||||
|
||||
if (!modified)
|
||||
{
|
||||
Console.Error.WriteLine("Error: No changes specified. Use --help to see available options.");
|
||||
return 1;
|
||||
}
|
||||
|
||||
await configFileService.SaveAppSettingsAsync(appSettingsPath, config);
|
||||
|
||||
if (!quiet)
|
||||
{
|
||||
Console.WriteLine($"Connection '{name}' updated successfully");
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
Console.Error.WriteLine($"Error: {ex.Message}");
|
||||
return 1;
|
||||
}
|
||||
}
|
||||
|
||||
private static string MaskPassword(string? password)
|
||||
{
|
||||
if (string.IsNullOrEmpty(password))
|
||||
|
||||
@@ -79,8 +79,9 @@ public static class Program
|
||||
rootCommand.AddCommand(pipelineCommand);
|
||||
|
||||
// Config command group
|
||||
var configCommand = new Command("config", "View configuration settings");
|
||||
var configCommand = new Command("config", "View and modify configuration settings");
|
||||
configCommand.AddCommand(ConfigCommands.CreateShowCommand(serviceProvider, configPathOption, verboseOption, quietOption));
|
||||
configCommand.AddCommand(ConfigCommands.CreateSetCommand(serviceProvider, configPathOption, verboseOption, quietOption));
|
||||
rootCommand.AddCommand(configCommand);
|
||||
|
||||
// Backup command group
|
||||
@@ -96,6 +97,7 @@ public static class Program
|
||||
connectionCommand.AddCommand(ConnectionCommands.CreateListCommand(serviceProvider, configPathOption, verboseOption, quietOption));
|
||||
connectionCommand.AddCommand(ConnectionCommands.CreateShowCommand(serviceProvider, configPathOption, verboseOption, quietOption));
|
||||
connectionCommand.AddCommand(ConnectionCommands.CreateAddCommand(serviceProvider, configPathOption, verboseOption, quietOption));
|
||||
connectionCommand.AddCommand(ConnectionCommands.CreateUpdateCommand(serviceProvider, configPathOption, verboseOption, quietOption));
|
||||
connectionCommand.AddCommand(ConnectionCommands.CreateRemoveCommand(serviceProvider, configPathOption, verboseOption, quietOption));
|
||||
rootCommand.AddCommand(connectionCommand);
|
||||
|
||||
|
||||
Reference in New Issue
Block a user