mirror of
https://github.com/chylex/Minecraft-Phantom-Panel.git
synced 2024-10-17 03:42:50 +02:00
87 lines
3.5 KiB
C#
87 lines
3.5 KiB
C#
using Phantom.Agent.Minecraft.Instance;
|
|
using Phantom.Agent.Minecraft.Launcher;
|
|
using Phantom.Agent.Minecraft.Server;
|
|
using Phantom.Common.Data;
|
|
using Phantom.Common.Data.Instance;
|
|
|
|
namespace Phantom.Agent.Services.Instances.State;
|
|
|
|
static class InstanceLaunchProcedure {
|
|
public static async Task<InstanceRunningState?> Run(InstanceContext context, InstanceConfiguration configuration, IServerLauncher launcher, InstanceTicketManager ticketManager, InstanceTicketManager.Ticket ticket, Action<IInstanceStatus> reportStatus, CancellationToken cancellationToken) {
|
|
context.Logger.Information("Session starting...");
|
|
|
|
Result<InstanceProcess, InstanceLaunchFailReason> result;
|
|
|
|
if (ticketManager.IsValid(ticket)) {
|
|
try {
|
|
result = await LaunchInstance(context, launcher, reportStatus, cancellationToken);
|
|
} catch (OperationCanceledException) {
|
|
reportStatus(InstanceStatus.NotRunning);
|
|
return null;
|
|
} catch (Exception e) {
|
|
context.Logger.Error(e, "Caught exception while launching instance.");
|
|
result = InstanceLaunchFailReason.UnknownError;
|
|
}
|
|
}
|
|
else {
|
|
context.Logger.Error("Attempted to launch instance with an invalid ticket!");
|
|
result = InstanceLaunchFailReason.UnknownError;
|
|
}
|
|
|
|
if (result) {
|
|
reportStatus(InstanceStatus.Running);
|
|
context.ReportEvent(InstanceEvent.LaunchSucceeded);
|
|
return new InstanceRunningState(context, configuration, launcher, ticket, result.Value, cancellationToken);
|
|
}
|
|
else {
|
|
reportStatus(InstanceStatus.Failed(result.Error));
|
|
context.ReportEvent(new InstanceLaunchFailedEvent(result.Error));
|
|
return null;
|
|
}
|
|
}
|
|
|
|
private static async Task<Result<InstanceProcess, InstanceLaunchFailReason>> LaunchInstance(InstanceContext context, IServerLauncher launcher, Action<IInstanceStatus> reportStatus, CancellationToken cancellationToken) {
|
|
cancellationToken.ThrowIfCancellationRequested();
|
|
|
|
byte lastDownloadProgress = byte.MaxValue;
|
|
|
|
void OnDownloadProgress(object? sender, DownloadProgressEventArgs args) {
|
|
byte progress = (byte) Math.Min(args.DownloadedBytes * 100 / args.TotalBytes, 100);
|
|
|
|
if (lastDownloadProgress != progress) {
|
|
lastDownloadProgress = progress;
|
|
reportStatus(InstanceStatus.Downloading(progress));
|
|
}
|
|
}
|
|
|
|
switch (await launcher.Launch(context.Logger, context.Services.LaunchServices, OnDownloadProgress, cancellationToken)) {
|
|
case LaunchResult.Success launchSuccess:
|
|
return launchSuccess.Process;
|
|
|
|
case LaunchResult.InvalidJavaRuntime:
|
|
context.Logger.Error("Session failed to launch, invalid Java runtime.");
|
|
return InstanceLaunchFailReason.JavaRuntimeNotFound;
|
|
|
|
case LaunchResult.CouldNotDownloadMinecraftServer:
|
|
context.Logger.Error("Session failed to launch, could not download Minecraft server.");
|
|
return InstanceLaunchFailReason.CouldNotDownloadMinecraftServer;
|
|
|
|
case LaunchResult.CouldNotPrepareMinecraftServerLauncher:
|
|
context.Logger.Error("Session failed to launch, could not prepare Minecraft server launcher.");
|
|
return InstanceLaunchFailReason.CouldNotPrepareMinecraftServerLauncher;
|
|
|
|
case LaunchResult.CouldNotConfigureMinecraftServer:
|
|
context.Logger.Error("Session failed to launch, could not configure Minecraft server.");
|
|
return InstanceLaunchFailReason.CouldNotConfigureMinecraftServer;
|
|
|
|
case LaunchResult.CouldNotStartMinecraftServer:
|
|
context.Logger.Error("Session failed to launch, could not start Minecraft server.");
|
|
return InstanceLaunchFailReason.CouldNotStartMinecraftServer;
|
|
|
|
default:
|
|
context.Logger.Error("Session failed to launch.");
|
|
return InstanceLaunchFailReason.UnknownError;
|
|
}
|
|
}
|
|
}
|