ServiceExtensions.cs

/*
 * Unless explicitly stated otherwise all files in this repository are licensed under the Apache License Version 2.0.
 * This product includes software developed at Datadog (https://www.datadoghq.com/).
 * Copyright 2025-Present Datadog, Inc.
 */

// Unless explicitly stated otherwise all files in this repository are licensed under the Apache License Version 2.0.
// This product includes software developed at Datadog (https://www.datadoghq.com/).
// Copyright 2025 Datadog, Inc.

using Amazon.DynamoDBv2;
using Amazon.EventBridge;
using Amazon.Runtime;
using Amazon.SimpleNotificationService;
using Amazon.SQS;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Stickerlandia.PrintService.Core;
using Stickerlandia.PrintService.Core.Observability;
using Stickerlandia.PrintService.Core.Outbox;
using Stickerlandia.PrintService.Core.PrintJobs;

namespace Stickerlandia.PrintService.AWS;

public static class ServiceExtensions
{
    public static IServiceCollection AddAwsAdapters(this IServiceCollection services, IConfiguration configuration,
        bool enableDefaultUi = true)
    {
        ArgumentNullException.ThrowIfNull(configuration);

        services.Configure<AwsConfiguration>(
            configuration.GetSection("Aws"));

        //services.AddSingleton<IMessagingWorker, SqsStickerClaimedWorker>();

        services.AddSingleton<IAmazonDynamoDB>(sp =>
        {
            var endpointUrl = Environment.GetEnvironmentVariable("AWS_ENDPOINT_URL_DYNAMODB");
            if (!string.IsNullOrEmpty(endpointUrl))
            {
                var credentials = new BasicAWSCredentials("dummyaccesskey", "dummysecretkey");
                var config = new AmazonDynamoDBConfig { ServiceURL = endpointUrl };
                return new AmazonDynamoDBClient(credentials, config);
            }

            return new AmazonDynamoDBClient();
        });
        services.AddSingleton(sp => new AmazonSQSClient());
        services.AddSingleton<IAmazonEventBridge>(sp => new AmazonEventBridgeClient());
        services.AddSingleton(sp => new AmazonSimpleNotificationServiceClient());
        // Transaction scope and unit of work. Overrides Core's NoOpUnitOfWork via "last wins"
        // DI semantics. This method MUST be called after AddStickerlandiaUserManagement().
        services.AddScoped<DynamoDbWriteTransaction>();
        services.AddScoped<IUnitOfWork>(sp => sp.GetRequiredService<DynamoDbWriteTransaction>());

        // Repositories and outbox are Scoped to share the transaction scope
        services.AddScoped<IPrinterRepository, DynamoDbPrinterRepository>();
        services.AddScoped<IPrintJobRepository, DynamoDbPrintJobRepository>();
        services.AddScoped<IPrinterKeyValidator, DynamoDbPrinterKeyValidator>();
        services.AddScoped<IOutbox, DynamoDbOutbox>();

        services.AddSingleton<IPrintServiceEventPublisher, EventBridgeEventPublisher>();

        services.AddHttpClient();
        services.AddSingleton<IDatadogTransactionTracker, DatadogTransactionTracker>();

        return services;
    }
}