feat: transfered from ecsact_runtime

Author: zaucy

.bazelignore

@@ -0,0 +1 @@
+tests

.bazelrc

@@ -0,0 +1,21 @@
+startup --windows_enable_symlinks
+common --enable_bzlmod
+build --registry=https://raw.githubusercontent.com/bazelboost/registry/main
+build --registry=https://bcr.bazel.build
+build --enable_platform_specific_config
+build --incompatible_use_platforms_repo_for_constraints
+build --incompatible_enable_cc_toolchain_resolution
+build --incompatible_strict_action_env
+build --enable_runfiles
+build --noincompatible_remove_rule_name_parameter
+query --noincompatible_remove_rule_name_parameter
+
+# Temporary until https://github.com/grailbio/bazel-toolchain/pull/198 is merged
+build:linux --extra_toolchains=@llvm_toolchain//:cc-toolchain-x86_64-linux
+
+common:ci --announce_rc
+common:ci --verbose_failures
+common:ci --keep_going
+common:ci --disk_cache=~/.cache/bazel-disk-cache
+
+try-import %workspace%/user.bazelrc

.bazelversion

@@ -0,0 +1 @@
+6.3.2

.clang-format

@@ -0,0 +1,99 @@
+AccessModifierOffset: -2
+AlignAfterOpenBracket: BlockIndent
+AlignConsecutiveAssignments: false
+AlignConsecutiveDeclarations: true
+AlignEscapedNewlines: Left
+AlignOperands: DontAlign
+AlignTrailingComments: false
+AllowAllArgumentsOnNextLine: false
+AllowAllParametersOfDeclarationOnNextLine: false
+AllowShortBlocksOnASingleLine: false
+AllowShortCaseLabelsOnASingleLine: false
+AllowShortFunctionsOnASingleLine: None
+AllowShortIfStatementsOnASingleLine: WithoutElse
+AllowShortLoopsOnASingleLine: false
+AlwaysBreakAfterDefinitionReturnType: None
+AlwaysBreakAfterReturnType: None
+AlwaysBreakBeforeMultilineStrings: true
+AlwaysBreakTemplateDeclarations: Yes
+BinPackArguments: false
+BinPackParameters: false
+BraceWrapping:
+  AfterClass: false
+  AfterControlStatement: false
+  AfterEnum: false
+  AfterFunction: false
+  AfterNamespace: false
+  AfterStruct: false
+  AfterUnion: false
+  AfterExternBlock: false
+  BeforeCatch: false
+  BeforeElse: false
+  IndentBraces: false
+  SplitEmptyFunction: false
+  SplitEmptyRecord: false
+  SplitEmptyNamespace: false
+BreakAfterJavaFieldAnnotations: false
+BreakBeforeBinaryOperators: None
+BreakBeforeBraces: Custom
+BreakBeforeInheritanceComma: false
+BreakBeforeTernaryOperators: true
+BreakConstructorInitializers: BeforeComma
+BreakConstructorInitializersBeforeComma: false
+BreakStringLiterals: true
+ColumnLimit: 80
+CompactNamespaces: false
+ConstructorInitializerAllOnOneLineOrOnePerLine: false
+ConstructorInitializerIndentWidth: 2
+ContinuationIndentWidth: 2
+Cpp11BracedListStyle: true
+DerivePointerAlignment: false
+DisableFormat: false
+ExperimentalAutoDetectBinPacking: false
+FixNamespaceComments: true
+IncludeBlocks: Preserve
+IncludeIsMainRegex: "(Test)?$"
+IndentCaseLabels: true
+IndentPPDirectives: AfterHash
+IndentWidth: 2
+IndentWrappedFunctionNames: false
+InsertBraces: true
+JavaScriptQuotes: Leave
+JavaScriptWrapImports: true
+KeepEmptyLinesAtTheStartOfBlocks: false
+MacroBlockBegin: ""
+MacroBlockEnd: ""
+MaxEmptyLinesToKeep: 1
+NamespaceIndentation: None
+PackConstructorInitializers: NextLine
+PenaltyBreakAssignment: 10
+PenaltyBreakBeforeFirstCallParameter: 30
+PenaltyBreakComment: 10
+PenaltyBreakFirstLessLess: 0
+PenaltyBreakString: 10
+PenaltyExcessCharacter: 400
+PenaltyReturnTypeOnItsOwnLine: 350
+PointerAlignment: Left
+ReflowComments: true
+RequiresClausePosition: OwnLine
+SortIncludes: false
+SortUsingDeclarations: true
+SpaceAfterCStyleCast: false
+SpaceAfterLogicalNot: false
+SpaceAfterTemplateKeyword: false
+SpaceBeforeAssignmentOperators: true
+SpaceBeforeCtorInitializerColon: true
+SpaceBeforeInheritanceColon: true
+SpaceBeforeParens: Never
+SpaceBeforeRangeBasedForLoopColon: true
+SpaceInEmptyParentheses: false
+SpacesBeforeTrailingComments: 1
+SpacesInAngles: Never
+SpacesInContainerLiterals: false
+SpacesInCStyleCastParentheses: false
+SpacesInParentheses: false
+SpacesInSquareBrackets: false
+SeparateDefinitionBlocks: Always
+Standard: Latest
+TabWidth: 2
+UseTab: ForContinuationAndIndentation

