Breadway/bread
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

test: stop emitting reserved bread.reload.* from the reload-storm test
Some checks failed
check / check (push) Failing after 3m23s
Details

Browse source 
`daemon_survives_repeated_reloads_and_pipeline_resumes` manually emitted
`bread.reload.before` / `.after`. Since "Allow well-formed bread.command
events on the emit bus" tightened the normalizer, a manual emit of an
adapter-owned domain (`reload`) is rejected, so this test — and every
push to main since — failed at the test step, blocking the dev-track
publish.

The event names are incidental here; the test only checks that events
flow through the pipeline before and after a reload storm. Renamed to
`bread.reloadtest.*` (a non-reserved domain).
This commit is contained in:
Breadway 2026-08-31 19:55:31 +08:00
parent c97029f654
commit 7286b49457
1 changed files with 8 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

12
breadd/tests/ipc_integration.rs
View file

@ -822,9 +822,13 @@ async fn daemon_survives_repeated_reloads_and_pipeline_resumes() -> Result<()> {
let harness = TestHarness::spawn()?; let harness = TestHarness::spawn()?;
harness.wait_until_ready().await?; harness.wait_until_ready().await?;
// Event emitted before any reload. // Event emitted before any reload. A non-reserved event name: `reload` is
// an adapter-owned domain, so a manual `emit` of `bread.reload.*` is now
// rejected by the normalizer (see "Allow well-formed bread.command events
// on the emit bus"). The name here is incidental — this test only cares
// that events flow through the pipeline before and after a reload storm.
harness harness
.send_request("emit", json!({"event": "bread.reload.before", "data": {}})) .send_request("emit", json!({"event": "bread.reloadtest.before", "data": {}}))
.await?; .await?;
// Hammer reload: each cycle drops and rebuilds the Lua VM, cancels timers, // Hammer reload: each cycle drops and rebuilds the Lua VM, cancels timers,
@ -845,7 +849,7 @@ async fn daemon_survives_repeated_reloads_and_pipeline_resumes() -> Result<()> {
// The pipeline must have resumed: an event emitted *after* the reloads // The pipeline must have resumed: an event emitted *after* the reloads
// still flows through normalization into the replay buffer. // still flows through normalization into the replay buffer.
harness harness
.send_request("emit", json!({"event": "bread.reload.after", "data": {}})) .send_request("emit", json!({"event": "bread.reloadtest.after", "data": {}}))
.await?; .await?;
sleep(Duration::from_millis(100)).await; sleep(Duration::from_millis(100)).await;
@ -859,7 +863,7 @@ async fn daemon_survives_repeated_reloads_and_pipeline_resumes() -> Result<()> {
.filter_map(|e| e.get("event").and_then(Value::as_str)) .filter_map(|e| e.get("event").and_then(Value::as_str))
.collect(); .collect();
assert!( assert!(
names.contains(&"bread.reload.after"), names.contains(&"bread.reloadtest.after"),
"event pipeline did not resume after reload; got {names:?}" "event pipeline did not resume after reload; got {names:?}"
); );