diff --git a/crates/onyx-core/src/sync.rs b/crates/onyx-core/src/sync.rs index 6bb626d..7d50be7 100644 --- a/crates/onyx-core/src/sync.rs +++ b/crates/onyx-core/src/sync.rs @@ -341,13 +341,7 @@ impl OfflineQueue { return Ok(()); } let content = serde_json::to_string_pretty(self)?; - // Atomic write: write to temp then rename - let temp_path = workspace_path.join(".syncqueue.json.tmp"); - std::fs::write(&temp_path, &content)?; - if let Err(e) = std::fs::rename(&temp_path, &queue_path) { - let _ = std::fs::remove_file(&temp_path); - return Err(e.into()); - } + atomic_write(&queue_path, content.as_bytes())?; Ok(()) }