prs/prs.server/Engines/WebEngine/WebEngine.cs

using System;
using System.Threading.Tasks;
using Comal.Classes;
using Comal.Stores;
using InABox.IPC;
using InABox.Clients;
using InABox.Configuration;
using InABox.Core;
using InABox.Wpf.Reports;
using InABox.Rpc;
using PRS.Shared;

namespace PRSServer
{
    public class WebEngine : Engine<WebServerProperties>
    {
        private WebListener listener;

        public override void Configure(Server server)
        {
            base.Configure(server);
            Logger.Send(LogType.Information, "", "Configuring...");
        }

        public override async void Run()
        {
            Logger.Send(LogType.Information, "", "Starting..");

            if (string.IsNullOrWhiteSpace(Properties.Server))
            {
                Logger.Send(LogType.Error, "", "Server is blank!");
                return;
            }
            //ClientFactory.SetClientType(typeof(IPCClient<>), Platform.WebEngine, Version, DatabaseServerProperties.GetPipeName(Properties.Server, false));
            var transport = new RpcClientPipeTransport(DatabaseServerProperties.GetPipeName(Properties.Server, true));
            ClientFactory.SetClientType(typeof(RpcClient<>), Platform.WebEngine, Version, transport);
            CheckConnection();
            
            Logger.Send(LogType.Information, "", "Registering Classes");

            StoreUtils.RegisterClasses();
            CoreUtils.RegisterClasses();
            ComalUtils.RegisterClasses();
            PRSSharedUtils.RegisterClasses();
            ReportUtils.RegisterClasses();
            ConfigurationUtils.RegisterClasses();
            
            try
            {
                listener?.Stop();
                listener = new WebListener(new WebHandlerProperties(Properties.MaxFileSize, (ulong)Properties.LoginExpiry * 3600));
                listener.InitHTTPS((ushort)Properties.ListenPort, CertificateFileName());

                Logger.Send(LogType.Information, "", "Starting Web Listener on port " + Properties.ListenPort);
                listener.Start();
            }
            catch (Exception eListen)
            {
                Logger.Send(LogType.Error, ClientFactory.UserID, eListen.Message);
            }
        }

        private void CheckConnection()
        {
            // Wait for server connection
            while (!Client.Ping())
            {
                Logger.Send(LogType.Error, "", "Database server unavailable. Trying again in 30 seconds...");
                Task.Delay(30_000).Wait();
                Logger.Send(LogType.Information, "", "Retrying connection...");
            }

            ClientFactory.SetBypass();
        }

        public override void Stop()
        {
            Logger.Send(LogType.Information, "", "Stopping..");
            listener?.Stop();
        }
        private string CertificateFileName() =>
            !string.IsNullOrWhiteSpace(Properties.CertificateFile)
            ? Properties.CertificateFile
            : CertificateEngine.CertificateFile;
    }
}