Hướng Dẫn Tích Hợp Wolverine và Azure Service Bus

public class Program
{
    public static async Task Main(string[] args)
    {
        var host = CreateApp(args);
        await host.RunAsync();
    }

    public static WebApplication CreateApp(string[] args)
    {
        var builder = WebApplication.CreateBuilder(args);

        builder.UseWolverine(opts =>
        {
            // Lấy chuỗi kết nối ASB từ biến môi trường hoặc cấu hình
            var connectionString = Environment.GetEnvironmentVariable("AzureServiceBusConnectionString");

            var azureServiceBus = opts.UseAzureServiceBus(connectionString);
            azureServiceBus
                .ListenToAzureServiceBusSubscription("my-subscription")
                .FromTopic("my-topic");

            // Lưu ý: Nếu bạn sử dụng bất kỳ tùy chọn nào sau đây, hãy đảm bảo chúng được *vô hiệu hóa* khi chạy bài kiểm tra tích hợp.
        });

        var services = builder.Services;

        var app = builder.Build();

        return app;
    }
}

using Wolverine;

public class MyMessageHandler
{
    public async Task Handle(MyMessage message, IMessageContext context)
    {
        // Xử lý tin nhắn ...
        return Task.CompletedTask;
    }
}

public class TestAppFactory : WebApplicationFactory<Program>
{
    public string ServiceBusConnectionString { get; set; }

    public IHost Host { get; private set; }

    protected override IHost CreateHost(IHostBuilder builder)
    {
        builder
            .ConfigureHostConfiguration(cfg =>
            {
                Environment.SetEnvironmentVariable("AzureServiceBusConnectionString", ServiceBusConnectionString);
            });

        Host = base.CreateHost(builder);

        return Host;
    }
}

{
  "UserConfig": {
    "Namespaces": [
      {
        "Name": "sbemulatorns",
        "Queues": [
          {
            "Name": "my-queue"
          }
        ],
        "Topics": [
          {
            "Name": "my-topic",
            "Subscriptions": [
              {
                "Name": "my-topic-subscription"
              }
            ]
          }
        ]
      }
    ],
    "Logging": {
      "Type": "File"
    }
  }
}

[CollectionDefinition(nameof(TestFixture), DisableParallelization = true)]
public class TestCollection : ICollectionFixture<TestFixture> { }

public class TestFixture
{
    public ServiceBusContainer ServiceBusContainer { get; protected set; } = null!;
    public TestAppFactory AppFactory { get; protected set; } = null!;

    public TestFixture()
    {
        var configPath = Path.Combine(AppContext.BaseDirectory, "azure-servicebus-config.json");

        ServiceBusContainer = new ServiceBusBuilder()
            .WithImage("mcr.microsoft.com/azure-messaging/servicebus-emulator:latest")
            .WithAcceptLicenseAgreement(true)
            .WithName("my-azure-service-bus-container")
            .WithConfig(configPath)
            .WithPortBinding(5672, false);
            .Build();

        await ServiceBusContainer.StartAsync();

        AppFactory = new TestAppFactory
        {
            ServiceBusConnectionString = ServiceBusContainer.GetConnectionString()
        };
    }
}

[Collection(nameof(TestFixture))]
public class MyTests
{
    private readonly TestFixture _fixture;
    private readonly TestAppFactory _app;

    public MyTests(TestFixture fixture)
    {
        _fixture = fixture;
        _app = _fixture.AppFactory;
    }

    [Fact]
    public async Task Handles_my_message()
    {
        // Arrange
        var message = new MyMessage();

        // Act
        await _app.Host
            .TrackActivity()
            .Timeout(5.Seconds())
            .WaitForMessageToBeReceivedAt<MyMessage>(_app.Host)
            .PublishMessageAndWaitAsync(message);

        // Assert
        // Logic xác minh khác ở đây
    }
}