-
Notifications
You must be signed in to change notification settings - Fork 48
/
Startup.cs
103 lines (93 loc) · 3.62 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
using System;
using System.Reflection;
using Autofac;
using Autofac.Extensions.DependencyInjection;
using Consul;
using DShop.Api.Services;
using DShop.Common;
using DShop.Common.Authentication;
using DShop.Common.Consul;
using DShop.Common.Dispatchers;
using DShop.Common.Jaeger;
using DShop.Common.Mvc;
using DShop.Common.RabbitMq;
using DShop.Common.Redis;
using DShop.Common.RestEase;
using DShop.Common.Swagger;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
namespace DShop.Api
{
public class Startup
{
private static readonly string[] Headers = new []{ "X-Operation", "X-Resource", "X-Total-Count" };
public IContainer Container { get; private set; }
public IConfiguration Configuration { get; }
public Startup(IConfiguration configuration)
{
Configuration = configuration;
}
public IServiceProvider ConfigureServices(IServiceCollection services)
{
services.AddCustomMvc();
services.AddSwaggerDocs();
services.AddConsul();
services.AddJwt();
services.AddJaeger();
services.AddOpenTracing();
services.AddRedis();
services.AddAuthorization(x => x.AddPolicy("admin", p => p.RequireRole("admin")));
services.AddCors(options =>
{
options.AddPolicy("CorsPolicy", cors =>
cors.AllowAnyOrigin()
.AllowAnyMethod()
.AllowAnyHeader()
.AllowCredentials()
.WithExposedHeaders(Headers));
});
services.RegisterServiceForwarder<IOperationsService>("operations-service");
services.RegisterServiceForwarder<ICustomersService>("customers-service");
services.RegisterServiceForwarder<IOrdersService>("orders-service");
services.RegisterServiceForwarder<IProductsService>("products-service");
var builder = new ContainerBuilder();
builder.RegisterAssemblyTypes(Assembly.GetEntryAssembly())
.AsImplementedInterfaces();
builder.Populate(services);
builder.AddRabbitMq();
builder.AddDispatchers();
Container = builder.Build();
return new AutofacServiceProvider(Container);
}
// This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
public void Configure(IApplicationBuilder app, IHostingEnvironment env,
IApplicationLifetime applicationLifetime, IConsulClient client,
IStartupInitializer startupInitializer)
{
if (env.IsDevelopment() || env.EnvironmentName == "local")
{
app.UseDeveloperExceptionPage();
}
app.UseCors("CorsPolicy");
app.UseAllForwardedHeaders();
app.UseSwaggerDocs();
app.UseErrorHandler();
app.UseAuthentication();
app.UseAccessTokenValidator();
app.UseServiceId();
app.UseMvc();
app.UseRabbitMq();
var consulServiceId = app.UseConsul();
applicationLifetime.ApplicationStopped.Register(() =>
{
client.Agent.ServiceDeregister(consulServiceId);
Container.Dispose();
});
startupInitializer.InitializeAsync();
}
}
}