fix(cache): fix recursive cache purges (#3221)

* feat(engine): add RocksDB engine run script

* fix(udb): fix rocksdb conflict tracker

* chore: bump version to 25.8.0

---------

Co-authored-by: MasterPtato <[email protected]>

Author: NathanFlurry

packages/common/cache/build/src/req_config.rs

@@ -320,6 +320,31 @@ impl RequestConfig {
 			}
 		}
 
+		// Delete keys locally
+		let raw_keys = cache_keys
+			.into_iter()
+			.map(RawCacheKey::from)
+			.collect::<Vec<_>>();
+		self.purge_local(base_key, raw_keys).await
+	}
+
+	/// Purges keys from the local cache without publishing to NATS.
+	/// This is used by the cache-purge service to avoid recursive publishing.
+	#[tracing::instrument(err, skip(keys))]
+	pub async fn purge_local(
+		self,
+		base_key: impl AsRef<str> + Debug,
+		keys: Vec<RawCacheKey>,
+	) -> Result<()> {
+		let base_key = base_key.as_ref();
+
+		if keys.is_empty() {
+			return Ok(());
+		}
+
+		// Convert RawCacheKey to String for driver
+		let cache_keys = keys.into_iter().map(|k| k.cache_key()).collect::<Vec<_>>();
+
 		// Delete keys locally
 		match self.cache.driver.delete_keys(base_key, cache_keys).await {
 			Ok(_) => {

packages/services/cache-purge/src/lib.rs

@@ -26,11 +26,11 @@ pub async fn start(config: rivet_config::Config, pools: rivet_pools::Pools) -> R
 					"received cache purge request"
 				);
 
-				// Purge the cache locally
+				// Purge the cache locally without publishing to NATS again
 				if let Err(err) = cache
 					.clone()
 					.request()
-					.purge(&purge_msg.base_key, purge_msg.keys)
+					.purge_local(&purge_msg.base_key, purge_msg.keys)
 					.await
 				{
 					tracing::error!(?err, base_key = ?purge_msg.base_key, "failed to purge cache");