⬆️Multipurpose Button Uplink decoder

Universal Decoder:

Supports: The Thinks Network, Milesight, DataCake, Chirpstack

// DataCake
function Decoder(bytes, port){
    var decoded = decodeUplink({ bytes: bytes, fPort: port }).data;
    return decoded;
}

// Milesight
function Decode(port, bytes){
    var decoded = decodeUplink({ bytes: bytes, fPort: port }).data;
    return decoded;
}

// The Things Industries / Main
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 '14':
                        {
                            command_len = 1;
                            data.childLock = toBool(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;
                    case 'a4':
                        {
                            command_len = 1;
                            data.region = parseInt(commands[i + 1], 16);
                        }
                    break;
                    case 'b1':
                        {
                            command_len = 3;
                            data.singlePressEventCounter =(parseInt(commands[i + 1], 16) << 16) | (parseInt(commands[i + 2], 16) << 8) | parseInt(commands[i + 3], 16);
                        }
                    break;
                    case 'b2':
                        {
                            command_len = 3;
                            data.doublePressEventCounter =(parseInt(commands[i + 1], 16) << 16) | (parseInt(commands[i + 2], 16) << 8) | parseInt(commands[i + 3], 16);
                        }
                    break;
                    case 'b3':
                        {
                            command_len = 3;
                            data.triplePressEventCounter =(parseInt(commands[i + 1], 16) << 16) | (parseInt(commands[i + 2], 16) << 8) | parseInt(commands[i + 3], 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');
    }
}

Last updated

Was this helpful?