subtr_actor/stats/analysis_graph/
mod.rs

1#![allow(dead_code)]
2
3use std::collections::HashSet;
4
5use crate::Collector;
6use crate::{SubtrActorError, SubtrActorErrorVariant, SubtrActorResult};
7
8pub mod graph;
9pub use graph::{
10    AnalysisDependency, AnalysisGraph, AnalysisNode, AnalysisNodeDyn, AnalysisStateContext,
11    AnalysisStateRef,
12};
13
14#[macro_use]
15mod node_macros;
16
17mod collector;
18mod nodes;
19
20use crate::stats::calculators::FrameInput;
21
22#[allow(unused_imports)]
23pub use collector::AnalysisNodeCollector;
24#[allow(unused_imports)]
25pub use nodes::*;
26
27pub(crate) fn boxed_analysis_node_by_name(name: &str) -> Option<Box<dyn AnalysisNodeDyn>> {
28    match name {
29        "core" => Some(nodes::match_stats::boxed_default()),
30        "backboard" => Some(nodes::backboard::boxed_default()),
31        "ceiling_shot" => Some(nodes::ceiling_shot::boxed_default()),
32        "double_tap" => Some(nodes::double_tap::boxed_default()),
33        "fifty_fifty" => Some(nodes::fifty_fifty::boxed_default()),
34        "possession" => Some(nodes::possession::boxed_default()),
35        "pressure" => Some(nodes::pressure::boxed_default()),
36        "rush" => Some(nodes::rush::boxed_default()),
37        "touch" => Some(nodes::touch::boxed_default()),
38        "whiff" => Some(nodes::whiff::boxed_default()),
39        "wavedash" => Some(nodes::wavedash::boxed_default()),
40        "speed_flip" => Some(nodes::speed_flip::boxed_default()),
41        "half_flip" => Some(nodes::half_flip::boxed_default()),
42        "flick" => Some(nodes::flick::boxed_default()),
43        "aerial_goal" => Some(nodes::goal_tags::boxed_aerial_goal()),
44        "high_aerial_goal" => Some(nodes::goal_tags::boxed_high_aerial_goal()),
45        "long_distance_goal" => Some(nodes::goal_tags::boxed_long_distance_goal()),
46        "own_half_goal" => Some(nodes::goal_tags::boxed_own_half_goal()),
47        "empty_net_goal" => Some(nodes::goal_tags::boxed_empty_net_goal()),
48        "flick_goal" => Some(nodes::goal_tags::boxed_flick_goal()),
49        "one_timer_goal" => Some(nodes::goal_tags::boxed_one_timer_goal()),
50        "air_dribble_goal" => Some(nodes::goal_tags::boxed_air_dribble_goal()),
51        "flip_reset_goal" => Some(nodes::goal_tags::boxed_flip_reset_goal()),
52        "musty_flick" => Some(nodes::musty_flick::boxed_default()),
53        "one_timer" => Some(nodes::one_timer::boxed_default()),
54        "pass" => Some(nodes::pass::boxed_default()),
55        "dodge_reset" => Some(nodes::dodge_reset::boxed_default()),
56        "ball_carry" => Some(nodes::ball_carry::boxed_default()),
57        "boost" => Some(nodes::boost::boxed_default()),
58        "movement" => Some(nodes::movement::boxed_default()),
59        "positioning" => Some(nodes::positioning::boxed_default()),
60        "powerslide" => Some(nodes::powerslide::boxed_default()),
61        "demo" => Some(nodes::demo::boxed_default()),
62        _ => None,
63    }
64}
65
66pub fn graph_with_builtin_analysis_nodes<I, S>(names: I) -> SubtrActorResult<AnalysisGraph>
67where
68    I: IntoIterator<Item = S>,
69    S: AsRef<str>,
70{
71    let mut graph = AnalysisGraph::new().with_input_state_type::<FrameInput>();
72    graph.push_boxed_node(nodes::live_play::boxed_default());
73    let mut seen = HashSet::new();
74    for name in names {
75        let name = name.as_ref();
76        if !seen.insert(name.to_owned()) {
77            continue;
78        }
79        graph.push_boxed_node(boxed_analysis_node_by_name(name).ok_or_else(|| {
80            SubtrActorError::new(SubtrActorErrorVariant::UnknownStatsModuleName(
81                name.to_owned(),
82            ))
83        })?);
84    }
85    Ok(graph)
86}
87
88pub fn collect_analysis_graph_for_replay(
89    replay: &boxcars::Replay,
90    graph: AnalysisGraph,
91) -> SubtrActorResult<AnalysisGraph> {
92    let collector = collector::AnalysisNodeCollector::new(graph).process_replay(replay)?;
93    Ok(collector.into_graph())
94}
95
96pub fn collect_builtin_analysis_graph_for_replay<I, S>(
97    replay: &boxcars::Replay,
98    names: I,
99) -> SubtrActorResult<AnalysisGraph>
100where
101    I: IntoIterator<Item = S>,
102    S: AsRef<str>,
103{
104    collect_analysis_graph_for_replay(replay, graph_with_builtin_analysis_nodes(names)?)
105}
106
107pub fn all_analysis_nodes() -> Vec<Box<dyn AnalysisNodeDyn>> {
108    vec![
109        nodes::backboard::boxed_default(),
110        nodes::ball_carry::boxed_default(),
111        nodes::boost::boxed_default(),
112        nodes::ceiling_shot::boxed_default(),
113        nodes::demo::boxed_default(),
114        nodes::dodge_reset::boxed_default(),
115        nodes::double_tap::boxed_default(),
116        nodes::fifty_fifty::boxed_default(),
117        nodes::match_stats::boxed_default(),
118        nodes::movement::boxed_default(),
119        nodes::flick::boxed_default(),
120        nodes::goal_tags::boxed_aerial_goal(),
121        nodes::goal_tags::boxed_high_aerial_goal(),
122        nodes::goal_tags::boxed_long_distance_goal(),
123        nodes::goal_tags::boxed_own_half_goal(),
124        nodes::goal_tags::boxed_empty_net_goal(),
125        nodes::goal_tags::boxed_flick_goal(),
126        nodes::goal_tags::boxed_one_timer_goal(),
127        nodes::goal_tags::boxed_air_dribble_goal(),
128        nodes::goal_tags::boxed_flip_reset_goal(),
129        nodes::musty_flick::boxed_default(),
130        nodes::one_timer::boxed_default(),
131        nodes::pass::boxed_default(),
132        nodes::positioning::boxed_default(),
133        nodes::possession::boxed_default(),
134        nodes::powerslide::boxed_default(),
135        nodes::pressure::boxed_default(),
136        nodes::rush::boxed_default(),
137        nodes::settings::boxed_default(),
138        nodes::speed_flip::boxed_default(),
139        nodes::half_flip::boxed_default(),
140        nodes::wavedash::boxed_default(),
141        nodes::touch::boxed_default(),
142        nodes::whiff::boxed_default(),
143    ]
144}
145
146pub fn graph_with_all_analysis_nodes() -> AnalysisGraph {
147    let mut graph = AnalysisGraph::new().with_input_state_type::<FrameInput>();
148    graph.push_boxed_node(nodes::live_play::boxed_default());
149    for node in all_analysis_nodes() {
150        graph.push_boxed_node(node);
151    }
152    graph
153}
154
155#[cfg(test)]
156#[path = "module_tests.rs"]
157mod tests;
subtr_actor/stats/analysis_graph/mod.rs

subtr_actor/stats/analysis_graph/
mod.rs
