Add log file checking to nrf command running

server/server_comm/test_runner/nrf_scripts/nrf_connect.py

@@ -2,6 +2,59 @@
 import subprocess
 
 
+def run_command(name, command, filename):
+    try:
+        result = subprocess.run(command, capture_output=True, text=True)
+        stdout, stderr = result.stdout, result.stderr
+    except Exception as e:
+        return {
+            "status": "error",
+            "message": f"Exception occurred while executing command: {name}",
+            "response": str(e),
+        }
+
+    if stderr:
+        return {
+            "status": "error",
+            "message": f"Error occurred while running command: {name}",
+            "response": stderr,
+        }
+
+    if "Error" in stdout:
+        return {
+            "status": "error",
+            "message": f"Error occurred while running command: {name}",
+            "response": stdout,
+        }
+
+    with open(filename, "r") as file:
+        lines = file.readlines()
+
+    if "completed" in lines[-1]:
+        return {
+            "status": "success",
+            "message": f"Command: {name}, ran successfully",
+            "response": "",
+        }
+
+    for i in range(len(lines)):
+        if name in lines[i]:
+            start_idx = i
+            break
+
+    error_lines = []
+    for line in lines[start_idx:]:
+        line = line.split("\t")
+        if line[0] == "E" or line[0] == "W":
+            error_lines.append(line)
+
+    return {
+        "status": "error",
+        "message": f"nRF script: {name}, failed",
+        "response": error_lines,
+    }
+
+
 def run_check_connection(
     android_device_id,
     mac_address,
@@ -19,11 +72,7 @@ def run_check_connection(
         "connection.xml",
     ]
 
-    try:
-        result = subprocess.run(command, capture_output=True, text=True)
-        return result.stdout, result.stderr
-    except Exception as e:
-        return None, str(e)
+    return run_command("Connect", command, "connection_result.txt")
 
 
 def run_check_service(
@@ -47,11 +96,9 @@ def run_check_service(
         "check_service.xml",
     ]
 
-    try:
-        result = subprocess.run(command, capture_output=True, text=True)
-        return result.stdout, result.stderr
-    except Exception as e:
-        return None, str(e)
+    return run_command(
+        "Check Service UUID", command, "check_service_result.txt"
+    )
 
 
 def run_check_characteristic(
@@ -79,11 +126,9 @@ def run_check_characteristic(
         "check_characteristic.xml",
     ]
 
-    try:
-        result = subprocess.run(command, capture_output=True, text=True)
-        return result.stdout, result.stderr
-    except Exception as e:
-        return None, str(e)
+    return run_command(
+        "Check Characteristic UUID", command, "check_characteristic_result.txt"
+    )
 
 
 def run_custom_script(android_device_id, mac_address, extras):
@@ -107,8 +152,4 @@ def run_custom_script(android_device_id, mac_address, extras):
     command.extend(extra_cmd)
     command.append("custom_script.xml")
 
-    try:
-        result = subprocess.run(command, capture_output=True, text=True)
-        return result.stdout, result.stderr
-    except Exception as e:
-        return None, str(e)
+    return run_command("Custom script", command, "custom_script_result.txt")