feat: unreal specific ecsact plugin + starting on ecsact runner (#11)

depends on ecsact-dev/ecsact_cli#120
depends on ecsact-dev/ecsact_codegen#53

Author: zaucy

.clang-tidy

@@ -0,0 +1,2 @@
+---
+Checks: 'clang-diagnostic-*,clang-analyzer-*,cppcoreguidelines-*,modernize-*,-modernize-use-trailing-return-type'

.gitattributes

@@ -1 +1,2 @@
 *.png filter=lfs diff=lfs merge=lfs -text
+*.dll filter=lfs diff=lfs merge=lfs -text

.github/workflows/main.yml

@@ -17,6 +17,5 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@v4
-      - uses: greut/eclint-action@v0
       - uses: jidicula/clang-format-action@v4.11.0
         with: { clang-format-version: "18" }

Config/FilterPlugin.ini

@@ -0,0 +1,8 @@
+[FilterPlugin]
+; This section lists additional files which will be packaged along with your plugin. Paths should be listed relative to the root plugin directory, and
+; may include "...", "*", and "?" wildcards to match directories, files, and individual characters respectively.
+;
+; Examples:
+;    /README.txt
+;    /Extras/...
+;    /Binaries/ThirdParty/*.dll

Ecsact.uplugin

@@ -25,6 +25,11 @@
 			"Name": "EcsactEditor",
 			"Type": "Editor",
 			"LoadingPhase": "Default"
+		},
+		{
+			"Name": "EcsactUnrealCodegenPlugin",
+			"Type": "Editor",
+			"LoadingPhase": "None"
 		}
 	]
 }

Source/Ecsact/Ecsact.Build.cs

@@ -2,9 +2,7 @@
 using System.IO;
 using System.Diagnostics;
 using System;
-using System.Linq;
 using System.Collections.Generic;
-using UnrealBuildBase;
 using EpicGames.Core;
 
 [Serializable]
@@ -33,13 +31,29 @@ public Ecsact(ReadOnlyTargetRules Target) : base(Target) {
 			"SlateCore",
 		});
 
+		DynamicallyLoadedModuleNames.AddRange(new string[] {
+			"EcsactUnrealCodegenPlugin",
+		});
+
+		var EcsactUnrealCodegenPluginPath = Path.Combine(
+			ModuleDirectory,
+			"..",
+			"..",
+			"Binaries",
+			Target.Platform.ToString(),
+			"UnrealEditor-EcsactUnrealCodegenPlugin.dll"
+		);
+
 		if(Target.bBuildEditor) {
 			PrivateDependencyModuleNames.Add("UnrealEd");
 		}
 
 		var EcsactSdkVersion = GetEcsactSdkVersion();
-		Environment.SetEnvironmentVariable("EcsactPlugin_SdkVersion", EcsactSdkVersion);
-		
+		Environment.SetEnvironmentVariable(
+			"EcsactPlugin_SdkVersion",
+			EcsactSdkVersion
+		);
+
 		var EcsactSdkIncludeDir = GetEcsactSdkIncludeDir();
 		PublicIncludePaths.Add(EcsactSdkIncludeDir);
 
@@ -64,6 +78,16 @@ public Ecsact(ReadOnlyTargetRules Target) : base(Target) {
 				"--plugin=cpp_systems_header",
 				"--plugin=cpp_systems_source"
 			};
+
+			// if(!File.Exists(EcsactUnrealCodegenPluginPath)) {
+			// 	Console.WriteLine(
+			// 		"warning: EcsactUnrealCodegenPlugin was not built. It should have "
+			// + 		"been shipped with the Ecsact Unreal integration plugin."
+			// 	);
+			// } else {
+			// 	CodegenArgs.Add($"--plugin={EcsactUnrealCodegenPluginPath}");
+			// }
+
 			CodegenArgs.AddRange(EcsactSources);
 			ExecEcsactCli(CodegenArgs);
 		}
@@ -158,14 +182,16 @@ private void ExecEcsactCli(IList<string> Args) {
 	}
 
 	private DirectoryReference GetProjectRoot(ReadOnlyTargetRules Target) {
-		if (Target.ProjectFile != null) {
+		if(Target.ProjectFile != null) {
 			return Target.ProjectFile.Directory;
 		}
 
-		// Without a Target.ProjectFile we're probably installed as an Engine plugin.
-		// Only information we have about the project is the current directory.
+		// Without a Target.ProjectFile we're probably installed as an Engine
+		// plugin. Only information we have about the project is the current
+		// directory.
 		var Root = new DirectoryReference(Directory.GetCurrentDirectory());
-		while (Root != null && !File.Exists(Path.Combine(Root.FullName, "*.uproject"))) {
+		while(Root != null &&
+					!File.Exists(Path.Combine(Root.FullName, "*.uproject"))) {
 			Root = Root.ParentDirectory;
 		}
 		return Root;

Source/Ecsact/Private/Ecsact.cpp

@@ -1,7 +1,10 @@
 #include "Ecsact.h"
 #include "CoreGlobals.h"
+#include "EcsactSettings.h"
 #include "HAL/PlatformProcess.h"
+#include "Logging/LogVerbosity.h"
 #include "Misc/Paths.h"
+#include "EcsactAsyncRunner.h"
 #include "ecsact/runtime.h"
 
 #define LOCTEXT_NAMESPACE "FEcsactModule"
@@ -12,6 +15,13 @@ DEFINE_LOG_CATEGORY(Ecsact);
 FOR_EACH_ECSACT_API_FN(INIT_ECSACT_API_FN, UNUSED_PARAM);
 #undef INIT_ECSACT_API_FN
 
+FEcsactModule* FEcsactModule::Self = nullptr;
+
+auto FEcsactModule::Get() -> FEcsactModule& {
+	check(Self != nullptr);
+	return *Self;
+}
+
 auto FEcsactModule::Abort() -> void {
 #ifdef WITH_EDITOR
 	if(GEditor) {
@@ -26,6 +36,7 @@ auto FEcsactModule::LoadEcsactRuntime() -> void {
 		FPaths::ProjectDir(),
 		TEXT("Binaries/Win64/EcsactRuntime.dll")
 	);
+	UE_LOG(Ecsact, Log, TEXT("Loading ecsact runtime %s"), *ecsact_runtime_path);
 
 	EcsactRuntimeHandle = FPlatformProcess::GetDllHandle(*ecsact_runtime_path);
 
@@ -43,12 +54,22 @@ auto FEcsactModule::LoadEcsactRuntime() -> void {
 #define LOAD_ECSACT_FN(fn, UNUSED_PARAM)                           \
 	fn = reinterpret_cast<decltype(fn)>(                             \
 		FPlatformProcess::GetDllExport(EcsactRuntimeHandle, TEXT(#fn)) \
-	)
+	);                                                               \
+	if(fn != nullptr) {                                              \
+		UE_LOG(Ecsact, Log, TEXT("loaded %s"), TEXT(#fn));             \
+	} else {                                                         \
+		UE_LOG(Ecsact, Error, TEXT("failed to load %s"), TEXT(#fn));   \
+	}                                                                \
+	static_assert(true, "require ;")
 	FOR_EACH_ECSACT_API_FN(LOAD_ECSACT_FN);
 #undef LOAD_ECSACT_FN
+	StartRunner();
 }
 
 auto FEcsactModule::UnloadEcsactRuntime() -> void {
+	UE_LOG(Ecsact, Log, TEXT("Unloading ecsact runtime"));
+
+	StopRunner();
 	if(EcsactRuntimeHandle) {
 		FPlatformProcess::FreeDllHandle(EcsactRuntimeHandle);
 		EcsactRuntimeHandle = nullptr;
@@ -60,6 +81,7 @@ auto FEcsactModule::UnloadEcsactRuntime() -> void {
 }
 
 auto FEcsactModule::StartupModule() -> void {
+	Self = this;
 	if(!GIsEditor) {
 		LoadEcsactRuntime();
 	}
@@ -78,6 +100,7 @@ auto FEcsactModule::ShutdownModule() -> void {
 	FEditorDelegates::PreBeginPIE.RemoveAll(this);
 	FEditorDelegates::EndPIE.RemoveAll(this);
 #endif
+	Self = nullptr;
 }
 
 auto FEcsactModule::OnPreBeginPIE(bool _) -> void {
@@ -88,6 +111,56 @@ auto FEcsactModule::OnEndPIE(bool _) -> void {
 	UnloadEcsactRuntime();
 }
 
+auto FEcsactModule::StartRunner() -> void {
+	const auto* settings = GetDefault<UEcsactSettings>();
+
+	if(Runner != nullptr) {
+		UE_LOG(
+			Ecsact,
+			Warning,
+			TEXT("StartRunner() was called while runner was already running. "
+					 "Stopping previous one before starting new.")
+		);
+		StopRunner();
+	}
+
+	switch(settings->Runner) {
+		case EEcsactRuntimeRunnerType::Automatic:
+			if(ecsact_async_flush_events == nullptr) {
+				Runner = NewObject<UEcsactSyncRunner>();
+			} else {
+				Runner = NewObject<UEcsactAsyncRunner>();
+			}
+			break;
+		case EEcsactRuntimeRunnerType::Asynchronous:
+			Runner = NewObject<UEcsactAsyncRunner>();
+			break;
+		case EEcsactRuntimeRunnerType::Custom:
+			if(settings->CustomRunnerClass != nullptr) {
+				Runner = NewObject<UEcsactRunner>(nullptr, settings->CustomRunnerClass);
+			}
+			break;
+	}
+
+	if(Runner != nullptr) {
+		UE_LOG(
+			Ecsact,
+			Verbose,
+			TEXT("Using ecsact runner: %s"),
+			*Runner->StaticClass()->GetName()
+		);
+		Runner->AddToRoot();
+	}
+}
+
+auto FEcsactModule::StopRunner() -> void {
+	if(Runner != nullptr) {
+		Runner->RemoveFromRoot();
+		Runner->ConditionalBeginDestroy();
+		Runner = nullptr;
+	}
+}
+
 #undef LOCTEXT_NAMESPACE
 
 IMPLEMENT_MODULE(FEcsactModule, Ecsact)

Source/Ecsact/Public/Ecsact.h

@@ -6,14 +6,24 @@
 DECLARE_LOG_CATEGORY_EXTERN(Ecsact, Log, All);
 
 class FEcsactModule : public IModuleInterface {
-	void* EcsactRuntimeHandle;
-	auto  LoadEcsactRuntime() -> void;
-	auto  UnloadEcsactRuntime() -> void;
-	auto  Abort() -> void;
-	auto  OnPreBeginPIE(bool bIsSimulating) -> void;
-	auto  OnEndPIE(const bool bIsSimulating) -> void;
+	friend class EcsactUnrealExecution;
+
+	static FEcsactModule* Self;
+	void*                 EcsactRuntimeHandle;
+	class UEcsactRunner*  Runner;
+
+	auto LoadEcsactRuntime() -> void;
+	auto UnloadEcsactRuntime() -> void;
+	auto Abort() -> void;
+	auto OnPreBeginPIE(bool bIsSimulating) -> void;
+	auto OnEndPIE(const bool bIsSimulating) -> void;
+
+	auto StartRunner() -> void;
+	auto StopRunner() -> void;
 
 public:
+	static auto Get() -> FEcsactModule&;
+
 	auto StartupModule() -> void override;
 	auto ShutdownModule() -> void override;
 };

Source/Ecsact/Public/EcsactAsyncRunner.cpp

@@ -0,0 +1,17 @@
+#include "EcsactAsyncRunner.h"
+#include "Ecsact.h"
+#include "EcsactUnrealEventsCollector.h"
+#include "ecsact/runtime/async.h"
+#include "ecsact/runtime/common.h"
+
+auto UEcsactAsyncRunner::Tick(float DeltaTime) -> void {
+	if(ecsact_async_flush_events == nullptr) {
+		UE_LOG(Ecsact, Error, TEXT("ecsact_async_flush_events is unavailable"));
+	} else {
+		ecsact_execution_events_collector* evc_c = nullptr;
+		if(EventsCollector != nullptr) {
+			evc_c = EventsCollector->GetCEVC();
+		}
+		ecsact_async_flush_events(evc_c, nullptr);
+	}
+}

Source/Ecsact/Public/EcsactAsyncRunner.h

@@ -0,0 +1,19 @@
+
+#pragma once
+
+#include "CoreMinimal.h"
+#include "Tickable.h"
+#include "UObject/NoExportTypes.h"
+#include "EcsactRunner.h"
+#include "EcsactAsyncRunner.generated.h"
+
+UCLASS(NotBlueprintable)
+
+class UEcsactAsyncRunner : public UEcsactRunner {
+	GENERATED_BODY()
+public:
+	UPROPERTY()
+	class UEcsactUnrealEventsCollector* EventsCollector;
+
+	auto Tick(float DeltaTime) -> void override;
+};