Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Set up options and track changes in management SDK. #1081

Merged
merged 31 commits into from
Nov 9, 2020
Merged
Show file tree
Hide file tree
Changes from 19 commits
Commits
Show all changes
31 commits
Select commit Hold shift + click to select a range
f1d6d2c
set up ServiceManagerContext and ServiceOptions; track changes
Y-Sindo Oct 27, 2020
ef79564
fix error in ServiceManagerBuilder as a temporary solution
Y-Sindo Oct 27, 2020
04d9b10
test for options changes detected
Y-Sindo Oct 27, 2020
1840a4d
make sure product info has default value
Y-Sindo Oct 27, 2020
8cb960c
fix default product info error
Y-Sindo Oct 28, 2020
fa833d2
remove limitation that AddSignalRServiceManager must be added after S…
Y-Sindo Oct 28, 2020
f9b358e
offer choices to configure with configration instance or action
Y-Sindo Oct 30, 2020
c4f2030
fix
Y-Sindo Oct 30, 2020
32636be
fix
Y-Sindo Oct 30, 2020
c83f4c9
fix
Y-Sindo Oct 30, 2020
17b6585
Enable service builder to build dynamically configurable service manager
Y-Sindo Oct 30, 2020
52dc94b
add config hot reload to ServiceManagerBuilder, fix productInfo error…
Y-Sindo Nov 2, 2020
5315a43
Update DiExtensionFacts.cs
Y-Sindo Nov 2, 2020
d3a3b68
fix
Y-Sindo Nov 2, 2020
1399157
rename & skip fail test
Y-Sindo Nov 3, 2020
d32b810
fix
Y-Sindo Nov 3, 2020
80874da
fix
Y-Sindo Nov 3, 2020
6786043
fix
Y-Sindo Nov 3, 2020
3d6a3ec
merge ServiceManagerOptions section key into one
Y-Sindo Nov 3, 2020
37947ab
rename service provider
Y-Sindo Nov 3, 2020
e3edf86
tracks change directly from IConfiguration; Add InMemoryConfigHotRelo…
Y-Sindo Nov 3, 2020
9a5c796
add memory config hot reload test to DependencyInjectionExtensionFact…
Y-Sindo Nov 3, 2020
a9a6153
Implement options changes tracking chain with self-creating IChangeTo…
Y-Sindo Nov 4, 2020
f6b7d91
dispose serviceProvider from serviceManager; delete unnecessary tests…
Y-Sindo Nov 4, 2020
2532535
fix
Y-Sindo Nov 4, 2020
514355a
fix
Y-Sindo Nov 4, 2020
13ec165
do not dispose ServiceProvider if ServiceManager is built from global…
Y-Sindo Nov 5, 2020
35c083e
change ServiceProvider to IServiceProvider in ServiceManager ctor and…
Y-Sindo Nov 5, 2020
4b73ac4
fix
Y-Sindo Nov 5, 2020
903f1c2
read from context
Y-Sindo Nov 9, 2020
383ad4b
Merge branch 'chained-options' of https://github.com/Y-Sindo/azure-si…
Y-Sindo Nov 9, 2020
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions build/dependencies.props
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,7 @@
<MicrosoftConfigurationUserSecretVersion>2.2.0</MicrosoftConfigurationUserSecretVersion>
<MicrosoftConfigurationEnvironmentVariablesVersion>2.2.0</MicrosoftConfigurationEnvironmentVariablesVersion>
<MicrosoftAspNetCoreSignalRProtocolsMessagePackPackageVersion>1.0.11</MicrosoftAspNetCoreSignalRProtocolsMessagePackPackageVersion>
<MicrosoftExtensionsOptionsConfigurationExtensionsVersion>2.1.0</MicrosoftExtensionsOptionsConfigurationExtensionsVersion>

