feat: add ws msg ack to runner protocol

Author: MasterPtato

Cargo.lock

@@ -148,7 +148,7 @@ version = "4.3"
 features = ["derive"]
 
 [workspace.dependencies.rivet-term]
-git = "https://github.com/rivet-gg/rivet-term"
+git = "https://github.com/rivet-dev/rivet-term"
 rev = "55e328470b68c557fb9bc8298369f90182d35b6d"
 
 [workspace.dependencies.clickhouse]
@@ -249,7 +249,8 @@ default-features = false
 features = ["ansi","fmt","json","env-filter"]
 
 [workspace.dependencies.vbare]
-version = "0.0.2"
+git = "https://github.com/rivet-dev/vbare"
+rev = "3ae474a0234801bb96d70bec4eddd4f2d640971e"
 
 [workspace.dependencies.vbare-compiler]
 version = "0.0.2"

Cargo.toml

@@ -135,7 +135,7 @@ pub async fn send_message_to_address(
 	let client = rivet_pools::reqwest::client().await?;
 
 	// Create the request
-	let request = versioned::Request::latest(request);
+	let request = versioned::Request::wrap_latest(request);
 
 	// Send the request
 	let response_result = client

engine/artifacts/errors/guard.websocket_pending_limit_reached.json

@@ -30,5 +30,5 @@ pub async fn message(ctx: ApiCtx, path: VersionedPath, _query: (), body: Bytes)
 	// Process message directly using ops
 	let response = crate::replica::message_request::message_request(&ctx, request).await?;
 
-	versioned::Response::latest(response).serialize(path.version)
+	versioned::Response::wrap_latest(response).serialize(path.version)
 }

engine/artifacts/errors/guard.websocket_service_retry.json

@@ -52,7 +52,7 @@ impl FormalKey for LogEntryKey {
 	}
 
 	fn serialize(&self, value: Self::Value) -> Result<Vec<u8>> {
-		epoxy_protocol::versioned::LogEntry::latest(value)
+		epoxy_protocol::versioned::LogEntry::wrap_latest(value)
 			.serialize_with_embedded_version(epoxy_protocol::PROTOCOL_VERSION)
 	}
 }
@@ -162,7 +162,7 @@ impl FormalKey for ConfigKey {
 	}
 
 	fn serialize(&self, value: Self::Value) -> Result<Vec<u8>> {
-		epoxy_protocol::versioned::ClusterConfig::latest(value)
+		epoxy_protocol::versioned::ClusterConfig::wrap_latest(value)
 			.serialize_with_embedded_version(epoxy_protocol::PROTOCOL_VERSION)
 	}
 }
@@ -223,7 +223,7 @@ impl FormalKey for CurrentBallotKey {
 	}
 
 	fn serialize(&self, value: Self::Value) -> Result<Vec<u8>> {
-		epoxy_protocol::versioned::Ballot::latest(value)
+		epoxy_protocol::versioned::Ballot::wrap_latest(value)
 			.serialize_with_embedded_version(epoxy_protocol::PROTOCOL_VERSION)
 	}
 }
@@ -262,7 +262,7 @@ impl FormalKey for InstanceBallotKey {
 	}
 
 	fn serialize(&self, value: Self::Value) -> Result<Vec<u8>> {
-		epoxy_protocol::versioned::Ballot::latest(value)
+		epoxy_protocol::versioned::Ballot::wrap_latest(value)
 			.serialize_with_embedded_version(epoxy_protocol::PROTOCOL_VERSION)
 	}
 }

engine/artifacts/errors/guard.websocket_service_timeout.json

@@ -81,6 +81,14 @@ pub struct ServiceUnavailable;
 )]
 pub struct WebSocketServiceUnavailable;
 
+#[derive(RivetError, Serialize, Deserialize)]
+#[error("guard", "websocket_service_retry", "WebSocket service retry.")]
+pub struct WebSocketServiceRetry;
+
+#[derive(RivetError, Serialize, Deserialize)]
+#[error("guard", "websocket_service_timeout", "WebSocket service timed out.")]
+pub struct WebSocketServiceTimeout;
+
 #[derive(RivetError, Serialize, Deserialize)]
 #[error(
 	"guard",