Refactor check_logs function in checker.py to improve logging and subscription status reporting. Renamed parameter from log_handler to logger for clarity. Added logging for cases where no subscription is found, enhancing the visibility of log analysis outcomes.

This commit is contained in:
vvzvlad 2025-01-19 11:42:55 +03:00
parent e5a0eef020
commit c1f23386b5

View File

@ -134,7 +134,7 @@ def clean_ansi(text):
ansi_escape = re.compile(r'\x1B(?:[@-Z\\-_]|\[[0-?]*[ -/]*[@-~])') ansi_escape = re.compile(r'\x1B(?:[@-Z\\-_]|\[[0-?]*[ -/]*[@-~])')
return ansi_escape.sub('', text) return ansi_escape.sub('', text)
def check_logs(log_handler): def check_logs(logger):
try: try:
logs = subprocess.run(['docker', 'logs', '--since', '10m', 'infernet-node'], capture_output=True, text=True, check=True) logs = subprocess.run(['docker', 'logs', '--since', '10m', 'infernet-node'], capture_output=True, text=True, check=True)
log_content = clean_ansi(logs.stdout) log_content = clean_ansi(logs.stdout)
@ -147,7 +147,9 @@ def check_logs(log_handler):
last_subscription_id = id_match.group(1) last_subscription_id = id_match.group(1)
if last_subscription_id: if last_subscription_id:
logger.info(f"Subscription: {last_subscription_id}")
return {"status": f"Subscription: {last_subscription_id}"} return {"status": f"Subscription: {last_subscription_id}"}
logger.info("Not found subscription")
return {"status": "Idle"} return {"status": "Idle"}
except subprocess.CalledProcessError as e: except subprocess.CalledProcessError as e: