⬆️Multipurpose Button Uplink decoder
function decodeUplink(input) {
try {
var bytes = input.bytes;
var data = {};
function calculateBatteryVoltage(byte) {
return byte * 8 + 1600;
}
function calculateTemperature(rawData) {
return rawData / 10.0;
}
function handleKeepalive(bytes, data) {
// Byte 1: Device battery voltage
var batteryVoltage = calculateBatteryVoltage(bytes[1]) / 1000;
data.batteryVoltage = Number(batteryVoltage.toFixed(1));
// Byte 2: Thermistor operational status and temperature data (bits 9:8)
var thermistorConnected = (bytes[2] & 0x04) === 0; // Bit 2
var temperatureHighBits = bytes[2] & 0x03; // Bits 1:0
// Byte 3: Thermistor temperature data (bits 7:0)
var temperatureLowBits = bytes[3];
var temperatureRaw = (temperatureHighBits << 8) | temperatureLowBits;
var temperatureCelsius = calculateTemperature(temperatureRaw);
data.thermistorProperlyConnected = thermistorConnected;
data.sensorTemperature = Number(temperatureCelsius.toFixed(1));
// Byte 4: Button event data
var buttonEventData = bytes[4];
data.pressEvent = buttonEventData;
return data;
}
function handleResponse(bytes, data){
var commands = bytes.map(function(byte){
return ("0" + byte.toString(16)).substr(-2);
});
commands = commands.slice(0,-5);
var command_len = 0;
commands.map(function (command, i) {
switch (command) {
case '04':
{
command_len = 2;
var hardwareVersion = commands[i + 1];
var softwareVersion = commands[i + 2];
data.deviceVersions = { hardware: Number(hardwareVersion), software: Number(softwareVersion) };
}
break;
case '12':
{
command_len = 1;
data.keepAliveTime = parseInt(commands[i + 1], 16);
}
break;
case '19':
{
command_len = 1;
var commandResponse = parseInt(commands[i + 1], 16);
var periodInMinutes = commandResponse * 5 / 60;
data.joinRetryPeriod = periodInMinutes;
}
break;
case '1b':
{
command_len = 1;
data.uplinkType = parseInt(commands[i + 1], 16) ;
}
break;
case '1d':
{
command_len = 2;
var wdpC = commands[i + 1] == '00' ? false : parseInt(commands[i + 1], 16);
var wdpUc = commands[i + 2] == '00' ? false : parseInt(commands[i + 2], 16);
data.watchDogParams= { wdpC: wdpC, wdpUc: wdpUc } ;
}
break;
case '1f':
{
command_len = 1;
data.sendEventLater = parseInt(commands[i + 1], 16) ;
}
break;
default:
break;
}
commands.splice(i,command_len);
});
return data;
}
if (bytes[0] == 1) {
data = handleKeepalive(bytes, data);
} else {
data = handleResponse(bytes, data);
// Handle the remaining keepalive data if required after response
bytes = bytes.slice(-5);
data = handleKeepalive(bytes, data);
}
return { data: data };
} catch (e) {
// console.log(e);
throw new Error('Unhandled data');
}
}
DataCake Decoder
function decodeUplink(input) {
try {
var bytes = input.bytes;
var data = {};
function calculateBatteryVoltage(byte) {
return byte * 8 + 1600;
}
function calculateTemperature(rawData) {
return rawData / 10.0;
}
function handleKeepalive(bytes, data) {
// Byte 1: Device battery voltage
var batteryVoltage = calculateBatteryVoltage(bytes[1]) / 1000;
data.batteryVoltage = Number(batteryVoltage.toFixed(1));
// Byte 2: Thermistor operational status and temperature data (bits 9:8)
var thermistorConnected = (bytes[2] & 0x04) === 0; // Bit 2
var temperatureHighBits = bytes[2] & 0x03; // Bits 1:0
// Byte 3: Thermistor temperature data (bits 7:0)
var temperatureLowBits = bytes[3];
var temperatureRaw = (temperatureHighBits << 8) | temperatureLowBits;
var temperatureCelsius = calculateTemperature(temperatureRaw);
data.thermistorProperlyConnected = thermistorConnected;
data.sensorTemperature = Number(temperatureCelsius.toFixed(1));
// Byte 4: Button event data
var buttonEventData = bytes[4];
data.pressEvent = buttonEventData;
return data;
}
function handleResponse(bytes, data) {
var commands = bytes.map(function (byte) {
return ("0" + byte.toString(16)).substr(-2);
});
commands = commands.slice(0, -5);
var command_len = 0;
commands.forEach(function (command, i) {
switch (command) {
case '04':
command_len = 2;
var hardwareVersion = commands[i + 1];
var softwareVersion = commands[i + 2];
data.deviceVersions = { hardware: Number(hardwareVersion), software: Number(softwareVersion) };
break;
case '12':
command_len = 1;
data.keepAliveTime = parseInt(commands[i + 1], 16);
break;
case '19':
command_len = 1;
var commandResponse = parseInt(commands[i + 1], 16);
var periodInMinutes = commandResponse * 5 / 60;
data.joinRetryPeriod = periodInMinutes;
break;
case '1b':
command_len = 1;
data.uplinkType = parseInt(commands[i + 1], 16);
break;
case '1d':
command_len = 2;
var wdpC = commands[i + 1] === '00' ? false : parseInt(commands[i + 1], 16);
var wdpUc = commands[i + 2] === '00' ? false : parseInt(commands[i + 2], 16);
data.watchDogParams = { wdpC: wdpC, wdpUc: wdpUc };
break;
case '1f':
command_len = 1;
data.sendEventLater = parseInt(commands[i + 1], 16);
break;
default:
break;
}
commands.splice(i, command_len);
});
return data;
}
if (bytes[0] == 1) {
data = handleKeepalive(bytes, data);
} else {
data = handleResponse(bytes, data);
// Handle the remaining keepalive data if required after response
bytes = bytes.slice(-5);
data = handleKeepalive(bytes, data);
}
return { data: data };
} catch (e) {
throw new Error('Unhandled data');
}
}
function Decoder(payload, port) {
var decoded = decodeUplink({ bytes: payload, fPort: port }).data;
// Array where we store the fields that are being sent to Datacake
var datacakeFields = [];
// Convert each field from decoded and convert them to Datacake format
for (var key in decoded) {
if (decoded.hasOwnProperty(key)) {
datacakeFields.push({ field: key.toUpperCase(), value: decoded[key] });
}
}
// Forward data to Datacake
return datacakeFields;
}
Last updated