This task follows #22 (setting up message broker in test mode). If we're not in test mode, we want to continuously wait for/read new sensor data packets from the RFD900 radio module and process them into the correct Redis stream. We should also be continuously decoding frames from the wfb-ng video stream and adding them to the Redis image_stream (the bulk of this work will be done in task #24, all that's left is to integrate it with the rest of the message broker).
You can refer to serial_radio.py from last year's code that does a very similar kind of message brokering: https://github.com/ubcaerodesign/codex/blob/main/gamer-gui/serial_radio.py
This task follows #22 (setting up message broker in test mode). If we're not in test mode, we want to continuously wait for/read new sensor data packets from the RFD900 radio module and process them into the correct Redis stream. We should also be continuously decoding frames from the wfb-ng video stream and adding them to the Redis
image_stream(the bulk of this work will be done in task #24, all that's left is to integrate it with the rest of the message broker).You can refer to
serial_radio.pyfrom last year's code that does a very similar kind of message brokering: https://github.com/ubcaerodesign/codex/blob/main/gamer-gui/serial_radio.py