jerry/buzz
1
0
Fork 0
mirror of https://github.com/block/buzz.git synced 2026-10-31 22:41:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(relay): reject failed local event writes

Browse Source 
Signed-off-by: npub13n66s06epmqf2kc3v373ez8hj65cuzyvxzjf93vwpervxqn2u7jq2qd9je <8cf5a83f590ec0955b11647d1c88f796a98e088c30a492c58e0e46c3026ae7a4@buzz.block.builderlab.xyz>
This commit is contained in:
npub13n66s06epmqf2kc3v373ez8hj65cuzyvxzjf93vwpervxqn2u7jq2qd9je
2026-08-01 07:49:35 -04:00
committed by Brother Darryl
parent 30df44197a
commit 9a800d6d7e
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
crates/buzz-relay/src/local_mode.rs
View File

@@ -140,13 +140,18 @@ async fn serve_socket(socket: WebSocket, state: LocalState) {
continue;
}
};
let inserted = sqlx::query("INSERT OR IGNORE INTO events (id, event_json) VALUES (?, ?)")
let inserted = match sqlx::query("INSERT OR IGNORE INTO events (id, event_json) VALUES (?, ?)")
.bind(&id)
.bind(event_json)
.execute(&state.db)
.await
.map(|result| result.rows_affected() == 1)
.unwrap_or(false);
{
Ok(result) => result.rows_affected() == 1,
Err(error) => {
let _ = tx.send(Message::Text(RelayMessage::ok(&id, false, &format!("error: {error}")).into())).await;
continue;
}
};
if inserted { let _ = state.fanout.send(event); }
let _ = tx.send(Message::Text(RelayMessage::ok(&id, true, if inserted { "" } else { "duplicate" }).into())).await;
}