<!-- Signing -->
<MicroBuildCorePackageVersion>0.3.0</MicroBuildCorePackageVersion>
Expand Down
1 change: 1 addition & 0 deletions src/Microsoft.Azure.SignalR.Common/Constants.cs
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ internal static class Constants
{
public static class Keys
{
public const string ServiceManagerOptionsSectionKey = "Azure:SignalR";
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

use a more common name if it is in Common project, or you can move the const to the Management project

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Move the key to ServiceManagerOptions as a const string named Section.

public const string ServerStickyModeDefaultKey = "Azure:SignalR:ServerStickyMode";
public const string ConnectionStringDefaultKey = "Azure:SignalR:ConnectionString";
public const string ApplicationNameDefaultKey = "Azure:SignalR:ApplicationName";
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,39 @@
// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.

using Microsoft.Extensions.FileProviders;
using Microsoft.Extensions.Options;
using Microsoft.Extensions.Primitives;

namespace Microsoft.Azure.SignalR.Management.Configuration
{
/// <summary>
/// Sets up TargetOptions from SourceOptions and tracks changes .
/// </summary>
internal abstract class CascadeOptionsSetup<SourceOptions, TargetOptions> : IConfigureOptions<TargetOptions>, IOptionsChangeTokenSource<TargetOptions>
where SourceOptions : class
where TargetOptions : class
{
private protected readonly IOptionsMonitor<SourceOptions> _monitor;
private readonly IOptionsChangeTokenSource<SourceOptions> _changeTokenSource;

//Making 'tokenSource' optional avoids error when 'tokenSource' is unavailable.
public CascadeOptionsSetup(IOptionsMonitor<SourceOptions> monitor, IOptionsChangeTokenSource<SourceOptions> changeTokenSource = null)
{
_monitor = monitor;
_changeTokenSource = changeTokenSource;
}

public string Name => Options.DefaultName;

public abstract void Configure(TargetOptions options);

public IChangeToken GetChangeToken()
{
return _changeTokenSource?.GetChangeToken() ?? NullChangeToken.Singleton;

//We can't return a ChangeToken as null.
//fixes in https://github.com/dotnet/runtime/pull/43306
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -18,16 +18,5 @@ internal class ServiceManagerContext
public IWebProxy Proxy { get; set; }

public ServiceTransportType ServiceTransportType { get; set; } = ServiceTransportType.Transient;

public void SetValueFromOptions(ServiceManagerOptions options)
{
ServiceEndpoints = options.ServiceEndpoints ?? (options.ServiceEndpoint != null
? (new ServiceEndpoint[] { options.ServiceEndpoint })
: (new ServiceEndpoint[] { new ServiceEndpoint(options.ConnectionString) }));
ApplicationName = options.ApplicationName;
ConnectionCount = options.ConnectionCount;
Proxy = options.Proxy;
ServiceTransportType = options.ServiceTransportType;
}
}
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,27 @@
// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.

using Microsoft.Azure.SignalR.Management.Configuration;
using Microsoft.Extensions.Options;

namespace Microsoft.Azure.SignalR.Management
{
internal class ServiceManagerContextSetup : CascadeOptionsSetup<ServiceManagerOptions, ServiceManagerContext>
{
public ServiceManagerContextSetup(IOptionsMonitor<ServiceManagerOptions> monitor, IOptionsChangeTokenSource<ServiceManagerOptions> changeTokenSource = null) : base(monitor, changeTokenSource)
{
}

public override void Configure(ServiceManagerContext options)
{
var serviceManagerOptions = _monitor.CurrentValue;
options.ServiceEndpoints = serviceManagerOptions.ServiceEndpoints ?? (serviceManagerOptions.ServiceEndpoint != null
? (new ServiceEndpoint[] { serviceManagerOptions.ServiceEndpoint })
: (new ServiceEndpoint[] { new ServiceEndpoint(serviceManagerOptions.ConnectionString) }));
options.ApplicationName = serviceManagerOptions.ApplicationName;
options.ConnectionCount = serviceManagerOptions.ConnectionCount;
options.Proxy = serviceManagerOptions.Proxy;
options.ServiceTransportType = serviceManagerOptions.ServiceTransportType;
}
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,35 @@
// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.

using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.FileProviders;
using Microsoft.Extensions.Options;
using Microsoft.Extensions.Primitives;

namespace Microsoft.Azure.SignalR.Management.Configuration
{
internal class ServiceManagerOptionsSetup : IConfigureOptions<ServiceManagerOptions>, IOptionsChangeTokenSource<ServiceManagerOptions>
{
private readonly IConfiguration _configuration;

public ServiceManagerOptionsSetup(IConfiguration configuration = null)
{
_configuration = configuration;
}

public string Name => Options.DefaultName;

public void Configure(ServiceManagerOptions options)
{
if (_configuration != null)
{
_configuration.GetSection(Constants.Keys.ServiceManagerOptionsSectionKey).Bind(options);
}
}

public IChangeToken GetChangeToken()
{
return _configuration?.GetReloadToken() ?? NullChangeToken.Singleton;
}
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,24 @@
// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.

using Microsoft.Azure.SignalR.Management.Configuration;
using Microsoft.Extensions.Options;

namespace Microsoft.Azure.SignalR.Management
{
internal class ServiceOptionsSetup : CascadeOptionsSetup<ServiceManagerContext, ServiceOptions>
{
public ServiceOptionsSetup(IOptionsMonitor<ServiceManagerContext> monitor, IOptionsChangeTokenSource<ServiceManagerContext> changeTokenSource = null) : base(monitor, changeTokenSource)
{
}

public override void Configure(ServiceOptions options)
{
var context = _monitor.CurrentValue;
options.ApplicationName = context.ApplicationName;
options.Endpoints = context.ServiceEndpoints;
options.Proxy = context.Proxy;
options.ConnectionCount = context.ConnectionCount;
}
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,69 @@
// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
using System;
using System.ComponentModel;
using System.Reflection;
using Microsoft.Azure.SignalR.Management.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Options;

namespace Microsoft.Azure.SignalR.Management
{
internal static class DependencyInjectionExtensions //TODO: not ready for public use
{
/// <summary>
/// Adds the essential SignalR Service Manager services to the specified services collection and configures <see cref="ServiceManagerOptions"/> with configuration instance registered in service collection.
/// </summary>
public static IServiceCollection AddSignalRServiceManager(this IServiceCollection services)
{
services.AddSingleton<ServiceManagerOptionsSetup>()
.AddSingleton<IConfigureOptions<ServiceManagerOptions>>(sp => sp.GetService<ServiceManagerOptionsSetup>())
.AddSingleton<IOptionsChangeTokenSource<ServiceManagerOptions>>(sp => sp.GetService<ServiceManagerOptionsSetup>());
return services.AddSignalRServiceManagerCore();
}

/// <summary>
/// Adds the essential SignalR Service Manager services to the specified services collection and registers an action used to configure <see cref="ServiceManagerOptions"/>
/// </summary>
public static IServiceCollection AddSignalRServiceManager(this IServiceCollection services, Action<ServiceManagerOptions> configure)
{
services.Configure(configure);
return services.AddSignalRServiceManager();
}

/// <summary>
/// Adds the minimum essential SignalR Service Manager services to the specified services collection.
/// </summary>
/// <param name="services"></param>
/// <returns></returns>
internal static IServiceCollection AddSignalRServiceManagerCore(this IServiceCollection services)
{
services.PostConfigure<ServiceManagerOptions>(o => o.ValidateOptions());
services.AddSingleton<ServiceManagerContextSetup>()
.AddSingleton<IConfigureOptions<ServiceManagerContext>>(sp => sp.GetService<ServiceManagerContextSetup>())
.AddSingleton<IOptionsChangeTokenSource<ServiceManagerContext>>(sp => sp.GetService<ServiceManagerContextSetup>());
services.AddSingleton<ServiceOptionsSetup>()
.AddSingleton<IConfigureOptions<ServiceOptions>>(sp => sp.GetService<ServiceOptionsSetup>())
.AddSingleton<IOptionsChangeTokenSource<ServiceOptions>>(sp => sp.GetService<ServiceOptionsSetup>());
return services.TrySetProductInfo();
}

/// <summary>
/// Adds product info to <see cref="ServiceManagerContext"/>
/// </summary>
/// <returns></returns>
[EditorBrowsable(EditorBrowsableState.Never)]
public static IServiceCollection WithAssembly(this IServiceCollection services, Assembly assembly)
{
var productInfo = ProductInfo.GetProductInfo(assembly);
return services.Configure<ServiceManagerContext>(o => o.ProductInfo = productInfo);
}

private static IServiceCollection TrySetProductInfo(this IServiceCollection services)
{
var assembly = Assembly.GetExecutingAssembly();
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

So this anyway executes even if ProductInfo is already set?

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Yes, but if ProductInfo is not null, then the value would not be overwritten.

var productInfo = ProductInfo.GetProductInfo(assembly);
return services.Configure<ServiceManagerContext>(o => o.ProductInfo = o.ProductInfo ?? productInfo);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,8 @@
</ItemGroup>
<ItemGroup Condition=" '$(TargetFramework)' == 'netstandard2.0'">
<PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="$(MicrosoftExtensionsDependencyInjectionPackageVersion)" />
<PackageReference Include="Microsoft.Extensions.Http" Version="$(MicrosoftExtensionHttpVersion)" />
<PackageReference Include="Microsoft.Extensions.Http" Version="$(MicrosoftExtensionHttpVersion)" />
<PackageReference Include="Microsoft.AspNetCore.SignalR" Version="$(MicrosoftAspNetCoreSignalRPackageVersion)" />
<PackageReference Include="Microsoft.Extensions.Options.ConfigurationExtensions" Version="$(MicrosoftExtensionsOptionsConfigurationExtensionsVersion)" />
</ItemGroup>
</Project>
47 changes: 35 additions & 12 deletions src/Microsoft.Azure.SignalR.Management/ServiceManagerBuilder.cs
Original file line number Diff line number Diff line change
Expand Up @@ -4,32 +4,47 @@
using System;
using System.ComponentModel;
using System.Reflection;

using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Options;
namespace Microsoft.Azure.SignalR.Management
{
/// <summary>
/// A builder for configuring <see cref="IServiceManager"/> instances.
/// </summary>
public class ServiceManagerBuilder : IServiceManagerBuilder
public class ServiceManagerBuilder : IServiceManagerBuilder, IDisposable
{
private readonly ServiceManagerOptions _options = new ServiceManagerOptions();
private readonly IServiceCollection _services = new ServiceCollection();
private Assembly _assembly;
private ServiceProvider _serviceProvider;

/// <summary>
/// Configures the <see cref="IServiceManager"/> instances.
/// Registers an action used to configure <see cref="IServiceManager"/>.
/// </summary>
/// <param name="configure">A callback to configure the <see cref="IServiceManager"/>.</param>
/// <returns>The same instance of the <see cref="ServiceManagerBuilder"/> for chaining.</returns>
public ServiceManagerBuilder WithOptions(Action<ServiceManagerOptions> configure)
{
configure?.Invoke(_options);
_services.Configure(configure);
return this;
}

/// <summary>
/// Registers a configuration instance to configure <see cref="IServiceManager"/>
/// </summary>
/// <param name="config">The configuration instance.</param>
/// <returns>The same instance of the <see cref="ServiceManagerBuilder"/> for chaining.</returns>
internal ServiceManagerBuilder WithConfiguration(IConfiguration config)
{
_services.Configure<ServiceManagerOptions>(config.GetSection(Constants.Keys.ServiceManagerOptionsSectionKey));
return this;
}

[EditorBrowsable(EditorBrowsableState.Never)]
public ServiceManagerBuilder WithCallingAssembly()
{
_assembly = Assembly.GetCallingAssembly();
_services.WithAssembly(_assembly);
return this;
}

Expand All @@ -39,16 +54,24 @@ public ServiceManagerBuilder WithCallingAssembly()
/// <returns>The instance of the <see cref="IServiceManager"/>.</returns>
public IServiceManager Build()
{
_options.ValidateOptions();

_services.AddSignalRServiceManagerCore();
_serviceProvider = _services.BuildServiceProvider();
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

what if Build is called twice? the first _serviceProvider never dispose?

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Check added, throw InvalidOperationException() if called twice.

var context = _serviceProvider.GetRequiredService<IOptions<ServiceManagerContext>>().Value;
var productInfo = ProductInfo.GetProductInfo(_assembly);
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

read from context?

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

fixed

var context = new ServiceManagerContext()
{
ProductInfo = productInfo
};
context.SetValueFromOptions(_options);
var restClientBuilder = new RestClientFactory(productInfo);
return new ServiceManager(context, restClientBuilder);
}

/// <summary>
/// Dispose unmanaged resources accociated with the builder and the instance built from it.
/// </summary>
public void Dispose()
{
_serviceProvider?.Dispose();
_serviceProvider = null;
}

//tests only
internal ServiceProvider GetServiceProvider() => _serviceProvider;
}
}
Loading