Ecosystem/serai
Ecosystem/serai
1
0
Fork 0
mirror of https://github.com/serai-dex/serai.git synced 2025-01-10 21:04:40 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

cargo fmt

Browse source
This commit is contained in:
Luke Parker 2023-09-02 16:32:42 -04:00
parent bd9a05feef
commit 69c3fad7ce
No known key found for this signature in database
1 changed files with 10 additions and 22 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
processor/messages/src/lib.rs
View file

@ -21,7 +21,9 @@ pub struct SubstrateContext {
pub mod key_gen {
use super::*;
#[derive(Clone, Copy, PartialEq, Eq, Hash, Debug, Zeroize, Encode, Decode, Serialize, Deserialize)]
#[derive(
Clone, Copy, PartialEq, Eq, Hash, Debug, Zeroize, Encode, Decode, Serialize, Deserialize,
)]
pub struct KeyGenId {
pub set: ValidatorSet,
pub attempt: u32,
@ -276,9 +278,7 @@ impl CoordinatorMessage {
// Accordingly, the intent is a combination of plan ID and actual TX
// While transaction alone may suffice, that doesn't cover cross-chain TX ID conflicts,
// which are possible
sign::CoordinatorMessage::Completed { id, tx, .. } => {
(3, (id, tx).encode())
}
sign::CoordinatorMessage::Completed { id, tx, .. } => (3, (id, tx).encode()),
};
let mut res = vec![COORDINATOR_UID, TYPE_SIGN_UID, sub];
@ -288,15 +288,9 @@ impl CoordinatorMessage {
CoordinatorMessage::Coordinator(msg) => {
let (sub, id) = match msg {
// Unique since this embeds the batch ID (hash of it, including its network) and attempt
coordinator::CoordinatorMessage::BatchPreprocesses { id, .. } => {
(0, id.encode())
}
coordinator::CoordinatorMessage::BatchShares { id, .. } => {
(1, id.encode())
}
coordinator::CoordinatorMessage::BatchReattempt { id, .. } => {
(2, id.encode())
}
coordinator::CoordinatorMessage::BatchPreprocesses { id, .. } => (0, id.encode()),
coordinator::CoordinatorMessage::BatchShares { id, .. } => (1, id.encode()),
coordinator::CoordinatorMessage::BatchReattempt { id, .. } => (2, id.encode()),
};
let mut res = vec![COORDINATOR_UID, TYPE_COORDINATOR_UID, sub];
@ -306,9 +300,7 @@ impl CoordinatorMessage {
CoordinatorMessage::Substrate(msg) => {
let (sub, id) = match msg {
// Unique since there's only one key pair for a set
substrate::CoordinatorMessage::ConfirmKeyPair { set, .. } => {
(0, set.encode())
}
substrate::CoordinatorMessage::ConfirmKeyPair { set, .. } => (0, set.encode()),
substrate::CoordinatorMessage::SubstrateBlock { network, block, .. } => {
(1, (network, block).encode())
}
@ -362,12 +354,8 @@ impl ProcessorMessage {
(0, (network, block).encode())
}
// Unique since SignId
coordinator::ProcessorMessage::BatchPreprocess { id, .. } => {
(1, id.encode())
}
coordinator::ProcessorMessage::BatchShare { id, .. } => {
(2, id.encode())
}
coordinator::ProcessorMessage::BatchPreprocess { id, .. } => (1, id.encode()),
coordinator::ProcessorMessage::BatchShare { id, .. } => (2, id.encode()),
};
let mut res = vec![PROCESSSOR_UID, TYPE_COORDINATOR_UID, sub];