Added MOKOsmart vendor and MOKOsmart LW005-MP device

vendors/mokosmart/codecs/lw005-mp.js

@@ -0,0 +1,283 @@
+//LW005-MP Payload Decoder rule
+//Creation time:2022-07-20 
+//Creator:yujiahang
+//Suitable firmware versions:LW005-MP V1.X.X
+//Programming languages:Javascript
+//Suitable platforms:Chirpstack
+var payloadTypeArray = [
+    "Switch"
+    , "Electrical"
+    , "Electrical"
+    , "Energy"
+    , "Over-voltage"
+    , "Sag-voltage"
+    , "Over-current"
+    , "Over-load"
+    , "Load state"
+    , "Countdown"
+];
+// Decode uplink function.
+//
+// Input is an object with the following fields:
+// - bytes = Byte array containing the uplink payload, e.g. [255, 230, 255, 0]
+// - fPort = Uplink fPort.
+// - variables = Object containing the configured device variables.
+//
+// Output must be an object with the following fields:
+// - data = Object representing the decoded payload.
+function decodeUplink(input) {
+    var bytes = input.bytes;
+    var fPort = input.fPort;
+    var deviceInfo = {};
+    var data = {};
+    if (fPort == 0) {
+        deviceInfo.data = data;
+        return deviceInfo;
+    }
+
+    data.port = fPort;
+    data.hex_format_payload = bytesToHexString(bytes, 0, bytes.length);
+    data.payload_type = payloadTypeArray[fPort - 5];
+    if (command_format_check(bytes, fPort) == false) {
+        data.result = "Format wrong";
+		deviceInfo.data = data;
+        return deviceInfo;
+    }
+    var timestamp = bytesToInt(bytes, 0, 4);
+    if (timestamp < 1000000000){
+        data.result = "Timestamp wrong";
+		deviceInfo.data = data;
+        return deviceInfo;
+    }
+    data.time = parse_time(timestamp, bytes[4] * 0.5);
+	data.timestamp = timestamp;
+    data.timezone = signedHexToInt(bytesToHexString(bytes, 4, 1)) / 2;
+    switch (fPort) {
+        case 5:
+            data.ac_output_state = bytes[5] == 1 ? "ON" : "OFF";
+            data.plug_load_status = bytes[6] == 1 ? "There is a load on the plug" : "No load on the plug";
+            break;
+        case 6:
+            data.instantaneous_voltage = bytesToInt(bytes, 5, 2) / 10 + "V";
+            data.instantaneous_current = bytesToInt(bytes, 7, 2) / 1000 + "A";
+            data.instantaneous_current_frequency = bytesToInt(bytes, 9, 2) / 1000 + "HZ";
+            break;
+        case 7:
+            data.instantaneous_active_power = bytesToInt(bytes, 5, 4) / 10 + "W";
+            data.instantaneous_power_factor = (bytes[9] & 0xFF) + "%";
+            break;
+        case 8:
+            data.total_energy = Number(bytesToInt(bytes, 5, 4) / 3200).toFixed(2) + "KWH";
+            data.energy_of_last_hour = Number(bytesToInt(bytes, 9, 2) / 3200).toFixed(2) + "KWH";
+            break;
+        case 9:
+            data.over_voltage_state = bytes[5];
+            data.current_instantaneous_voltage = bytesToInt(bytes, 6, 2) / 10 + "V";
+            data.over_voltage_threshold = bytesToInt(bytes, 8, 2) / 10 + "V";
+            break;
+        case 10:
+            data.sag_voltage_state = bytes[5];
+            data.current_instantaneous_voltage = bytesToInt(bytes, 6, 2) / 10 + "V";
+            data.sag_voltage_threshold = bytesToInt(bytes, 8, 2) / 10 + "V";
+            break;
+        case 11:
+            data.over_current_state = bytes[5];
+            data.current_instantaneous_current = parse_int16(bytesToInt(bytes, 6, 2)) / 1000 + "A";
+            data.over_current_threshold = bytesToInt(bytes, 8, 2) / 1000 + "A";
+            break;
+        case 12:
+            data.over_load_state = bytes[5];
+            data.current_instantaneous_power = parse_int24(bytesToInt(bytes, 6, 3)) / 10 + "W";
+            data.over_load_threshold = bytesToInt(bytes, 9, 2) / 10 + "W";
+            break;
+        case 13:
+            data.load_change_state = bytes[5] == 1 ? "load starts working" : "load starts stop";
+            break;
+        case 14:
+            data.ac_output_state_after_countdown = bytes[5] == 1 ? "ON" : "OFF";;
+            data.remaining_time_of_countdown_process = bytesToInt(bytes, 6, 4) + "s";
+            break;
+        default:
+            break;
+    }
+	deviceInfo.data = data;
+    return deviceInfo;
+}
+
+function command_format_check(bytes, port) {
+    if (port >= 1 || port <= 4) {
+        return true;
+    }
+    switch (port) {
+        case 5:
+            if (bytes.length === 7)
+                return true;
+            break;
+
+        case 6:
+            if (bytes.length === 11)
+                return true;
+            break;
+
+        case 7:
+            if (bytes.length === 10)
+                return true;
+            break;
+
+        case 8:
+            if (bytes.length === 11)
+                return true;
+            break;
+
+        case 9:
+            if (bytes.length === 10)
+                return true;
+            break;
+
+        case 10:
+            if (bytes.length === 10)
+                return true;
+            break;
+
+        case 11:
+            if (bytes.length === 10)
+                return true;
+            break;
+
+        case 12:
+            if (bytes.length === 11)
+                return true;
+            break;
+
+        case 13:
+            if (bytes.length === 6)
+                return true;
+            break;
+
+        case 14:
+            if (bytes.length === 10)
+                return true;
+            break;
+
+        default:
+            break;
+    }
+
+    return false;
+}
+
+function bytesToHexString(bytes, start, len) {
+    var char = [];
+    for (var i = 0; i < len; i++) {
+        var data = bytes[start + i].toString(16);
+        var dataHexStr = ("0x" + data) < 0x10 ? ("0" + data) : data;
+        char.push(dataHexStr);
+    }
+    return char.join("");
+}
+
+function parse_int16(num) {
+    if (num & 0x8000)
+        return (num - 0x10000);
+    else
+        return num;
+}
+
+function parse_int24(num) {
+    if (num & 0x800000)
+        return (num - 0x1000000);
+    else
+        return num;
+}
+
+
+function parse_time(timestamp, timezone) {
+    timezone = timezone > 64 ? timezone - 128 : timezone;
+    timestamp = timestamp + timezone * 3600;
+    if (timestamp < 0) {
+        timestamp = 0;
+    }
+
+    var d = new Date(timestamp * 1000);
+    //d.setUTCSeconds(1660202724);
+
+    var time_str = "";
+    time_str += d.getUTCFullYear();
+    time_str += "-";
+    time_str += formatNumber(d.getUTCMonth() + 1);
+    time_str += "-";
+    time_str += formatNumber(d.getUTCDate());
+    time_str += " ";
+
+    time_str += formatNumber(d.getUTCHours());
+    time_str += ":";
+    time_str += formatNumber(d.getUTCMinutes());
+    time_str += ":";
+    time_str += formatNumber(d.getUTCSeconds());
+
+    return time_str;
+}
+
+function formatNumber(number) {
+    return number < 10 ? "0" + number : number;
+}
+
+function signedHexToInt(hexStr) {
+    var twoStr = parseInt(hexStr, 16).toString(2); // 将十六转十进制，再转2进制
+    var bitNum = hexStr.length * 4; // 1个字节 = 8bit ，0xff 一个 "f"就是4位
+    if (twoStr.length < bitNum) {
+        while (twoStr.length < bitNum) {
+            twoStr = "0" + twoStr;
+        }
+    }
+    if (twoStr.substring(0, 1) == "0") {
+        // 正数
+        twoStr = parseInt(twoStr, 2); // 二进制转十进制
+        return twoStr;
+    }
+    // 负数
+    var twoStr_unsign = "";
+    twoStr = parseInt(twoStr, 2) - 1; // 补码：(负数)反码+1，符号位不变；相对十进制来说也是 +1，但这里是负数，+1就是绝对值数据-1
+    twoStr = twoStr.toString(2);
+    twoStr_unsign = twoStr.substring(1, bitNum); // 舍弃首位(符号位)
+    // 去除首字符，将0转为1，将1转为0   反码
+    twoStr_unsign = twoStr_unsign.replace(/0/g, "z");
+    twoStr_unsign = twoStr_unsign.replace(/1/g, "0");
+    twoStr_unsign = twoStr_unsign.replace(/z/g, "1");
+    twoStr = -parseInt(twoStr_unsign, 2);
+    return twoStr;
+}
+
+function bytesToInt(bytes, start, len) {
+	var value = 0;
+	for (var i = 0; i < len; i++) {
+		var m = ((len - 1) - i) * 8;
+		value = value | bytes[start + i] << m;
+	}
+	// var value = ((bytes[start] << 24) | (bytes[start + 1] << 16) | (bytes[start + 2] << 8) | (bytes[start + 3]));
+	return value;
+}
+
+// function getData(hex) {
+// 	var length = hex.length;
+// 	var datas = [];
+// 	for (var i = 0; i < length; i += 2) {
+// 		var start = i;
+// 		var end = i + 2;
+// 		var data = parseInt("0x" + hex.substring(start, end));
+// 		datas.push(data);
+// 	}
+// 	return datas;
+// }
+
+// var input = {};
+// input.fPort = 8;
+// input.bytes = getData("0000000010000216eb0000");
+// console.log(decodeUplink(input));
+
+//deviceInfo = Decoder([0x62, 0xF4, 0xBA, 0xDA, 0x10, 0x00, 0x00], 5);
+//deviceInfo = Decoder([0x61, 0xAD, 0x6C, 0x62, 0x10, 0x09, 0x2D, 0xF2, 0x0F, 0xC3, 0x65], 6);
+//deviceInfo = Decoder([0x61, 0xAD, 0x6C, 0x62, 0x10, 0x00, 0x00, 0x78, 0xF9, 0x26], 7);
+// deviceInfo = Decoder([0x61, 0xAD, 0x6C, 0x44, 0x10, 0x00, 0xB4, 0x1F, 0x3F, 0x01, 0x67], 8);
+// console.log(deviceInfo);
+// console.log(parse_time(1660202724, 0));

