beet_build 0.0.8

Codegen and compilation tooling for beet
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

use beet_core::prelude::*;
use beet_flow::prelude::*;
use beet_net::prelude::*;
use beet_rsx::prelude::*;

#[construct]
pub fn PushAssets() -> impl Bundle {
	(
		Name::new("Push Assets"),
		OnSpawn::observe(
			move |ev: On<GetOutcome>,
			      pkg_config: Res<PackageConfig>,
			      commands: AsyncCommands|
			      -> Result {
				let src = AbsPathBuf::new_workspace_rel("assets")?.to_string();
				let dst = format!("s3://{}/", pkg_config.assets_bucket_name());
				s3_sync(ev, src, dst, commands);
				Ok(())
			},
		),
	)
}

#[construct]
pub fn PullAssets() -> impl Bundle {
	(
		Name::new("Pull Assets"),
		OnSpawn::observe(
			move |ev: On<GetOutcome>,
			      pkg_config: Res<PackageConfig>,
			      commands: AsyncCommands|
			      -> Result {
				let src = format!("s3://{}/", pkg_config.assets_bucket_name());
				let dst = AbsPathBuf::new_workspace_rel("assets")?.to_string();
				s3_sync(ev, src, dst, commands);
				Ok(())
			},
		),
	)
}


#[construct]
pub fn PushHtml() -> impl Bundle {
	(
		Name::new("Push Html"),
		OnSpawn::observe(
			move |ev: On<GetOutcome>,
			      pkg_config: Res<PackageConfig>,
			      ws_config: Res<WorkspaceConfig>,
			      commands: AsyncCommands| {
				let src = ws_config.html_dir.into_abs().to_string();
				let dst = format!("s3://{}", pkg_config.html_bucket_name());
				s3_sync(ev, src, dst, commands)
			},
		),
	)
}


fn s3_sync(
	ev: On<GetOutcome>,
	src: String,
	dst: String,
	mut commands: AsyncCommands,
) {
	let src = src.clone();
	let dst = dst.clone();
	let target = ev.target();
	commands.run(async move |world: AsyncWorld| {
		let result = S3Sync {
			src,
			dst,
			delete: true,
			..default()
		}
		.send()
		.await;

		world
			.with_then(move |world| {
				let outcome = if result.is_ok() {
					Outcome::Pass
				} else {
					Outcome::Fail
				};
				world.entity_mut(target).trigger_target(outcome);
			})
			.await;
	});
}