99 lines
3.3 KiB
C#
99 lines
3.3 KiB
C#
using System.Security.Cryptography;
|
|
using System.Text.Json;
|
|
using EmbedIO;
|
|
using EmbedIO.BearerToken;
|
|
using EmbedIO.WebApi;
|
|
using Microsoft.IdentityModel.Tokens;
|
|
using NLog;
|
|
using Torch.API;
|
|
using Torch.API.Managers;
|
|
using Torch.Managers;
|
|
using Torch.Server.Managers;
|
|
using TorchRemote.Plugin.Controllers;
|
|
using TorchRemote.Plugin.Modules;
|
|
using TorchRemote.Plugin.Utils;
|
|
using VRage.Game.ModAPI;
|
|
namespace TorchRemote.Plugin.Managers;
|
|
|
|
public class ApiServerManager : Manager
|
|
{
|
|
private static readonly ILogger Log = LogManager.GetCurrentClassLogger();
|
|
|
|
private readonly Config _config;
|
|
private readonly IWebServer _server;
|
|
[Dependency]
|
|
private readonly SettingManager _settingManager = null!;
|
|
[Dependency]
|
|
private readonly InstanceManager _instanceManager = null!;
|
|
public ApiServerManager(ITorchBase torchInstance, Config config) : base(torchInstance)
|
|
{
|
|
_config = config;
|
|
|
|
if (string.IsNullOrEmpty(_config.SecurityKey))
|
|
_config.SecurityKey = CreateSecurityKey();
|
|
|
|
var apiModule = new WebApiModule("/api/v1", async (context, data) =>
|
|
{
|
|
try
|
|
{
|
|
context.Response.ContentType = "application/json";
|
|
using var stream = context.OpenResponseStream();
|
|
await JsonSerializer.SerializeAsync(stream, data, Statics.SerializerOptions);
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
Log.Error(e);
|
|
throw HttpException.InternalServerError(e.Message, e.Message);
|
|
}
|
|
});
|
|
|
|
var chatModule = new ChatModule("/api/live/chat", true);
|
|
Statics.ChatModule = chatModule;
|
|
|
|
_server = new WebServer(o => o
|
|
.WithUrlPrefix(_config.Listener.UrlPrefix)
|
|
.WithMicrosoftHttpListener())
|
|
.WithLocalSessionManager()
|
|
.WithCors("/api", "*", "*", "*")
|
|
.WithModule(apiModule
|
|
.WithController<ServerController>()
|
|
.WithController<SettingsController>()
|
|
.WithController<WorldsController>()
|
|
.WithController<ChatController>()
|
|
.WithController<PluginsController>()
|
|
.WithController<PluginDownloadsController>()
|
|
.WithController<PlayersController>())
|
|
.WithModule(new LogsModule("/api/live/logs", true))
|
|
.WithModule(chatModule)
|
|
.WithBearerToken("/api", new SymmetricSecurityKey(Convert.FromBase64String(_config.SecurityKey)), new BasicAuthorizationServerProvider());
|
|
}
|
|
|
|
public override void Attach()
|
|
{
|
|
base.Attach();
|
|
|
|
Starter();
|
|
Log.Info("Listening on {0}", _config.Listener.UrlPrefix);
|
|
|
|
//_instanceManager.InstanceLoaded += model => _settingManager.RegisterSetting(model.Model, typeof(IMyConfigDedicated), false);
|
|
}
|
|
public override void Detach()
|
|
{
|
|
base.Detach();
|
|
_server.Dispose();
|
|
}
|
|
|
|
private async void Starter()
|
|
{
|
|
await _server.RunAsync();
|
|
}
|
|
|
|
private static string CreateSecurityKey()
|
|
{
|
|
var aes = Aes.Create();
|
|
aes.GenerateIV();
|
|
aes.GenerateKey();
|
|
|
|
return Convert.ToBase64String(aes.Key);
|
|
}
|
|
} |