Prevent to update stale updates

utxo/src/storage/sqlite/batch.rs

@@ -269,20 +269,38 @@ impl<'a> storage::Batch<'a> for Batch<'a> {
         .await
         .map_err(|e| Error::Storage(e.to_string()))?;
 
-        sqlx::query(
-            r#"
+        if let Some(previous) = transaction.previous() {
+            let r = sqlx::query(
+                r#"
+                UPDATE "transactions" SET "blob_id" = ?, "status" = ?
+                WHERE "transaction_id" = ? and "blob_id" = ?
+                "#,
+            )
+            .bind(transaction.current.to_string())
+            .bind(transaction.status().to_string())
+            .bind(transaction.id.to_string())
+            .bind(previous.to_string())
+            .execute(&mut *self.inner)
+            .await
+            .map_err(|e| Error::Storage(e.to_string()))?;
+
+            if r.rows_affected() == 0 {
+                return Err(Error::NoUpdate);
+            }
+        } else {
+            sqlx::query(
+                r#"
                 INSERT INTO "transactions"("transaction_id", "blob_id", "status")
                 VALUES(?, ?, ?)
-                ON CONFLICT("transaction_id")
-                    DO UPDATE SET "blob_id" = EXCLUDED."blob_id", "status" = EXCLUDED."status"
             "#,
-        )
-        .bind(transaction.id.to_string())
-        .bind(transaction.current.to_string())
-        .bind(transaction.status().to_string())
-        .execute(&mut *self.inner)
-        .await
-        .map_err(|e| Error::Storage(e.to_string()))?;
+            )
+            .bind(transaction.id.to_string())
+            .bind(transaction.current.to_string())
+            .bind(transaction.status().to_string())
+            .execute(&mut *self.inner)
+            .await
+            .map_err(|e| Error::Storage(e.to_string()))?;
+        }
 
         Ok(())
     }

utxo/src/transaction/inner.rs

@@ -211,6 +211,11 @@ impl Transaction {
         .try_into()
     }
 
+    /// Returns the previous revision of this transaction, if any
+    pub fn previous(&self) -> Option<RevisionId> {
+        self.inner.previous.clone()
+    }
+
     /// Returns a unique list of accounts involved in this transaction.
     ///
     /// Accounts are sorted and unique, and they include the accounts that spent and that receives