diff --git a/swap/src/network/request_response.rs b/swap/src/network/request_response.rs
index c1dbc73a..ab721f84 100644
--- a/swap/src/network/request_response.rs
+++ b/swap/src/network/request_response.rs
@@ -59,12 +59,12 @@ impl ProtocolName for EncryptedSignatureProtocol {
}
#[derive(Clone, Copy, Debug, Default)]
-pub struct OneShotCodec
{
+pub struct CborCodec
{
phantom: PhantomData
,
}
#[async_trait]
-impl
RequestResponseCodec for OneShotCodec
+impl
RequestResponseCodec for CborCodec
where
P: Send + Sync + Clone + ProtocolName,
{
diff --git a/swap/src/protocol/alice/encrypted_signature.rs b/swap/src/protocol/alice/encrypted_signature.rs
index 2b66dcd5..1c7cf0eb 100644
--- a/swap/src/protocol/alice/encrypted_signature.rs
+++ b/swap/src/protocol/alice/encrypted_signature.rs
@@ -1,6 +1,6 @@
use crate::{
network::request_response::{
- EncryptedSignatureProtocol, OneShotCodec, Request, Response, TIMEOUT,
+ CborCodec, EncryptedSignatureProtocol, Request, Response, TIMEOUT,
},
protocol::bob::EncryptedSignature,
};
@@ -30,7 +30,7 @@ pub enum OutEvent {
#[behaviour(out_event = "OutEvent", poll_method = "poll")]
#[allow(missing_debug_implementations)]
pub struct Behaviour {
- rr: RequestResponse>,
+ rr: RequestResponse>,
#[behaviour(ignore)]
events: VecDeque,
}
@@ -41,7 +41,7 @@ impl Behaviour {
_: &mut Context<'_>,
_: &mut impl PollParameters,
) -> Poll<
- NetworkBehaviourAction>, OutEvent>,
+ NetworkBehaviourAction>, OutEvent>,
> {
if let Some(event) = self.events.pop_front() {
return Poll::Ready(NetworkBehaviourAction::GenerateEvent(event));
@@ -59,7 +59,7 @@ impl Default for Behaviour {
Self {
rr: RequestResponse::new(
- OneShotCodec::default(),
+ CborCodec::default(),
vec![(EncryptedSignatureProtocol, ProtocolSupport::Inbound)],
config,
),
diff --git a/swap/src/protocol/alice/swap_response.rs b/swap/src/protocol/alice/swap_response.rs
index 98b23a51..be67f7a6 100644
--- a/swap/src/protocol/alice/swap_response.rs
+++ b/swap/src/protocol/alice/swap_response.rs
@@ -1,6 +1,6 @@
use crate::{
monero,
- network::request_response::{OneShotCodec, Request, Response, Swap, TIMEOUT},
+ network::request_response::{CborCodec, Request, Response, Swap, TIMEOUT},
protocol::bob,
};
use anyhow::{anyhow, Result};
@@ -37,7 +37,7 @@ pub struct SwapResponse {
#[behaviour(out_event = "OutEvent", poll_method = "poll")]
#[allow(missing_debug_implementations)]
pub struct Behaviour {
- rr: RequestResponse>,
+ rr: RequestResponse>,
#[behaviour(ignore)]
events: VecDeque,
}
@@ -55,7 +55,7 @@ impl Behaviour {
&mut self,
_: &mut Context<'_>,
_: &mut impl PollParameters,
- ) -> Poll>, OutEvent>> {
+ ) -> Poll>, OutEvent>> {
if let Some(event) = self.events.pop_front() {
return Poll::Ready(NetworkBehaviourAction::GenerateEvent(event));
}
@@ -73,7 +73,7 @@ impl Default for Behaviour {
Self {
rr: RequestResponse::new(
- OneShotCodec::default(),
+ CborCodec::default(),
vec![(Swap, ProtocolSupport::Inbound)],
config,
),
diff --git a/swap/src/protocol/alice/transfer_proof.rs b/swap/src/protocol/alice/transfer_proof.rs
index 422fa782..c37b4f0b 100644
--- a/swap/src/protocol/alice/transfer_proof.rs
+++ b/swap/src/protocol/alice/transfer_proof.rs
@@ -1,6 +1,6 @@
use crate::{
monero,
- network::request_response::{OneShotCodec, Request, Response, TransferProofProtocol, TIMEOUT},
+ network::request_response::{CborCodec, Request, Response, TransferProofProtocol, TIMEOUT},
};
use libp2p::{
request_response::{
@@ -34,7 +34,7 @@ pub enum OutEvent {
#[behaviour(out_event = "OutEvent", poll_method = "poll")]
#[allow(missing_debug_implementations)]
pub struct Behaviour {
- rr: RequestResponse>,
+ rr: RequestResponse>,
#[behaviour(ignore)]
events: VecDeque,
}
@@ -49,7 +49,7 @@ impl Behaviour {
&mut self,
_: &mut Context<'_>,
_: &mut impl PollParameters,
- ) -> Poll>, OutEvent>>
+ ) -> Poll>, OutEvent>>
{
if let Some(event) = self.events.pop_front() {
return Poll::Ready(NetworkBehaviourAction::GenerateEvent(event));
@@ -67,7 +67,7 @@ impl Default for Behaviour {
Self {
rr: RequestResponse::new(
- OneShotCodec::default(),
+ CborCodec::default(),
vec![(TransferProofProtocol, ProtocolSupport::Outbound)],
config,
),
diff --git a/swap/src/protocol/bob/encrypted_signature.rs b/swap/src/protocol/bob/encrypted_signature.rs
index cf167f36..c304d48a 100644
--- a/swap/src/protocol/bob/encrypted_signature.rs
+++ b/swap/src/protocol/bob/encrypted_signature.rs
@@ -1,5 +1,5 @@
use crate::network::request_response::{
- EncryptedSignatureProtocol, OneShotCodec, Request, Response, TIMEOUT,
+ CborCodec, EncryptedSignatureProtocol, Request, Response, TIMEOUT,
};
use libp2p::{
request_response::{
@@ -32,7 +32,7 @@ pub enum OutEvent {
#[behaviour(out_event = "OutEvent", poll_method = "poll")]
#[allow(missing_debug_implementations)]
pub struct Behaviour {
- rr: RequestResponse>,
+ rr: RequestResponse>,
#[behaviour(ignore)]
events: VecDeque,
}
@@ -48,7 +48,7 @@ impl Behaviour {
_: &mut Context<'_>,
_: &mut impl PollParameters,
) -> Poll<
- NetworkBehaviourAction>, OutEvent>,
+ NetworkBehaviourAction>, OutEvent>,
> {
if let Some(event) = self.events.pop_front() {
return Poll::Ready(NetworkBehaviourAction::GenerateEvent(event));
@@ -66,7 +66,7 @@ impl Default for Behaviour {
Self {
rr: RequestResponse::new(
- OneShotCodec::default(),
+ CborCodec::default(),
vec![(EncryptedSignatureProtocol, ProtocolSupport::Outbound)],
config,
),
diff --git a/swap/src/protocol/bob/swap_request.rs b/swap/src/protocol/bob/swap_request.rs
index ab84f506..c57790d0 100644
--- a/swap/src/protocol/bob/swap_request.rs
+++ b/swap/src/protocol/bob/swap_request.rs
@@ -1,5 +1,5 @@
use crate::{
- network::request_response::{OneShotCodec, Request, Response, Swap, TIMEOUT},
+ network::request_response::{CborCodec, Request, Response, Swap, TIMEOUT},
protocol::alice::SwapResponse,
};
use anyhow::Result;
@@ -35,7 +35,7 @@ pub struct OutEvent {
#[behaviour(out_event = "OutEvent", poll_method = "poll")]
#[allow(missing_debug_implementations)]
pub struct Behaviour {
- rr: RequestResponse>,
+ rr: RequestResponse>,
#[behaviour(ignore)]
events: VecDeque,
}
@@ -52,7 +52,7 @@ impl Behaviour {
&mut self,
_: &mut Context<'_>,
_: &mut impl PollParameters,
- ) -> Poll>, OutEvent>> {
+ ) -> Poll>, OutEvent>> {
if let Some(event) = self.events.pop_front() {
return Poll::Ready(NetworkBehaviourAction::GenerateEvent(event));
}
@@ -70,7 +70,7 @@ impl Default for Behaviour {
Self {
rr: RequestResponse::new(
- OneShotCodec::default(),
+ CborCodec::default(),
vec![(Swap, ProtocolSupport::Outbound)],
config,
),
diff --git a/swap/src/protocol/bob/transfer_proof.rs b/swap/src/protocol/bob/transfer_proof.rs
index 6caa3475..6746d7cc 100644
--- a/swap/src/protocol/bob/transfer_proof.rs
+++ b/swap/src/protocol/bob/transfer_proof.rs
@@ -1,5 +1,5 @@
use crate::{
- network::request_response::{OneShotCodec, Request, Response, TransferProofProtocol, TIMEOUT},
+ network::request_response::{CborCodec, Request, Response, TransferProofProtocol, TIMEOUT},
protocol::alice::TransferProof,
};
use libp2p::{
@@ -28,7 +28,7 @@ pub enum OutEvent {
#[behaviour(out_event = "OutEvent", poll_method = "poll")]
#[allow(missing_debug_implementations)]
pub struct Behaviour {
- rr: RequestResponse>,
+ rr: RequestResponse>,
#[behaviour(ignore)]
events: VecDeque,
}
@@ -38,7 +38,7 @@ impl Behaviour {
&mut self,
_: &mut Context<'_>,
_: &mut impl PollParameters,
- ) -> Poll>, OutEvent>>
+ ) -> Poll>, OutEvent>>
{
if let Some(event) = self.events.pop_front() {
return Poll::Ready(NetworkBehaviourAction::GenerateEvent(event));
@@ -56,7 +56,7 @@ impl Default for Behaviour {
Self {
rr: RequestResponse::new(
- OneShotCodec::default(),
+ CborCodec::default(),
vec![(TransferProofProtocol, ProtocolSupport::Inbound)],
config,
),