Initial commit for testing discovery between Linux tv-casting-app and Linux tv-app.

Author: shaoltan-amazon

.github/workflows/examples-linux-tv-casting-app.yaml

@@ -61,6 +61,11 @@ jobs:
                   ./scripts/run_in_build_env.sh \
                     "scripts/examples/gn_build_example.sh examples/tv-casting-app/linux/ out/tv-casting-app"
 
+            - name: Test Discovery between Linux tv-casting-app and Linux tv-app
+              run: |
+                  ./scripts/run_in_build_env.sh \
+                    "./scripts/tests/run_test_suite.py"
+
             - name: Uploading Size Reports
               uses: ./.github/actions/upload-size-reports
               if: ${{ !env.ACT }}

scripts/tests/run_tv_casting_test.py

@@ -0,0 +1,132 @@
+#!/usr/bin/env -S python3 -B
+
+# Copyright (c) 2024 Project CHIP Authors
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+import os
+import subprocess
+import sys
+import time
+
+def read_logs(log_file):
+   
+    with open(log_file, 'r') as file:
+        lines = file.readlines()
+
+    discovered_commissioners = []
+
+    print('Reading from Linux-tv-casting-logs.txt')
+
+    found_cast_request_0 = False
+
+    # Read through the Linux-tv-casting-logs.txt line by line
+    for i, line in enumerate(lines):
+
+        if "commissioner(s) discovered" in line:
+            print('----------------------------------------------------------------')
+            print(line)
+        
+        if "cast request 0" in line:
+            print(line)
+            found_cast_request_0 = True
+            # sys.exit(0)
+            print('DONE!!')   
+
+        if "No commissioner discovered" in line:
+            print(line)
+            sys.exit(1)
+            break
+
+        # Look for "Discovered Commissioner"
+        if "Discovered Commissioner" in line:
+            print('----------------------------------------------------------------')
+            print(line)
+
+            # Extract the relevant part of the string
+            commissioner = line.split("Discovered Commissioner")[-1].strip()
+            commissioner = commissioner.replace('\x1b[0m', '')
+
+            # Initialize variables for Vendor ID, Product ID, and Device Type
+            vendor_id = None
+            product_id = None
+            device_type = None
+
+            # Iterate through the subsequent lines to find product id, vendor id, and device type
+            for next_line in lines[i+1:]:
+                # Check if the line contains the required information
+                if "Vendor ID:" in next_line:
+                    print(next_line)
+                    vendor_id = next_line.split(":")[-1].strip()
+                    vendor_id = vendor_id.replace('\x1b[0m', '')
+
+                elif "Product ID:" in next_line:
+                    print(next_line)
+                    product_id = next_line.split(":")[-1].strip()
+                    product_id = product_id.replace('\x1b[0m', '')
+                
+                elif "Device Type:" in next_line:
+                    print(next_line)
+                    device_type = next_line.split(":")[-1].strip()
+                    device_type = device_type.replace('\x1b[0m', '')
+
+                elif "commissioner(s) discovered" in next_line:
+                    parsing_allowed = False
+                    break
+                
+                # If the next line starts with "Discovered Commissioner", break the loop
+                if "Discovered Commissioner" in next_line:
+                    break
+            
+            # Append the extracted information to the devices list
+            discovered_commissioners.append({
+                "discovered_commissioner": commissioner,
+                "vendor_id": vendor_id,
+                "product_id": product_id,
+                "device_type": device_type
+            })
+
+    if len(discovered_commissioners) == 0:
+        print('No Commissioner(s) Discovered! The list of discovered commissioners is empty!')
+        sys.exit(1)
+
+    # Print the list of discovered commissioners
+    print("Discovered Commissioners:")
+    for discovered_commissioner in discovered_commissioners:
+        print(discovered_commissioner)           
+            
+    if not found_cast_request_0:
+        print('Discovery did not finish successfully! No user prompt for "cast request 0" displayed!')
+        sys.exit(1)
+
+if __name__ == '__main__':
+
+    with open('Linux-tv-app-logs.txt', 'w') as fd1, open('Linux-tv-casting-app-logs.txt', 'w') as fd2:
+
+        # Run the Linux tv-app and write the output to file
+        tv_app_rel_path = '../../out/tv-app/chip-tv-app'
+        tv_app_abs_path = os.path.abspath(tv_app_rel_path)
+        p1 = subprocess.Popen(tv_app_abs_path, stdout=fd1, text=True)
+
+        time.sleep(5)
+
+        # Run the Linux tv-casting-app and write the output to file
+        tv_casting_app_rel_path = '../../out/tv-casting-app/chip-tv-casting-app'
+        tv_casting_app_abs_path = os.path.abspath(tv_casting_app_rel_path)
+        p2 = subprocess.Popen(tv_casting_app_abs_path, stdout=fd2, text=True)
+
+    # Wait for the processes to finish writing before attempting to read
+    time.sleep(15)
+
+    read_logs('Linux-tv-casting-app-logs.txt')
+    # print('Finished reading')