fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-05-30 11:11:21 +00:00
Code Issues Projects Releases Wiki Activity

transports/websocket/: Update to soketto v0.7.0 #2271

Browse Source 
Co-authored-by: James Wilson <james@jsdw.me>
This commit is contained in:
Max Inden 2021-10-05 23:10:28 +02:00 committed by GitHub
parent e9ac6d2a6a
commit d60a6d55dc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
transports/websocket/Cargo.toml
View File

@ -17,7 +17,7 @@ libp2p-core = { version = "0.30.0", path = "../../core", default-features = fals
log = "0.4.8" log = "0.4.8"
quicksink = "0.1" quicksink = "0.1"
rw-stream-sink = "0.2.0" rw-stream-sink = "0.2.0"
soketto = { version = "0.4.1", features = ["deflate"] } soketto = { version = "0.7.0", features = ["deflate"] }
url = "2.1" url = "2.1"
webpki-roots = "0.21" webpki-roots = "0.21"

5
transports/websocket/src/framed.rs
View File

@ -205,13 +205,13 @@ where
.receive_request() .receive_request()
.map_err(|e| Error::Handshake(Box::new(e))) .map_err(|e| Error::Handshake(Box::new(e)))
.await?; .await?;
request.into_key() request.key()
}; };
trace!("accepting websocket handshake request from {}", remote2); trace!("accepting websocket handshake request from {}", remote2);
let response = handshake::server::Response::Accept { let response = handshake::server::Response::Accept {
key: &ws_key, key: ws_key,
protocol: None, protocol: None,
}; };
@ -583,6 +583,7 @@ where
Ok(soketto::Incoming::Pong(pong)) => { Ok(soketto::Incoming::Pong(pong)) => {
Some((Ok(IncomingData::Pong(Vec::from(pong))), (data, receiver))) Some((Ok(IncomingData::Pong(Vec::from(pong))), (data, receiver)))
} }
Ok(soketto::Incoming::Closed(_)) => None,
Err(connection::Error::Closed) => None, Err(connection::Error::Closed) => None,
Err(e) => Some((Err(e), (data, receiver))), Err(e) => Some((Err(e), (data, receiver))),
} }