Startup.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Identity;
using Microsoft.AspNetCore.Http;
using Microsoft.EntityFrameworkCore;
using Microsoft.AspNetCore.Hosting;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Hosting;
using Pomelo.EntityFrameworkCore.MySql;
using Hangfire;
using Hangfire.MySql.Core;
using Hangfire.Dashboard;
using viafront3.Data;
using viafront3.Models;
using viafront3.Services;

namespace viafront3
{
    public class GeneralSettings
    {
        public string SiteName { get; set; }
    }

    public class MySqlSettings
    {
        public string Host { get; set; }
        public string Database { get; set; }
        public string User { get; set; }
        public string Password { get; set; }
    }

    public class AssetSettings
    {
        public int Decimals { get; set; }
    }

    public class MarketSettings
    {
        public string PriceUnit { get; set; }
        public string AmountUnit { get; set; }
        public int PriceDecimals { get; set; }
        public int AmountDecimals { get; set; }
        public string PriceInterval { get; set; }
        public string AmountInterval { get; set; }
    }

    public class ExchangeSettings
    {
        public MySqlSettings MySql { get; set; } = new MySqlSettings();
        public string AccessHttpUrl { get; set; } = "http://localhost:8080";
        public string AccessWsUrl { get; set; } = "ws://localhost:8090";
        public string AccessWsIp { get; set; } = "127.0.0.1";
        public string WebsocketUrl { get; set; } = "ws://localhost/ws";
        public string KafkaHost { get; set; } = "127.0.0.1:9092";
        public Dictionary<string, AssetSettings> Assets { get; set; } = new Dictionary<string, AssetSettings>();
        public Dictionary<string, MarketSettings> Markets { get; set; } = new Dictionary<string, MarketSettings>();
        public int OrderBookLimit { get; set; } = 99;
        public string TakerFeeRate { get; set; } = "0.02";
        public string MakerFeeRate { get; set; } = "0.01";
        public bool MarketOrderBidAmountMoney { get; set; } = false;
    }

    public enum LedgerModel
    {
        Account,
        UTXO
    }

    public class ChainAssetSettings
    {
        public string NodeUrl { get; set; }
        public long FeeUnit { get; set; }
        public long FeeMax { get; set; }
        public int MinConf { get; set; }
        public LedgerModel LedgerModel { get; set; }
    }

    public class WalletSettings
    {
        public bool Mainnet { get; set; } = false;
        public string ConsolidatedFundsTag { get; set; } = "Consolidate";
        public MySqlSettings MySql { get; set; } = new MySqlSettings();
        public Dictionary<string, string> DbNames { get; set; } = new Dictionary<string, string>();
        public Dictionary<string, ChainAssetSettings> ChainAssetSettings { get; set; } = new Dictionary<string, ChainAssetSettings>();
        public Dictionary<string, xchwallet.BankAccount> BankAccounts { get; set; } = new Dictionary<string, xchwallet.BankAccount>();
    }

    public class EmailSenderSettings
    {
        public string From { get; set; }
        public string SmtpHost { get; set; }
        public string SmtpUser { get; set; }
        public string SmtpPass { get; set; }
        public int SmtpPort { get; set; }
        public bool SmtpSsl { get; set; }
        public string Signature { get; set; }
        public string TemplateFile { get; set; }
    }

    public class Broker
    {
        public decimal Fee { get; set; }
        public int TimeLimitMinutes { get; set; }
        public int TimeLimitGracePeriod { get; set; }
        public List<string> SellMarkets { get; set; }
        public List<string> BuyMarkets { get; set; }
        public Dictionary<string, decimal> MinimumOrderAmount {get; set;}
        public string BrokerTag { get; set; }
    }

    public class ApiSettings
    {
        public int CreationExpiryMinutes { get; set; }
        public Broker Broker { get; set; }
    }

    public enum WithdrawalPeriod
    {
        Daily,
        Weekly,
        Monthly,
    }

    public class KycLevel
    {
        public string Name { get; set; }
        public string WithdrawalLimit { get; set; }

