Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: Add OpenFeature.Extensions.Hosting package
See: open-feature/dotnet-sdk-contrib#127 Signed-off-by: Austin Drenski <austin@austindrenski.io>
- Loading branch information
1 parent
7eebcdd
commit bcf19c4
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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,36 @@ | ||
| using System.Collections.Generic; | ||
| using System.Threading; | ||
| using System.Threading.Tasks; | ||
| using Microsoft.Extensions.Hosting; | ||
|
|
||
| namespace OpenFeature.Internal; | ||
|
|
||
| /// <summary> | ||
| /// | ||
| /// </summary> | ||
| public sealed class OpenFeatureHostedService(Api api, IEnumerable<FeatureProvider> providers) : IHostedLifecycleService | ||
| { | ||
| readonly Api _api = Check.NotNull(api); | ||
| readonly IEnumerable<FeatureProvider> _providers = Check.NotNull(providers); | ||
|
|
||
| async Task IHostedLifecycleService.StartingAsync(CancellationToken cancellationToken) | ||
| { | ||
| foreach (var provider in this._providers) | ||
| { | ||
| await this._api.SetProviderAsync(provider.GetMetadata().Name, provider).ConfigureAwait(false); | ||
|
|
||
| if (this._api.GetProviderMetadata() is { Name: "No-op Provider" }) | ||
| await this._api.SetProviderAsync(provider).ConfigureAwait(false); | ||
| } | ||
| } | ||
|
|
||
| Task IHostedService.StartAsync(CancellationToken cancellationToken) => Task.CompletedTask; | ||
|
|
||
| Task IHostedLifecycleService.StartedAsync(CancellationToken cancellationToken) => Task.CompletedTask; | ||
|
|
||
| Task IHostedLifecycleService.StoppingAsync(CancellationToken cancellationToken) => Task.CompletedTask; | ||
|
|
||
| Task IHostedService.StopAsync(CancellationToken cancellationToken) => Task.CompletedTask; | ||
|
|
||
| Task IHostedLifecycleService.StoppedAsync(CancellationToken cancellationToken) => this._api.Shutdown(); | ||
| } |
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,25 @@ | ||
| <Project Sdk="Microsoft.NET.Sdk"> | ||
|
|
||
| <PropertyGroup> | ||
| <Nullable>enable</Nullable> | ||
| <TargetFrameworks>netstandard2.0;net6.0;net7.0;net8.0;net462</TargetFrameworks> | ||
| </PropertyGroup> | ||
|
|
||
| <PropertyGroup> | ||
| <PackageReadmeFile>README.md</PackageReadmeFile> | ||
| <RootNamespace>OpenFeature</RootNamespace> | ||
| </PropertyGroup> | ||
|
|
||
| <ItemGroup> | ||
| <None Include="../../README.md" Pack="true" PackagePath="/" /> | ||
| </ItemGroup> | ||
|
|
||
| <ItemGroup> | ||
| <PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" /> | ||
| </ItemGroup> | ||
|
|
||
| <ItemGroup> | ||
| <ProjectReference Include="../OpenFeature/OpenFeature.csproj" /> | ||
| </ItemGroup> | ||
|
|
||
| </Project> |
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,9 @@ | ||
| using Microsoft.Extensions.DependencyInjection; | ||
|
|
||
| namespace OpenFeature; | ||
|
|
||
| /// <summary> | ||
| /// | ||
| /// </summary> | ||
| /// <param name="Services"></param> | ||
| public sealed record OpenFeatureBuilder(IServiceCollection Services); |
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,145 @@ | ||
| using System; | ||
| using Microsoft.Extensions.DependencyInjection; | ||
| using Microsoft.Extensions.DependencyInjection.Extensions; | ||
| using Microsoft.Extensions.Logging; | ||
| using OpenFeature.Internal; | ||
| using OpenFeature.Model; | ||
|
|
||
| namespace OpenFeature; | ||
|
|
||
| /// <summary> | ||
| /// | ||
| /// </summary> | ||
| public static class OpenFeatureBuilderExtensions | ||
| { | ||
| /// <summary> | ||
| /// | ||
| /// </summary> | ||
| /// <param name="builder"></param> | ||
| /// <param name="configure"></param> | ||
| /// <returns> | ||
| /// | ||
| /// </returns> | ||
| public static OpenFeatureBuilder AddContext( | ||
| this OpenFeatureBuilder builder, | ||
| Action<EvaluationContextBuilder> configure) | ||
| { | ||
| Check.NotNull(builder); | ||
| Check.NotNull(configure); | ||
|
|
||
| AddContext(builder, null, (b, _, _) => configure(b)); | ||
|
|
||
| return builder; | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// | ||
| /// </summary> | ||
| /// <param name="builder"></param> | ||
| /// <param name="configure"></param> | ||
| /// <returns> | ||
| /// | ||
| /// </returns> | ||
| public static OpenFeatureBuilder AddContext( | ||
| this OpenFeatureBuilder builder, | ||
| Action<EvaluationContextBuilder, IServiceProvider> configure) | ||
| { | ||
| Check.NotNull(builder); | ||
| Check.NotNull(configure); | ||
|
|
||
| AddContext(builder, null, (b, _, s) => configure(b, s)); | ||
|
|
||
| return builder; | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// | ||
| /// </summary> | ||
| /// <param name="builder"></param> | ||
| /// <param name="providerName"></param> | ||
| /// <param name="configure"></param> | ||
| /// <returns> | ||
| /// | ||
| /// </returns> | ||
| public static OpenFeatureBuilder AddContext( | ||
| this OpenFeatureBuilder builder, | ||
| string? providerName, | ||
| Action<EvaluationContextBuilder, string?, IServiceProvider> configure) | ||
| { | ||
| Check.NotNull(builder); | ||
| Check.NotNull(configure); | ||
|
|
||
| builder.Services.AddKeyedSingleton(providerName, (services, key) => | ||
| { | ||
| var b = EvaluationContext.Builder(); | ||
| configure(b, key as string, services); | ||
| return b.Build(); | ||
| }); | ||
|
|
||
| return builder; | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// | ||
| /// </summary> | ||
| /// <param name="builder"></param> | ||
| /// <param name="providerName"></param> | ||
| public static void TryAddOpenFeatureClient(this OpenFeatureBuilder builder, string? providerName = null) | ||
| { | ||
| Check.NotNull(builder); | ||
|
|
||
| builder.Services.AddHostedService<OpenFeatureHostedService>(); | ||
|
|
||
| builder.Services.TryAddKeyedSingleton(providerName, static (services, providerName) => | ||
| { | ||
| var api = providerName switch | ||
| { | ||
| null => Api.Instance, | ||
| not null => services.GetRequiredKeyedService<Api>(null) | ||
| }; | ||
| api.AddHooks(services.GetKeyedServices<Hook>(providerName)); | ||
| api.SetContext(services.GetRequiredKeyedService<EvaluationContextBuilder>(providerName).Build()); | ||
| return api; | ||
| }); | ||
|
|
||
| builder.Services.TryAddKeyedSingleton(providerName, static (services, providerName) => providerName switch | ||
| { | ||
| null => services.GetRequiredService<ILogger<FeatureClient>>(), | ||
| not null => services.GetRequiredService<ILoggerFactory>().CreateLogger($"OpenFeature.FeatureClient.{providerName}") | ||
| }); | ||
|
|
||
| builder.Services.TryAddKeyedTransient(providerName, static (services, providerName) => | ||
| { | ||
| var builder = providerName switch | ||
| { | ||
| null => EvaluationContext.Builder(), | ||
| not null => services.GetRequiredKeyedService<EvaluationContextBuilder>(null) | ||
| }; | ||
| foreach (var c in services.GetKeyedServices<EvaluationContext>(providerName)) | ||
| { | ||
| builder.Merge(c); | ||
| } | ||
| return builder; | ||
| }); | ||
|
|
||
| builder.Services.TryAddKeyedTransient<IFeatureClient>(providerName, static (services, providerName) => | ||
| { | ||
| var api = services.GetRequiredService<Api>(); | ||
| return api.GetClient( | ||
| api.GetProviderMetadata(providerName as string).Name, | ||
| null, | ||
| services.GetRequiredKeyedService<ILogger>(providerName), | ||
| services.GetRequiredKeyedService<EvaluationContextBuilder>(providerName).Build()); | ||
| }); | ||
|
|
||
| if (providerName is not null) | ||
| builder.Services.Replace(ServiceDescriptor.Transient(services => services.GetRequiredKeyedService<IFeatureClient>(providerName))); | ||
| } | ||
| } | ||
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,44 @@ | ||
| using System; | ||
| using OpenFeature; | ||
|
|
||
| #pragma warning disable IDE0130 // Namespace does not match folder structure | ||
| // ReSharper disable once CheckNamespace | ||
| namespace Microsoft.Extensions.DependencyInjection; | ||
|
|
||
| /// <summary> | ||
| /// | ||
| /// </summary> | ||
| public static class OpenFeatureServiceCollectionExtensions | ||
| { | ||
| /// <summary> | ||
| /// | ||
| /// </summary> | ||
| /// <param name="services"></param> | ||
| /// <param name="configure"></param> | ||
| /// <returns></returns> | ||
| public static IServiceCollection AddOpenFeature(this IServiceCollection services, Action<OpenFeatureBuilder> configure) | ||
| { | ||
| Check.NotNull(services); | ||
| Check.NotNull(configure); | ||
|
|
||
| configure(AddOpenFeature(services)); | ||
|
|
||
| return services; | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// | ||
| /// </summary> | ||
| /// <param name="services"></param> | ||
| /// <returns></returns> | ||
| public static OpenFeatureBuilder AddOpenFeature(this IServiceCollection services) | ||
| { | ||
| Check.NotNull(services); | ||
|
|
||
| var builder = new OpenFeatureBuilder(services); | ||
|
|
||
| builder.TryAddOpenFeatureClient(); | ||
|
|
||
| return builder; | ||
| } | ||
| } |
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,24 @@ | ||
| // @formatter:off | ||
| // ReSharper disable All | ||
| #if NETCOREAPP3_0_OR_GREATER | ||
| // https://github.com/dotnet/runtime/issues/96197 | ||
| [assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Runtime.CompilerServices.CallerArgumentExpressionAttribute))] | ||
| #else | ||
| #pragma warning disable | ||
| // Licensed to the .NET Foundation under one or more agreements. | ||
| // The .NET Foundation licenses this file to you under the MIT license. | ||
|
|
||
| namespace System.Runtime.CompilerServices | ||
| { | ||
| [AttributeUsage(AttributeTargets.Parameter, AllowMultiple = false, Inherited = false)] | ||
| internal sealed class CallerArgumentExpressionAttribute : Attribute | ||
| { | ||
| public CallerArgumentExpressionAttribute(string parameterName) | ||
| { | ||
| ParameterName = parameterName; | ||
| } | ||
|
|
||
| public string ParameterName { get; } | ||
| } | ||
| } | ||
| #endif | ||
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,22 @@ | ||
| #nullable enable | ||
| using System; | ||
| using System.Diagnostics; | ||
| using System.Runtime.CompilerServices; | ||
|
|
||
| namespace OpenFeature; | ||
|
|
||
| [DebuggerStepThrough] | ||
| static class Check | ||
| { | ||
| public static T NotNull<T>(T? value, [CallerArgumentExpression("value")] string name = null!) | ||
| { | ||
| #if NET8_0_OR_GREATER | ||
| ArgumentNullException.ThrowIfNull(value, name); | ||
| #else | ||
| if (value is null) | ||
| throw new ArgumentNullException(name); | ||
| #endif | ||
|
|
||
| return value; | ||
| } | ||
| } | ||
Oops, something went wrong.