ayan.poddar/Vault.Demo.hashicorp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add the replace

Browse Source
This commit is contained in:
Ayan Poddar 2025-07-02 16:58:01 +05:30
parent efad7e7ce3
commit 34e3ce8ce1
3 changed files with 40 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/Acme.BookStore.HttpApi.Host/Acme.BookStore.HttpApi.Host.csproj
View File

@ -17,6 +17,7 @@
<PackageReference Include="AspNetCore.HealthChecks.UI.Client" Version="9.0.0" />
<PackageReference Include="AspNetCore.HealthChecks.UI.InMemory.Storage" Version="9.0.0" />
<PackageReference Include="Microsoft.EntityFrameworkCore.InMemory" Version="9.0.4" />
<PackageReference Include="Newtonsoft.Json" Version="13.0.1" />
<PackageReference Include="Serilog.AspNetCore" Version="9.0.0" />
<PackageReference Include="Serilog.Sinks.Async" Version="2.1.0" />
</ItemGroup>

43
src/Acme.BookStore.HttpApi.Host/Infrastructure/EnviromentLoader.cs
View File

@ -2,8 +2,10 @@
using Microsoft.AspNetCore.Builder;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Hosting;
using Newtonsoft.Json.Linq;
using System;
using System.Diagnostics.CodeAnalysis;
using System.IO;
using System.Text;
using System.Threading.Tasks;
using VaultSharp;
@ -16,24 +18,43 @@ public static class EnviromentLoader
{
public static async Task SetDatabaseEnviroment([NotNull] this WebApplicationBuilder builder)
{
if (!builder.Environment.IsProduction())
return;
#if !DEBUG
builder.Host.AddAppSettingsSecretsJson();
#else
var stream = await GetUpdatedConnectionStringsStreamAsync("appsettings.json");
builder.Configuration.AddJsonStream(stream);
#endif
var connectionSection = builder.Configuration.GetSection("ConnectionStrings");
var connections = connectionSection.GetChildren();
var sb = new StringBuilder();
}
foreach (var connection in connections)
public static async Task<Stream> GetUpdatedConnectionStringsStreamAsync(string file)
{
sb.Append(connection.Path);
sb.Append('=');
sb.Append(await UpdateVaue(connection.Key));
var content = JObject.Parse(await File.ReadAllTextAsync(file));
if (content["ConnectionStrings"] is not JObject jsonReader)
return Stream.Null;
foreach (var item in jsonReader.Properties())
{
var value = await UpdateValue(item.Name);
if (!string.IsNullOrEmpty(value))
{
jsonReader[item.Name] = value;
}
}
builder.Configuration.AddEnvironmentVariables(sb.ToString());
var memoryStream = new MemoryStream();
using (var writer = new StreamWriter(memoryStream, leaveOpen: true))
{
await writer.WriteAsync(content.ToString());
await writer.FlushAsync();
}
private static async Task<string> UpdateVaue(string key)
memoryStream.Position = 0;
return memoryStream;
}
private static async Task<string> UpdateValue(string key)
{
var secrate = await GetSecret();
return secrate.Data.Data.TryGetValue(key, out var val)

7
src/Acme.BookStore.HttpApi.Host/Program.cs
View File

@ -23,16 +23,15 @@ public class Program
Log.Information("Starting Acme.BookStore.HttpApi.Host.");
var builder = WebApplication.CreateBuilder(args);
builder.Host
.AddAppSettingsSecretsJson()
.UseAutofac()
.UseSerilog((context, services, loggerConfiguration) =>
{
loggerConfiguration
#if DEBUG
#if DEBUG
.MinimumLevel.Debug()
#else
#else
.MinimumLevel.Information()
#endif
#endif
.MinimumLevel.Override("Microsoft", LogEventLevel.Information)
.MinimumLevel.Override("Microsoft.EntityFrameworkCore", LogEventLevel.Warning)
.Enrich.FromLogContext()