From a2e2619ced0fe703c780ca703348402b4946f041 Mon Sep 17 00:00:00 2001 From: Franck Royer Date: Thu, 4 Feb 2021 11:49:13 +1100 Subject: [PATCH] Rename bob::Message1 to Message2 As per sequence diagram. --- swap/src/network/request_response.rs | 4 ++-- swap/src/protocol/alice/execution_setup.rs | 8 ++++---- swap/src/protocol/alice/state.rs | 4 ++-- swap/src/protocol/bob.rs | 2 +- swap/src/protocol/bob/execution_setup.rs | 8 ++++---- swap/src/protocol/bob/state.rs | 6 +++--- 6 files changed, 16 insertions(+), 16 deletions(-) diff --git a/swap/src/network/request_response.rs b/swap/src/network/request_response.rs index 47c97e30..64775e74 100644 --- a/swap/src/network/request_response.rs +++ b/swap/src/network/request_response.rs @@ -2,7 +2,7 @@ use crate::protocol::{ alice, alice::{Message3, TransferProof}, bob, - bob::{EncryptedSignature, Message4}, + bob::{EncryptedSignature, Message2, Message4}, }; use async_trait::async_trait; use futures::prelude::*; @@ -27,7 +27,7 @@ pub const BUF_SIZE: usize = 1024 * 1024; pub enum BobToAlice { SwapRequest(Box), Message0(Box), - Message1(Box), + Message2(Box), Message4(Box), } diff --git a/swap/src/protocol/alice/execution_setup.rs b/swap/src/protocol/alice/execution_setup.rs index e799d067..8e698058 100644 --- a/swap/src/protocol/alice/execution_setup.rs +++ b/swap/src/protocol/alice/execution_setup.rs @@ -6,7 +6,7 @@ use crate::{ protocol::{ alice::{State0, State3}, bob, - bob::Message4, + bob::{Message2, Message4}, }, }; use anyhow::{Context, Error, Result}; @@ -82,11 +82,11 @@ impl Behaviour { .await?; let state2 = { - let bob_message1 = serde_cbor::from_slice::( + let message2 = serde_cbor::from_slice::( &substream.read_message(BUF_SIZE).await?, ) - .context("failed to deserialize message1")?; - state1.receive(bob_message1) + .context("failed to deserialize message2")?; + state1.receive(message2) }; { diff --git a/swap/src/protocol/alice/state.rs b/swap/src/protocol/alice/state.rs index d3050647..2f439cc4 100644 --- a/swap/src/protocol/alice/state.rs +++ b/swap/src/protocol/alice/state.rs @@ -11,7 +11,7 @@ use crate::{ alice, alice::{Message3, TransferProof}, bob, - bob::{EncryptedSignature, Message4}, + bob::{EncryptedSignature, Message2, Message4}, SwapAmounts, }, }; @@ -197,7 +197,7 @@ pub struct State1 { } impl State1 { - pub fn receive(self, msg: bob::Message1) -> State2 { + pub fn receive(self, msg: Message2) -> State2 { State2 { a: self.a, B: self.B, diff --git a/swap/src/protocol/bob.rs b/swap/src/protocol/bob.rs index cb151d8d..84e118cb 100644 --- a/swap/src/protocol/bob.rs +++ b/swap/src/protocol/bob.rs @@ -26,7 +26,7 @@ pub use self::{ swap::{run, run_until}, swap_request::*, }; -pub use execution_setup::{Message0, Message1, Message4}; +pub use execution_setup::{Message0, Message2, Message4}; mod encrypted_signature; pub mod event_loop; diff --git a/swap/src/protocol/bob/execution_setup.rs b/swap/src/protocol/bob/execution_setup.rs index 6f024835..9f90c862 100644 --- a/swap/src/protocol/bob/execution_setup.rs +++ b/swap/src/protocol/bob/execution_setup.rs @@ -24,7 +24,7 @@ pub struct Message0 { } #[derive(Clone, Debug, Serialize, Deserialize)] -pub struct Message1 { +pub struct Message2 { pub(crate) tx_lock: crate::bitcoin::TxLock, } @@ -90,11 +90,11 @@ impl Behaviour { .receive(bitcoin_wallet.as_ref(), alice_message0) .await?; { - let bob_message1 = state1.next_message(); + let message2 = state1.next_message(); substream .write_message( - &serde_cbor::to_vec(&bob_message1) - .context("failed to serialize Message1")?, + &serde_cbor::to_vec(&message2) + .context("failed to serialize message2")?, ) .await?; } diff --git a/swap/src/protocol/bob/state.rs b/swap/src/protocol/bob/state.rs index 11a3c99e..7ccc4452 100644 --- a/swap/src/protocol/bob/state.rs +++ b/swap/src/protocol/bob/state.rs @@ -13,7 +13,7 @@ use crate::{ alice, alice::Message3, bob, - bob::{EncryptedSignature, Message4}, + bob::{EncryptedSignature, Message2, Message4}, SwapAmounts, }, }; @@ -189,8 +189,8 @@ pub struct State1 { } impl State1 { - pub fn next_message(&self) -> bob::Message1 { - bob::Message1 { + pub fn next_message(&self) -> Message2 { + Message2 { tx_lock: self.tx_lock.clone(), } }