mittens-engine 0.7.0

A Vulkan and OpenXR scene engine with ECS, reactive signals, and Meow Meow scripting
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

use crate::engine::ecs::RxWorld;
use crate::engine::ecs::component::SignalRouteUpwardComponent;
use crate::engine::ecs::rx::signal_pipeline::{
    SignalPipeline, SignalPipelineOp, SignalRouteUpward,
};
use crate::engine::ecs::{ComponentId, World};

/// Maintains RxWorld-owned intent routing pipelines based on operator components.
#[derive(Debug, Default)]
pub struct PipelineSystem;

impl PipelineSystem {
    pub fn register_signal_route_upward(
        &mut self,
        world: &World,
        rx: &mut RxWorld,
        operator_component: ComponentId,
    ) {
        let Some(cfg) =
            world.get_component_by_id_as::<SignalRouteUpwardComponent>(operator_component)
        else {
            return;
        };

        let Some(owner) = world.parent_of(operator_component) else {
            return;
        };

        let pipeline = SignalPipeline {
            source_operator: operator_component,
            ops: vec![SignalPipelineOp::RouteUpward(SignalRouteUpward {
                intent_kind: cfg.intent_kind.clone(),
                parent_type: cfg.parent_type.clone(),
            })],
        };

        rx.register_pipeline(owner, pipeline);
    }

    pub fn remove_signal_route_upward(
        &mut self,
        rx: &mut RxWorld,
        operator_component: ComponentId,
    ) {
        rx.remove_pipelines_from_operator(operator_component);
    }
}