LicensingEngine.cs 5.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170
  1. using Comal.Classes;
  2. using Comal.Stores;
  3. using GenHTTP.Api.Protocol;
  4. using GenHTTP.Modules.IO;
  5. using InABox.Clients;
  6. using InABox.Configuration;
  7. using InABox.Core;
  8. using InABox.Rpc;
  9. using InABox.Wpf.Reports;
  10. using PRS.Shared;
  11. using PRSServer;
  12. using PRSServices;
  13. using System;
  14. using System.Collections.Generic;
  15. using System.Linq;
  16. using System.Text;
  17. using System.Threading;
  18. using System.Threading.Tasks;
  19. using RequestMethod = GenHTTP.Api.Protocol.RequestMethod;
  20. namespace PRSLicensing;
  21. public class LicensingHandler : Handler<LicensingHandlerProperties>
  22. {
  23. public override void Init(LicensingHandlerProperties properties)
  24. {
  25. }
  26. private IResponseBuilder HandleGET(IRequest request)
  27. {
  28. return request.Respond().Content("Hello, World!").Status(ResponseStatus.OK);
  29. }
  30. private IResponseBuilder HandlePOST(IRequest request)
  31. {
  32. return request.Respond().Status(ResponseStatus.NotFound);
  33. }
  34. public override ValueTask<IResponse?> HandleAsync(IRequest request)
  35. {
  36. try
  37. {
  38. switch (request.Method.KnownMethod)
  39. {
  40. case RequestMethod.GET:
  41. return new ValueTask<IResponse?>(HandleGET(request).Build());
  42. case RequestMethod.POST:
  43. return new ValueTask<IResponse?>(HandlePOST(request).Build());
  44. default:
  45. Logger.Send(LogType.Error, ClientFactory.UserID, $"Request method {request.Method.RawMethod} unknown");
  46. return new ValueTask<IResponse?>(request.Respond().Status(ResponseStatus.MethodNotAllowed).Build());
  47. }
  48. }
  49. catch (Exception eListen)
  50. {
  51. Logger.Send(LogType.Error, ClientFactory.UserID, eListen.Message);
  52. return new ValueTask<IResponse?>(request.Respond().Status(ResponseStatus.InternalServerError).Build());
  53. }
  54. }
  55. }
  56. public class LicensingHandlerProperties
  57. {
  58. }
  59. public class LicensingEngine : Engine<LicensingEngineProperties>
  60. {
  61. private Listener<LicensingHandler, LicensingHandlerProperties> listener;
  62. public override void Run()
  63. {
  64. Logger.Send(LogType.Information, "", "Starting..");
  65. if (string.IsNullOrWhiteSpace(Properties.Server))
  66. {
  67. Logger.Send(LogType.Error, "", "Server is blank!");
  68. return;
  69. }
  70. var transport = new RpcClientPipeTransport(DatabaseServerProperties.GetPipeName(Properties.Server, true));
  71. ClientFactory.SetClientType(typeof(RpcClient<>), Platform.WebEngine, Version, transport);
  72. CheckConnection();
  73. Logger.Send(LogType.Information, "", "Registering Classes");
  74. StoreUtils.RegisterClasses();
  75. CoreUtils.RegisterClasses();
  76. ComalUtils.RegisterClasses();
  77. PRSSharedUtils.RegisterClasses();
  78. ReportUtils.RegisterClasses();
  79. ConfigurationUtils.RegisterClasses();
  80. Logger.Send(LogType.Information, "", "Starting Listener on port " + Properties.ListenPort);
  81. try
  82. {
  83. listener = new Listener<LicensingHandler, LicensingHandlerProperties>(new LicensingHandlerProperties());
  84. listener.InitHTTPS((ushort)Properties.ListenPort, CertificateFileName());
  85. Logger.Send(LogType.Information, "", "Starting Web Listener on port " + Properties.ListenPort);
  86. listener.Start();
  87. }
  88. catch (Exception eListen)
  89. {
  90. Logger.Send(LogType.Error, ClientFactory.UserID, eListen.Message);
  91. }
  92. }
  93. private string CertificateFileName() => Properties.CertificateFile;
  94. private void CheckConnection()
  95. {
  96. // Wait for server connection
  97. while (!Client.Ping())
  98. {
  99. Logger.Send(LogType.Error, "", "Database server unavailable. Trying again in 30 seconds...");
  100. Task.Delay(30_000).Wait();
  101. Logger.Send(LogType.Information, "", "Retrying connection...");
  102. }
  103. ClientFactory.SetBypass();
  104. }
  105. public override void Stop()
  106. {
  107. Logger.Send(LogType.Information, "", "Stopping");
  108. listener?.Stop();
  109. }
  110. }
  111. public class LicensingEngineProperties : ServerProperties
  112. {
  113. [ComboLookupEditor(typeof(LicensingDatabaseServerLookupGenerator))]
  114. [EditorSequence(1)]
  115. public string Server { get; set; }
  116. [IntegerEditor]
  117. [EditorSequence(2)]
  118. public int ListenPort { get; set; }
  119. [EditorSequence(3)]
  120. [FileNameEditor("Certificate Files (*.pfx)|*.pfx")]
  121. public string CertificateFile { get; set; }
  122. public override ServerType Type()
  123. {
  124. return ServerType.Other;
  125. }
  126. }
  127. public class LicensingDatabaseServerLookupGenerator : LookupGenerator<LicensingEngineProperties>
  128. {
  129. public LicensingDatabaseServerLookupGenerator(LicensingEngineProperties[] items) : base(items)
  130. {
  131. }
  132. protected override void DoGenerateLookups()
  133. {
  134. var config = new LocalConfiguration<ServerSettings>(CoreUtils.GetCommonAppData("PRSServer"), "");
  135. var servers = config.LoadAll();
  136. foreach (var server in servers.Select(x => x.Value.CreateServer(x.Key)))
  137. {
  138. if (server.Type == ServerType.Database)
  139. {
  140. AddValue(server.Key, server.Name);
  141. }
  142. }
  143. }
  144. }