chore(release): update version to 2.3.0-rc.5

Author: NathanFlurry

Cargo.lock

@@ -71,7 +71,7 @@ members = [
 ]
 
   [workspace.package]
-  version = "2.3.0-rc.4"
+  version = "2.3.0-rc.5"
   edition = "2024"
   authors = [ "Rivet Gaming, LLC <developer@rivet.gg>" ]
   license = "Apache-2.0"

Cargo.toml

@@ -860,10 +860,12 @@ impl VfsState {
 		if !can_read_cached_page(config, pgno) {
 			return None;
 		}
-		self
-			.committed_page_cache
+		self.committed_page_cache
 			.get(&pgno)
-			.or_else(|| self.protected_page_cache.read_sync(&pgno, |_, bytes| bytes.clone()))
+			.or_else(|| {
+				self.protected_page_cache
+					.read_sync(&pgno, |_, bytes| bytes.clone())
+			})
 			.or_else(|| self.page_cache.get(&pgno))
 	}
 

engine/artifacts/openapi.json

@@ -649,11 +649,13 @@ impl FaultScenarioCtx {
 					*candidate_pgno / depot::keys::SHARD_SIZE == pgno / depot::keys::SHARD_SIZE
 				})
 				.map(|candidate_pgno| {
-					let bytes = state.cached_page(&ctx.config, candidate_pgno).with_context(|| {
-						format!(
-							"page {candidate_pgno} should be present in VFS cache before cold-ref seed"
-						)
-					})?;
+					let bytes = state
+						.cached_page(&ctx.config, candidate_pgno)
+						.with_context(|| {
+							format!(
+								"page {candidate_pgno} should be present in VFS cache before cold-ref seed"
+							)
+						})?;
 					Ok(DirtyPage {
 						pgno: candidate_pgno,
 						bytes,

engine/packages/depot-client/src/vfs.rs

@@ -65,10 +65,7 @@ fn vfs_config_wires_optimization_flags() {
 		config.cache_capacity_pages,
 		DEFAULT_VFS_PAGE_CACHE_CAPACITY_PAGES / 2
 	);
-	assert_eq!(
-		config.protected_cache_pages,
-		0
-	);
+	assert_eq!(config.protected_cache_pages, 0);
 	assert_eq!(
 		config.staging_cache_ttl_ms,
 		DEFAULT_VFS_STAGING_CACHE_TTL_MS / 2
@@ -425,13 +422,12 @@ fn open_worker_handle_with_vfs(
 		)
 		.expect("worker vfs should register"),
 	);
-	let db =
-		crate::database::NativeDatabaseHandle::new_with_metrics(
-			vfs.clone(),
-			harness.actor_id.clone(),
-			metrics,
-		)
-		.expect("worker handle should start");
+	let db = crate::database::NativeDatabaseHandle::new_with_metrics(
+		vfs.clone(),
+		harness.actor_id.clone(),
+		metrics,
+	)
+	.expect("worker handle should start");
 	(vfs, db)
 }
 
@@ -3555,7 +3551,9 @@ fn resolve_pages_sends_known_head_txid_as_read_fence() {
 	ctx.resolve_pages(&[2], false)
 		.expect("read should fetch from transport");
 	let requests = hooks.get_pages_requests();
-	let request = requests.last().expect("get_pages request should be recorded");
+	let request = requests
+		.last()
+		.expect("get_pages request should be recorded");
 	assert_eq!(request.expected_head_txid, Some(7));
 }
 
@@ -3573,7 +3571,10 @@ fn fatal_sqlite_error_reports_first_message_through_worker_boundary() {
 	ctx.mark_fatal("second fatal sqlite error".to_string());
 
 	assert!(ctx.is_dead());
-	assert_eq!(ctx.clone_fatal_error().as_deref(), Some("first fatal sqlite error"));
+	assert_eq!(
+		ctx.clone_fatal_error().as_deref(),
+		Some("first fatal sqlite error")
+	);
 
 	let err = runtime
 		.block_on(db.exec("SELECT 1;".to_string()))

engine/packages/depot-client/tests/inline/fault/scenario.rs

@@ -351,7 +351,9 @@ impl DirectStorage {
 
 		let actor_db = self.actor_db(actor_id.to_string()).await;
 		self.counters.depot_get_pages.fetch_add(1, Ordering::SeqCst);
-		actor_db.get_pages_with_options(pgnos.to_vec(), options).await
+		actor_db
+			.get_pages_with_options(pgnos.to_vec(), options)
+			.await
 	}
 
 	pub(crate) async fn read_mirror(
@@ -437,7 +439,11 @@ impl SqliteTransport for DirectDepotTransport {
 		{
 			Ok(result) => Ok(protocol::SqliteGetPagesResponse::SqliteGetPagesOk(
 				protocol::SqliteGetPagesOk {
-					pages: result.pages.into_iter().map(protocol_fetched_page).collect(),
+					pages: result
+						.pages
+						.into_iter()
+						.map(protocol_fetched_page)
+						.collect(),
 					head_txid: Some(result.head_txid),
 				},
 			)),
@@ -544,9 +550,7 @@ impl SqliteTransport for DirectMirrorTransport {
 			.await
 		{
 			Ok(()) => Ok(protocol::SqliteCommitResponse::SqliteCommitOk(
-				protocol::SqliteCommitOk {
-					head_txid: None,
-				},
+				protocol::SqliteCommitOk { head_txid: None },
 			)),
 			Err(err) => Ok(protocol::SqliteCommitResponse::SqliteErrorResponse(
 				sqlite_error_response(&err),

engine/packages/depot-client/tests/inline/vfs.rs

@@ -48,14 +48,9 @@ impl Db {
 		db_size_pages: u32,
 		now_ms: i64,
 	) -> Result<()> {
-		self.commit_with_options(
-			dirty_pages,
-			db_size_pages,
-			now_ms,
-			CommitOptions::default(),
-		)
-		.await
-		.map(|_| ())
+		self.commit_with_options(dirty_pages, db_size_pages, now_ms, CommitOptions::default())
+			.await
+			.map(|_| ())
 	}
 
 	pub async fn commit_with_options(

engine/packages/depot-client/tests/inline/vfs_support.rs

@@ -319,60 +319,63 @@ async fn commit_head_fence_rejects_stale_writer() -> Result<()> {
 
 #[tokio::test]
 async fn get_pages_head_fence_rejects_stale_reader() -> Result<()> {
-	commit_matrix!("depot-get-pages-head-fence-stale", |ctx, db, database_db| {
-		let _ = &db;
-		let first = database_db
-			.commit_with_options(
-				vec![page(1, 0x11)],
-				1,
-				1_000,
-				CommitOptions {
-					expected_head_txid: Some(0),
-				},
-			)
-			.await?;
-		assert_eq!(first.head_txid, 1);
-
-		let read = database_db
-			.get_pages_with_options(
-				vec![1],
-				GetPagesOptions {
-					expected_head_txid: Some(1),
-				},
-			)
-			.await?;
-		assert_eq!(read.head_txid, 1);
-		assert_eq!(read.pages, vec![fetched_page(1, 0x11)]);
-
-		let second = database_db
-			.commit_with_options(
-				vec![page(1, 0x22)],
-				1,
-				1_001,
-				CommitOptions {
-					expected_head_txid: Some(1),
-				},
-			)
-			.await?;
-		assert_eq!(second.head_txid, 2);
-
-		let err = database_db
-			.get_pages_with_options(
-				vec![1],
-				GetPagesOptions {
-					expected_head_txid: Some(1),
-				},
-			)
-			.await
-			.expect_err("stale reader should be rejected");
-		assert!(
-			err.chain()
-				.any(|source| source.to_string().contains("head fence mismatch")),
-			"unexpected error: {err:#}"
-		);
+	commit_matrix!(
+		"depot-get-pages-head-fence-stale",
+		|ctx, db, database_db| {
+			let _ = &db;
+			let first = database_db
+				.commit_with_options(
+					vec![page(1, 0x11)],
+					1,
+					1_000,
+					CommitOptions {
+						expected_head_txid: Some(0),
+					},
+				)
+				.await?;
+			assert_eq!(first.head_txid, 1);
+
+			let read = database_db
+				.get_pages_with_options(
+					vec![1],
+					GetPagesOptions {
+						expected_head_txid: Some(1),
+					},
+				)
+				.await?;
+			assert_eq!(read.head_txid, 1);
+			assert_eq!(read.pages, vec![fetched_page(1, 0x11)]);
+
+			let second = database_db
+				.commit_with_options(
+					vec![page(1, 0x22)],
+					1,
+					1_001,
+					CommitOptions {
+						expected_head_txid: Some(1),
+					},
+				)
+				.await?;
+			assert_eq!(second.head_txid, 2);
+
+			let err = database_db
+				.get_pages_with_options(
+					vec![1],
+					GetPagesOptions {
+						expected_head_txid: Some(1),
+					},
+				)
+				.await
+				.expect_err("stale reader should be rejected");
+			assert!(
+				err.chain()
+					.any(|source| source.to_string().contains("head fence mismatch")),
+				"unexpected error: {err:#}"
+			);
 
-		Ok(())
-	})
+			Ok(())
+		}
+	)
 }
 
 #[tokio::test]

engine/packages/depot/src/conveyer/commit/apply.rs

@@ -109,19 +109,11 @@ pub struct ServiceUnavailable;
 pub struct ActorStoppedWhileWaiting;
 
 #[derive(RivetError, Serialize, Deserialize)]
-#[error(
-	"guard",
-	"tunnel_request_aborted",
-	"Actor tunnel aborted the request."
-)]
+#[error("guard", "tunnel_request_aborted", "Actor tunnel aborted the request.")]
 pub struct TunnelRequestAborted;
 
 #[derive(RivetError, Serialize, Deserialize)]
-#[error(
-	"guard",
-	"tunnel_message_timeout",
-	"Actor tunnel message timed out."
-)]
+#[error("guard", "tunnel_message_timeout", "Actor tunnel message timed out.")]
 pub struct TunnelMessageTimeout;
 
 #[derive(RivetError, Serialize, Deserialize)]