Add callback for CPX app messages

src/modules/interface/cpx/cpx.h

@@ -94,8 +94,12 @@ typedef struct {
   uint8_t data[CPX_MAX_PAYLOAD_SIZE - CPX_ROUTING_PACKED_SIZE];
 } CPXRoutablePacket_t;
 
+typedef void (*cpxAppMessageHandlerCallback_t)(const CPXPacket_t* cpxRx);
+
 void cpxInitRoute(const CPXTarget_t source, const CPXTarget_t destination, const CPXFunction_t function, CPXRouting_t* route);
 
 void cpxInit();
 
+void cpxRegisterAppMessageHandler(cpxAppMessageHandlerCallback_t callback);
+
 bool cpxCheckVersion(uint8_t version);

src/modules/src/cpx/cpx.c

@@ -47,6 +47,8 @@
 
 static CPXPacket_t cpxRx;
 
+static volatile cpxAppMessageHandlerCallback_t appMessageHandlerCallback;
+
 #define WIFI_SET_SSID_CMD         0x10
 #define WIFI_SET_KEY_CMD          0x11
 
@@ -86,6 +88,10 @@ bool cpxCheckVersion(const uint8_t version) {
   return isVersionOk;
 }
 
+void cpxRegisterAppMessageHandler(cpxAppMessageHandlerCallback_t callback) {
+  appMessageHandlerCallback = callback;
+}
+
 static void cpx(void* _param) {
   systemWaitStart();
   while (1) {
@@ -145,6 +151,11 @@ static void cpx(void* _param) {
           }
         }
         break;
+      case CPX_F_APP:
+        if (appMessageHandlerCallback) {
+          appMessageHandlerCallback(&cpxRx);
+        }
+        break;
       default:
         DEBUG_PRINT("Not handling function [0x%02X] from [0x%02X]\n", cpxRx.route.function, cpxRx.route.source);
     }

src/modules/src/cpx/cpx_internal_router.c

@@ -77,6 +77,7 @@ void cpxInternalRouterRouteIn(const CPXRoutablePacket_t* packet) {
       case CPX_F_CONSOLE:
       case CPX_F_WIFI_CTRL:
       case CPX_F_BOOTLOADER:
+      case CPX_F_APP:
       case CPX_F_TEST:
         xQueueSend(mixedQueue, packet, portMAX_DELAY);
         break;