vendors/mokosmart/codecs/test_decode_lw005-mp.json

@@ -0,0 +1 @@
+[]

vendors/mokosmart/codecs/test_encode_lw005-mp.json

@@ -0,0 +1 @@
+[]

vendors/mokosmart/devices/lw005-mp.toml

@@ -0,0 +1,18 @@
+[device]
+id = "f2b69399-969c-45e6-bef4-898e74332fd2"
+name = "LW005-MP"
+description = "Smart plug with power and energy monitoring"
+
+[[device.firmware]]
+version = "1.0"
+profiles = [
+    "EU868-1_0_3.toml",
+    "AU915-1_0_3.toml",
+    "AS923-1_0_3.toml",
+    "US915-1_0_3.toml",
+]
+codec = "lw005-mp.js"
+
+[device.metadata]
+product_url = "https://www.mokosmart.com/lorawan-meter-plug-lw005-mp/"
+documentation_url = "https://www.mokosmart.com/lorawan-meter-plug-lw005-mp/"

vendors/mokosmart/profiles/AS923-1_0_3.toml

@@ -0,0 +1,25 @@
+[profile]
+id = "a36dade4-89e5-4aee-9c16-a2d7d8403c12"
+vendor_profile_id = 0
+region = "AS923"
+mac_version = "1.0.3"
+reg_params_revision = "A"
+supports_otaa = true
+supports_class_b = false
+supports_class_c = false
+max_eirp = 16
+
+[profile.abp]
+rx1_delay = 0
+rx1_dr_offset = 0
+rx2_dr = 0
+rx2_freq = 0
+
+[profile.class_b]
+timeout_secs = 0
+ping_slot_nb_k = 0
+ping_slot_dr = 0
+ping_slot_freq = 0
+
+[profile.class_c]
+timeout_secs = 0

