Skip to content

Commit 3d2e43e

Browse files
committed
fix: use correct vbare functions for runner tunnel
1 parent e7e4a9e commit 3d2e43e

File tree

2 files changed

+12
-15
lines changed

2 files changed

+12
-15
lines changed

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

Lines changed: 11 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -33,20 +33,17 @@ pub async fn task(
3333
);
3434

3535
// Parse message
36-
let msg =
37-
match versioned::ToServer::deserialize_version(&data, conn.protocol_version)
38-
.and_then(|x| x.unwrap_latest())
39-
{
40-
Ok(x) => x,
41-
Err(err) => {
42-
tracing::warn!(
43-
?err,
44-
data_len = data.len(),
45-
"failed to deserialize message"
46-
);
47-
continue;
48-
}
49-
};
36+
let msg = match versioned::ToServer::deserialize(&data, conn.protocol_version) {
37+
Ok(x) => x,
38+
Err(err) => {
39+
tracing::warn!(
40+
?err,
41+
data_len = data.len(),
42+
"failed to deserialize message"
43+
);
44+
continue;
45+
}
46+
};
5047

5148
handle_message(&ctx, &conn, msg)
5249
.await

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,7 @@ pub async fn task(conn: Arc<Conn>, mut sub: Subscriber) -> Result<()> {
9292

9393
// Forward raw message to WebSocket
9494
let serialized_msg =
95-
match versioned::ToClient::wrap_latest(msg).serialize_version(conn.protocol_version) {
95+
match versioned::ToClient::wrap_latest(msg).serialize(conn.protocol_version) {
9696
Result::Ok(x) => x,
9797
Err(err) => {
9898
tracing::error!(?err, "failed to serialize tunnel message");

0 commit comments

Comments
 (0)