Index: tst_cloud_sync_device_registration/test.py =================================================================== diff -u -rf17d0b3a1bd0e3dec8ead6d11be0a96514a1d875 -r16b51bc5a664cfdac954366e8b371e2ebed1ccf2 --- tst_cloud_sync_device_registration/test.py (.../test.py) (revision f17d0b3a1bd0e3dec8ead6d11be0a96514a1d875) +++ tst_cloud_sync_device_registration/test.py (.../test.py) (revision 16b51bc5a664cfdac954366e8b371e2ebed1ccf2) @@ -16,14 +16,17 @@ # NOTE: # This test verifies the logs for the messages provided import builtins +import csv from dialin.ui import HDSimulator from dialin.ui import DGSimulator from dialin.ui import utils from configuration import utility from configuration import config +from builtins import int as pyInt +from builtins import str as pyStr import time +from datetime import datetime - hd_simulator = HDSimulator() dg_simulator = DGSimulator() @@ -32,28 +35,45 @@ MESSAGE_ID_RESPONSE = "1002" EXPECTED_SOFTWARE_VERSION = "06300216" -def retrive_log_data(): +def retrive_log_data_second_line(): """ Method to read latest input buf file and getting log data from it - @return: epoch value, message id, number of parameters, HD serial version, DG serial version, software version + @return: message id """ + file_name = utility.get_extracted_file_inp_buf() try: with open(file_name,mode = 'r') as inp_buf: - last_line_one = inp_buf.readline(-1) - last_line_one = last_line_one.strip() - last_line_one = last_line_one.split(",") - test.log(str(last_line_one)) - last_line_two = inp_buf.readline(-2) last_line_two = last_line_two.strip() last_line_two = last_line_two.split(",") - - test.log(str(last_line_two)) - return (last_line_one[0], last_line_one[3], last_line_one[4], last_line_one[5], last_line_one[6], last_line_one[7], last_line_two[3]) + return (last_line_two[3]) except: - test.fail("Input buf file is not created or it is not created based on standard naming format.") + test.fail("Input buf file is not created or it is not created based on standard naming format.") +def retrive_log_data_first_line(): + """ + Method to read latest input buf file and getting log data from it + @return: epoch value, message id, number of parameters, HD serial version, DG serial version, software version + """ + + file_name = utility.get_extracted_file_inp_buf() + + try: + with open(file_name) as f: + contents = f.read() + test.log(str(contents)) + with open(file_name,mode = 'r') as f: + contents = csv.reader(f) + try: + for row in reversed(list(contents)): + test.log(str(row)) + return (row[0],row[3],row[4],row[5],row[6],row[7]) + except: + test.fail("application log data is corrupted") + except: + test.fail("Log file is not created or log file is not created based on standard log naming format.") + def system_date_time(): """ Method to get systems date and time @@ -70,7 +90,7 @@ date_time_format = time.strftime('%Y-%m-%d %H:%M', time.localtime(epoch)) return date_time_format -def verify_inp_buf_data(actual_epoch, actual_message_id, actual_parameters, actual_hd_version_serial, actual_dg_version_serial, actual_sw_version, message_id_request): +def verify_inp_buf_data(actual_epoch, actual_message_id, actual_parameters, actual_hd_version_serial, actual_dg_version_serial, actual_sw_version, message_id_response): """ Method to verify and compare epoch value, number of parameters and software version from input buf file @return: None @@ -80,8 +100,8 @@ actual_epoch = builtins.int(actual_epoch) actual_epoch = epoch_value_conversion(actual_epoch) test.compare(actual_epoch, EXPECTED_EPOCH, "The epoch should be: "+EXPECTED_EPOCH) - test.compare(actual_message_id, MESSAGE_ID_REQUEST, "The message id request should be: "+MESSAGE_ID_REQUEST) - test.compare(message_id_request, MESSAGE_ID_RESPONSE, "The message id response should be: "+MESSAGE_ID_RESPONSE) + test.compare(message_id_response, MESSAGE_ID_REQUEST, "The message id request should be: "+MESSAGE_ID_REQUEST) + test.compare(actual_message_id, MESSAGE_ID_RESPONSE, "The message id response should be: "+MESSAGE_ID_RESPONSE) test.compare(actual_parameters, EXPECTED_NUMBER_OF_PARAMETERS, "The number of parameters should be: "+EXPECTED_NUMBER_OF_PARAMETERS) test.compare(actual_sw_version, EXPECTED_SOFTWARE_VERSION, "The software version should be: "+EXPECTED_SOFTWARE_VERSION) test.endSection() @@ -90,35 +110,37 @@ utils.tstStart(__file__) startApplication(config.AUT_NAME) - for index in range (3): - hd_simulator.cmd_send_serial_hd_data(serial = config.CLOUD_SYNC["HD_VERSION_SERIAL"][index]) + for value in range (3): + hd_simulator.cmd_send_serial_hd_data(serial = config.CLOUD_SYNC["HD_VERSION_SERIAL"][value]) utils.waitForGUI(5) - actual_epoch, actual_message_id, actual_parameters, actual_hd_version_serial, actual_dg_version_serial, actual_sw_version, message_id_request = retrive_log_data() - test.log(str(message_id_request)) - test.compare(actual_hd_version_serial, config.CLOUD_SYNC["HD_VERSION_SERIAL"][index], "The HD serial version should be: "+config.CLOUD_SYNC["HD_VERSION_SERIAL"][index]) - verify_inp_buf_data(actual_epoch, actual_message_id, actual_parameters, actual_hd_version_serial, actual_dg_version_serial, actual_sw_version, message_id_request) + actual_epoch, actual_message_id, actual_parameters, actual_hd_version_serial, actual_dg_version_serial, actual_sw_version = retrive_log_data_first_line() + message_id_response = retrive_log_data_second_line() + test.compare(actual_hd_version_serial, config.CLOUD_SYNC["HD_VERSION_SERIAL"][value], "The HD serial version should be: "+config.CLOUD_SYNC["HD_VERSION_SERIAL"][value]) + verify_inp_buf_data(actual_epoch, actual_message_id, actual_parameters, actual_hd_version_serial, actual_dg_version_serial, actual_sw_version, message_id_response) - #utils.waitForGUI(5) + utils.waitForGUI(5) - for index in range (3): - dg_simulator.cmd_send_serial_dg_data(serial = config.CLOUD_SYNC["DG_VERSION_SERIAL"][index]) + for value in range (3): + dg_simulator.cmd_send_serial_dg_data(serial = config.CLOUD_SYNC["DG_VERSION_SERIAL"][value]) utils.waitForGUI(5) - actual_epoch, actual_message_id, actual_parameters, actual_hd_version_serial, actual_dg_version_serial, actual_sw_version, message_id_request = retrive_log_data() - test.compare(actual_dg_version_serial, config.CLOUD_SYNC["DG_VERSION_SERIAL"][index], "The DG serial version should be: "+config.CLOUD_SYNC["DG_VERSION_SERIAL"][index]) - verify_inp_buf_data(actual_epoch, actual_message_id, actual_parameters, actual_hd_version_serial, actual_dg_version_serial, actual_sw_version, message_id_request) + actual_epoch, actual_message_id, actual_parameters, actual_hd_version_serial, actual_dg_version_serial, actual_sw_version = retrive_log_data_first_line() + message_id_response = retrive_log_data_second_line() + test.compare(actual_dg_version_serial, config.CLOUD_SYNC["DG_VERSION_SERIAL"][value], "The DG serial version should be: "+config.CLOUD_SYNC["DG_VERSION_SERIAL"][value]) + verify_inp_buf_data(actual_epoch, actual_message_id, actual_parameters, actual_hd_version_serial, actual_dg_version_serial, actual_sw_version, message_id_response) - #utils.waitForGUI(5) + utils.waitForGUI(5) - for index in range (3): - hd_simulator.cmd_send_serial_hd_data(serial = config.CLOUD_SYNC["HD_VERSION_SERIAL"][index]) - dg_simulator.cmd_send_serial_dg_data(serial = config.CLOUD_SYNC["DG_VERSION_SERIAL"][index]) + for value in range (3): + hd_simulator.cmd_send_serial_hd_data(serial = config.CLOUD_SYNC["HD_VERSION_SERIAL"][value]) + dg_simulator.cmd_send_serial_dg_data(serial = config.CLOUD_SYNC["DG_VERSION_SERIAL"][value]) utils.waitForGUI(5) - actual_epoch, actual_message_id, actual_parameters, actual_hd_version_serial, actual_dg_version_serial, actual_sw_version, message_id_request = retrive_log_data() - test.compare(actual_hd_version_serial, config.CLOUD_SYNC["HD_VERSION_SERIAL"][index], "The HD serial version should be: "+config.CLOUD_SYNC["HD_VERSION_SERIAL"][index]) - test.compare(actual_dg_version_serial, config.CLOUD_SYNC["DG_VERSION_SERIAL"][index], "The DG serial version should be: "+config.CLOUD_SYNC["DG_VERSION_SERIAL"][index]) - verify_inp_buf_data(actual_epoch, actual_message_id, actual_parameters, actual_hd_version_serial, actual_dg_version_serial, actual_sw_version, message_id_request) + actual_epoch, actual_message_id, actual_parameters, actual_hd_version_serial, actual_dg_version_serial, actual_sw_version = retrive_log_data_first_line() + message_id_response = retrive_log_data_second_line() + test.compare(actual_hd_version_serial, config.CLOUD_SYNC["HD_VERSION_SERIAL"][value], "The HD serial version should be: "+config.CLOUD_SYNC["HD_VERSION_SERIAL"][value]) + test.compare(actual_dg_version_serial, config.CLOUD_SYNC["DG_VERSION_SERIAL"][value], "The DG serial version should be: "+config.CLOUD_SYNC["DG_VERSION_SERIAL"][value]) + verify_inp_buf_data(actual_epoch, actual_message_id, actual_parameters, actual_hd_version_serial, actual_dg_version_serial, actual_sw_version, message_id_response) - #utils.waitForGUI(5) + utils.waitForGUI(5) utils.tstDone()