mirror of
https://github.com/EpinelPS/EpinelPS.git
synced 2025-12-15 08:24:52 +01:00
504 lines
20 KiB
C#
504 lines
20 KiB
C#
using EpinelPS.Database;
|
|
using EpinelPS.LobbyServer;
|
|
using EpinelPS.LobbyServer.Msgs.Stage;
|
|
using EpinelPS.StaticInfo;
|
|
using EpinelPS.Utils;
|
|
using Microsoft.AspNetCore.Server.Kestrel.Https;
|
|
using System.Net;
|
|
using System.Net.Http.Headers;
|
|
using System.Security.Cryptography.X509Certificates;
|
|
using System.Text;
|
|
|
|
namespace EpinelPS
|
|
{
|
|
internal class Program
|
|
{
|
|
static async Task Main(string[] args)
|
|
{
|
|
try
|
|
{
|
|
Console.WriteLine("Initializing JsonDb");
|
|
JsonDb.Save();
|
|
|
|
GameData.Instance.GetAllCostumes(); // force static data to be loaded
|
|
|
|
Console.WriteLine("Initialize handlers");
|
|
LobbyHandler.Init();
|
|
|
|
Console.WriteLine("Starting ASP.NET core on ports 80/443");
|
|
new Thread(() =>
|
|
{
|
|
var builder = WebApplication.CreateBuilder(args);
|
|
|
|
// Configure HTTPS
|
|
var httpsConnectionAdapterOptions = new HttpsConnectionAdapterOptions
|
|
{
|
|
SslProtocols = System.Security.Authentication.SslProtocols.Tls12,
|
|
ClientCertificateMode = ClientCertificateMode.AllowCertificate,
|
|
ServerCertificate = new X509Certificate2(AppDomain.CurrentDomain.BaseDirectory + @"site.pfx")
|
|
};
|
|
|
|
builder.WebHost.ConfigureKestrel(serverOptions =>
|
|
{
|
|
serverOptions.Listen(IPAddress.Any, 443,
|
|
listenOptions =>
|
|
{
|
|
listenOptions.UseHttps(AppDomain.CurrentDomain.BaseDirectory + @"site.pfx", "");
|
|
});
|
|
|
|
// TODO
|
|
serverOptions.AllowSynchronousIO = true;
|
|
});
|
|
|
|
// Add services to the container.
|
|
|
|
builder.Services.AddControllers();
|
|
// Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
|
|
builder.Services.AddEndpointsApiExplorer();
|
|
builder.Services.AddRouting();
|
|
|
|
var app = builder.Build();
|
|
|
|
app.UseDefaultFiles();
|
|
app.UseStaticFiles();
|
|
|
|
// Configure the HTTP request pipeline.
|
|
if (app.Environment.IsDevelopment())
|
|
{
|
|
|
|
}
|
|
|
|
app.UseHttpsRedirection();
|
|
|
|
app.UseAuthorization();
|
|
app.UseHttpsRedirection();
|
|
app.UseRouting();
|
|
|
|
app.MapControllers();
|
|
|
|
app.MapPost("/$batch", HandleBatchRequests);
|
|
app.MapGet("/prdenv/{**all}", AssetDownloadUtil.HandleReq);
|
|
app.MapGet("/PC/{**all}", AssetDownloadUtil.HandleReq);
|
|
app.MapGet("/media/{**all}", AssetDownloadUtil.HandleReq);
|
|
|
|
// NOTE: pub prefixes shows public (production server), local is local server (does not have any effect), dev is development server, etc.
|
|
// It does not have any effect, except for the publisher server, which adds a watermark?
|
|
|
|
app.MapGet("/route/*/route_config.json", () => @"{
|
|
""Config"": [
|
|
{
|
|
""VersionRange"": {
|
|
""From"": ""{GameMinVer}"",
|
|
""To"": ""{GameMaxVer}"",
|
|
""PackageName"": ""com.proximabeta.nikke""
|
|
},
|
|
""Route"": [
|
|
{
|
|
""WorldId"": 81,
|
|
""Name"": ""pub:live-jp"",
|
|
""Url"": ""https://jp-lobby.nikke-kr.com/"",
|
|
""Description"": ""JAPAN"",
|
|
""Tags"": []
|
|
},
|
|
{
|
|
""WorldId"": 82,
|
|
""Name"": ""pub:live-na"",
|
|
""Url"": ""https://us-lobby.nikke-kr.com/"",
|
|
""Description"": ""NA"",
|
|
""Tags"": []
|
|
},
|
|
{
|
|
""WorldId"": 83,
|
|
""Name"": ""pub:live-kr"",
|
|
""Url"": ""https://kr-lobby.nikke-kr.com/"",
|
|
""Description"": ""KOREA"",
|
|
""Tags"": []
|
|
},
|
|
{
|
|
""WorldId"": 84,
|
|
""Name"": ""pub:live-global"",
|
|
""Url"": ""https://global-lobby.nikke-kr.com/"",
|
|
""Description"": ""GLOBAL"",
|
|
""Tags"": []
|
|
},
|
|
{
|
|
""WorldId"": 85,
|
|
""Name"": ""pub:live-sea"",
|
|
""Url"": ""https://sea-lobby.nikke-kr.com/"",
|
|
""Description"": ""SEA"",
|
|
""Tags"": []
|
|
}
|
|
]
|
|
},
|
|
{
|
|
""VersionRange"": {
|
|
""From"": ""{GameMinVer}"",
|
|
""To"": ""{GameMaxVer}"",
|
|
""PackageName"": ""com.gamamobi.nikke""
|
|
},
|
|
""Route"": [
|
|
{
|
|
""WorldId"": 91,
|
|
""Name"": ""pub:live-hmt"",
|
|
""Url"": ""https://hmt-lobby.nikke-kr.com/"",
|
|
""Description"": ""HMT"",
|
|
""Tags"": []
|
|
}
|
|
]
|
|
}
|
|
]
|
|
}".Replace("{GameMinVer}", GameConfig.Root.GameMinVer).Replace("{GameMaxVer}", GameConfig.Root.GameMaxVer));
|
|
|
|
app.Run();
|
|
}).Start();
|
|
|
|
CliLoop();
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Console.WriteLine("Fatal error:");
|
|
Console.WriteLine(ex.ToString());
|
|
Console.WriteLine("Press any key to exit");
|
|
Console.ReadKey();
|
|
}
|
|
}
|
|
|
|
private static void CliLoop()
|
|
{
|
|
ulong selectedUser = 0;
|
|
string prompt = "# ";
|
|
while (true)
|
|
{
|
|
Console.Write(prompt);
|
|
|
|
var input = Console.ReadLine();
|
|
var args = input.Split(' ');
|
|
if (string.IsNullOrEmpty(input) || string.IsNullOrWhiteSpace(input))
|
|
{
|
|
|
|
}
|
|
else if (input == "?" || input == "help")
|
|
{
|
|
Console.WriteLine("EpinelPS CLI");
|
|
Console.WriteLine();
|
|
Console.WriteLine("Commands:");
|
|
Console.WriteLine(" help - show this help");
|
|
Console.WriteLine(" ls /users - show all users");
|
|
Console.WriteLine(" cd (user id) - select user by id");
|
|
Console.WriteLine(" rmuser - delete selected user");
|
|
Console.WriteLine(" ban - ban selected user from game");
|
|
Console.WriteLine(" unban - unban selected user from game");
|
|
Console.WriteLine(" exit - exit server application");
|
|
Console.WriteLine(" completestage (chapter num)-(stage number) - complete selected stage and get rewards (and all previous ones). Example completestage 15-1. Note that the exact stage number cleared may not be exact.");
|
|
}
|
|
else if (input == "ls /users")
|
|
{
|
|
Console.WriteLine("Id,Username,Nickname");
|
|
foreach (var item in JsonDb.Instance.Users)
|
|
{
|
|
Console.WriteLine($"{item.ID},{item.Username},{item.Nickname}");
|
|
}
|
|
}
|
|
else if (input.StartsWith("cd"))
|
|
{
|
|
if (args.Length == 2)
|
|
{
|
|
if (ulong.TryParse(args[1], out ulong id))
|
|
{
|
|
// check if user id exists
|
|
var user = JsonDb.Instance.Users.FirstOrDefault(x => x.ID == id);
|
|
if (user != null)
|
|
{
|
|
selectedUser = user.ID;
|
|
Console.WriteLine("Selected user: " + user.Username);
|
|
prompt = "/users/" + user.Username + "# ";
|
|
}
|
|
else
|
|
{
|
|
Console.WriteLine("User not found");
|
|
}
|
|
}
|
|
else
|
|
{
|
|
Console.WriteLine("Argument #1 should be a number");
|
|
Console.WriteLine("Usage: chroot (user id)");
|
|
}
|
|
}
|
|
else
|
|
{
|
|
Console.WriteLine("Incorrect number of arguments for chroot");
|
|
Console.WriteLine("Usage: chroot (user id)");
|
|
}
|
|
}
|
|
else if (input.StartsWith("rmuser"))
|
|
{
|
|
if (selectedUser == 0)
|
|
{
|
|
Console.WriteLine("No user selected");
|
|
}
|
|
else
|
|
{
|
|
var user = JsonDb.Instance.Users.FirstOrDefault(x => x.ID == selectedUser);
|
|
if (user == null)
|
|
{
|
|
Console.WriteLine("Selected user does not exist");
|
|
selectedUser = 0;
|
|
prompt = "# ";
|
|
}
|
|
else
|
|
{
|
|
Console.Write("Are you sure you want to delete user " + user.Username + "? (y/n) ");
|
|
var confirm = Console.ReadLine();
|
|
if (confirm == "y")
|
|
{
|
|
JsonDb.Instance.Users.Remove(user);
|
|
JsonDb.Save();
|
|
Console.WriteLine("User deleted");
|
|
selectedUser = 0;
|
|
prompt = "# ";
|
|
}
|
|
else
|
|
{
|
|
Console.WriteLine("User not deleted");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
else if (input.StartsWith("completestage"))
|
|
{
|
|
if (selectedUser == 0)
|
|
{
|
|
Console.WriteLine("No user selected");
|
|
}
|
|
else
|
|
{
|
|
var user = JsonDb.Instance.Users.FirstOrDefault(x => x.ID == selectedUser);
|
|
if (user == null)
|
|
{
|
|
Console.WriteLine("Selected user does not exist");
|
|
selectedUser = 0;
|
|
prompt = "# ";
|
|
}
|
|
else
|
|
{
|
|
if (args.Length == 2)
|
|
{
|
|
var input2 = args[1];
|
|
try
|
|
{
|
|
var chapter = int.TryParse(input2.Split('-')[0], out int chapterNumber);
|
|
var stage = int.TryParse(input2.Split('-')[1], out int stageNumber);
|
|
|
|
if (chapter && stage)
|
|
{
|
|
for (int i = 0; i < chapterNumber + 1; i++)
|
|
{
|
|
var stages = GameData.Instance.GetStageIdsForChapter(i, true);
|
|
int target = 1;
|
|
foreach (var item in stages)
|
|
{
|
|
if (!user.IsStageCompleted(item, true))
|
|
{
|
|
Console.WriteLine("Completing stage " + item);
|
|
ClearStage.CompleteStage(user, item, true);
|
|
}
|
|
|
|
if (i == chapterNumber && target == stageNumber)
|
|
{
|
|
break;
|
|
}
|
|
|
|
target++;
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
Console.WriteLine("chapter and stage number must be a 32 bit integer");
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Console.WriteLine("exception:" + ex.ToString());
|
|
}
|
|
}
|
|
else
|
|
{
|
|
Console.WriteLine("invalid argument length, must be 1");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
else if (input == "exit")
|
|
{
|
|
Environment.Exit(0);
|
|
}
|
|
else if (input == "ban")
|
|
{
|
|
Console.WriteLine("Not implemented");
|
|
}
|
|
else if (input == "unban")
|
|
{
|
|
Console.WriteLine("Not implemented");
|
|
}
|
|
else
|
|
{
|
|
Console.WriteLine("Unknown command");
|
|
}
|
|
}
|
|
}
|
|
private static string LauncherEndpoint = Encoding.UTF8.GetString(Convert.FromBase64String("L25pa2tlX2xhdW5jaGVy"));
|
|
|
|
|
|
private static async Task HandleBatchRequests(HttpContext ctx)
|
|
{
|
|
var theBytes = await PacketDecryption.DecryptOrReturnContentAsync(ctx);
|
|
|
|
// this actually uses gzip compression, unlike other requests.
|
|
|
|
using MemoryStream streamforparser = new(theBytes.Contents);
|
|
StreamContent content = new(streamforparser);
|
|
content.Headers.Remove("Content-Type");
|
|
content.Headers.TryAddWithoutValidation("Content-Type", (string?)ctx.Request.Headers["Content-Type"]);
|
|
|
|
// we have the form contents,
|
|
var multipart = await content.ReadAsMultipartAsync();
|
|
|
|
HttpClient cl = new();
|
|
|
|
// TODO: the server returns different boundary each time, looks like a GUID
|
|
List<byte> response = [.. Encoding.UTF8.GetBytes("--f5d5cf4d-5627-422f-b3c6-532f1a0cbc0a\r\n")];
|
|
|
|
int i = 0;
|
|
foreach (var item in multipart.Contents)
|
|
{
|
|
i++;
|
|
response.AddRange(Encoding.UTF8.GetBytes("Content-Type: application/http\r\n"));
|
|
response.AddRange(Encoding.UTF8.GetBytes($"Content-ID: {item.Headers.NonValidated["Content-ID"]}\r\n"));
|
|
response.AddRange(Encoding.UTF8.GetBytes("\r\n"));
|
|
|
|
var bin = await item.ReadAsByteArrayAsync();
|
|
var res = await SendReqLocalAndReadResponseAsync(bin);
|
|
|
|
if (res != null)
|
|
{
|
|
List<byte> ResponseWithBytes =
|
|
[
|
|
.. Encoding.UTF8.GetBytes("HTTP/1.1 200 OK\r\n"),
|
|
.. Encoding.UTF8.GetBytes($"Content-Type: application/octet-stream+protobuf\r\n"),
|
|
.. Encoding.UTF8.GetBytes($"Content-Length: {res.Length}\r\n"),
|
|
.. Encoding.UTF8.GetBytes($"\r\n"),
|
|
.. res,
|
|
];
|
|
response.AddRange([.. ResponseWithBytes]);
|
|
}
|
|
else
|
|
{
|
|
List<byte> ResponseWithBytes =
|
|
[ .. Encoding.UTF8.GetBytes("HTTP/1.1 404 Not Found\r\n"),
|
|
//.. Encoding.UTF8.GetBytes($"Content-Type: application/octet-stream+protobuf\r\n"),
|
|
.. Encoding.UTF8.GetBytes($"Content-Length: 0\r\n"),
|
|
.. Encoding.UTF8.GetBytes($"\r\n"),
|
|
];
|
|
}
|
|
|
|
// add boundary, also include http newline if there is binary content
|
|
|
|
if (i == multipart.Contents.Count)
|
|
response.AddRange(Encoding.UTF8.GetBytes("\r\n--f5d5cf4d-5627-422f-b3c6-532f1a0cbc0a--\r\n"));
|
|
else
|
|
response.AddRange(Encoding.UTF8.GetBytes("\r\n--f5d5cf4d-5627-422f-b3c6-532f1a0cbc0a\r\n"));
|
|
|
|
}
|
|
|
|
var responseBytes = response.ToArray();
|
|
ctx.Response.ContentType = "multipart/mixed; boundary=\"f5d5cf4d-5627-422f-b3c6-532f1a0cbc0a\"";
|
|
ctx.Response.Body.Write(responseBytes);
|
|
}
|
|
public static string GetCachePathForPath(string path)
|
|
{
|
|
return AppDomain.CurrentDomain.BaseDirectory + "cache/" + path;
|
|
}
|
|
private static (string key, string value) GetHeader(string line)
|
|
{
|
|
var pieces = line.Split([':'], 2);
|
|
|
|
return (pieces[0].Trim(), pieces[1].Trim());
|
|
}
|
|
private static async Task<byte[]?> SendReqLocalAndReadResponseAsync(byte[] bytes)
|
|
{
|
|
int line = 0;
|
|
var bodyStartStr = Encoding.UTF8.GetString(bytes);
|
|
|
|
string method;
|
|
string url = "";
|
|
string httpVer;
|
|
string authToken = "";
|
|
List<NameValueHeaderValue> headers = [];
|
|
|
|
int currentByte = 0;
|
|
|
|
foreach (var item in bodyStartStr.Split("\r\n"))
|
|
{
|
|
if (line == 0)
|
|
{
|
|
var parts = item.Split(" ");
|
|
method = parts[0];
|
|
url = parts[1];
|
|
httpVer = parts[2];
|
|
}
|
|
else if (item == null || string.IsNullOrEmpty(item))
|
|
{
|
|
currentByte += 2;
|
|
break;
|
|
}
|
|
else
|
|
{
|
|
var (key, value) = GetHeader(item);
|
|
headers.Add(new NameValueHeaderValue(key, value));
|
|
|
|
if (key == "Authorization")
|
|
{
|
|
authToken = value.Replace("Bearer ", "");
|
|
}
|
|
}
|
|
currentByte += 2 + item.Length;
|
|
line++;
|
|
}
|
|
byte[] body;
|
|
if (currentByte == bytes.Length)
|
|
{
|
|
// empty body
|
|
body = [];
|
|
}
|
|
else
|
|
{
|
|
body = bytes.Skip(currentByte).ToArray();
|
|
}
|
|
|
|
if (!url.StartsWith("/v1/"))
|
|
{
|
|
throw new NotImplementedException("handler for " + url + " not implemented");
|
|
}
|
|
|
|
url = url.Replace("/v1", "");
|
|
|
|
// find appropriate handler
|
|
Console.WriteLine("BATCH: /v1" + url);
|
|
|
|
foreach (var item in LobbyHandler.Handlers)
|
|
{
|
|
if (item.Key == url)
|
|
{
|
|
item.Value.Reset();
|
|
item.Value.Contents = body;
|
|
await item.Value.HandleAsync(authToken);
|
|
return item.Value.ReturnBytes;
|
|
}
|
|
}
|
|
Console.WriteLine("HANDLER NOT FOUND: " + url);
|
|
return null;
|
|
}
|
|
}
|
|
}
|