        public override string ToString()
        {
            return $"Withdrawal limit: {WithdrawalLimit} ({Name})";
        }
    }

    public class KycSettings
    {
        public List<KycLevel> Levels { get; set; }
        public WithdrawalPeriod WithdrawalPeriod { get; set; }
        public string WithdrawalAsset { get; set; }
        public Dictionary<string, decimal> WithdrawalAssetBaseRates { get; set; } = new Dictionary<string, decimal>();
        public bool KycServerEnabled { get; set; }
        public string KycServerUrl { get; set; }
        public string KycServerApiKey { get; set; }
        public string KycServerApiSecret { get; set; }
    }

    public class TripwireSettings
    {
        public string AlertEmail { get; set; }
        public int TimePeriodInMinutes { get; set; }
        public Dictionary<TripwireEventType, int> Maximum { get; set; }
    }

    public class FiatProcessorSettings
    {
        public string FiatServerUrl { get; set; }
        public string FiatServerApiKey { get; set; }
        public string FiatServerSecret { get; set; }
        public bool PaymentsEnabled { get; set; }
        public string[] PaymentsAssets { get; set; }
        public bool PayoutsEnabled { get; set; }
        public string[] PayoutsAssets { get; set; }
        public string PayoutsReference { get; set; }
    }

    public class HangfireAuthorizationFilter : IDashboardAuthorizationFilter
    {
        public bool Authorize(DashboardContext context)
        {
            var httpContext = context.GetHttpContext();

            // Allow all authenticated users with the admin role to see the Dashboard.
            return httpContext.User.Identity.IsAuthenticated &&
                   httpContext.User.IsInRole(Utils.AdminRole);
        }
    }

    public class Startup
    {
        public Startup(IConfiguration configuration)
        {
            Configuration = configuration;
        }

        public IConfiguration Configuration { get; }

        // This method gets called by the runtime. Use this method to add services to the container.
        public void ConfigureServices(IServiceCollection services)
        {
            // Add ExchangeSettings so it can be injected in controllers
            services.Configure<GeneralSettings>(options => Configuration.GetSection("General").Bind(options));
            services.Configure<ExchangeSettings>(options => Configuration.GetSection("Exchange").Bind(options));
            services.Configure<WalletSettings>(options => Configuration.GetSection("Wallet").Bind(options));
            services.Configure<EmailSenderSettings>(options => Configuration.GetSection("EmailSender").Bind(options));
            services.Configure<ApiSettings>(options => Configuration.GetSection("Api").Bind(options));
            services.Configure<KycSettings>(options => Configuration.GetSection("Kyc").Bind(options));
            services.Configure<TripwireSettings>(options => Configuration.GetSection("Tripwire").Bind(options));
            services.Configure<FiatProcessorSettings>(options => Configuration.GetSection("FiatProcessor").Bind(options));

            services.AddDbContext<ApplicationDbContext>(options =>
                options.UseLazyLoadingProxies()
                       .UseMySql(Configuration.GetConnectionString("DefaultConnection")));

            services.AddIdentity<ApplicationUser, IdentityRole>()
                .AddEntityFrameworkStores<ApplicationDbContext>()
                .AddDefaultTokenProviders();

            services.ConfigureApplicationCookie(options =>
            {
                // use our efcore ticket store
                options.ExpireTimeSpan = TimeSpan.FromDays(14);
                options.SlidingExpiration = true;
                options.SessionStore = new EfTicketStore(services.BuildServiceProvider());
                // set our session cookie security policy
                options.Cookie.HttpOnly = true;
                options.Cookie.SameSite = Microsoft.AspNetCore.Http.SameSiteMode.Lax;
                options.Cookie.SecurePolicy = Microsoft.AspNetCore.Http.CookieSecurePolicy.SameAsRequest;
            });
            services.AddAntiforgery(options =>
            {
                // set our CSRF cookie security policy
                options.Cookie.HttpOnly = true;
                options.Cookie.SameSite = Microsoft.AspNetCore.Http.SameSiteMode.Strict;
                options.Cookie.SecurePolicy = Microsoft.AspNetCore.Http.CookieSecurePolicy.SameAsRequest;
            });

            // catch exception which happens if the database does not yet exist because of migrations still in the process of being applied
            try
            {
                // add hangfire service (using out mysql db)
                var storage = new MySqlStorage(Configuration.GetConnectionString("DefaultConnection"), new MySqlStorageOptions { TablePrefix = "Hangfire" });
                services.AddHangfire(x =>
                    x.UseStorage(storage));
            }
            catch
            {
                Console.WriteLine("Failed to add hangfire! App will fail unless we are just doing design time stuff (migrations etc)");
            }

            // Add application services.
            services.AddTransient<IEmailSender, EmailSender>();
            services.AddSingleton<IWebsocketTokens, WebsocketTokens>();
            services.AddSingleton<IWalletProvider, WalletProvider>();
            services.AddTransient<IBroker, viafront3.Services.Broker>();
            services.AddSingleton<ITripwire, Tripwire>();
            services.AddSingleton<IDepositsWithdrawals, DepositsWithdrawals>();
            services.AddSingleton<IUserLocks, UserLocks>();
            services.AddTransient<IAppVersion, AppVersion>();

            services.AddMvc(options =>
                options.Filters.Add(new AutoValidateAntiforgeryTokenAttribute()));

            System.ComponentModel.TypeDescriptor.AddAttributes(typeof(DateTime), new System.ComponentModel.TypeConverterAttribute(typeof(NzDateTimeConverter)));
        }

        // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
        public void Configure(IApplicationBuilder app, IWebHostEnvironment env, ILoggerFactory loggerFactory)
        {
            if (env.IsDevelopment())
            {
                app.UseDeveloperExceptionPage();
                app.UseDatabaseErrorPage();
            }
            else
            {
                app.UseExceptionHandler("/Home/Error");
            }

            // enable buffering so our authentication stuff in ApiController can re-read the body after MVC
            app.Use((context, next) =>
            {
                context.Request.EnableBuffering();
                return next();
            });

            // add CSP header
            app.Use(async (context, next) =>
            {
                context.Response.Headers.Add(
                    "Content-Security-Policy",
                    "default-src 'self'; script-src 'self'; style-src 'unsafe-inline' 'self'; img-src 'self' data:;");
                await next();
            });

            app.UseStaticFiles();
            app.UseRouting();
            
            app.UseAuthentication();
            app.UseAuthorization();

            app.UseEndpoints(endpoints => {
                endpoints.MapControllerRoute("default", "{controller=Home}/{action=Index}/{id?}");
            });

            var options = new DashboardOptions
            {
                Authorization = new[] { new HangfireAuthorizationFilter() }
            };
            app.UseHangfireDashboard("/hangfire", options);
            app.UseHangfireServer();
            RecurringJob.AddOrUpdate<IWalletProvider>(
                provider => provider.UpdateBlockchainWallets(), "0 */5 * ? * *"); // every 5 minutes
            RecurringJob.AddOrUpdate<IBroker>(
                broker => broker.ProcessOrders(), "0 */5 * ? * *"); // every 5 minutes
            RecurringJob.AddOrUpdate<IDepositsWithdrawals>(
                depositsWithdrawals => depositsWithdrawals.ProcessChainDeposits(), "0 */10 * ? * *"); // every 10 minutes
            RecurringJob.AddOrUpdate<IDepositsWithdrawals>(
                depositsWithdrawals => depositsWithdrawals.ProcessChainWithdrawals(), "0 */10 * ? * *"); // every 10 minutes
            RecurringJob.AddOrUpdate<IDepositsWithdrawals>(
                depositsWithdrawals => depositsWithdrawals.ProcessFiatWithdrawals(), "0 */10 * ? * *"); // every 10 minutes

            var defaultLogLevel = Configuration.GetSection("Logging").GetSection("LogLevel").GetValue<LogLevel>("Default");
            loggerFactory.AddFile("logs/viafront-{Date}.txt", defaultLogLevel);
        }
    }
}