-
-
Notifications
You must be signed in to change notification settings - Fork 302
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
fa256c6
commit cdd69fb
Showing
17 changed files
with
559 additions
and
11 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1 @@ | ||
| root = true |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,178 @@ | ||
| namespace Testcontainers.EventHubs; | ||
|
|
||
| /// <inheritdoc cref="ContainerBuilder{TBuilderEntity, TContainerEntity, TConfigurationEntity}" /> | ||
| [PublicAPI] | ||
| public sealed class EventHubsBuilder : ContainerBuilder<EventHubsBuilder, EventHubsContainer, EventHubsConfiguration> | ||
| { | ||
| public const string EventHubsNetworkAlias = "eventhubs-container"; | ||
|
|
||
| public const string AzuriteNetworkAlias = "azurite-container"; | ||
|
|
||
| public const string EventHubsImage = "mcr.microsoft.com/azure-messaging/eventhubs-emulator:latest"; | ||
|
|
||
| public const ushort EventHubsPort = 5672; | ||
|
|
||
| /// <summary> | ||
| /// Initializes a new instance of the <see cref="EventHubsBuilder" /> class. | ||
| /// </summary> | ||
| public EventHubsBuilder() | ||
| : this(new EventHubsConfiguration()) | ||
| { | ||
| DockerResourceConfiguration = Init().DockerResourceConfiguration; | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Initializes a new instance of the <see cref="EventHubsBuilder" /> class. | ||
| /// </summary> | ||
| /// <param name="resourceConfiguration">The Docker resource configuration.</param> | ||
| private EventHubsBuilder(EventHubsConfiguration resourceConfiguration) | ||
| : base(resourceConfiguration) | ||
| { | ||
| DockerResourceConfiguration = resourceConfiguration; | ||
| } | ||
|
|
||
| /// <inheritdoc /> | ||
| protected override EventHubsConfiguration DockerResourceConfiguration { get; } | ||
|
|
||
| /// <inheritdoc /> | ||
| protected override string AcceptLicenseAgreementEnvVar { get; } = "ACCEPT_EULA"; | ||
|
|
||
| /// <inheritdoc /> | ||
| protected override string AcceptLicenseAgreement { get; } = "Y"; | ||
|
|
||
| /// <inheritdoc /> | ||
| protected override string DeclineLicenseAgreement { get; } = "N"; | ||
|
|
||
| /// <summary> | ||
| /// Accepts the license agreement. | ||
| /// </summary> | ||
| /// <remarks> | ||
| /// When <paramref name="acceptLicenseAgreement" /> is set to <c>true</c>, the Azure Event Hubs Emulator <see href="https://github.com/Azure/azure-event-hubs-emulator-installer/blob/main/EMULATOR_EULA.md">license</see> is accepted. | ||
| /// </remarks> | ||
| /// <param name="acceptLicenseAgreement">A boolean value indicating whether the Azure Event Hubs Emulator license agreement is accepted.</param> | ||
| /// <returns>A configured instance of <see cref="EventHubsBuilder" />.</returns> | ||
| public override EventHubsBuilder WithAcceptLicenseAgreement(bool acceptLicenseAgreement) | ||
| { | ||
| var licenseAgreement = acceptLicenseAgreement ? AcceptLicenseAgreement : DeclineLicenseAgreement; | ||
| return WithEnvironment(AcceptLicenseAgreementEnvVar, licenseAgreement); | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Sets the dependent Azurite container for the Azure Event Hubs Emulator. | ||
| /// </summary> | ||
| /// <remarks> | ||
| /// This method allows an existing Azurite container to be attached to the Azure Event | ||
| /// Hubs Emulator. The containers must be on the same network to enable communication | ||
| /// between them. | ||
| /// </remarks> | ||
| /// <param name="network">The network to connect the container to.</param> | ||
| /// <param name="container">The Azurite container.</param> | ||
| /// <param name="networkAlias">The Azurite container network alias.</param> | ||
| /// <returns>A configured instance of <see cref="EventHubsBuilder" />.</returns> | ||
| public EventHubsBuilder WithAzuriteContainer( | ||
| INetwork network, | ||
| AzuriteContainer container, | ||
| string networkAlias) | ||
| { | ||
| return Merge(DockerResourceConfiguration, new EventHubsConfiguration(azuriteContainer: container)) | ||
| .DependsOn(container) | ||
| .WithNetwork(network) | ||
| .WithNetworkAliases(EventHubsNetworkAlias) | ||
| .WithEnvironment("BLOB_SERVER", networkAlias) | ||
| .WithEnvironment("METADATA_SERVER", networkAlias); | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Sets the Azure Event Hubs Emulator configuration. | ||
| /// </summary> | ||
| /// <param name="serviceConfiguration">The service configuration.</param> | ||
| /// <returns>A configured instance of <see cref="EventHubsBuilder" />.</returns> | ||
| public EventHubsBuilder WithConfigurationBuilder(EventHubsServiceConfiguration serviceConfiguration) | ||
| { | ||
| var resourceContent = Encoding.Default.GetBytes(serviceConfiguration.Build()); | ||
| return Merge(DockerResourceConfiguration, new EventHubsConfiguration(serviceConfiguration: serviceConfiguration)) | ||
| .WithResourceMapping(resourceContent, "Eventhubs_Emulator/ConfigFiles/Config.json"); | ||
| } | ||
|
|
||
| /// <inheritdoc /> | ||
| public override EventHubsContainer Build() | ||
| { | ||
| Validate(); | ||
| ValidateLicenseAgreement(); | ||
|
|
||
| if (DockerResourceConfiguration.AzuriteContainer != null) | ||
| { | ||
| return new EventHubsContainer(DockerResourceConfiguration); | ||
| } | ||
|
|
||
| // If the user has not provided an existing Azurite container instance, | ||
| // we configure one. | ||
| var network = new NetworkBuilder() | ||
| .Build(); | ||
|
|
||
| var container = new AzuriteBuilder() | ||
| .WithNetwork(network) | ||
| .WithNetworkAliases(AzuriteNetworkAlias) | ||
| .Build(); | ||
|
|
||
| var eventHubsContainer = WithAzuriteContainer(network, container, AzuriteNetworkAlias); | ||
| return new EventHubsContainer(eventHubsContainer.DockerResourceConfiguration); | ||
| } | ||
|
|
||
| /// <inheritdoc /> | ||
| protected override void Validate() | ||
| { | ||
| base.Validate(); | ||
|
|
||
| _ = Guard.Argument(DockerResourceConfiguration.ServiceConfiguration, nameof(DockerResourceConfiguration.ServiceConfiguration)) | ||
| .NotNull() | ||
| .ThrowIf(argument => !argument.Value.Validate(), _ => throw new ArgumentException("The service configuration of the Azure Event Hubs Emulator is invalid.")); | ||
| } | ||
|
|
||
| /// <inheritdoc /> | ||
| protected override EventHubsBuilder Init() | ||
| { | ||
| return base.Init() | ||
| .WithImage(EventHubsImage) | ||
| .WithPortBinding(EventHubsPort, true) | ||
| .WithWaitStrategy(Wait.ForUnixContainer() | ||
| .UntilMessageIsLogged("Emulator Service is Successfully Up!") | ||
| .AddCustomWaitStrategy(new WaitTwoSeconds())); | ||
| } | ||
|
|
||
| /// <inheritdoc /> | ||
| protected override EventHubsBuilder Clone(IResourceConfiguration<CreateContainerParameters> resourceConfiguration) | ||
| { | ||
| return Merge(DockerResourceConfiguration, new EventHubsConfiguration(resourceConfiguration)); | ||
| } | ||
|
|
||
| /// <inheritdoc /> | ||
| protected override EventHubsBuilder Clone(IContainerConfiguration resourceConfiguration) | ||
| { | ||
| return Merge(DockerResourceConfiguration, new EventHubsConfiguration(resourceConfiguration)); | ||
| } | ||
|
|
||
| /// <inheritdoc /> | ||
| protected override EventHubsBuilder Merge(EventHubsConfiguration oldValue, EventHubsConfiguration newValue) | ||
| { | ||
| return new EventHubsBuilder(new EventHubsConfiguration(oldValue, newValue)); | ||
| } | ||
|
|
||
| /// <inheritdoc cref="IWaitUntil" /> | ||
| /// <remarks> | ||
| /// This is a workaround to ensure that the wait strategy does not indicate | ||
| /// readiness too early: | ||
| /// https://github.com/Azure/azure-service-bus-emulator-installer/issues/35#issuecomment-2497164533. | ||
| /// </remarks> | ||
| private sealed class WaitTwoSeconds : IWaitUntil | ||
| { | ||
| /// <inheritdoc /> | ||
| public async Task<bool> UntilAsync(IContainer container) | ||
| { | ||
| await Task.Delay(TimeSpan.FromSeconds(2)) | ||
| .ConfigureAwait(false); | ||
|
|
||
| return true; | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,70 @@ | ||
| namespace Testcontainers.EventHubs; | ||
|
|
||
| /// <inheritdoc cref="ContainerConfiguration" /> | ||
| [PublicAPI] | ||
| public sealed class EventHubsConfiguration : ContainerConfiguration | ||
| { | ||
| /// <summary> | ||
| /// Initializes a new instance of the <see cref="EventHubsConfiguration" /> class. | ||
| /// </summary> | ||
| /// <param name="azuriteContainer">The Azurite container.</param> | ||
| /// <param name="serviceConfiguration">The service configuration.</param> | ||
| public EventHubsConfiguration(AzuriteContainer azuriteContainer = null, | ||
| EventHubsServiceConfiguration serviceConfiguration = null) | ||
| { | ||
| AzuriteContainer = azuriteContainer; | ||
| ServiceConfiguration = serviceConfiguration; | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Initializes a new instance of the <see cref="EventHubsConfiguration" /> class. | ||
| /// </summary> | ||
| /// <param name="resourceConfiguration">The Docker resource configuration.</param> | ||
| public EventHubsConfiguration(IResourceConfiguration<CreateContainerParameters> resourceConfiguration) | ||
| : base(resourceConfiguration) | ||
| { | ||
| // Passes the configuration upwards to the base implementations to create an updated immutable copy. | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Initializes a new instance of the <see cref="EventHubsConfiguration" /> class. | ||
| /// </summary> | ||
| /// <param name="resourceConfiguration">The Docker resource configuration.</param> | ||
| public EventHubsConfiguration(IContainerConfiguration resourceConfiguration) | ||
| : base(resourceConfiguration) | ||
| { | ||
| // Passes the configuration upwards to the base implementations to create an updated immutable copy. | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Initializes a new instance of the <see cref="EventHubsConfiguration" /> class. | ||
| /// </summary> | ||
| /// <param name="resourceConfiguration">The Docker resource configuration.</param> | ||
| public EventHubsConfiguration(EventHubsConfiguration resourceConfiguration) | ||
| : this(new EventHubsConfiguration(), resourceConfiguration) | ||
| { | ||
| // Passes the configuration upwards to the base implementations to create an updated immutable copy. | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Initializes a new instance of the <see cref="EventHubsConfiguration" /> class. | ||
| /// </summary> | ||
| /// <param name="oldValue">The old Docker resource configuration.</param> | ||
| /// <param name="newValue">The new Docker resource configuration.</param> | ||
| public EventHubsConfiguration(EventHubsConfiguration oldValue, EventHubsConfiguration newValue) | ||
| : base(oldValue, newValue) | ||
| { | ||
| AzuriteContainer = BuildConfiguration.Combine(oldValue.AzuriteContainer, newValue.AzuriteContainer); | ||
| ServiceConfiguration = BuildConfiguration.Combine(oldValue.ServiceConfiguration, newValue.ServiceConfiguration); | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Gets the Azurite container. | ||
| /// </summary> | ||
| public AzuriteContainer AzuriteContainer { get; } | ||
|
|
||
| /// <summary> | ||
| /// Gets the service configuration. | ||
| /// </summary> | ||
| public EventHubsServiceConfiguration ServiceConfiguration { get; } | ||
| } |
Oops, something went wrong.