The Encoder function of simulated two-way RPC call via MQTT Integration from ThingsBoard tutorial

Uplink_RPC

/** Decoder **/
 
// decode payload to string
var payloadStr = decodeToString(payload);
var data = JSON.parse(payloadStr);
var topicPattern = 'tb/mqtt-integration-guide/sensors/(.+?)/.*';
 
var deviceName =  metadata.topic.match(topicPattern)[1];
// decode payload to JSON
var deviceType = 'sensor';
 
// Result object with device attributes/telemetry data
var telemetry;
if (metadata.topic.endsWith('/temperature')) {
    // Transform the incoming data as before
    telemetry = getTemperatureTelemetry(data);
} else if (metadata.topic.endsWith('/rx/response')) {
    // Get the input value as is
    telemetry = data;
}
 
var result = {
   deviceName: deviceName,
   deviceType: deviceType,
   attributes: {
       integrationName: metadata['integrationName'],
   },
   telemetry: telemetry
};
 
/** Helper functions **/
 
function getTemperatureTelemetry(data) {
    return {temperature: data.value}
}
 
function decodeToString(payload) {
   return String.fromCharCode.apply(String, payload);
}
 
function decodeToJson(payload) {
   // covert payload to string.
   var str = decodeToString(payload);
 
   // parse string to JSON
   var data = JSON.parse(str);
   return data;
}
 
return result;