Skip to content

Commit

Permalink
using RpcVersion::v08 to serialize subscription ID
Browse files Browse the repository at this point in the history
  • Loading branch information
vbar committed Jan 22, 2025
1 parent 9821042 commit a977074
Showing 1 changed file with 11 additions and 11 deletions.
22 changes: 11 additions & 11 deletions crates/rpc/src/method/subscribe_transaction_status.rs
Original file line number Diff line number Diff line change
Expand Up @@ -461,7 +461,7 @@ mod tests {
"finality_status": "RECEIVED",
}
},
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V07)).unwrap(),
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V08)).unwrap(),
}
}),
serde_json::json!({
Expand Down Expand Up @@ -562,7 +562,7 @@ mod tests {
"execution_status": "SUCCEEDED",
}
},
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V07)).unwrap(),
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V08)).unwrap(),
}
})
);
Expand Down Expand Up @@ -591,7 +591,7 @@ mod tests {
"finality_status": "RECEIVED",
}
},
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V07)).unwrap(),
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V08)).unwrap(),
}
}),
serde_json::json!({
Expand All @@ -606,7 +606,7 @@ mod tests {
"failure_reason": "tx revert"
}
},
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V07)).unwrap(),
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V08)).unwrap(),
}
}),
]
Expand Down Expand Up @@ -636,7 +636,7 @@ mod tests {
"finality_status": "RECEIVED",
}
},
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V07)).unwrap(),
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V08)).unwrap(),
}
}),
serde_json::json!({
Expand All @@ -650,7 +650,7 @@ mod tests {
"execution_status": "SUCCEEDED"
}
},
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V07)).unwrap(),
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V08)).unwrap(),
}
}),
serde_json::json!({
Expand All @@ -664,7 +664,7 @@ mod tests {
"execution_status": "SUCCEEDED"
}
},
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V07)).unwrap(),
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V08)).unwrap(),
}
}),
]
Expand Down Expand Up @@ -696,7 +696,7 @@ mod tests {
"finality_status": "RECEIVED",
}
},
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V07)).unwrap(),
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V08)).unwrap(),
}
}),
serde_json::json!({
Expand All @@ -711,7 +711,7 @@ mod tests {
"failure_reason": "tx revert"
}
},
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V07)).unwrap(),
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V08)).unwrap(),
}
}),
serde_json::json!({
Expand All @@ -726,7 +726,7 @@ mod tests {
"failure_reason": "tx revert"
}
},
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V07)).unwrap(),
"subscription_id": subscription_id.serialize(Serializer::new(RpcVersion::V08)).unwrap(),
}
}),
]
Expand Down Expand Up @@ -1105,7 +1105,7 @@ mod tests {
_ => panic!("Expected text message"),
};

let subscription_id = crate::dto::Value::new(subscription_id, RpcVersion::V07);
let subscription_id = crate::dto::Value::new(subscription_id, RpcVersion::V08);
let subscription_id: SubscriptionId = subscription_id.deserialize().unwrap();
for msg in expected(subscription_id) {
let status = sender_rx.recv().await.unwrap().unwrap();
Expand Down

0 comments on commit a977074

Please sign in to comment.