beet_net 0.0.3

A very flexible AI behavior library for games and robotics.
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

use crate::prelude::*;
use beet_ecs::prelude::*;
use bevy::prelude::*;
use serde::Deserialize;
use serde::Serialize;


/**
 * This adds common replication events to the app.
 * It should be added before any other events in order
 * to preserve the registration ids:
 *
 * - `0`: AppReady
 * - `1`: SpawnScene
*/
pub struct CommonEventsPlugin;

impl Plugin for CommonEventsPlugin {
	fn build(&self, app: &mut App) {
		app
			// AppStartup
			.add_event::<AppStartup>()
			.replicate_event_outgoing::<AppStartup>()
			.add_systems(Startup, |mut events: EventWriter<AppStartup>| {
				events.send(AppStartup);
			})
			// AppReady
			.add_event::<AppReady>()
			.replicate_observer_outgoing::<AppReady>()
			.add_plugins(ActionPlugin::<(
				TriggerOnRun<AppReady>,
				RunOnAppReady,
			)>::default())
			// SpawnSceneFile
			.add_event::<SpawnSceneFile>()
			.replicate_event_incoming::<SpawnSceneFile>()
			.add_event::<SpawnSceneFileResponse>()
			.replicate_event_outgoing::<SpawnSceneFileResponse>()
			.add_systems(Update, handle_spawn_scene)
			.replicate_observer_incoming::<OnUserMessage>()
			.observe(log_on_user_message)
			.replicate_observer_outgoing::<OnAppMessage>();
		// Screenshot

		#[cfg(not(test))]
		app.add_event::<SaveScreenshot>()
		.replicate_event_incoming::<SaveScreenshot>()
		.add_systems(Update,screenshot_on_event)
		.add_systems(Update,screenshot_on_keypress)
		// .observe(screenshot_on_event)
		// .observe(screenshot_on_keypress)
			/*-*/;
	}
}

/// Sent from this app on the Startup schedule.
#[derive(Debug, Default, Clone, Serialize, Deserialize, Event, Reflect)]
#[reflect(Default)]
pub struct AppStartup;
/// Sent from this app, usually once assets are ready.
#[derive(Debug, Default, Clone, Serialize, Deserialize, Event, Reflect)]
#[reflect(Default)]
pub struct AppReady;

pub type RunOnAppReady = TriggerOnGlobalTrigger<AppReady, OnRun>;




/// User messages received either internally or externally, can be treated like an StdIn.
#[derive(
	Debug, Clone, Deref, DerefMut, Serialize, Deserialize, Event, Reflect,
)]
pub struct OnUserMessage(pub String);
/// App messages for outputting, can be treated like an StdOut.
#[derive(
	Debug, Clone, Deref, DerefMut, Serialize, Deserialize, Event, Reflect,
)]
pub struct OnAppMessage(pub String);


fn log_on_user_message(
	trigger: Trigger<OnUserMessage>,
	mut commands: Commands,
) {
	commands.trigger(OnLogMessage::new(format!("User: {}", &trigger.event().0)))
}