nlansing/DedicatedServerCourse
Template
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Lesson 55 working properly now

Browse Source
This commit is contained in:
Norman Lansing
2026-03-26 21:07:11 -04:00
parent 241b78fa4a
commit f093212884
28 changed files with 65618 additions and 529 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
Source/DedicatedServers/DedicatedServers.build.cs
View File

@@ -1,16 +1,18 @@
using UnrealBuildTool;
using System.IO;
public class DedicatedServers : ModuleRules
{
public DedicatedServers(ReadOnlyTargetRules Target) : base(Target)
{
PCHUsage = PCHUsageMode.UseExplicitOrSharedPCHs;
PublicDependencyModuleNames.AddRange(new string[]
{
"Core",
"CoreUObject",
"Engine",
"OpenSSL",
});
PrivateDependencyModuleNames.AddRange(new string[]
@@ -23,7 +25,7 @@ public class DedicatedServers : ModuleRules
if (Target.Type == TargetType.Server)
{
PublicDependencyModuleNames.Add("GameLiftServerSDK");
PublicDependencyModuleNames.Add("GameLiftServerSDK");
}
else
{

0
Source/DedicatedServers/Private/DedicatedServersModule.cpp
View File

155
Source/FPSTemplate/Private/Game/ShooterGameMode.cpp → Source/DedicatedServers/Private/Game/DS_GameMode.cpp
View File

@@ -1,29 +1,23 @@
// Fill out your copyright notice in the Description page of Project Settings.
#include "Game/ShooterGameMode.h"
#include "GenericPlatform/GenericPlatformMisc.h"
#include "Containers/UnrealString.h"
#include "GameLiftClpTypes.h"
#include "GameLift/GameLiftClp.h"
#include "Game/DS_GameMode.h"
#include "GameLiftClp.h"
#include "openssl/sha.h"
#include "Game/GameLift/GameLiftClpTypes.h"
#if WITH_GAMELIFT
#include "GameLiftServerSDK.h"
#endif
DEFINE_LOG_CATEGORY(LogShooterGameMode);
DEFINE_LOG_CATEGORY(LogDS_GameMode);
// Function implementations.
AShooterGameMode::AShooterGameMode()
{
}
void AShooterGameMode::BeginPlay()
void ADS_GameMode::BeginPlay()
{
Super::BeginPlay();
#if WITH_GAMELIFT
if ((GameLiftConfig.bIsAnywhereFleet && GameLiftConfig.bAllOptionsFound) ||
!GameLiftConfig.bIsAnywhereFleet)
{
@@ -31,41 +25,42 @@ void AShooterGameMode::BeginPlay()
}
else
{
{
UE_LOG(LogShooterGameMode, Error, TEXT("GameLift Anywhere fleet missing required options. Exiting."));
FGenericPlatformMisc::RequestExit(false);
}
UE_LOG(LogDS_GameMode, Error, TEXT("GameLift Anywhere fleet missing required options. Exiting."));
FGenericPlatformMisc::RequestExit(false);
}
#endif
}
void AShooterGameMode::InitGame(const FString& MapName, const FString& Options, FString& ErrorMessage)
void ADS_GameMode::InitGame(const FString& MapName, const FString& Options, FString& ErrorMessage)
{
Super::InitGame(MapName, Options, ErrorMessage);
#if WITH_GAMELIFT
CachedCommandLine = FCommandLine::Get();
const FPortResult PortResult = cmdlineparser::details::GetConfiguredOrDefaultPort(CachedCommandLine, TEXT("port"));;
if (PortResult.bUsedDefaultPort)
{
UE_LOGFMT (LogShooterGameMode, Warning, "{0}", PortResult.WarningMessage);
UE_LOGFMT (LogDS_GameMode, Warning, "{0}", PortResult.WarningMessage);
}
GameLiftConfig.ServerPort = PortResult.Port;
if (FParse::Param(*CachedCommandLine, TEXT("glAnywhereFleet")))
{
UE_LOGFMT(LogShooterGameMode, Log, "Fleet type: Anywhere");
UE_LOGFMT(LogDS_GameMode, Log, "Fleet type: Anywhere");
GameLiftConfig.bIsAnywhereFleet = true;
GameLiftConfig.bAllOptionsFound = GetAnywhereFleetParameters(CachedCommandLine);
LogAnywhereFleetParameters();
}
else
{
UE_LOGFMT(LogShooterGameMode, Log, "Fleet type: EC2");
UE_LOGFMT(LogDS_GameMode, Log, "Fleet type: EC2");
// TODO: EC2 configuration
}
#endif
}
FString AShooterGameMode::GetSHA256Hash(const FString& InString)
FString ADS_GameMode::GetSHA256Hash(const FString& InString)
{
if (InString.IsEmpty())
@@ -88,16 +83,16 @@ FString AShooterGameMode::GetSHA256Hash(const FString& InString)
return Hash.ToString();
}
void AShooterGameMode::InitGameLift()
void ADS_GameMode::InitGameLift()
{
#if WITH_GAMELIFT
UE_LOGFMT(LogShooterGameMode, Log, "Calling InitGameLift...");
UE_LOGFMT(LogDS_GameMode, Log, "Calling InitGameLift...");
// Get the module first
FGameLiftServerSDKModule* GameLiftSdkModule = &FModuleManager::LoadModuleChecked<FGameLiftServerSDKModule>("GameLiftServerSDK");
FGameLiftGenericOutcome InitSdkOutcome;
UE_LOGFMT(LogShooterGameMode, Log, "Initializing the GameLift Server...");
UE_LOGFMT(LogDS_GameMode, Log, "Initializing the GameLift Server...");
if (GameLiftConfig.bIsAnywhereFleet)
{
// Define the server parameters for an Anywhere fleet. These are not needed for a GameLift managed EC2 fleet.
@@ -106,7 +101,7 @@ void AShooterGameMode::InitGameLift()
uint32 PID = FPlatformProcess::GetCurrentProcessId();
FString PIDString = FString::FromInt(static_cast<int32>(PID));
UE_LOGFMT(LogShooterGameMode, Log, "Configuring server parameters for Anywhere...");
UE_LOGFMT(LogDS_GameMode, Log, "Configuring server parameters for Anywhere...");
// If AnywhereFleets are being used load the command line arguments parsed earlier.
ServerParametersForAnywhere.m_webSocketUrl = TCHAR_TO_UTF8(*GameLiftConfig.WebSocketUrlResult.Value);
ServerParametersForAnywhere.m_fleetId = TCHAR_TO_UTF8((*GameLiftConfig.FleetIdResult.Value));
@@ -125,17 +120,17 @@ void AShooterGameMode::InitGameLift()
if (InitSdkOutcome.IsSuccess())
{
UE_LOG(LogShooterGameMode, SetColor, TEXT("%s"), COLOR_GREEN);
UE_LOG(LogShooterGameMode, Log, TEXT("GameLift InitSDK succeeded!"));
UE_LOG(LogShooterGameMode, SetColor, TEXT("%s"), COLOR_NONE);
UE_LOG(LogDS_GameMode, SetColor, TEXT("%s"), COLOR_GREEN);
UE_LOG(LogDS_GameMode, Log, TEXT("GameLift InitSDK succeeded!"));
UE_LOG(LogDS_GameMode, SetColor, TEXT("%s"), COLOR_NONE);
}
else
{
UE_LOG(LogShooterGameMode, SetColor, TEXT("%s"), COLOR_RED);
UE_LOG(LogShooterGameMode, Log, TEXT("ERROR: InitSDK failed : ("));
UE_LOG(LogDS_GameMode, SetColor, TEXT("%s"), COLOR_RED);
UE_LOG(LogDS_GameMode, Log, TEXT("ERROR: InitSDK failed : ("));
FGameLiftError GameLiftError = InitSdkOutcome.GetError();
UE_LOG(LogShooterGameMode, Log, TEXT("ERROR: %s"), *GameLiftError.m_errorMessage);
UE_LOG(LogShooterGameMode, SetColor, TEXT("%s"), COLOR_NONE);
UE_LOG(LogDS_GameMode, Log, TEXT("ERROR: %s"), *GameLiftError.m_errorMessage);
UE_LOG(LogDS_GameMode, SetColor, TEXT("%s"), COLOR_NONE);
return;
}
@@ -147,7 +142,7 @@ void AShooterGameMode::InitGameLift()
ProcessParameters->OnStartGameSession.BindLambda([=](Aws::GameLift::Server::Model::GameSession InGameSession)
{
const FString GameSessionId = FString(InGameSession.GetGameSessionId());
UE_LOG(LogShooterGameMode, Log, TEXT("GameSession Initializing: %s"), *GameSessionId);
UE_LOG(LogDS_GameMode, Log, TEXT("GameSession Initializing: %s"), *GameSessionId);
GameLiftSdkModule->ActivateGameSession();
});
@@ -156,24 +151,24 @@ void AShooterGameMode::InitGameLift()
//In this case, we simply tell Amazon GameLift Servers we are indeed going to shut down.
ProcessParameters->OnTerminate.BindLambda([=]()
{
UE_LOG(LogShooterGameMode, Log, TEXT("Game Server Process is terminating"));
UE_LOG(LogDS_GameMode, Log, TEXT("Game Server Process is terminating"));
// First call ProcessEnding()
FGameLiftGenericOutcome processEndingOutcome = GameLiftSdkModule->ProcessEnding();
// Then call Destroy() to free the SDK from memory
FGameLiftGenericOutcome destroyOutcome = GameLiftSdkModule->Destroy();
// Exit the process with success or failure
if (processEndingOutcome.IsSuccess() && destroyOutcome.IsSuccess()) {
UE_LOG(LogShooterGameMode, Log, TEXT("Server process ending successfully"));
UE_LOG(LogDS_GameMode, Log, TEXT("Server process ending successfully"));
}
else {
if (!processEndingOutcome.IsSuccess()) {
const FGameLiftError& error = processEndingOutcome.GetError();
UE_LOG(LogShooterGameMode, Error, TEXT("ProcessEnding() failed. Error: %s"),
UE_LOG(LogDS_GameMode, Error, TEXT("ProcessEnding() failed. Error: %s"),
error.m_errorMessage.IsEmpty() ? TEXT("Unknown error") : *error.m_errorMessage);
}
if (!destroyOutcome.IsSuccess()) {
const FGameLiftError& error = destroyOutcome.GetError();
UE_LOG(LogShooterGameMode, Error, TEXT("Destroy() failed. Error: %s"),
UE_LOG(LogDS_GameMode, Error, TEXT("Destroy() failed. Error: %s"),
error.m_errorMessage.IsEmpty() ? TEXT("Unknown error") : *error.m_errorMessage);
}
}
@@ -189,7 +184,7 @@ void AShooterGameMode::InitGameLift()
//In this case, we're always healthy!
ProcessParameters->OnHealthCheck.BindLambda([]()
{
UE_LOG(LogShooterGameMode, Log, TEXT("Performing Health Check"));
UE_LOG(LogDS_GameMode, Log, TEXT("Performing Health Check"));
return true;
});
@@ -199,32 +194,33 @@ void AShooterGameMode::InitGameLift()
Logfiles.Add(TEXT("FPSTemplate/Saved/Log/server.log"));
ProcessParameters->logParameters = Logfiles;
UE_LOGFMT(LogShooterGameMode, Log, "Calling Process Ready...");
UE_LOGFMT(LogDS_GameMode, Log, "Calling Process Ready...");
FGameLiftGenericOutcome ProcessReadyOutcome = GameLiftSdkModule->ProcessReady(*ProcessParameters);
if (ProcessReadyOutcome.IsSuccess())
{
UE_LOG(LogShooterGameMode, SetColor, TEXT("%s"), COLOR_GREEN);
UE_LOG(LogShooterGameMode, Log, TEXT("Process Ready!"));
UE_LOG(LogShooterGameMode, SetColor, TEXT("%s"), COLOR_NONE);
UE_LOG(LogDS_GameMode, SetColor, TEXT("%s"), COLOR_GREEN);
UE_LOG(LogDS_GameMode, Log, TEXT("Process Ready!"));
UE_LOG(LogDS_GameMode, SetColor, TEXT("%s"), COLOR_NONE);
}
else
{
UE_LOG(LogShooterGameMode, SetColor, TEXT("%s"), COLOR_RED);
UE_LOG(LogShooterGameMode, Log, TEXT("ERROR: Process Ready Failed!"));
UE_LOG(LogDS_GameMode, SetColor, TEXT("%s"), COLOR_RED);
UE_LOG(LogDS_GameMode, Log, TEXT("ERROR: Process Ready Failed!"));
FGameLiftError ProcessReadyError = ProcessReadyOutcome.GetError();
UE_LOG(LogShooterGameMode, Log, TEXT("ERROR: %s"), *ProcessReadyError.m_errorMessage);
UE_LOG(LogShooterGameMode, SetColor, TEXT("%s"), COLOR_NONE);
UE_LOG(LogDS_GameMode, Log, TEXT("ERROR: %s"), *ProcessReadyError.m_errorMessage);
UE_LOG(LogDS_GameMode, SetColor, TEXT("%s"), COLOR_NONE);
return;
}
UE_LOGFMT(LogShooterGameMode, Log, "InitGameLift completed!");
UE_LOGFMT(LogDS_GameMode, Log, "InitGameLift completed!");
#endif
}
bool AShooterGameMode::GetAnywhereFleetParameters(const FString& CommandLineString)
bool ADS_GameMode::GetAnywhereFleetParameters(const FString& CommandLineString)
{
#if WITH_GAMELIFT
bool bAllAnywhereFleetParametersValid = true;
GameLiftConfig.AuthTokenResult = cmdlineparser::GetValueOfToken(CommandLineString, cmdlineparser::details::EAvailableTokens::AuthToken);
if (!GameLiftConfig.AuthTokenResult.bIsValid) bAllAnywhereFleetParametersValid = false;
@@ -239,25 +235,29 @@ bool AShooterGameMode::GetAnywhereFleetParameters(const FString& CommandLineStri
if (!GameLiftConfig.WebSocketUrlResult.bIsValid) bAllAnywhereFleetParametersValid = false;
return bAllAnywhereFleetParametersValid;
#else
return false;
#endif
}
void AShooterGameMode::LogAnywhereFleetParameters()
void ADS_GameMode::LogAnywhereFleetParameters()
{
// Lambda for getting the token name from token
auto GetTokenName = [](const cmdlineparser::details::FParseResult& Result) -> FString
{
return cmdlineparser::details::CLI_TOKENS[static_cast<int32>(Result.Token)];
return cmdlineparser::details::CLI_TOKENS.FindRef(Result.Token);
};
UE_LOGFMT(LogShooterGameMode, Log, "Anywhere Fleet Parameters:");
UE_LOGFMT(LogDS_GameMode, Log, "Anywhere Fleet Parameters:");
if (GameLiftConfig.AuthTokenResult.bIsValid)
{
UE_LOGFMT(LogShooterGameMode, Log, "AuthToken: {0}", GetValueOrHash(GameLiftConfig.AuthTokenResult.Value));
UE_LOGFMT(LogDS_GameMode, Log, "AuthToken: {0}", GetValueOrHash(GameLiftConfig.AuthTokenResult.Value));
}
else
{
UE_LOGFMT(
LogShooterGameMode,
LogDS_GameMode,
Error,
"AuthToken: {0}",
FString::Format(
@@ -272,12 +272,12 @@ void AShooterGameMode::LogAnywhereFleetParameters()
if (GameLiftConfig.FleetIdResult.bIsValid)
{
UE_LOGFMT(LogShooterGameMode, Log, "FleetId: {0}", GameLiftConfig.FleetIdResult.Value);
UE_LOGFMT(LogDS_GameMode, Log, "FleetId: {0}", GameLiftConfig.FleetIdResult.Value);
}
else
{
UE_LOGFMT(
LogShooterGameMode,
LogDS_GameMode,
Error,
"FleetId: {0}",
FString::Format(
@@ -292,12 +292,12 @@ void AShooterGameMode::LogAnywhereFleetParameters()
if (GameLiftConfig.HostIdResult.bIsValid)
{
UE_LOGFMT(LogShooterGameMode, Log, "HostId: {0}", GameLiftConfig.HostIdResult.Value);
UE_LOGFMT(LogDS_GameMode, Log, "HostId: {0}", GameLiftConfig.HostIdResult.Value);
}
else
{
UE_LOGFMT(
LogShooterGameMode,
LogDS_GameMode,
Error,
"HostId: {0}",
FString::Format(
@@ -312,12 +312,12 @@ void AShooterGameMode::LogAnywhereFleetParameters()
if (GameLiftConfig.WebSocketUrlResult.bIsValid)
{
UE_LOGFMT(LogShooterGameMode, Log, "WebSocketUrl: {0}", GameLiftConfig.WebSocketUrlResult.Value);
UE_LOGFMT(LogDS_GameMode, Log, "WebSocketUrl: {0}", GameLiftConfig.WebSocketUrlResult.Value);
}
else
{
UE_LOGFMT(
LogShooterGameMode,
LogDS_GameMode,
Error,
"WebSocketUrl: {0}",
FString::Format(
@@ -330,53 +330,52 @@ void AShooterGameMode::LogAnywhereFleetParameters()
);
}
UE_LOGFMT(LogShooterGameMode, Log, "Server Port: {0}", GameLiftConfig.ServerPort);
UE_LOGFMT(LogDS_GameMode, Log, "Server Port: {0}", GameLiftConfig.ServerPort);
if (GameLiftConfig.bAllOptionsFound)
{
UE_LOGFMT(LogShooterGameMode, Log, "Anywhere Fleet Parameters Loaded Successfully....");
UE_LOGFMT(LogDS_GameMode, Log, "Anywhere Fleet Parameters Loaded Successfully....");
}
else
{
UE_LOGFMT(LogShooterGameMode, Error, "Anywhere Fleet Parameters Load FAILED....");
UE_LOGFMT(LogDS_GameMode, Error, "Anywhere Fleet Parameters Load FAILED....");
}
}
#if WITH_GAMELIFT
void AShooterGameMode::LogServerParameters(const FServerParameters& InServerParameters)
void ADS_GameMode::LogServerParameters(const FServerParameters& InServerParameters)
{
UE_LOGFMT(LogShooterGameMode, Log, ">>>> WebSocket URL: {WebSocketUrl}", InServerParameters.m_webSocketUrl);
UE_LOGFMT(LogShooterGameMode, Log, ">>>> Fleet ID: {FleetId}", InServerParameters.m_fleetId);
UE_LOGFMT(LogShooterGameMode, Log, ">>>> Process ID: {ProcessId}", InServerParameters.m_processId);
UE_LOGFMT(LogShooterGameMode, Log, ">>>> Host ID (Compute Name): {HostId}", InServerParameters.m_hostId);
UE_LOGFMT(LogShooterGameMode, Log, ">>>> Auth Token: {AuthToken}", GetValueOrHash(InServerParameters.m_authToken));
#if WITH_GAMELIFT
UE_LOGFMT(LogDS_GameMode, Log, ">>>> WebSocket URL: {WebSocketUrl}", InServerParameters.m_webSocketUrl);
UE_LOGFMT(LogDS_GameMode, Log, ">>>> Fleet ID: {FleetId}", InServerParameters.m_fleetId);
UE_LOGFMT(LogDS_GameMode, Log, ">>>> Process ID: {ProcessId}", InServerParameters.m_processId);
UE_LOGFMT(LogDS_GameMode, Log, ">>>> Host ID (Compute Name): {HostId}", InServerParameters.m_hostId);
UE_LOGFMT(LogDS_GameMode, Log, ">>>> Auth Token: {AuthToken}", GetValueOrHash(InServerParameters.m_authToken));
if (!InServerParameters.m_awsRegion.IsEmpty())
{
UE_LOGFMT(LogShooterGameMode, Log, ">>>> Aws Region: {AwsRegion}", InServerParameters.m_awsRegion);
UE_LOGFMT(LogDS_GameMode, Log, ">>>> Aws Region: {AwsRegion}", InServerParameters.m_awsRegion);
}
if (!InServerParameters.m_accessKey.IsEmpty())
{
UE_LOGFMT(LogShooterGameMode, Log, ">>>> Access Key: {AccessKey}", GetValueOrHash(InServerParameters.m_accessKey));
UE_LOGFMT(LogDS_GameMode, Log, ">>>> Access Key: {AccessKey}", GetValueOrHash(InServerParameters.m_accessKey));
}
if (!InServerParameters.m_secretKey.IsEmpty())
{
UE_LOGFMT(LogShooterGameMode, Log, ">>>> Secret Key: {SecretKey}", GetValueOrHash(InServerParameters.m_secretKey));
UE_LOGFMT(LogDS_GameMode, Log, ">>>> Secret Key: {SecretKey}", GetValueOrHash(InServerParameters.m_secretKey));
}
if (!InServerParameters.m_sessionToken.IsEmpty())
{
UE_LOGFMT(LogShooterGameMode, Log, ">>>> Session Token: {SessionToken}", GetValueOrHash(InServerParameters.m_sessionToken));
UE_LOGFMT(LogDS_GameMode, Log, ">>>> Session Token: {SessionToken}", GetValueOrHash(InServerParameters.m_sessionToken));
}
#endif
}
#endif
FString AShooterGameMode::GetValueOrHash(const FString& Value)
FString ADS_GameMode::GetValueOrHash(const FString& Value)
{
#if UE_BUILD_DEBUG || UE_BUILD_DEVELOPMENT
return Value;

108
Source/DedicatedServers/Private/Game/GameLift/GameLiftClp.cpp Normal file
View File

@@ -0,0 +1,108 @@
#include "GameLiftClp.h"
namespace cmdlineparser
{
FPortResult cmdlineparser::GetConfiguredOrDefaultPort(const FString& Token)
{
return details::GetConfiguredOrDefaultPort(FCommandLine::Get(), Token);
}
FPortResult cmdlineparser::GetConfiguredOrDefaultPort(const FString& CommandLine, const FString& Token)
{
return details::GetConfiguredOrDefaultPort(CommandLine, Token);
}
details::FParseResult cmdlineparser::GetValueOfToken(const FString& CommandLine, const details::EAvailableTokens Token)
{
details::FParseResult Result;
FString ValueOfToken;
Result.Token = Token;
ensure(Token != details::EAvailableTokens::Unknown);
const bool bTokenFound = FParse::Value(
*CommandLine,
*details::EnsureEndsWith(details::CLI_TOKENS.FindRef(Token), TEXT("=")),
ValueOfToken
);
if (!bTokenFound)
{
Result.Value = FString();
Result.ErrorCode = details::EErrorCodes::TokenNotFound;
Result.bIsValid = false;
}
else
{
if (ValueOfToken.IsEmpty())
{
Result.Value = FString();
Result.ErrorCode = details::EErrorCodes::ValueEmpty;
Result.bIsValid = false;
}
else
{
if (details::DoesRegExMatch(ValueOfToken, details::REGEX_PATTERNS.FindRef(Token)))
{
Result.ErrorCode = details::EErrorCodes::NoError;
Result.bIsValid = true;
}
else
{
Result.ErrorCode = details::EErrorCodes::FailedValidation;
Result.bIsValid = false;
}
Result.Value = ValueOfToken;
}
}
ensure(Result.ErrorCode < details::EErrorCodes::MaxCode);
FString ErrorMessage = details::ERROR_MESSAGES.FindRef(Result.ErrorCode);
FString TokenName = details::CLI_TOKENS.FindRef(Result.Token);
FString Value = Result.Value;
Result.ErrorMessage = ErrorMessage;
return Result;
}
// cmdlineparser::Details namespace
namespace details
{
FString details::EnsureEndsWith(const FString& Token, const TCHAR* Suffix)
{
return Token.EndsWith(Suffix) ? Token : Token + Suffix;
}
FPortResult details::GetConfiguredOrDefaultPort(const FString& CommandLine, const FString& Token)
{
FPortResult PortResult;
PortResult.Port = FURL::UrlConfig.DefaultPort;
if (int32 CliPort; FParse::Value(*CommandLine, *EnsureEndsWith(Token, TEXT("=")), CliPort))
{
if (CliPort >= details::MIN_PORT && CliPort <= details::MAX_PORT)
{
PortResult.Port = CliPort;
PortResult.bUsedDefaultPort = false;
PortResult.WarningMessage = FString();
return PortResult;
}
PortResult.bUsedDefaultPort = true;
PortResult.WarningMessage = FString::Printf(TEXT("Command Line Option for Port is out of ranged... Using Default Port %d"), PortResult.Port);
return PortResult;
}
PortResult.bUsedDefaultPort = true;
PortResult.WarningMessage = FString::Printf(TEXT("Command Line Option for Port not found... Using Default Port %d"), PortResult.Port);
return PortResult;
}
bool details::DoesRegExMatch(const FString& Text, const FString& Pattern)
{
const FRegexPattern RegexPattern(Pattern);
FRegexMatcher Matcher(RegexPattern, Text);
return Matcher.FindNext();
}
}
}

35
Source/FPSTemplate/Public/Game/ShooterGameMode.h → Source/DedicatedServers/Public/Game/DS_GameMode.h
View File

@@ -2,15 +2,15 @@
#pragma once
#include "CoreMinimal.h"
#include "GameLiftClpTypes.h"
#include "ShooterGameModeBase.h"
#include "ShooterGameMode.generated.h"
DECLARE_LOG_CATEGORY_EXTERN(LogShooterGameMode, Log, All);
struct FProcessParameters;
struct FServerParameters;
struct FProcessParameters;
#include "CoreMinimal.h"
#include "GameFramework/GameMode.h"
#include "Game/GameLift/GameLiftClpTypes.h"
#include "DS_GameMode.generated.h"
DECLARE_LOG_CATEGORY_EXTERN(LogDS_GameMode, Log, All);
struct FGameLiftConfig
{
@@ -25,34 +25,31 @@ struct FGameLiftConfig
cmdlineparser::details::FParseResult WebSocketUrlResult;
};
/**
*
*/
UCLASS()
class FPSTEMPLATE_API AShooterGameMode : public AShooterGameModeBase
class DEDICATEDSERVERS_API ADS_GameMode : public AGameMode
{
GENERATED_BODY()
public:
AShooterGameMode();
public:
protected:
virtual void BeginPlay() override;
virtual void InitGame(const FString& MapName, const FString& Options, FString& ErrorMessage) override;
private:
FGameLiftConfig GameLiftConfig;
FString CachedCommandLine;
static FString GetSHA256Hash(const FString& CommandLineString);
static FString GetSHA256Hash(const FString& InString);
void InitGameLift();
bool GetAnywhereFleetParameters(const FString& CommandLineString);
void LogAnywhereFleetParameters();
#if WITH_GAMELIFT
static void LogServerParameters(const FServerParameters& InServerParameters);
#endif
static FString GetValueOrHash(const FString& Value);
TSharedPtr<FProcessParameters> ProcessParameters;
static void LogServerParameters(const FServerParameters& InServerParameters);
static FString GetValueOrHash(const FString& Value);
};

79
Source/DedicatedServers/Public/Game/GameLift/GameLiftClpTypes.h Normal file
View File

@@ -0,0 +1,79 @@
#pragma once
namespace cmdlineparser::details
{
enum EAvailableTokens
{
Unknown = 0,
AuthToken,
HostId,
FleetId,
WebsocketUrl,
MaxToken
};
enum EErrorCodes
{
NoError,
TokenNotFound,
ValueEmpty,
FailedValidation,
MaxCode
};
inline static const TMap<EErrorCodes, FString>& ERROR_MESSAGES = []() ->
const TMap<EErrorCodes, FString>&
{
static TMap<EErrorCodes, FString> Error_Messages =
{
{NoError,TEXT("VALID: {0}: {1}") },
{FailedValidation,TEXT("VALIDATION FAILED: [-{0}=] found.... Value: [{1}]") },
{TokenNotFound,TEXT("INVALID TOKEN: [-{0}=] not found in command line arguments") },
{ValueEmpty,TEXT("EMPTY VALUE: [-{0}=] found. No value assigned") },
};
return Error_Messages;
}();
inline static const TMap<EAvailableTokens, FString>& CLI_TOKENS = []() ->
const TMap<EAvailableTokens, FString>&
{
static TMap<EAvailableTokens, FString> Cli_Tokens =
{
{AuthToken, TEXT("authtoken") },
{FleetId, TEXT("fleetid") },
{HostId, TEXT("hostid") },
{Unknown, TEXT("unknown") },
{WebsocketUrl, TEXT("websocketurl") }
};
return Cli_Tokens;
}();
inline static const TMap<EAvailableTokens, FString>& REGEX_PATTERNS = []() ->
const TMap<EAvailableTokens, FString>&
{
static TMap<EAvailableTokens, FString> Regex_Patterns =
{
{Unknown,TEXT(".*") },
{AuthToken,TEXT("^[a-zA-Z0-9\\-]+$") },
{HostId,TEXT("^[a-zA-Z0-9][a-zA-Z0-9\\-]{0,62}[a-zA-Z0-9]?$") },
{FleetId,TEXT("^[a-z]*fleet-[a-zA-Z0-9\\-]+$|^arn:.*:[a-z]*fleet\\/[a-z]*fleet-[a-zA-Z0-9\\-]+$") },
{WebsocketUrl,TEXT("^wss://[a-z0-9-]+(\\.[a-z0-9-]+)*\\.api\\.amazongamelift\\.com(:[0-9]+)?/?$") },
};
return Regex_Patterns;
}();
// extern const TMap<EErrorCodes, FString>& ERROR_MESSAGES;
// extern const TMap<EAvailableTokens, FString>& CLI_TOKENS;
// extern const TMap<EAvailableTokens, FString>& REGEX_PATTERNS;
struct FParseResult
{
EAvailableTokens Token = EAvailableTokens::Unknown;
FString Value = FString();
bool bIsValid = false;
EErrorCodes ErrorCode = EErrorCodes::TokenNotFound;
FString ErrorMessage = FString();
};
}

29
Source/DedicatedServers/Public/GameLiftClp.h Normal file
View File

@@ -0,0 +1,29 @@
#pragma once
#include "Game/GameLift/GameLiftClpTypes.h"
#include "CoreMinimal.h"
struct FPortResult
{
int32 Port;
bool bUsedDefaultPort;
FString WarningMessage;
};
namespace cmdlineparser
{
FPortResult GetConfiguredOrDefaultPort(const FString& Token = TEXT("port="));
FPortResult GetConfiguredOrDefaultPort(const FString& CommandLine, const FString& Token = TEXT("port="));
details::FParseResult GetValueOfToken(const FString& CommandLine, const details::EAvailableTokens Token);
namespace details
{
inline static constexpr int32 MIN_PORT = 1024;
inline static constexpr int32 MAX_PORT = 65535;
inline const TCHAR* DEFAULT_PORT_TOKEN = TEXT("port=");
FString EnsureEndsWith(const FString& Token, const TCHAR* Suffix);
FPortResult GetConfiguredOrDefaultPort(const FString& CommandLine, const FString& Token);
bool DoesRegExMatch(const FString& Text, const FString& Pattern);
}
}

1
Source/FPSTemplate.Target.cs
View File

@@ -11,6 +11,5 @@ public class FPSTemplateTarget : TargetRules
DefaultBuildSettings = BuildSettingsVersion.V6;
IncludeOrderVersion = EngineIncludeOrderVersion.Unreal5_7;
ExtraModuleNames.Add("FPSTemplate");
ExtraModuleNames.Add("DedicatedServers");
}
}

14
Source/FPSTemplate/FPSTemplate.Build.cs
View File

@@ -19,6 +19,7 @@ public class FPSTemplate : ModuleRules
"EnhancedInput",
"PhysicsCore",
"OpenSSL",
"DedicatedServers"
});
PrivateDependencyModuleNames.AddRange(new string[]
@@ -29,19 +30,6 @@ public class FPSTemplate : ModuleRules
"OpenSSL",
});
// Adds in the plugin for GameLiftServerSDK if it is the server build.
if (Target.Type == TargetType.Server)
{
PublicDependencyModuleNames.Add("GameLiftServerSDK");
PublicDependencyModuleNames.Add("DedicatedServers");
}
else
{
PublicDefinitions.Add("WITH_GAMELIFT=0");
}
bEnableExceptions = true;
// Uncomment if you are using Slate UI
// PrivateDependencyModuleNames.AddRange(new string[] { "Slate", "SlateCore" });

100
Source/FPSTemplate/Private/GameLift/GameLiftClp.cpp
View File

@@ -1,100 +0,0 @@
#include "GameLift/GameLiftClp.h"
FPortResult cmdlineparser::GetConfiguredOrDefaultPort(const FString& Token)
{
return details::GetConfiguredOrDefaultPort(FCommandLine::Get(), Token);
}
FPortResult cmdlineparser::GetConfiguredOrDefaultPort(const FString& CommandLine, const FString& Token)
{
return details::GetConfiguredOrDefaultPort(CommandLine, Token);
}
cmdlineparser::details::FParseResult cmdlineparser::GetValueOfToken(const FString& CommandLine, const details::EAvailableTokens Token)
{
details::FParseResult Result;
FString ValueOfToken;
Result.Token = Token;
ensure(Token != details::EAvailableTokens::Unknown);
ensure(Token < details::EAvailableTokens::MaxToken);
const bool bTokenFound = FParse::Value(
*CommandLine,
*details::EnsureEndsWith(details::CLI_TOKENS[static_cast<int32>(Token)],
TEXT("=")),
ValueOfToken
);
if (!bTokenFound)
{
Result.Value = FString();
Result.ErrorCode = details::EErrorCodes::TokenNotFound;
Result.bIsValid = false;
}
else
{
if (ValueOfToken.IsEmpty())
{
Result.Value = FString();
Result.ErrorCode = details::EErrorCodes::ValueEmpty;
Result.bIsValid = false;
}
else
{
if (details::DoesRegExMatch(ValueOfToken, details::REGEX_PATTERNS[static_cast<int32>(Token)]))
{
Result.ErrorCode = details::EErrorCodes::NoError;
Result.bIsValid = true;
}
else
{
Result.ErrorCode = details::EErrorCodes::FailedValidation;
Result.bIsValid = false;
}
Result.Value = ValueOfToken;
}
}
ensure(Result.ErrorCode < details::EErrorCodes::MaxCode);
FString ErrorMessage = details::ERROR_MESSAGES[static_cast<int32>(Result.ErrorCode)];
FString TokenName = details::CLI_TOKENS[static_cast<int32>(Result.Token)];
FString Value = Result.Value;
Result.ErrorMessage = ErrorMessage;
return Result;
}
// cmdlineparser::Details namespace
FString cmdlineparser::details::EnsureEndsWith(const FString& Token, const TCHAR* Suffix)
{
return Token.EndsWith(Suffix) ? Token : Token + Suffix;
}
FPortResult cmdlineparser::details::GetConfiguredOrDefaultPort(const FString& CommandLine, const FString& Token)
{
FPortResult PortResult;
PortResult.Port = FURL::UrlConfig.DefaultPort;
if (int32 CliPort; FParse::Value(*CommandLine, *EnsureEndsWith(Token, TEXT("=")), CliPort))
{
if (CliPort >= details::MIN_PORT && CliPort <= details::MAX_PORT)
{
PortResult.Port = CliPort;
PortResult.bUsedDefaultPort = false;
PortResult.WarningMessage = FString();
return PortResult;
}
}
PortResult.bUsedDefaultPort = true;
PortResult.WarningMessage = FString::Printf(TEXT("Command Line Option for Port is out of ranged... Using Default Port %d"), PortResult.Port);
return PortResult;
}
bool cmdlineparser::details::DoesRegExMatch(const FString& Text, const FString& Pattern)
{
const FRegexPattern RegexPattern(Pattern);
FRegexMatcher Matcher(RegexPattern, Text);
return Matcher.FindNext();
}

34
Source/FPSTemplate/Private/GameLiftClpTypes.cpp
View File

@@ -1,34 +0,0 @@
#include "GameLiftClpTypes.h"
const TArray<FString>& cmdlineparser::details::ERROR_MESSAGES = []() -> const TArray<FString>&
{
static TArray<FString> Error_Messages;
Error_Messages.Add(TEXT("VALID: {0}: {1}"));
Error_Messages.Add(TEXT("INVALID TOKEN: [-{0}=] not found in command line arguments"));
Error_Messages.Add(TEXT("EMPTY VALUE: [-{0}=] found. No value assigned"));
Error_Messages.Add(TEXT("VALIDATION FAILED: [-{0}=] found.... Value: [{1}]"));
return Error_Messages;
}();
const TArray<FString>& cmdlineparser::details::CLI_TOKENS = []() -> const TArray<FString>&
{
static TArray<FString> Cli_Tokens;
Cli_Tokens.Add(TEXT("unknown")); // Unknown = 0;
Cli_Tokens.Add(TEXT("authtoken"));
Cli_Tokens.Add(TEXT("hostid"));
Cli_Tokens.Add(TEXT("fleetid"));
Cli_Tokens.Add(TEXT("websocketurl"));
return Cli_Tokens;
}();
const TArray<FString>& cmdlineparser::details::REGEX_PATTERNS = []() -> const TArray<FString>&
{
static TArray<FString> Cli_Tokens;
Cli_Tokens.Add(TEXT(".*")); // unknown = 0
Cli_Tokens.Add(TEXT("^[a-zA-Z0-9\\-]+$"));
Cli_Tokens.Add(TEXT("^[a-zA-Z0-9][a-zA-Z0-9\\-]{0,62}[a-zA-Z0-9]?$"));
Cli_Tokens.Add(TEXT("^[a-z]*fleet-[a-zA-Z0-9\\-]+$|^arn:.*:[a-z]*fleet\\/[a-z]*fleet-[a-zA-Z0-9\\-]+$"));
Cli_Tokens.Add(TEXT("^wss://[a-z0-9-]+(\\.[a-z0-9-]+)*\\.api\\.amazongamelift\\.com(:[0-9]+)?/?$"));
return Cli_Tokens;
}();

4
Source/FPSTemplate/Public/Game/ShooterGameModeBase.h
View File

@@ -3,14 +3,14 @@
#pragma once
#include "CoreMinimal.h"
#include "GameFramework/GameMode.h"
#include "DedicatedServers/Public/Game/DS_GameMode.h"
#include "ShooterGameModeBase.generated.h"
/**
*
*/
UCLASS()
class FPSTEMPLATE_API AShooterGameModeBase : public AGameMode
class FPSTEMPLATE_API AShooterGameModeBase : public ADS_GameMode
{
GENERATED_BODY()
public:

30
Source/FPSTemplate/Public/GameLift/GameLiftClp.h
View File

@@ -1,30 +0,0 @@
#pragma once
#include "GameLiftClpTypes.h"
#include "CoreMinimal.h"
struct FPortResult
{
int32 Port;
bool bUsedDefaultPort;
FString WarningMessage;
};
namespace cmdlineparser
{
FPortResult GetConfiguredOrDefaultPort(const FString& Token = TEXT("port="));
FPortResult GetConfiguredOrDefaultPort(const FString& CommandLine, const FString& Token = TEXT("port="));
details::FParseResult GetValueOfToken(const FString& CommandLine, const details::EAvailableTokens Token);
}
namespace cmdlineparser::details
{
inline static constexpr int32 MIN_PORT = 1024;
inline static constexpr int32 MAX_PORT = 65535;
inline static constexpr const TCHAR* DEFAULT_PORT_TOKEN = TEXT("port=");
FString EnsureEndsWith(const FString& Token, const TCHAR* Suffix);
FPortResult GetConfiguredOrDefaultPort(const FString& CommandLine, const FString& Token);
bool DoesRegExMatch(const FString& Text, const FString& Pattern);
}

37
Source/FPSTemplate/Public/GameLiftClpTypes.h
View File

@@ -1,37 +0,0 @@
#pragma once
namespace cmdlineparser::details
{
enum EAvailableTokens
{
Unknown = 0,
AuthToken,
HostId,
FleetId,
WebsocketUrl,
MaxToken
};
enum EErrorCodes
{
NoError,
TokenNotFound,
ValueEmpty,
FailedValidation,
MaxCode
};
extern const TArray<FString>& ERROR_MESSAGES;
extern const TArray<FString>& CLI_TOKENS;
extern const TArray<FString>& REGEX_PATTERNS;
struct FParseResult
{
EAvailableTokens Token = EAvailableTokens::Unknown;
FString Value = FString();
bool bIsValid = false;
EErrorCodes ErrorCode = EErrorCodes::TokenNotFound;
FString ErrorMessage = FString();
};
}

1
Source/FPSTemplateClient.Target.cs
View File

@@ -11,6 +11,5 @@ public class FPSTemplateClientTarget : TargetRules
DefaultBuildSettings = BuildSettingsVersion.V6;
IncludeOrderVersion = EngineIncludeOrderVersion.Unreal5_7;
ExtraModuleNames.Add("FPSTemplate");
ExtraModuleNames.Add("DedicatedServers");
}
}