Adding debugging msgs to fns related to test_subscripstion.

Author: shaoltan-amazon

scripts/tests/run_tv_casting_test.py

@@ -332,14 +332,19 @@ def parse_tv_casting_app_for_report_data_msg(tv_casting_app_info: Tuple[subproce
     report_data_message = []
 
     start_wait_time = time.time()
-
+    print('SHAO before parsing for the `ReportDataMessage` block!')
     while True:
         # Check if we exceeded the maximum wait time to parse the Linux tv-casting-app output for `ReportDataMessage` block.
         if time.time() - start_wait_time > VERIFY_SUBSCRIPTION_STATE_MAX_WAIT_SEC:
             logging.error(
                 'The relevant `ReportDataMessage` block was not found in the Linux tv-casting-app process within the timeout.')
-            # report_data_message.clear() # SHAO OG
-            report_data_message = [] # SHAO
+            
+            logging.error('SHAO debugging when we hit timeout:')
+            for report_data_msg_line in report_data_message:
+                logging.error(report_data_msg_line)
+
+            report_data_message.clear() # SHAO OG
+            # report_data_message = [] # SHAO
             return report_data_message
 
         tv_casting_line = tv_casting_app_process.stdout.readline()
@@ -350,22 +355,24 @@ def parse_tv_casting_app_for_report_data_msg(tv_casting_app_info: Tuple[subproce
 
             if 'ReportDataMessage =' in tv_casting_line:
                 report_data_message.append(tv_casting_line.rstrip('\n'))
+                logging.info(tv_casting_line.rstrip('\n')) # SHAO
                 continue_parsing = True
             elif continue_parsing:
                 report_data_message.append(tv_casting_line.rstrip('\n'))
+                logging.info(tv_casting_line.rstrip('\n'))  # SHAO
 
                 if 'Cluster =' in tv_casting_line:
                     cluster_value = extract_value_from_string(tv_casting_line)
                     if cluster_value != CLUSTER_MEDIA_PLAYBACK:
-                        # report_data_message.clear() # SHAO OG
-                        report_data_message = [] # SHAO
+                        report_data_message.clear() # SHAO OG
+                        # report_data_message = [] # SHAO
                         continue_parsing = False
 
                 elif 'Attribute =' in tv_casting_line:
                     attribute_value = extract_value_from_string(tv_casting_line)
                     if attribute_value != ATTRIBUTE_CURRENT_PLAYBACK_STATE:
-                        # report_data_message.clear() # SHAO OG
-                        report_data_message = [] # SHAO
+                        report_data_message.clear() # SHAO OG
+                        # report_data_message = [] # SHAO
                         continue_parsing = False
 
                 elif 'InteractionModelRevision' in tv_casting_line:
@@ -374,6 +381,7 @@ def parse_tv_casting_app_for_report_data_msg(tv_casting_app_info: Tuple[subproce
                     linux_tv_casting_app_log_file.write(tv_casting_line)
                     linux_tv_casting_app_log_file.flush()
                     report_data_message.append(tv_casting_line.rstrip('\n'))
+                    logging.info(tv_casting_line.rstrip('\n'))  # SHAO
                     return report_data_message