Git-Mirrors/xmr-btc-swap
1
0
Fork 0
mirror of https://github.com/comit-network/xmr-btc-swap.git synced 2024-10-01 01:45:40 -04:00
Code Issues Packages Projects Releases Wiki Activity

make happy path pass

Browse Source
This commit is contained in:
Daniel Karzel 2021-06-25 12:11:37 +10:00
parent d4f9acc1b1
commit f9c03fa335
No known key found for this signature in database
GPG Key ID: 30C3FC2E438ADB6E
3 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
swap/src/network/swap_setup.rs
View File

@ -101,7 +101,7 @@ where
T: Serialize,
{
let bytes = serde_cbor::to_vec(&message)?;
upgrade::write_one(substream, &bytes).await?;
upgrade::write_with_len_prefix(substream, &bytes).await?;
Ok(())
}

15
swap/src/protocol/alice/swap_setup.rs
View File

@ -444,8 +444,13 @@ where
Self::Error,
>,
> {
if let Some(event) = self.events.pop_front() {
return Poll::Ready(ProtocolsHandlerEvent::Custom(event));
}
if let Some(result) = futures::ready!(self.inbound_stream.poll_unpin(cx)) {
self.keep_alive = KeepAlive::No;
self.inbound_stream = OptionFuture::from(None);
return Poll::Ready(ProtocolsHandlerEvent::Custom(HandlerOutEvent::Completed(
result,
)));
@ -478,17 +483,17 @@ pub enum Error {
},
#[error("Failed to fetch latest rate")]
LatestRateFetchFailed(#[source] Box<dyn std::error::Error + Send + Sync + 'static>),
#[error("Failed to calculate quote: {0}")]
#[error("Failed to calculate quote")]
SellQuoteCalculationFailed(#[source] anyhow::Error),
#[error("Blockchain networks did not match, we are on {asb:?}, but request from {cli:?}")]
BlockchainNetworkMismatch {
cli: BlockchainNetwork,
asb: BlockchainNetwork,
},
#[error("Io Error: {0}")]
Io(anyhow::Error),
#[error("Failed to request wallet snapshot: {0}")]
WalletSnapshotFailed(anyhow::Error),
#[error("Io Error")]
Io(#[source] anyhow::Error),
#[error("Failed to request wallet snapshot")]
WalletSnapshotFailed(#[source] anyhow::Error),
#[error("Failed to complete execution setup within {seconds}s")]
Timeout { seconds: u64 },
}

1
swap/src/protocol/bob/swap_setup.rs
View File

@ -238,6 +238,7 @@ impl ProtocolsHandler for Handler {
if let Some(result) = futures::ready!(self.outbound_stream.poll_unpin(cx)) {
self.keep_alive = KeepAlive::No;
self.outbound_stream = OptionFuture::from(None);
return Poll::Ready(ProtocolsHandlerEvent::Custom(Completed(result)));
}