jerry/buzz
1
0
Fork 0
mirror of https://github.com/block/buzz.git synced 2026-11-08 02:11:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(cli): pin sidebar sections head read to the writer

Browse Source 
The head read gates a full-snapshot publish, so a replica-routed read
could return a lagging or empty head and erase the caller's own
just-accepted edits. Send consistency: strong on the head query and
bind it in the fake relay.

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
Signed-off-by: Blake McAnally <bmcanally@squareup.com>
This commit is contained in:
Blake McAnally
2026-10-30 12:57:55 -05:00
parent 22a12bf079
commit ad4cca47e4
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
crates/buzz-cli/src/commands/sidebar.rs
View File

@@ -36,6 +36,9 @@ fn now() -> std::time::Duration {
/// The relay's current sections event for this identity, decoded. An absent
/// head is an empty tree; an unreadable one is an error, never an empty list.
/// The read is pinned to the writer (`consistency: strong`): a write derives a
/// full snapshot from it, and a lagging replica would drop the caller's own
/// just-accepted edits.
async fn fetch_head(client: &BuzzClient) -> Result<Head, CliError> {
let me = client.keys().public_key();
let filter = json!({
@@ -43,6 +46,7 @@ async fn fetch_head(client: &BuzzClient) -> Result<Head, CliError> {
"authors": [me.to_hex()],
"#d": [D_TAG],
"limit": 1,
"consistency": "strong",
});
let raw = client.query(&filter).await?;
let events: Vec<Value> = serde_json::from_str(&raw)
@@ -316,6 +320,7 @@ mod tests {
assert_eq!(filter["kinds"], json!([KIND_READ_STATE]));
assert_eq!(filter["#d"], json!([D_TAG]));
assert_eq!(filter["limit"], json!(1));
assert_eq!(filter["consistency"], json!("strong"));
let author = &filter["authors"][0];
let relay = relay.lock().unwrap();
let matching: Vec<_> = relay