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
|
//! Shirabe-specific integration tests for the subscriber plugin path: upstream Composer
//! has no test that exercises `addSubscriber`/`getSubscribedEvents` through a real plugin, so
//! these tests use a Shirabe-owned fixture (`fixtures/subscriber-v1`) instead of a ported one.
use crate::async_runtime::run;
use crate::plugin_installer_test::{lock_php_worker, new_installer, php_runtime_available, set_up};
use shirabe::installer::InstallerInterface;
use shirabe::package::PackageInterfaceHandle;
use shirabe::package::loader::{ArrayLoader, JsonLoader, JsonLoaderInput};
fn subscriber_fixture_package() -> PackageInterfaceHandle {
let loader = JsonLoader::new(Box::new(ArrayLoader::new(None, false)));
let path = std::path::Path::new(env!("CARGO_MANIFEST_DIR"))
.join("tests/plugin/fixtures/subscriber-v1/composer.json");
loader
.load(JsonLoaderInput::String(
path.canonicalize().unwrap().to_str().unwrap().to_string(),
))
.unwrap()
}
/// Installs the subscriber fixture plugin: activate runs in the PHP child and
/// `addSubscriber` registers its listeners with the event dispatcher.
fn install_subscriber_plugin(set_up: &crate::plugin_installer_test::SetUp) {
let installer = new_installer(set_up);
set_up.pm.borrow_mut().load_installed_plugins().unwrap();
run(installer.install(&set_up.repository, subscriber_fixture_package())).unwrap();
assert_eq!("activate subscriber-v1\n", set_up.io.borrow().get_output());
}
fn dispatch(set_up: &crate::plugin_installer_test::SetUp, event_name: &str) -> i64 {
let dispatcher = set_up.composer.borrow().get_event_dispatcher();
let result = dispatcher.borrow_mut().dispatch(Some(event_name), None);
result.unwrap()
}
#[test]
fn test_subscriber_listener_receives_event() {
if !php_runtime_available() {
return;
}
let _worker = lock_php_worker();
let set_up = set_up();
install_subscriber_plugin(&set_up);
// 'post-install-cmd' => 'onPostInstall' (bare method-name shape); the listener calls
// $event->getName() back over RPC.
let return_code = dispatch(&set_up, "post-install-cmd");
assert_eq!(0, return_code);
assert_eq!(
"activate subscriber-v1\nsubscriber saw post-install-cmd\n",
set_up.io.borrow().get_output()
);
}
#[test]
fn test_subscriber_listeners_run_in_priority_order() {
if !php_runtime_available() {
return;
}
let _worker = lock_php_worker();
let set_up = set_up();
install_subscriber_plugin(&set_up);
// 'shirabe-priority-event' => [['early', 10], ['late', -10]] (multi-handler shape).
let return_code = dispatch(&set_up, "shirabe-priority-event");
assert_eq!(0, return_code);
assert_eq!(
"activate subscriber-v1\nearly listener\nlate listener\n",
set_up.io.borrow().get_output()
);
}
#[test]
fn test_subscriber_listener_returning_false_sets_return_code() {
if !php_runtime_available() {
return;
}
let _worker = lock_php_worker();
let set_up = set_up();
install_subscriber_plugin(&set_up);
// 'shirabe-false-event' => ['returnsFalse', 0] (method+priority shape); PHP maps a false
// listener return to exit code 1.
let return_code = dispatch(&set_up, "shirabe-false-event");
assert_eq!(1, return_code);
assert_eq!(
"activate subscriber-v1\nfailing listener\n",
set_up.io.borrow().get_output()
);
}
#[test]
fn test_unrelated_event_does_not_reach_the_subscriber() {
if !php_runtime_available() {
return;
}
let _worker = lock_php_worker();
let set_up = set_up();
install_subscriber_plugin(&set_up);
let return_code = dispatch(&set_up, "shirabe-unrelated-event");
assert_eq!(0, return_code);
assert_eq!("activate subscriber-v1\n", set_up.io.borrow().get_output());
}
|
