BodyComputerManager.py

import can
import os
from ExceptionAwareThread import ExceptionAwareThread
from FiatProtocol import *
from SteeringWheelButtons import SteeringWheelButtons


class BodyComputerManager(ExceptionAwareThread):

    should_run = True
    listeners = {}
    buttons = None

    def __init__(self, bus):
        super().__init__()
        self.bus = bus
        self.buttons = SteeringWheelButtons()

    def try_run(self):
        br = can.BufferedReader()
        notifier = can.Notifier(self.bus, [br])

        audio_channel = None
        date_sync = False

        while self.should_run:
            message = br.get_message(1)
            if message is not None:
                arbid = "{0:08x}".format(message.arbitration_id).upper()
                payload = ba(message.data)
                #print("From {}: {}".format(arbid, payload))

                if message.arbitration_id == CANID_BODY_BUTTONS:  # buttons
                    if payload & MASK_BUTTON_VOLUME_UP == MASK_BUTTON_VOLUME_UP:
                        self.buttons.debounce('vol+')
                    if payload & MASK_BUTTON_VOLUME_DN == MASK_BUTTON_VOLUME_DN:
                        self.buttons.debounce('vol-')
                    if payload & MASK_BUTTON_WINDOWS == MASK_BUTTON_WINDOWS:
                        self.buttons.debounce('win')
                    if payload & MASK_BUTTON_MUTE == MASK_BUTTON_MUTE:
                        self.buttons.debounce('mute')
                    if payload & MASK_BUTTON_UP == MASK_BUTTON_UP:
                        self.buttons.debounce('up')
                    if payload & MASK_BUTTON_DOWN == MASK_BUTTON_DOWN:
                        self.buttons.debounce('down')
                    if payload & MASK_BUTTON_MENU == MASK_BUTTON_MENU:
                        self.buttons.debounce('menu')
                    if payload & MASK_BUTTON_SOURCE == MASK_BUTTON_SOURCE:
                        self.buttons.debounce('src')

                elif message.arbitration_id == CANID_4003_CLOCK:
                    if not date_sync:
                        payload_str = payload.__str__()
                        formatted_date = "{}-{}-{} {}:{}:00".format(
                            payload_str[10:14], payload_str[8:10], payload_str[6:8], payload_str[2:4], payload_str[4:6]
                        )
                        os.system('sudo date -s "{}"'.format(formatted_date))
                        date_sync = True

                elif message.arbitration_id == CANID_RADIO_AUDIOCH:
                    prev_audio_channel = audio_channel
                    if payload & MASK_RADIO_AUDIOCH_MPPLAYING == MASK_RADIO_AUDIOCH_MPPLAYING:
                        audio_channel = 'bm'
                    else:
                        audio_channel = 'fm'
                    if prev_audio_channel != audio_channel:
                        self.fire_event('audio_channel', audio_channel)

        notifier.stop()

    def shutdown(self):
        self.should_run = False



    def fire_event(self, event, *args):
        if event not in self.listeners:
            return
        for listener in self.listeners[event]:
            listener(*args)

    def on_event(self, event, callback):
        if event not in self.listeners:
            self.listeners[event] = []
        self.listeners[event].append(callback)