vendors/mokosmart/profiles/AU915-1_0_3.toml

@@ -0,0 +1,25 @@
+[profile]
+id = "9067cb54-7f52-4f37-85d1-851c1e96c4e6"
+vendor_profile_id = 0
+region = "AU915"
+mac_version = "1.0.3"
+reg_params_revision = "A"
+supports_otaa = true
+supports_class_b = false
+supports_class_c = false
+max_eirp = 30
+
+[profile.abp]
+rx1_delay = 0
+rx1_dr_offset = 0
+rx2_dr = 0
+rx2_freq = 0
+
+[profile.class_b]
+timeout_secs = 0
+ping_slot_nb_k = 0
+ping_slot_dr = 0
+ping_slot_freq = 0
+
+[profile.class_c]
+timeout_secs = 0

vendors/mokosmart/profiles/EU868-1_0_3.toml

@@ -0,0 +1,25 @@
+[profile]
+id = "03d8d816-bf65-42d1-bccf-b3a5451f41b0"
+vendor_profile_id = 0
+region = "EU868"
+mac_version = "1.0.3"
+reg_params_revision = "A"
+supports_otaa = true
+supports_class_b = false
+supports_class_c = false
+max_eirp = 16
+
+[profile.abp]
+rx1_delay = 0
+rx1_dr_offset = 0
+rx2_dr = 0
+rx2_freq = 0
+
+[profile.class_b]
+timeout_secs = 0
+ping_slot_nb_k = 0
+ping_slot_dr = 0
+ping_slot_freq = 0
+
+[profile.class_c]
+timeout_secs = 0