from DialIn.CoreCANProtocol import DenaliMessage, DenaliCanMessenger, DenaliChannels
from time import sleep

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 respondToCommand(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=respondToCommand)

dialin_messenger.start()

# This is the main loop
while True:
    dialin_messenger.send(publication_msg)
    print(".", end='', flush=True)
    sleep(1)