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

fix(db): use deref instead of clone on Copy type DateTime<Utc>

Browse Source 
Clippy clone_on_copy: DateTime<Utc> is Copy, dereference instead.
This commit is contained in:
Will Pfleger
2026-07-14 00:25:23 -04:00
parent ea6c2fc16c
commit f31b405fd5
1 changed files with 9 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
crates/buzz-db/src/lib.rs
View File

@@ -2939,16 +2939,15 @@ impl Db {
// Stale-write protection: reject if either durable ordering source
// dominates the incoming tuple. Equal timestamps use lowest event id.
let incoming_id = event.id.as_bytes().as_slice();
let existing_ordering = existing
.as_ref()
.map(|(ts, id, _)| (ts.clone(), id.clone()));
let dominated = existing_ordering
.iter()
.chain(watermark.iter())
.any(|(accepted_ts, accepted_id)| {
created_at < *accepted_ts
|| (created_at == *accepted_ts && incoming_id >= accepted_id.as_slice())
});
let existing_ordering = existing.as_ref().map(|(ts, id, _)| (*ts, id.clone()));
let dominated =
existing_ordering
.iter()
.chain(watermark.iter())
.any(|(accepted_ts, accepted_id)| {
created_at < *accepted_ts
|| (created_at == *accepted_ts && incoming_id >= accepted_id.as_slice())
});
if dominated {
tx.rollback().await?;
let received_at = chrono::Utc::now();