Compare commits

2 Commits

Author SHA1 Message Date
cuddle-please
35d579819c chore(release): 0.2.0
All checks were successful
continuous-integration/drone/push Build is passing
2025-09-25 08:49:47 +00:00
271823e278 feat: reset after failure
Some checks failed
continuous-integration/drone/push Build is failing
Signed-off-by: kjuulh <contact@kjuulh.io>
2025-09-25 10:49:29 +02:00
2 changed files with 18 additions and 9 deletions

View File

@@ -9,6 +9,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
## [0.2.0] - 2025-09-25 ## [0.2.0] - 2025-09-25
### Added ### Added
- reset after failure
- print as well - print as well
- add publish - add publish
- add features for nats and postgres - add features for nats and postgres

View File

@@ -144,18 +144,22 @@ impl BackendEdge for PostgresBackend {
let res = match res { let res = match res {
Ok(res) => res, Ok(res) => res,
Err(e) => match &e { Err(e) => {
sqlx::Error::Database(database_error) => { self.revision.store(0, Ordering::Relaxed);
if database_error.is_unique_violation() {
anyhow::bail!("update conflict: another leader holds lock") match &e {
} else { sqlx::Error::Database(database_error) => {
if database_error.is_unique_violation() {
anyhow::bail!("update conflict: another leader holds lock")
} else {
anyhow::bail!(e);
}
}
_ => {
anyhow::bail!(e); anyhow::bail!(e);
} }
} }
_ => { }
anyhow::bail!(e);
}
},
}; };
match res { match res {
@@ -170,6 +174,8 @@ impl BackendEdge for PostgresBackend {
// Only update our local revision if the update succeeded with our expected value // Only update our local revision if the update succeeded with our expected value
self.revision.store(rec.revision as u64, Ordering::Relaxed); self.revision.store(rec.revision as u64, Ordering::Relaxed);
} else { } else {
self.revision.store(0, Ordering::Relaxed);
anyhow::bail!( anyhow::bail!(
"update conflict: expected value={}, revision={}, got value={}, revision={}", "update conflict: expected value={}, revision={}, got value={}, revision={}",
val.0.to_string(), val.0.to_string(),
@@ -207,6 +213,8 @@ impl BackendEdge for PostgresBackend {
.await .await
.context("failed to release lock, it will expire naturally")?; .context("failed to release lock, it will expire naturally")?;
self.revision.store(0, Ordering::Relaxed);
Ok(()) Ok(())
} }
} }