summaryrefslogtreecommitdiff
path: root/runtime/inspector.rs
diff options
context:
space:
mode:
authorLuca Casonato <lucacasonato@yahoo.com>2021-01-04 12:19:23 +0100
committerGitHub <noreply@github.com>2021-01-04 12:19:23 +0100
commit379eedc05c1a841557d8f0a9c2cd33ec3362d607 (patch)
tree4e5a86b26aedcf0bd4a47f5aeb746583c53d13ed /runtime/inspector.rs
parent1a6969bebbaaf2615b73a8582ba95be70a64c582 (diff)
Revert "fix(inspector): add back list endpoint (#8894)" (#8977)
This reverts commit 1a2e7741c33490d2a91147966019853c6b1d6a48.
Diffstat (limited to 'runtime/inspector.rs')
-rw-r--r--runtime/inspector.rs34
1 files changed, 15 insertions, 19 deletions
diff --git a/runtime/inspector.rs b/runtime/inspector.rs
index befaaebee..58df05c54 100644
--- a/runtime/inspector.rs
+++ b/runtime/inspector.rs
@@ -182,21 +182,20 @@ fn handle_ws_request(
.status(http::StatusCode::BAD_REQUEST)
.body("Not a valid Websocket Request".into()),
});
- if resp.is_ok() {
- tokio::task::spawn_local(async move {
- let upgraded = body.on_upgrade().await.unwrap();
- let websocket = tokio_tungstenite::WebSocketStream::from_raw_socket(
- upgraded,
- tungstenite::protocol::Role::Server,
- None,
- )
- .await;
- let (proxy, pump) = create_websocket_proxy(websocket);
+ tokio::task::spawn_local(async move {
+ let upgraded = body.on_upgrade().await.unwrap();
+ let websocket = tokio_tungstenite::WebSocketStream::from_raw_socket(
+ upgraded,
+ tungstenite::protocol::Role::Server,
+ None,
+ )
+ .await;
+ let (proxy, pump) = create_websocket_proxy(websocket);
+
+ let _ = new_websocket_tx.unbounded_send(proxy);
+ pump.await;
+ });
- let _ = new_websocket_tx.unbounded_send(proxy);
- pump.await;
- });
- }
resp
} else {
http::Response::builder()
@@ -276,14 +275,11 @@ async fn server(
(&http::Method::GET, path) if path.starts_with("/ws/") => {
handle_ws_request(req, inspector_map.clone())
}
- (&http::Method::GET, "/json/version") => {
- handle_json_version_request(json_version_response.clone())
- }
(&http::Method::GET, "/json") => {
handle_json_request(inspector_map.clone())
}
- (&http::Method::GET, "/json/list") => {
- handle_json_request(inspector_map.clone())
+ (&http::Method::GET, "/json/version") => {
+ handle_json_version_request(json_version_response.clone())
}
_ => http::Response::builder()
.status(http::StatusCode::NOT_FOUND)