Remove ping responses
This commit is contained in:
parent
3d91cca7c6
commit
4a6331c71f
@ -20,4 +20,4 @@
|
|||||||
|
|
||||||
- This will start the proxy with,
|
- This will start the proxy with,
|
||||||
- RPC endpoint at: <http://0.0.0.0:8545>
|
- RPC endpoint at: <http://0.0.0.0:8545>
|
||||||
- WS endpoint at: <http://0.0.0.0:8545/ws>
|
- WS endpoint at: <ws://0.0.0.0:8545/ws>
|
||||||
|
19
ws_proxy.py
19
ws_proxy.py
@ -74,17 +74,6 @@ class WebSocketProxy:
|
|||||||
|
|
||||||
self.logger.debug(f"Received from client: {data}")
|
self.logger.debug(f"Received from client: {data}")
|
||||||
|
|
||||||
# Handle ping messages locally
|
|
||||||
if method == "ping":
|
|
||||||
pong_response = {
|
|
||||||
"jsonrpc": "2.0",
|
|
||||||
"result": "pong",
|
|
||||||
"id": data.get("id")
|
|
||||||
}
|
|
||||||
await client_ws.send_str(json.dumps(pong_response))
|
|
||||||
self.logger.debug("Responded to ping with pong")
|
|
||||||
continue
|
|
||||||
|
|
||||||
transformed_request = provider.transform_request(data)
|
transformed_request = provider.transform_request(data)
|
||||||
|
|
||||||
await provider_ws.send_str(json.dumps(transformed_request))
|
await provider_ws.send_str(json.dumps(transformed_request))
|
||||||
@ -96,10 +85,6 @@ class WebSocketProxy:
|
|||||||
self.logger.error(f"Error forwarding to provider: {e}")
|
self.logger.error(f"Error forwarding to provider: {e}")
|
||||||
break
|
break
|
||||||
|
|
||||||
elif msg.type == WSMsgType.PING:
|
|
||||||
await client_ws.pong(msg.data)
|
|
||||||
self.logger.debug("Responded to WebSocket ping with pong")
|
|
||||||
|
|
||||||
elif msg.type == WSMsgType.ERROR:
|
elif msg.type == WSMsgType.ERROR:
|
||||||
self.logger.error(f'WebSocket error: {client_ws.exception()}')
|
self.logger.error(f'WebSocket error: {client_ws.exception()}')
|
||||||
break
|
break
|
||||||
@ -140,10 +125,6 @@ class WebSocketProxy:
|
|||||||
# Don't break here - continue processing other messages
|
# Don't break here - continue processing other messages
|
||||||
continue
|
continue
|
||||||
|
|
||||||
elif msg.type == WSMsgType.PING:
|
|
||||||
await provider_ws.pong(msg.data)
|
|
||||||
self.logger.debug(f"Responded to provider WebSocket ping from {provider.name}")
|
|
||||||
|
|
||||||
elif msg.type == WSMsgType.ERROR:
|
elif msg.type == WSMsgType.ERROR:
|
||||||
self.logger.error(f'Provider WebSocket error: {provider_ws.exception()}')
|
self.logger.error(f'Provider WebSocket error: {provider_ws.exception()}')
|
||||||
break
|
break
|
||||||
|
Loading…
Reference in New Issue
Block a user