feat: API for streaming components

Author: Kelwan

ecsact/runtime/async.h

@@ -205,12 +205,25 @@ ECSACT_ASYNC_API_FN(void, ecsact_async_disconnect)(void);
  */
 ECSACT_ASYNC_API_FN(int32_t, ecsact_async_get_current_tick)(void);
 
+/**
+ * Sends Ecsact stream data to the specified registry. Stream data will be
+ * applied on the next ecsact_execute_systems call.
+ */
+ECSACT_CORE_API_FN(ecsact_async_request_id, ecsact_async_stream)
+( //
+	int32_t                    count,
+	const ecsact_entity_id*    entities,
+	const ecsact_component_id* component_ids,
+	const void*                components_data
+);
+
 #define FOR_EACH_ECSACT_ASYNC_API_FN(fn, ...)              \
 	fn(ecsact_async_enqueue_execution_options, __VA_ARGS__); \
 	fn(ecsact_async_flush_events, __VA_ARGS__);              \
 	fn(ecsact_async_connect, __VA_ARGS__);                   \
 	fn(ecsact_async_disconnect, __VA_ARGS__);                \
-	fn(ecsact_async_get_current_tick, __VA_ARGS__);
+	fn(ecsact_async_get_current_tick, __VA_ARGS__);          \
+	fn(ecsact_async_stream, __VA_ARGS__)
 
 #undef ECSACT_ASYNC_API
 #undef ECSACT_ASYNC_API_FN

ecsact/runtime/common.h

@@ -274,6 +274,15 @@ typedef enum {
 	ECSACT_EXEC_SYS_ERR_ACTION_ENTITY_CONSTRAINT_BROKEN = 2,
 } ecsact_execute_systems_error;
 
+typedef enum {
+	ECSACT_STREAM_OK = 0,
+
+	/**
+	 * An invalid or non-stream component ID was passed into the stream.
+	 */
+	ECSACT_STREAM_INVALID_COMPONENT_ID = 1,
+} ecsact_stream_error;
+
 typedef enum {
 	/**
 	 * System has no capabilities for this component.
@@ -287,7 +296,8 @@ typedef enum {
 
 	/**
 	 * System may only write to component.
-	 * NOTE: This flag is only valid if accompanied by `ECSACT_SYS_CAP_READONLY`.
+	 * NOTE: This flag is only valid if accompanied by
+	 * `ECSACT_SYS_CAP_READONLY`.
 	 */
 	ECSACT_SYS_CAP_WRITEONLY = 2,
 
@@ -342,6 +352,11 @@ typedef enum {
 	 * `ECSACT_SYS_CAP_INCLUDE`
 	 */
 	ECSACT_SYS_CAP_REMOVES = 64 | ECSACT_SYS_CAP_INCLUDE,
+
+	/**
+	 * System may enable or disable streaming data for this component.
+	 */
+	ECSACT_SYS_CAP_STREAM_TOGGLE = 128,
 } ecsact_system_capability;
 
 /**
@@ -661,6 +676,32 @@ typedef enum {
 	ECSACT_EVENT_DESTROY_ENTITY = 4,
 } ecsact_event;
 
+typedef enum ecsact_component_type {
+	/**
+	 * The component has no unique type
+	 */
+	ECSACT_COMPONENT_TYPE_NONE = 0,
+
+	/*
+	 * The component takes in a continuous feed of data. Look at stream toggle to
+	 * see how you can set the component to receive updates from either
+	 * ecsact_stream or systems.
+	 */
+	ECSACT_COMPONENT_TYPE_STREAM = 1,
+
+	/*
+	 * The component is a stream component (@see ECSACT_COMPONENT_TYPE_STREAM) but
+	 * may be updated overtime instead of all at once.
+	 */
+	ECSACT_COMPONENT_TYPE_LAZY_STREAM = 2,
+
+	/**
+	 * The component only lives during system execution and is automatically
+	 * removed.
+	 */
+	ECSACT_COMPONENT_TYPE_TRANSIENT = 3
+} ecsact_component_stream;
+
 /**
  * Component event callback
  */

ecsact/runtime/core.h

@@ -264,6 +264,19 @@ ECSACT_CORE_API_FN(ecsact_ees, ecsact_get_entity_execution_status)
 	ecsact_system_like_id system_like_id
 );
 
+/**
+ * Sends Ecsact stream data to the specified registry. Stream data will be
+ * applied on the next ecsact_execute_systems call.
+ */
+ECSACT_CORE_API_FN(ecsact_stream_error, ecsact_stream)
+( //
+	ecsact_registry_id         registry_id,
+	int32_t                    count,
+	const ecsact_entity_id*    entities,
+	const ecsact_component_id* component_ids,
+	const void*                components_data
+);
+
 // # BEGIN FOR_EACH_ECSACT_CORE_API_FN
 #ifdef ECSACT_MSVC_TRADITIONAL
 #	define FOR_EACH_ECSACT_CORE_API_FN(fn, ...) ECSACT_MSVC_TRADITIONAL_ERROR()
@@ -287,6 +300,7 @@ ECSACT_CORE_API_FN(ecsact_ees, ecsact_get_entity_execution_status)
 		fn(ecsact_update_component, __VA_ARGS__);  \
 		fn(ecsact_remove_component, __VA_ARGS__);  \
 		fn(ecsact_execute_systems, __VA_ARGS__);   \
+		fn(ecsact_stream, __VA_ARGS__);            \
 		fn(ecsact_get_entity_execution_status, __VA_ARGS__)
 #endif
 

ecsact/runtime/dynamic.h

@@ -515,6 +515,12 @@ ECSACT_DYNAMIC_API_FN(void, ecsact_set_system_notify_component_setting)
 	ecsact_system_notify_setting setting
 );
 
+ECSACT_DYNAMIC_API_FN(void, ecsact_set_component_type)
+( //
+	ecsact_component_id   comopnent_id,
+	ecsact_component_type component_type
+);
+
 // # BEGIN FOR_EACH_ECSACT_DYNAMIC_API_FN
 #ifdef ECSACT_MSVC_TRADITIONAL
 #	define FOR_EACH_ECSACT_DYNAMIC_API_FN(fn, ...) \

ecsact/runtime/meta.h

@@ -511,6 +511,14 @@ ECSACT_META_API_FN(void, ecsact_meta_system_notify_settings)
 	int32_t*                      out_notifies_count
 );
 
+/**
+ * Check the type of a component.
+ */
+ECSACT_META_API_FN(ecsact_component_type, ecsact_meta_component_type)
+( //
+	ecsact_component_id component_id
+);
+
 // # BEGIN FOR_EACH_ECSACT_META_API_FN
 #ifdef ECSACT_MSVC_TRADITIONAL
 #	define FOR_EACH_ECSACT_META_API_FN(fn, ...) ECSACT_MSVC_TRADITIONAL_ERROR()
@@ -575,7 +583,8 @@ ECSACT_META_API_FN(void, ecsact_meta_system_notify_settings)
 		fn(ecsact_meta_get_lazy_iteration_rate, __VA_ARGS__);               \
 		fn(ecsact_meta_get_system_parallel_execution, __VA_ARGS__);         \
 		fn(ecsact_meta_system_notify_settings_count, __VA_ARGS__);          \
-		fn(ecsact_meta_system_notify_settings, __VA_ARGS__)
+		fn(ecsact_meta_system_notify_settings, __VA_ARGS__);                \
+		fn(ecsact_meta_component_stream, __VA_ARGS__)
 #endif
 
 #endif // ECSACT_RUNTIME_META_H