setup to receive & process event postings

src/Events/Startup.cs

@@ -1,36 +1,119 @@
-using System;
+using System.Security.Claims;
+using Bit.Core;
+using Bit.Core.IdentityServer;
+using Bit.Core.Services;
+using Bit.Core.Utilities;
+using IdentityModel;
+using IdentityServer4.AccessTokenValidation;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Logging;
+using Serilog.Events;
 
 namespace Bit.Events
 {
     public class Startup
     {
-        public Startup(IConfiguration configuration)
+        public Startup(IHostingEnvironment env, IConfiguration configuration)
         {
             Configuration = configuration;
+            Environment = env;
         }
 
         public IConfiguration Configuration { get; }
+        public IHostingEnvironment Environment { get; set; }
 
         public void ConfigureServices(IServiceCollection services)
         {
             // Options
             services.AddOptions();
 
+            // Settings
+            var globalSettings = services.AddGlobalSettingsServices(Configuration);
+
+            // Repositories
+            services.AddSqlServerRepositories(globalSettings);
+
+            // Context
+            services.AddScoped<CurrentContext>();
+
+            // Identity
+            services
+                .AddAuthentication(IdentityServerAuthenticationDefaults.AuthenticationScheme)
+                .AddIdentityServerAuthentication(options =>
+                {
+                    options.Authority = globalSettings.BaseServiceUri.InternalIdentity;
+                    options.RequireHttpsMetadata = !Environment.IsDevelopment() &&
+                        globalSettings.BaseServiceUri.InternalIdentity.StartsWith("https");
+                    options.NameClaimType = ClaimTypes.Email;
+                    options.TokenRetriever = TokenRetrieval.FromAuthorizationHeaderOrQueryString(
+                        new string[] { "Bearer", "Bearer3" });
+                    options.SupportedTokens = SupportedTokens.Jwt;
+                });
+
+            services.AddAuthorization(config =>
+            {
+                config.AddPolicy("Application", policy =>
+                {
+                    policy.RequireAuthenticatedUser();
+                    policy.RequireClaim(JwtClaimTypes.AuthenticationMethod, "Application");
+                });
+            });
+
+            // Services
+            services.AddScoped<IEventService, EventService>();
+            if(!globalSettings.SelfHosted && CoreHelpers.SettingHasValue(globalSettings.Storage.ConnectionString))
+            {
+                services.AddSingleton<IEventWriteService, AzureQueueEventWriteService>();
+            }
+            else
+            {
+                services.AddSingleton<IEventWriteService, RepositoryEventWriteService>();
+            }
+
             // Mvc
             services.AddMvc();
         }
 
-        public void Configure(IApplicationBuilder app, IHostingEnvironment env)
+        public void Configure(
+            IApplicationBuilder app,
+            IHostingEnvironment env,
+            ILoggerFactory loggerFactory,
+            IApplicationLifetime appLifetime,
+            GlobalSettings globalSettings)
         {
+            loggerFactory.AddSerilog(env, appLifetime, globalSettings, (e) =>
+            {
+                var context = e.Properties["SourceContext"].ToString();
+                if(context.Contains("IdentityServer4.Validation.TokenValidator") ||
+                    context.Contains("IdentityServer4.Validation.TokenRequestValidator"))
+                {
+                    return e.Level > LogEventLevel.Error;
+                }
+
+                return e.Level >= LogEventLevel.Error;
+            });
+
             if(env.IsDevelopment())
             {
                 app.UseDeveloperExceptionPage();
             }
 
+            // Default Middleware
+            app.UseDefaultMiddleware(env);
+
+            // Add Cors
+            app.UseCors("All");
+
+            // Add authentication to the request pipeline.
+            app.UseAuthentication();
+
+            // Add current context
+            app.UseMiddleware<CurrentContextMiddleware>();
+
+            // Add MVC to the request pipeline.
             app.UseMvc();
         }
     }