LaconicNetwork/solana-proxy
7
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Remove debug logs

Browse Source
This commit is contained in:
Shreerang Kale 2025-07-28 15:21:06 +05:30
parent f8e8b359bc
commit 02ee35437b
2 changed files with 1 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
http_proxy.py
View File

@ -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)

20
ws_proxy.py
View File

@ -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", {})):