Chore support messagereceived event

README.md

@@ -189,6 +189,11 @@ carries a `QVariantList data` with positional values:
   - `data[0]` (`QString`): request id
   - `data[1]` (`QString`): message hash
   - `data[2]` (`QString`): local timestamp (ISO-8601)
+- **`messageReceived`** – a message arrived on a subscribed topic
+  - `data[0]` (`QString`): message hash
+  - `data[1]` (`QString`): content topic
+  - `data[2]` (`QString`): payload (base64-encoded)
+  - `data[3]` (`QString`): timestamp (nanoseconds since epoch)
 - **`connectionStateChanged`** – node connectivity change
   - `data[0]` (`QString`): connection status
   - `data[1]` (`QString`): local timestamp (ISO-8601)

delivery_module_plugin.cpp

@@ -101,6 +101,16 @@ void DeliveryModulePlugin::event_callback(int callerRet, const char* msg, size_t
             eventData << timestamp;
             plugin->emitEvent("messagePropagated", eventData);
 
+        } else if (eventType == "message_received") {
+            // MessageReceivedEvent: messageHash, message (WakuMessage)
+            QJsonObject msgObj = jsonObj["message"].toObject();
+            QVariantList eventData;
+            eventData << jsonObj["messageHash"].toString();
+            eventData << msgObj["contentTopic"].toString();
+            eventData << msgObj["payload"].toString();
+            eventData << QString::number(msgObj["timestamp"].toDouble(), 'f', 0);
+            plugin->emitEvent("messageReceived", eventData);
+
         } else if (eventType == "connection_status_change") {
             QVariantList eventData;
             eventData << jsonObj["connectionStatus"].toString();

delivery_module_plugin.h

@@ -34,6 +34,11 @@
  *   - `data[0]` (`QString`): request id
  *   - `data[1]` (`QString`): message hash
  *   - `data[2]` (`QString`): local timestamp (ISO-8601)
+ * - `messageReceived` (emitted when a message arrives on a subscribed topic)
+ *   - `data[0]` (`QString`): message hash
+ *   - `data[1]` (`QString`): content topic
+ *   - `data[2]` (`QString`): payload (base64-encoded)
+ *   - `data[3]` (`QString`): timestamp (nanoseconds since epoch)
  * - `connectionStateChanged`
  *   - `data[0]` (`QString`): connection status
  *   - `data[1]` (`QString`): local timestamp (ISO-8601)
@@ -42,6 +47,7 @@
  * - `message_sent` -> `messageSent`
  * - `message_error` -> `messageError`
  * - `message_propagated` -> `messagePropagated`
+ * - `message_received` -> `messageReceived`
  * - `connection_status_change` -> `connectionStateChanged`
  * 
  * As a general concept consider using proper content_topic format for your purpose.