.gitignore

@@ -0,0 +1,9 @@
+# bazel
+bazel-*
+user.bazelrc
+
+# dev stuff
+compile_commands.json
+external
+.cache/
+.vs

BUILD.bazel

@@ -0,0 +1,11 @@
+module(name = "ecsact_rt_reference")
+
+bazel_dep(name = "rules_cc", version = "0.0.8")
+bazel_dep(name = "ecsact_runtime")
+bazel_dep(name = "ecsact_codegen")
+
+git_override(
+    module_name = "ecsact_codegen",
+    remote = "https://github.com/ecsact-dev/ecsact_codegen",
+    commit = "d947cb8bef1c488d814dc2b43bd4a0ab982572cd",
+)

MODULE.bazel

@@ -0,0 +1,58 @@
+load("@rules_cc//cc:defs.bzl", "cc_library")
+load("@ecsact_runtime//bazel:copts.bzl", "copts")
+
+package(default_visibility = ["//visiblity:public"])
+
+exports_files([
+    "async_reference.hh",
+    "async_reference.cc",
+    "async.cc",
+])
+
+cc_library(
+    name = "async_reference",
+    srcs = ["async_reference.cc"],
+    hdrs = ["async_reference.hh"],
+    copts = copts,
+    linkstatic = True,
+    visibility = ["//visibility:public"],
+    deps = [
+        "//:async",
+        "//:core",
+        "//async_reference/callbacks:async_callbacks",
+        "//async_reference/callbacks:execution_callbacks",
+        "//async_reference/detail/c_execution_options",
+        "//async_reference/request_id_factory",
+        "//async_reference/tick_manager",
+        "//async_reference/util",
+        "//async_reference/util:types",
+    ],
+)
+
+cc_library(
+    name = "async",
+    srcs = ["async.cc"],
+    copts = copts,
+    defines = ["ECSACT_ASYNC_API_EXPORT="],
+    visibility = ["//visibility:public"],
+    deps = [
+        ":async_reference",
+        "//:async",
+    ],
+)
+
+filegroup(
+    name = "sources",
+    srcs = glob([
+        "**/*.cc",
+        "**/*.hh",
+    ]) + [
+        "//async_reference/callbacks:callback_source",
+        "//async_reference/detail/c_execution_options:c_execution_source",
+        "//async_reference/tick_manager:tick_source",
+        "//async_reference/util:util_source",
+        "//async_reference/request_id_factory:sources",
+        "//serialize_reference:serialize_source",
+    ],
+    visibility = ["//visibility:public"],
+)

WORKSPACE.bazel

@@ -0,0 +1,62 @@
+#include <optional>
+
+#include "ecsact/runtime/async.h"
+#include "async_reference.hh"
+#include "callbacks/async_callbacks.hh"
+#include "request_id_factory/request_id_factory.hh"
+
+using namespace ecsact::async_reference;
+
+// NOTE: These are the singletons for managing the reference library state.
+//       This file should be small. Declare a few variables and call a few
+//       functions in the C function bodies. Keep the logic minimal.
+static auto async_callbacks = detail::async_callbacks{};
+static auto request_id_factory = detail::request_id_factory{};
+static auto reference = std::optional<detail::async_reference>{};
+
+ecsact_async_request_id ecsact_async_connect(const char* connection_string) {
+	auto req_id = request_id_factory.next_id();
+	reference.emplace(async_callbacks);
+	reference->connect(req_id, connection_string);
+	return req_id;
+}
+
+void ecsact_async_disconnect() {
+	if(reference) {
+		reference->disconnect();
+		reference.reset();
+	}
+}
+
+void ecsact_async_flush_events(
+	const ecsact_execution_events_collector* execution_evc,
+	const ecsact_async_events_collector*     async_evc
+) {
+	async_callbacks.invoke(async_evc);
+	if(reference) {
+		reference->invoke_execution_events(execution_evc);
+	}
+}
+
+ecsact_async_request_id ecsact_async_enqueue_execution_options(
+	const ecsact_execution_options options
+) {
+	auto req_id = request_id_factory.next_id();
+	if(!reference) {
+		async_callbacks.add(detail::types::async_error{
+			.error = ECSACT_ASYNC_ERR_NOT_CONNECTED,
+			.request_ids = {req_id},
+		});
+		return req_id;
+	}
+
+	reference->enqueue_execution_options(req_id, options);
+	return req_id;
+}
+
+int32_t ecsact_async_get_current_tick() {
+	if(reference) {
+		return reference->get_current_tick();
+	}
+	return 0;
+}