rivetkit-core 2.3.0-rc.12

Core runtime primitives for RivetKit actor hosts
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

use super::*;
use rivet_error::{MacroMarker, RivetErrorSchema};

#[test]
fn preserves_internal_anyhow_message_until_client_boundary() {
	let error = ActionDispatchError::from_anyhow(anyhow::anyhow!("plain failure"));

	assert_eq!(error.group, "core");
	assert_eq!(error.code, "internal_error");
	assert_eq!(error.message, "plain failure");
	assert_eq!(error.client_message(), "An internal error occurred");
	assert_eq!(error.client_metadata(), None);
}

#[test]
fn preserves_public_error_message_for_client_boundary() {
	static TEST_ERROR: RivetErrorSchema = RivetErrorSchema {
		group: "actor",
		code: "action_not_found",
		default_message: "action `missing` was not found",
		meta_type: None,
		_macro_marker: MacroMarker { _private: () },
	};
	let error = ActionDispatchError::from_anyhow(TEST_ERROR.build());

	assert_eq!(error.group, "actor");
	assert_eq!(error.code, "action_not_found");
	assert_eq!(error.message, "action `missing` was not found");
	assert_eq!(error.client_message(), "action `missing` was not found");
}

#[test]
fn preserves_user_error_message_and_metadata_for_client_boundary() {
	let error = ActionDispatchError {
		group: "user".to_owned(),
		code: "detailed_error".to_owned(),
		message: "Detailed error message".to_owned(),
		metadata: Some(serde_json::json!({ "reason": "test" })),
		actor: None,
	};

	assert_eq!(error.client_message(), "Detailed error message");
	assert_eq!(
		error.client_metadata(),
		Some(&serde_json::json!({ "reason": "test" }))
	);
}

#[test]
fn masks_private_structured_message_at_client_boundary() {
	static TEST_ERROR: RivetErrorSchema = RivetErrorSchema {
		group: "sqlite",
		code: "remote_execution_failed",
		default_message: "private storage failure",
		meta_type: None,
		_macro_marker: MacroMarker { _private: () },
	};
	let error = ActionDispatchError::from_anyhow(TEST_ERROR.build());

	assert_eq!(error.group, "sqlite");
	assert_eq!(error.code, "remote_execution_failed");
	assert_eq!(error.message, "private storage failure");
	assert_eq!(error.client_message(), "An internal error occurred");
	assert_eq!(error.client_metadata(), None);
}