StakeSquid/ethereum-rpc-docker
1
0
Fork 0
Code Issues 1 Packages Projects Releases Wiki Activity

simple look

Browse Source
This commit is contained in:
Para Dox
2025-04-27 23:29:43 +07:00
parent 2684dec118
commit ef725c1768
1 changed files with 23 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
logging-proxy/proxy.py
View File

@@ -77,23 +77,31 @@ def proxy():
response = requests.post(TARGET_URL_HTTP, json=incoming) response = requests.post(TARGET_URL_HTTP, json=incoming)
outgoing = response.json() outgoing = response.json()
# Initialize log_lines here, decide what to include based on error status # Initialize log_lines here, decide what to include based on error status and ignored methods
log_lines = [] log_lines = []
log_this_error = True # Flag to control logging of the current error
if 'error' in outgoing: if 'error' in outgoing:
# For errors, log both request and response method_name = None
log_lines.append(request_log)
response_log = f"<== Response (Error):\n{json.dumps(outgoing, indent=2)}"
log_lines.append(response_log)
# Track the method name if an error occurred and method exists in request,
# unless the method is in the ignored set.
if isinstance(incoming, dict) and 'method' in incoming: if isinstance(incoming, dict) and 'method' in incoming:
method_name = incoming['method'] method_name = incoming['method']
if method_name not in ignored_error_methods: # Check if the method causing the error should be ignored
if method_name in ignored_error_methods:
log_this_error = False
# Optional: Log that an error for this method was ignored without details
print(f"INFO: Ignored error for method '{method_name}' (logging suppressed).", file=sys.stdout, flush=True)
# Only log the request/error response if log_this_error is True
if log_this_error:
log_lines.append(request_log)
response_log = f"<== Response (Error):\n{json.dumps(outgoing, indent=2)}"
log_lines.append(response_log)
# Track the method name only if we logged the error
if method_name:
error_methods.add(method_name) error_methods.add(method_name)
else: # If method_name was None but we are logging, maybe track as 'unknown' or similar?
# Optional: Log that an error for this method was ignored # else: error_methods.add("unknown_method_with_error")
print(f"INFO: Ignored error for method '{method_name}' as per IGNORE_ERROR_METHODS.", file=sys.stdout, flush=True)
else: else:
# For success, log only the success message with the method name # For success, log only the success message with the method name
method_name = "unknown_method" # Default if not found method_name = "unknown_method" # Default if not found
@@ -102,8 +110,10 @@ def proxy():
response_log = f"<== Response (Success): Method '{method_name}' completed." response_log = f"<== Response (Success): Method '{method_name}' completed."
log_lines.append(response_log) log_lines.append(response_log)
print('\n---\n'.join(log_lines), file=sys.stdout, flush=True) # Only print if there are lines to print (avoids empty separators for ignored errors)
if log_lines:
print('\n---\n'.join(log_lines), file=sys.stdout, flush=True)
return jsonify(outgoing) return jsonify(outgoing)
# WebSocket handler moved to '/ws' # WebSocket handler moved to '/ws'