-
Notifications
You must be signed in to change notification settings - Fork 2.4k
/
Copy pathStartup.cs
125 lines (113 loc) · 4.69 KB
/
Startup.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
using System;
using System.Linq;
using System.Net.Security;
using System.Security.Cryptography.X509Certificates;
using Microsoft.AspNetCore.DataProtection.KeyManagement;
using Microsoft.Extensions.Caching.Distributed;
using Microsoft.Extensions.Caching.StackExchangeRedis;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using OrchardCore.Caching.Distributed;
using OrchardCore.Environment.Cache;
using OrchardCore.Environment.Shell;
using OrchardCore.Environment.Shell.Configuration;
using OrchardCore.Locking.Distributed;
using OrchardCore.Modules;
using OrchardCore.Redis.Options;
using OrchardCore.Redis.Services;
using StackExchange.Redis;
namespace OrchardCore.Redis
{
public class Startup : StartupBase
{
private readonly string _tenant;
private readonly IShellConfiguration _configuration;
private readonly ILogger _logger;
public Startup(ShellSettings shellSettings, IShellConfiguration configuration, ILogger<Startup> logger)
{
_tenant = shellSettings.Name;
_configuration = configuration;
_logger = logger;
}
public override void ConfigureServices(IServiceCollection services)
{
try
{
var section = _configuration.GetSection("OrchardCore_Redis");
var configuration = section["Configuration"];
var configurationOptions = ConfigurationOptions.Parse(configuration);
var instancePrefix = section["InstancePrefix"];
if (section.GetValue("DisableCertificateVerification", false))
{
configurationOptions.CertificateValidation += IgnoreCertificateErrors;
}
services.Configure<RedisOptions>(options =>
{
options.Configuration = configuration;
options.ConfigurationOptions = configurationOptions;
options.InstancePrefix = instancePrefix;
});
}
catch (Exception e)
{
_logger.LogError(e, "'Redis' features are not active on tenant '{TenantName}' as the 'Configuration' string is missing or invalid.", _tenant);
return;
}
services.AddSingleton<IRedisService, RedisService>();
services.AddSingleton<IModularTenantEvents>(sp => sp.GetRequiredService<IRedisService>());
services.AddSingleton<IRedisDatabaseFactory, RedisDatabaseFactory>();
}
// Callback for accepting any certificate as long as it exists, while ignoring other SSL policy errors.
// This allows the use of self-signed certificates on the Redis server.
private static bool IgnoreCertificateErrors(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors sslPolicyErrors)
=> (sslPolicyErrors & SslPolicyErrors.RemoteCertificateNotAvailable) == 0;
}
[Feature("OrchardCore.Redis.Cache")]
public class RedisCacheStartup : StartupBase
{
public override void ConfigureServices(IServiceCollection services)
{
if (services.Any(d => d.ServiceType == typeof(IRedisService)))
{
services.AddSingleton<IDistributedCache, RedisCacheWrapper>();
services.AddTransient<IConfigureOptions<RedisCacheOptions>, RedisCacheOptionsSetup>();
services.AddScoped<ITagCache, RedisTagCache>();
}
}
}
[Feature("OrchardCore.Redis.Bus")]
public class RedisBusStartup : StartupBase
{
public override void ConfigureServices(IServiceCollection services)
{
if (services.Any(d => d.ServiceType == typeof(IRedisService)))
{
services.AddSingleton<IMessageBus, RedisBus>();
}
}
}
[Feature("OrchardCore.Redis.Lock")]
public class RedisLockStartup : StartupBase
{
public override void ConfigureServices(IServiceCollection services)
{
if (services.Any(d => d.ServiceType == typeof(IRedisService)))
{
services.AddSingleton<IDistributedLock, RedisLock>();
}
}
}
[Feature("OrchardCore.Redis.DataProtection")]
public class RedisDataProtectionStartup : StartupBase
{
public override void ConfigureServices(IServiceCollection services)
{
if (services.Any(d => d.ServiceType == typeof(IRedisService)))
{
services.AddTransient<IConfigureOptions<KeyManagementOptions>, RedisKeyManagementOptionsSetup>();
}
}
}
}