Hare/yoi
1
1
Fork 0
Code Actions Packages Releases Activity

fix: initialize restored worker observations

Browse Source
This commit is contained in:
Keisuke Hirata 2026-06-28 04:46:08 +09:00
parent 2d59717384
commit 761b60c857
No known key found for this signature in database
1 changed files with 24 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
crates/worker-runtime/src/runtime.rs
View File

@ -937,6 +937,12 @@ impl RuntimeState {
config_bundles: persisted.config_bundles, config_bundles: persisted.config_bundles,
events: persisted.events, events: persisted.events,
diagnostics: persisted.diagnostics, diagnostics: persisted.diagnostics,
#[cfg(feature = "ws-server")]
next_observation_sequence: 1,
#[cfg(feature = "ws-server")]
observation_events: VecDeque::new(),
#[cfg(feature = "ws-server")]
observation_tx: broadcast::channel(256).0,
}) })
} }
@ -2051,6 +2057,24 @@ mod tests {
.unwrap(); .unwrap();
assert_eq!(direct_transcript.items[0].content, "second"); assert_eq!(direct_transcript.items[0].content, "second");
#[cfg(feature = "ws-server")]
{
let observation = restored
.observe_worker_event(
&worker.worker_ref,
protocol::Event::TextDelta {
text: "restored observation bus".to_string(),
},
)
.unwrap();
assert_eq!(observation.sequence, 1);
let observations = restored
.read_worker_observation_events(&worker.worker_ref, WorkerObservationCursor::zero())
.unwrap();
assert_eq!(observations.len(), 1);
assert_eq!(observations[0].cursor, observation.cursor);
}
let _ = std::fs::remove_dir_all(root); let _ = std::fs::remove_dir_all(root);
} }