diff --git a/src/AssociationRegistry.KboMutations.SyncLambda/Function.cs b/src/AssociationRegistry.KboMutations.SyncLambda/Function.cs index 70bf0c678..f61d67944 100644 --- a/src/AssociationRegistry.KboMutations.SyncLambda/Function.cs +++ b/src/AssociationRegistry.KboMutations.SyncLambda/Function.cs @@ -10,6 +10,7 @@ using AssociationRegistry.KboMutations.SyncLambda.JsonSerialization; using AssociationRegistry.KboMutations.SyncLambda.Logging; using AssociationRegistry.Magda; +using AssociationRegistry.Magda.Models; using Marten; using Marten.Events; using Marten.Services; @@ -19,21 +20,17 @@ using Npgsql; using Weasel.Core; using PostgreSqlOptionsSection = AssociationRegistry.KboMutations.SyncLambda.Logging.PostgreSqlOptionsSection; +using SsmClientWrapper = AssociationRegistry.KboMutations.SsmClientWrapper; namespace AssociationRegistry.KboMutations.SyncLambda; using KboMutations.Configuration; -using Magda.Models; using Notifications; -using System.Diagnostics.Metrics; public class Function { - private static OpenTelemetrySetup _openTelemetrySetup; - private static async Task Main() { - var handler = FunctionHandler; await LambdaBootstrapBuilder.Create(handler, new SourceGeneratorLambdaJsonSerializer()) .Build() @@ -42,12 +39,10 @@ private static async Task Main() private static async Task FunctionHandler(SQSEvent @event, ILambdaContext context) { - - var configurationBuilder = new ConfigurationBuilder() - .SetBasePath(Directory.GetCurrentDirectory()) - .AddJsonFile("appsettings.json", true, true) - .AddEnvironmentVariables(); + .SetBasePath(Directory.GetCurrentDirectory()) + .AddJsonFile("appsettings.json", true, true) + .AddEnvironmentVariables(); var configuration = configurationBuilder.Build(); var awsConfigurationSection = configuration @@ -71,20 +66,11 @@ private static async Task FunctionHandler(SQSEvent @event, ILambdaContext contex var eventConflictResolver = new EventConflictResolver(Array.Empty(), Array.Empty()); - _openTelemetrySetup = new OpenTelemetrySetup(context.Logger, configuration); - var loggerFactory = LoggerFactory.Create(builder => { builder.AddProvider(new LambdaLoggerProvider(context.Logger)); - - _openTelemetrySetup.SetUpLogging(builder); }); - var meter = new Meter(OpenTelemetrySetup.MeterName); - - var counter = meter.CreateCounter("kbosync_started"); - counter.Add(1); - var repository = new VerenigingsRepository(new EventStore.EventStore(store, eventConflictResolver, loggerFactory.CreateLogger())); var geefOndernemingService = new MagdaGeefVerenigingService( @@ -113,9 +99,9 @@ private static async Task FunctionHandler(SQSEvent @event, ILambdaContext contex context.Logger.LogInformation($"{@event.Records.Count} RECORDS PROCESSED BY THE MESSAGE PROCESSOR"); } - public static async Task GetMagdaOptions(IConfiguration config, - SsmClientWrapper ssmClient, - ParamNamesConfiguration? paramNamesConfiguration) + private static async Task GetMagdaOptions(IConfiguration config, + SsmClientWrapper ssmClient, + ParamNamesConfiguration? paramNamesConfiguration) { var magdaOptions = config.GetSection(MagdaOptionsSection.SectionName) .Get(); @@ -142,10 +128,6 @@ private static async Task SetUpDocumentStore(IConfiguration confi throw new ApplicationException("PostgresSqlOptions is missing some values"); var opts = new StoreOptions(); - - opts.OpenTelemetry.TrackConnections = TrackLevel.Normal; - opts.OpenTelemetry.TrackEventCounters(); - var connectionStringBuilder = new NpgsqlConnectionStringBuilder(); connectionStringBuilder.Host = postgresSection.Host; connectionStringBuilder.Database = postgresSection.Database;