from DialityCoreCanProtocol import *
from time import sleep

dialin_messenger = DialinCanMessenger()

# Building response message

response_msg = DialinMessage.buildMessage(channel_id=DialinChannels.dg_to_hd_ch_id,
                                          message_id=0x7000,
                                          payload=[1])

# Building Publication message
publication_msg = DialinMessage.buildMessage(channel_id=DialinChannels.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.registerReceivingPublicationFunction(channel_id=DialinChannels.hd_to_dg_ch_id,
                                                      message_id=0x7000,
                                                      function=respondToCommand)

dialin_messenger.start()

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