Files
podnoms/server/Startup.cs

208 lines
8.8 KiB
C#

using System;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using AutoMapper;
using Hangfire;
using Hangfire.Dashboard;
using Hangfire.MemoryStorage;
using Microsoft.AspNetCore.Authentication.JwtBearer;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Http.Features;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Mvc.Formatters;
using Microsoft.AspNetCore.Mvc.Formatters.Xml;
using Microsoft.AspNetCore.SignalR;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Primitives;
using Microsoft.IdentityModel.Tokens;
using Newtonsoft.Json;
using Newtonsoft.Json.Serialization;
using PodNoms.Api.Models;
using PodNoms.Api.Models.ViewModels;
using PodNoms.Api.Persistence;
using PodNoms.Api.Providers;
using PodNoms.Api.Services;
using PodNoms.Api.Services.Auth;
using PodNoms.Api.Services.Hubs;
using PodNoms.Api.Services.Jobs;
using PodNoms.Api.Services.Processor;
using PodNoms.Api.Services.Realtime;
using PodNoms.Api.Services.Storage;
namespace PodNoms.Api {
public class Startup {
public IConfiguration Configuration { get; }
public Startup (IConfiguration configuration) {
Configuration = configuration;
}
public void ConfigureProductionServices (IServiceCollection services) {
ConfigureServices (services);
services.AddHangfire (config => {
config.UseSqlServerStorage (Configuration["ConnectionStrings:DefaultConnection"]);
});
}
public void ConfigureDevelopmentServices (IServiceCollection services) {
ConfigureServices (services);
services.AddHangfire (config => {
config.UseMemoryStorage ();
});
}
public void ConfigureServices (IServiceCollection services) {
Console.WriteLine ($"Configuring services: {Configuration.ToString()}");
services.AddDbContext<PodnomsDbContext> (options =>
options.UseSqlServer (Configuration.GetConnectionString ("DefaultConnection")));
services.AddOptions ();
services.Configure<AppSettings> (Configuration.GetSection ("App"));
services.Configure<StorageSettings> (Configuration.GetSection ("Storage"));
services.Configure<ApplicationsSettings> (Configuration.GetSection ("ApplicationsSettings"));
services.Configure<ImageFileStorageSettings> (Configuration.GetSection ("ImageFileStorageSettings"));
services.Configure<AudioFileStorageSettings> (Configuration.GetSection ("AudioFileStorageSettings"));
services.Configure<FormOptions> (options => {
options.ValueCountLimit = 10;
options.ValueLengthLimit = int.MaxValue;
options.MemoryBufferThreshold = Int32.MaxValue;
options.MultipartBodyLengthLimit = long.MaxValue;
});
services.AddAutoMapper (e => {
e.AddProfile (new MappingProvider (Configuration));
});
services.AddAuthentication (options => {
options.DefaultAuthenticateScheme = JwtBearerDefaults.AuthenticationScheme;
options.DefaultChallengeScheme = JwtBearerDefaults.AuthenticationScheme;
options.DefaultSignInScheme = JwtBearerDefaults.AuthenticationScheme;
}).AddJwtBearer (options => {
options.Audience = Configuration["auth0:clientId"];
options.Authority = $"https://{Configuration["auth0:domain"]}/";
options.TokenValidationParameters = new TokenValidationParameters {
NameClaimType = "name"
};
options.Events = new JwtBearerEvents () {
OnTokenValidated = AuthenticationMiddleware.OnTokenValidated
};
options.Events.OnMessageReceived = context => {
StringValues token;
if (context.Request.Path.Value.StartsWith ("/hubs/") && context.Request.Query.TryGetValue ("token", out token)) {
context.Token = token;
}
return Task.CompletedTask;
};
});
var defaultPolicy =
new AuthorizationPolicyBuilder ()
.AddAuthenticationSchemes ("Bearer")
.RequireAuthenticatedUser ()
.Build ();
services.AddAuthorization (j => {
j.DefaultPolicy = defaultPolicy;
});
services.AddMvc (options => {
options.OutputFormatters.Add (new XmlSerializerOutputFormatter ());
options.OutputFormatters
.OfType<StringOutputFormatter> ()
.Single ().SupportedMediaTypes.Add ("text/html");
})
.SetCompatibilityVersion (CompatibilityVersion.Version_2_1)
.AddJsonOptions (options => {
options.SerializerSettings.ContractResolver = new CamelCasePropertyNamesContractResolver ();
options.SerializerSettings.ReferenceLoopHandling = ReferenceLoopHandling.Serialize;
})
.AddXmlSerializerFormatters ();
services.Configure<FormOptions> (x => {
x.ValueLengthLimit = int.MaxValue;
x.MultipartBodyLengthLimit = int.MaxValue; // In case of multipart
});
services.AddSignalR (config => { });
services.AddCors (options => {
options.AddPolicy ("AllowAllOrigins",
builder => builder
.AllowAnyOrigin ()
.AllowAnyMethod ()
.AllowAnyHeader ()
.AllowCredentials ());
});
services.AddTransient<IFileUploader, AzureFileUploader> ();
services.AddTransient<IRealTimeUpdater, SignalRUpdater> ();
services.AddScoped<IUnitOfWork, UnitOfWork> ();
services.AddScoped<IPodcastRepository, PodcastRepository> ();
services.AddScoped<IEntryRepository, EntryRepository> ();
services.AddScoped<IUserRepository, UserRepository> ();
services.AddScoped<IUrlProcessService, UrlProcessService> ();
services.AddScoped<IAudioUploadProcessService, AudioUploadProcessService> ();
services.AddSingleton (typeof (HubLifetimeManager<DebugHub>),
typeof (DebugHubLifetimeManager<DebugHub>));
//register the codepages (required for slugify)
var instance = CodePagesEncodingProvider.Instance;
Encoding.RegisterProvider (instance);
}
public void Configure (IApplicationBuilder app, IHostingEnvironment env,
ILoggerFactory loggerFactory, IServiceProvider serviceProvider) {
if (env.IsDevelopment ()) {
app.UseDeveloperExceptionPage ();
} else {
app.UseExceptionHandler ("/Home/Error");
}
Console.WriteLine ("Performing migrations");
//TODO: Fix this when EF sucks less
// using (var context = new PodnomsDbContext(
// app.ApplicationServices.GetRequiredService<DbContextOptions<PodnomsDbContext>>()))
// {
// context.Database.Migrate();
// }
Console.WriteLine ("Successfully migrated");
// app.UseHsts();
// app.UseHttpsRedirection();
app.UseStaticFiles ();
GlobalConfiguration.Configuration.UseActivator (new ServiceProviderActivator (serviceProvider));
if ((env.IsProduction () || true)) {
app.UseHangfireServer ();
app.UseHangfireDashboard ("/hangfire", new DashboardOptions {
Authorization = new [] { new HangFireAuthorizationFilter () }
});
}
app.UseCors ("AllowAllOrigins");
app.UseSignalR (routes => {
routes.MapHub<AudioProcessingHub> ("/hubs/audioprocessing");
routes.MapHub<DebugHub> ("/hubs/debug");
});
app.UseMvc (routes => {
routes.MapRoute (
name: "default",
template: "{controller=Home}/{action=Index}/{id?}");
});
//start hangfire jobs
//RecurringJob.AddOrUpdate<ClearOrphanAudioJob>(x => x.Execute(), Cron.Hourly);
}
}
}