⬆️T-Valve 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) {
var bytes = input.bytes;
var data = {};
var messageTypes = ['keepalive', 'testButtonPressed', 'floodDetected', 'controlButtonPressed', 'fraudDetected'];
function shortPackage(byteArray, data) {
data.reason = 'keepalive';
data.waterTemp = (byteArray[0] & 0xFF) / 2;
data.valveState = !!(byteArray[1] & 0x80);
data.ambientTemp = ((byteArray[1] & 0x7F) - 20) / 2;
return data;
}
function longPackage(byteArray, data) {
data.reason = messageTypes[(byteArray[0] >> 5) & 0x7]; // Extract bits 7:5 using right shift and mask
data.boxTamper = !!(byteArray[0] & (1 << 3)); // Extract bit 3
data.floodDetectionWireState = !!(byteArray[0] & (1 << 2)); // Extract bit 2
data.flood = !!(byteArray[0] & (1 << 1)); // Extract bit 1
data.magnet = !!(byteArray[0] & 1); // Extract bit 0
data.alarmValidated = !!(byteArray[1] & (1 << 7)); // Extract bit 7
data.manualOpenIndicator = !!(byteArray[1] & (1 << 6)); // Extract bit 6
data.manualCloseIndicator = !!(byteArray[1] & (1 << 5)); // Extract bit 5
data.softwareVersion = byteArray[1] & 0x1F; // Extract bits 4:0
data.closeTime = byteArray[2]; // Byte 2
data.openTime = byteArray[3]; // Byte 3
data.battery = ((byteArray[4] * 8) + 1600) / 1000; // Byte 4, battery calculation
return data;
}
function handleResponse(bytes, data) {
var commands = bytes.map(function (byte) {
return ("0" + byte.toString(16)).substr(-2);
});
var command_len = 0;
commands.map(function (command, i) {
switch (command) {
case '0e':
{
command_len = 4;
var openingTime = (parseInt(commands[i + 1], 16) << 8) | parseInt(commands[i + 2], 16);
var closingTime = (parseInt(commands[i + 3], 16) << 8) | parseInt(commands[i + 4], 16);
data.openCloseTimeExtended = { 'openingTime': Number(openingTime), 'closingTime': Number(closingTime) };
}
break;
case '0f':
{
command_len = 1;
data.emergencyOpenings = parseInt(commands[i + 1], 16);
}
break;
case '10':
{
command_len = 1;
data.floodAlarmTime = parseInt(commands[i + 1], 16);
}
break;
case '11':
{
command_len = 1;
data.workingVoltage = parseInt(commands[i + 1], 16);
}
break;
case '12':
{
command_len = 1;
data.keepAliveTime = parseInt(commands[i + 1], 16);
}
break;
case '13':
{
command_len = 1;
data.deviceFloodSensor = parseInt(commands[i + 1], 16);
}
break;
case '16':
{
command_len = 1;
var commandResponse = parseInt(commands[i + 1], 16);
var periodInMinutes = commandResponse * 5 / 60;
data.joinRetryPeriod = periodInMinutes;
}
break;
case '18':
{
command_len = 1;
data.uplinkType = parseInt(commands[i + 1], 16);
}
break;
case '1a':
{
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 'a0':
command_len = 4;
var fuota_address = (parseInt(commands[i + 1], 16) << 24) | (parseInt(commands[i + 2], 16) << 16) | (parseInt(commands[i + 3], 16) << 8) | parseInt(commands[i + 4], 16);
var fuota_address_raw = (parseInt(commands[i + 1], 16) << 24) | (parseInt(commands[i + 2], 16) << 16) | (parseInt(commands[i + 3], 16) << 8) | parseInt(commands[i + 4], 16);
data.fuota = { 'fuota_address': fuota_address, 'fuota_address_raw': fuota_address_raw };
break;
default:
break;
}
commands.splice(i, command_len);
});
return data;
}
if (bytes.length == 5) {
data = longPackage(bytes, data);
} else if (bytes.length == 2) {
data = shortPackage(bytes, data);
} else {
data = longPackage(bytes, data);
bytes = bytes.slice(5);
data = handleResponse(bytes, data);
}
return { data: data };
}
Last updated
Was this helpful?