diff --git a/http_proxy.py b/http_proxy.py index 5be8b23..c49b073 100644 --- a/http_proxy.py +++ b/http_proxy.py @@ -36,16 +36,9 @@ async def handle_rpc_request(request: web.Request) -> web.Response: }, status=400) logger.info(f"Handling RPC request: {method}") - - # Special logging for signature status requests - if method == "getSignatureStatuses": - signatures = params if isinstance(params, list) else [] - logger.info(f"GET_SIGNATURE_STATUSES: Checking signatures: {signatures}") response = await router.route_request(method, params) - - if method == "getSignatureStatuses": - logger.info(f"GET_SIGNATURE_STATUSES: Response: {response}") + response["id"] = request_id return web.json_response(response) diff --git a/ws_proxy.py b/ws_proxy.py index 7d335b2..35e6789 100644 --- a/ws_proxy.py +++ b/ws_proxy.py @@ -86,16 +86,8 @@ class WebSocketProxy: self.logger.info("Responded to ping with pong") continue - # Special logging for signature subscriptions - if method == "signatureSubscribe": - signature = data.get('params', [None])[0] if data.get('params') else None - self.logger.info(f"SIGNATURE_SUBSCRIBE: Forwarding to {provider.name} for signature: {signature}") - transformed_request = provider.transform_request(data) - if method == "signatureSubscribe": - self.logger.info(f"SIGNATURE_SUBSCRIBE: Sending to provider {provider.name}: {transformed_request}") - await provider_ws.send_str(json.dumps(transformed_request)) self.logger.info(f"Forwarded message to {provider.name}: {method}") @@ -117,24 +109,12 @@ class WebSocketProxy: break async def _proxy_provider_to_client(self, provider_ws, client_ws: web.WebSocketResponse, provider) -> None: - self.logger.info(f"Starting provider-to-client message loop for {provider.name}") - message_count = 0 async for msg in provider_ws: - message_count += 1 - self.logger.info(f"Provider {provider.name} message #{message_count}, type: {msg.type}") if msg.type == WSMsgType.TEXT: try: data = json.loads(msg.data) self.logger.info(f"Received from provider {provider.name}: {data}") - # Special logging for signature subscription responses - if "result" in data and isinstance(data.get("result"), (int, str)): - self.logger.info(f"SIGNATURE_SUBSCRIBE: Got subscription ID response from {provider.name}: {data.get('result')}") - elif data.get("method") == "signatureNotification": - subscription_id = data.get("params", {}).get("subscription") - result = data.get("params", {}).get("result") - self.logger.info(f"SIGNATURE_NOTIFICATION: From {provider.name}, subscription {subscription_id}, result: {result}") - transformed_response = provider.transform_response(data) if "result" in transformed_response and "subscription" in str(transformed_response.get("result", {})):