###########################################################################
#
#  Copyright (c) 2019-2019 Diality Inc. - All Rights Reserved.
#
#  THIS CODE MAY NOT BE COPIED OR REPRODUCED IN ANY FORM, IN PART OR IN
#  WHOLE, WITHOUT THE EXPLICIT PERMISSION OF THE COPYRIGHT OWNER.
#
#  @file hd_tests_script.py
#
#  @date 7-Apr-2019
#  @author P. Lucia
#
#  @brief This is an example test script for the HD.
#
############################################################################
import sys
sys.path.append("..")
from dialin.protocols.CAN import DenaliMessage, DenaliCanMessenger, DenaliChannels
from dialin.dg.dialysate_generator import DG
from time import sleep
import unittest


class Test(unittest.TestCase):

    # @unittest.skip("Skipping dg_start.")
    def test_dg_start(self):
        dg = DG()
        sleep(2)
        success = dg.fill("start")
        self.assertTrue(success)

    # @unittest.skip("Skipping dg_start_stop.")
    def test_dg_start_stop(self):
        dg = DG()
        sleep(2)
        success = dg.fill("start")
        self.assertTrue(success)
        sleep(2)
        success = dg.fill('stop')
        self.assertTrue(success)

    @unittest.skip("Skipping test_dg_3")
    def test_dg_3(self):
        raise NotImplementedError

        """
        
        dialin_messenger = DenaliCanMessenger()

        # Building response message
        response_msg = DenaliMessage.build_message(channel_id=DenaliChannels.dg_to_hd_ch_id,
                                                   message_id=1000,
                                                   payload=[1])

        # Building Publication message
        publication_msg = DenaliMessage.build_message(channel_id=DenaliChannels.dg_sync_broadcast_ch_id,
                                                      message_id=0x7100,
                                                      payload=[1, 2, 3, 4, 5])

        print("")
        print("o ->  response to fill command")
        print(". ->  publication message")
        print("")


        def respond_to_command(message):
            dialin_messenger.send(response_msg)
            print("o", end='', flush=True)


        # Register response command for the DG
        dialin_messenger.register_receiving_publication_function(channel_id=DenaliChannels.ui_to_hd_ch_id,
                                                                 message_id=1000,
                                                                 function=respond_to_command)

        dialin_messenger.start()

        while True:
            dialin_messenger.send(publication_msg)
            print(".", end='', flush=True)
            sleep(1)
            
        """



if __name__ == '__main__':
    unittest.main(verbosity=2)