Add content type checking

eclipse-thingweb · Jan 9, 2020 · 32f7879 · 32f7879
1 parent f775403
commit 32f7879
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/packages/binding-mqtt/src/mqtt-broker-server.ts b/packages/binding-mqtt/src/mqtt-broker-server.ts
@@ -156,7 +156,16 @@ export default class MqttBrokerServer implements ProtocolServer {
               if (action) {
                 thing.invokeAction(segments[3], 
                 // action.invoke(
-                  JSON.parse(payload))
+                  function() {
+                    let value;
+                    try {
+                      value = ContentSerdes.get().contentToValue({ type: packet.properties.contentType, body: Buffer.from(payload) }, action.input);
+                      return value;
+                    } catch(err) {
+                      console.warn(`MqttBrokerServer at ${this.brokerURI} cannot process received message for '${segments[3]}': ${err.message}`);
+                      return;
+                    }
+                  })
                   .then((output) => {
                     // MQTT cannot return results
                     if (output) {