animgraph 0.1.0

Animation data flow library using hierarchical state machines
Documentation 
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150

use serde_derive::{Deserialize, Serialize};

use crate::{
    io::{Event, EventEmit, NumberRef, Timer},
    FlowState, GraphBoolean, GraphNodeConstructor, Seconds,
};

use super::{GraphNode, GraphVisitor};

#[derive(Debug, Copy, Clone, Serialize, Deserialize)]
pub struct TimedEventNode {
    pub timer: Timer,
    pub event: Event,
    pub condition: GraphBoolean,
    pub duration: NumberRef<Seconds>,
    pub emit: EventEmit,
    pub elapsed: bool,
}

impl GraphNodeConstructor for TimedEventNode {
    fn identity() -> &'static str {
        "timed_event"
    }

    fn construct_entry(
        self,
        metrics: &crate::GraphMetrics,
    ) -> anyhow::Result<crate::GraphNodeEntry> {
        metrics.validate_timer(&self.timer, Self::identity())?;
        metrics.validate_event(&self.event, Self::identity())?;
        metrics.validate_bool(self.condition, Self::identity())?;
        metrics.validate_number_ref(&self.duration, Self::identity())?;
        Ok(crate::GraphNodeEntry::Process(Box::new(self)))
    }
}

impl GraphNode for TimedEventNode {
    fn visit(&self, visitor: &mut GraphVisitor) {
        let emit = if visitor.graph.get_bool(self.condition) {
            self.emit
        } else {
            EventEmit::Never
        };

        let duration = self.duration.get(visitor.graph);

        let in_event = if self.elapsed {
            self.timer.elapsed(visitor.graph).0 >= duration.0
        } else {
            self.timer.remaining(visitor.graph).0 <= duration.0
        };

        let state = if in_event {
            visitor.graph.get_state(visitor.context.state)
        } else {
            FlowState::Exited
        };

        self.event.emit(visitor, state, emit);
    }
}

#[cfg(feature = "compiler")]
pub mod compile {
    use serde_derive::{Deserialize, Serialize};
    use serde_json::Value;

    use crate::{
        compiler::prelude::{
            Extras, IOSlot, IOType, Node, NodeCompilationError, NodeCompiler,
            NodeSerializationContext, NodeSettings,
        },
        io::{Event, EventEmit, Timer},
        GraphNodeConstructor, Seconds,
    };

    pub use super::TimedEventNode;

    #[derive(Debug, Clone, Serialize, Deserialize, Default)]
    pub struct TimedEventSettings {
        pub emit: EventEmit,
        pub elapsed: bool,
    }

    impl NodeSettings for TimedEventSettings {
        fn name() -> &'static str {
            TimedEventNode::identity()
        }

        fn input() -> &'static [(&'static str, IOType)] {
            use IOType::*;
            &[
                ("timer", Timer),
                ("event", Event),
                ("condition", Bool),
                ("duration", Number),
            ]
        }

        fn output() -> &'static [(&'static str, IOType)] {
            &[]
        }

        fn build(self) -> anyhow::Result<Extras> {
            Ok(serde_json::to_value(self)?)
        }
    }

    impl NodeCompiler for TimedEventNode {
        type Settings = TimedEventSettings;
        fn build<'a>(
            context: &NodeSerializationContext<'a>,
        ) -> Result<Value, NodeCompilationError> {
            let timer = context.input_timer(0)?;
            let event = context.input_event(1)?;
            let condition = context.input_bool(2)?;
            let duration = context.input_number::<Seconds>(3)?;
            let settings = context.settings::<TimedEventSettings>()?;

            context.serialize_node(TimedEventNode {
                timer,
                event,
                condition,
                duration,
                emit: settings.emit,
                elapsed: settings.elapsed,
            })
        }
    }

    pub fn remaining_event(
        timer: impl IOSlot<Timer>,
        event: impl IOSlot<Event>,
        condition: impl IOSlot<bool>,
        duration: impl IOSlot<Seconds>,
        emit: EventEmit,
    ) -> Node {
        let settings = TimedEventSettings {
            emit,
            elapsed: false,
        };
        let input = vec![
            timer.into_slot("timer"),
            event.into_slot("event"),
            condition.into_slot("condition"),
            duration.into_slot("duration"),
        ];
        Node::new(input, vec![], settings).expect("Valid")
    }
}