fix: use correct vbare functions for runner tunnel

Author: MasterPtato

engine/packages/epoxy/src/http_client.rs

@@ -135,12 +135,14 @@ pub async fn send_message_to_address(
 	let client = rivet_pools::reqwest::client().await?;
 
 	// Create the request
-	let request = versioned::Request::wrap_latest(request);
+	let request = versioned::Request::wrap_latest(request)
+		.serialize()
+		.context("failed to serialize epoxy request")?;
 
 	// Send the request
 	let response_result = client
 		.post(replica_url.to_string())
-		.body(request.serialize()?)
+		.body(request)
 		.send()
 		.custom_instrument(tracing::info_span!("http_request"))
 		.await;

engine/packages/epoxy/src/lib.rs

@@ -19,6 +19,7 @@ pub fn registry() -> WorkflowResult<Registry> {
 	let mut registry = Registry::new();
 	registry.register_workflow::<coordinator::Workflow>()?;
 	registry.register_workflow::<replica::Workflow>()?;
+	registry.register_workflow::<purger::Workflow>()?;
 
 	Ok(registry)
 }

engine/packages/pegboard-runner/src/client_to_pubsub_task.rs

@@ -33,20 +33,17 @@ pub async fn task(
 				);
 
 				// Parse message
-				let msg =
-					match versioned::ToServer::deserialize_version(&data, conn.protocol_version)
-						.and_then(|x| x.unwrap_latest())
-					{
-						Ok(x) => x,
-						Err(err) => {
-							tracing::warn!(
-								?err,
-								data_len = data.len(),
-								"failed to deserialize message"
-							);
-							continue;
-						}
-					};
+				let msg = match versioned::ToServer::deserialize(&data, conn.protocol_version) {
+					Ok(x) => x,
+					Err(err) => {
+						tracing::warn!(
+							?err,
+							data_len = data.len(),
+							"failed to deserialize message"
+						);
+						continue;
+					}
+				};
 
 				handle_message(&ctx, &conn, msg)
 					.await

engine/packages/pegboard-runner/src/pubsub_to_client_task.rs

@@ -92,7 +92,7 @@ pub async fn task(conn: Arc<Conn>, mut sub: Subscriber) -> Result<()> {
 
 		// Forward raw message to WebSocket
 		let serialized_msg =
-			match versioned::ToClient::wrap_latest(msg).serialize_version(conn.protocol_version) {
+			match versioned::ToClient::wrap_latest(msg).serialize(conn.protocol_version) {
 				Result::Ok(x) => x,
 				Err(err) => {
 					tracing::error!(?err, "failed to serialize tunnel message");