BASELINE=27a14c1cdd379598d57f7545a6d55fa3a2ea7ba4 NFF_COMMUNE_BUS_MUTATED_BODY: fn publish_commune_io(owner: &str, kind: &str, payload: &str) { let owlery = perch::owlery_dir(); // THE ASSEMBLY POINT, not a hand-rolled bus. This site used to build its own // `IoBus` and register the one sink it knew about — exactly the shape // [`crate::iobus::default_bus`]'s own doc says it exists to prevent, and the // cost was precise: COMMUNE and COMMUNE_FAIL never reached the adapter log, // so `spt api io-events` could not answer with two of the six kinds it // documents, forever and on every box. The funnel's claim that a new reader // costs one registration is only true while every publisher registers // through here (releases#234 respin). let mut bus = crate::iobus::IoBus::new(); NFF_COMMUNE_BUS_EXIT=100 FAIL [ 3.104s] (1/4) spt::io_events_undriven_kinds_e2e a_consumed_commune_reaches_the_log_and_polls_back test a_consumed_commune_reaches_the_log_and_polls_back ... FAILED test result: FAILED. 0 passed; 1 failed; 0 ignored; 0 measured; 3 filtered out; finished in 3.09s FAIL [ 1.428s] (2/4) spt::io_events_undriven_kinds_e2e a_failed_commune_ingest_polls_back_as_its_own_kind test a_failed_commune_ingest_polls_back_as_its_own_kind ... FAILED test result: FAILED. 0 passed; 1 failed; 0 ignored; 0 measured; 3 filtered out; finished in 1.41s PSYCHE_INGEST_FAIL:alice: ingest: Access is denied. (os error 5) right: ["COMMUNE_FAIL"] PASS [ 1.575s] (3/4) spt::io_events_undriven_kinds_e2e the_delivery_edge_polls_back_as_msg_in_on_the_receiver PASS [ 1.529s] (4/4) spt::io_events_undriven_kinds_e2e the_send_edge_polls_back_as_msg_out_on_the_sender FAIL [ 3.104s] (1/4) spt::io_events_undriven_kinds_e2e a_consumed_commune_reaches_the_log_and_polls_back FAIL [ 1.428s] (2/4) spt::io_events_undriven_kinds_e2e a_failed_commune_ingest_polls_back_as_its_own_kind NFF_COMMUNE_BUS_RESTORE=BYTE_IDENTICAL_vs_27a14c1cdd379598d57f7545a6d55fa3a2ea7ba4 NFF_COMMUNE_FAIL_MUTATED_BODY: // the event and the log can never disagree about // why. The drop FILE is untouched by this arm and // stays the on-disk diagnostic; the event is the // push signal that a silent failure just happened — // the measured gap being six PSYCHE_INGEST_FAIL // lines across three agents that nobody was told // about. // [impl->REQ-IO-COMMUNE-FAIL-EVENT] publish_commune_io( NFF_COMMUNE_FAIL_EXIT=100 PASS [ 2.929s] (1/4) spt::io_events_undriven_kinds_e2e a_consumed_commune_reaches_the_log_and_polls_back FAIL [ 1.411s] (2/4) spt::io_events_undriven_kinds_e2e a_failed_commune_ingest_polls_back_as_its_own_kind test a_failed_commune_ingest_polls_back_as_its_own_kind ... FAILED test result: FAILED. 0 passed; 1 failed; 0 ignored; 0 measured; 3 filtered out; finished in 1.40s PSYCHE_INGEST_FAIL:alice: ingest: Access is denied. (os error 5) right: ["COMMUNE_FAIL"] PASS [ 1.576s] (3/4) spt::io_events_undriven_kinds_e2e the_delivery_edge_polls_back_as_msg_in_on_the_receiver PASS [ 1.328s] (4/4) spt::io_events_undriven_kinds_e2e the_send_edge_polls_back_as_msg_out_on_the_sender FAIL [ 1.411s] (2/4) spt::io_events_undriven_kinds_e2e a_failed_commune_ingest_polls_back_as_its_own_kind NFF_COMMUNE_FAIL_RESTORE=BYTE_IDENTICAL_vs_27a14c1cdd379598d57f7545a6d55fa3a2ea7ba4 NFF_MSG_OUT_MUTATED_BODY: pub(crate) fn publish_msg_io(owner: &str, kind: &str, peer: &str, body: &str) { let owlery = perch::owlery_dir(); let mut bus = spt_daemon::iobus::IoBus::new(); bus.register(Box::new(spt_daemon::iobus::ShellLinkSink::new(&owlery))); // The PEER rides along (W5): LAST_MSGS answers "who", and this edge is the // one place that knows — a consumer reconstructing it downstream would be // guessing from a payload that never carried it. NFF_MSG_OUT_EXIT=100 PASS [ 3.203s] (1/4) spt::io_events_undriven_kinds_e2e a_consumed_commune_reaches_the_log_and_polls_back PASS [ 1.458s] (2/4) spt::io_events_undriven_kinds_e2e a_failed_commune_ingest_polls_back_as_its_own_kind PASS [ 1.556s] (3/4) spt::io_events_undriven_kinds_e2e the_delivery_edge_polls_back_as_msg_in_on_the_receiver FAIL [ 1.584s] (4/4) spt::io_events_undriven_kinds_e2e the_send_edge_polls_back_as_msg_out_on_the_sender test the_send_edge_polls_back_as_msg_out_on_the_sender ... FAILED test result: FAILED. 0 passed; 1 failed; 0 ignored; 0 measured; 3 filtered out; finished in 1.57s FAIL [ 1.584s] (4/4) spt::io_events_undriven_kinds_e2e the_send_edge_polls_back_as_msg_out_on_the_sender NFF_MSG_OUT_RESTORE=BYTE_IDENTICAL_vs_27a14c1cdd379598d57f7545a6d55fa3a2ea7ba4 NFF_MSG_IN_MUTATED_BODY: fn publish_msg_io_local(id: &str, kind: &str, peer: &str, body: &str) { let owlery = perch::owlery_dir(); let mut bus = spt_daemon::iobus::IoBus::new(); bus.register(Box::new(spt_daemon::iobus::ShellLinkSink::new(&owlery))); // The SENDER rides along (W5): LAST_MSGS answers "who", and this edge knows. let ev = spt_daemon::iobus::IoEvent::new(id, kind, body).with_peer(peer); for outcome in bus.publish(&ev) { NFF_MSG_IN_EXIT=100 PASS [ 2.970s] (1/4) spt::io_events_undriven_kinds_e2e a_consumed_commune_reaches_the_log_and_polls_back PASS [ 1.481s] (2/4) spt::io_events_undriven_kinds_e2e a_failed_commune_ingest_polls_back_as_its_own_kind FAIL [ 1.583s] (3/4) spt::io_events_undriven_kinds_e2e the_delivery_edge_polls_back_as_msg_in_on_the_receiver test the_delivery_edge_polls_back_as_msg_in_on_the_receiver ... FAILED test result: FAILED. 0 passed; 1 failed; 0 ignored; 0 measured; 3 filtered out; finished in 1.57s PASS [ 1.626s] (4/4) spt::io_events_undriven_kinds_e2e the_send_edge_polls_back_as_msg_out_on_the_sender FAIL [ 1.583s] (3/4) spt::io_events_undriven_kinds_e2e the_delivery_edge_polls_back_as_msg_in_on_the_receiver NFF_MSG_IN_RESTORE=BYTE_IDENTICAL_vs_27a14c1cdd379598d57f7545a6d55fa3a2ea7ba4 NFFMUT_DONE