Initial commit for Cors System Organisation

vendor/corssystem/cortu-gen-2.yaml

@@ -0,0 +1,129 @@
+name: CorTU Genesis 2 # Device name can not contain the vendor name
+description: Remote Data Acquisition Board with Support for LoRaWAN and RF
+
+# Hardware versions (optional, use when you have revisions)
+hardwareVersions:
+ - version: '1.0'
+ numeric: 1
+ - version: '1.0-rev-A'
+ numeric: 2
+
+# Firmware versions (at least one is mandatory)
+firmwareVersions:
+ - # Firmware version
+ version: '1.0'
+ numeric: 1
+ # Corresponding hardware versions (optional)
+ hardwareVersions:
+ - '1.0'
+
+ # Firmware features (optional)
+ # Valid values are: remote rejoin (trigger a join from the application layer), transmission interval (configure how
+ # often he device sends a message).
+ features:
+ - remote rejoin
+ - transmission interval
+
+ # LoRaWAN Device Profiles per region
+ # Supported regions are EU863-870, US902-928, AU915-928, AS923, CN779-787, EU433, CN470-510, KR920-923, IN865-867,
+ # RU864-870
+ profiles:
+ EU863-870:
+ # Optional identifier of the vendor of the profile. When you specify the vendorID, the profile is loaded from
+ # the vendorID's folder. This allows you to reuse profiles from module or LoRaWAN end device stack vendors.
+ # If vendorID is empty, the current vendor ID is used. In this example, the vendorID is the current vendor ID,
+ # which is verbose.
+ # vendorID: example
+ # Identifier of the profile (lowercase, alphanumeric with dashes, max 36 characters)
+ id: cortugenesis-profile
+ # lorawanCertified: true
+ codec: cortugenesis-codec
+ US902-928:
+ id: cortugenesis-profile
+ # lorawanCertified: true
+ codec: cortugenesis-codec
+
+# Type of device (optional)
+# Valid values are: devkit, module, cots
+deviceType: cots
+
+# Sensors that this device features (optional)
+# Valid values are:
+# 4-20 ma, accelerometer, altitude, analog input, auxiliary, barometer, battery, button, bvoc, co, co2, conductivity, current, digital input,
+# digital output, dissolved oxygen, distance, dust, energy, gps, gyroscope, h2s, hall effect, humidity, iaq, infrared, leaf wetness, level,
+# light, lightning, link, magnetometer, moisture, motion, nfc, no, no2, o3, occupancy, optical meter, particulate matter, ph, pir,
+# pm2.5, pm10, potentiometer, power, precipitation, pressure, proximity, pulse count, pulse frequency, radar, rainfall, reed switch, rssi,
+# sap flow, smart valve, smoke, snr, so2, solar radiation, sound, strain, surface temperature, switch, temperature, tilt, time, turbidity,
+# tvoc, uv, vapor pressure, velocity, vibration, voltage, water potential, water, weight, wifi ssid, wind direction, wind speed.
+sensors:
+ - 4-20 ma
+ - analog input
+ - digital input
+
+# Additional radios that this device has (optional)
+# Valid values are: ble, nfc, wifi, cellular.
+# additionalRadios:
+# - ble
+# - cellular
+
+# Bridge interfaces (optional)
+# Valid values are: modbus, m-bus, can bus, rs-485, sdi-12, analog, ethernet.
+bridgeInterfaces:
+ - modbus
+ - rs-485
+ - analog
+
+# Dimensions in mm (optional)
+# Use width, height, length and/or diameter
+dimensions:
+ width: 110
+ length: 110
+ height: 40
+
+# Weight in grams (optional)
+weight: 350
+
+# Operating conditions (optional)
+operatingConditions:
+ # Temperature (Celsius)
+ temperature:
+ min: -30
+ max: 85
+ # Relative humidity (fraction of 1)
+ relativeHumidity:
+ min: 0
+ max: 0.97
+
+# IP rating (optional)
+# ipCode: IP64
+
+# Key provisioning (optional)
+# Valid values are: custom (user can configure keys), join server and manifest.
+keyProvisioning:
+ - custom
+ - join server
+
+# Key programming (optional)
+# Valid values are: bluetooth, nfc, wifi, ethernet (via a webpage), serial (when the user has a serial interface to set the keys)
+# and firmware (when the user should change the firmware to set the keys).
+keyProgramming:
+ - serial
+ - firmware
+
+# Key security (optional)
+# Valid values are: none, read protected and secure element.
+keySecurity: none
+
+# Firmware programming (optional)
+# Valid values are: serial (when the user has a serial interface to update the firmware), ethernet, fuota lorawan (when the device
+# supports LoRaWAN FUOTA via standard interfaces) and fuota other (other wireless update mechanism).
+firmwareProgramming:
+ - serial
+ # - fuota lorawan
+
+# Product and data sheet URLs (optional)
+productURL: https://corssystem.com/products/cortu-v1-0/
+
+# Photos
+photos:
+ main: cortugenesis.png # Image needs to have a transparent background

vendor/corssystem/cortugenesis-codec.yaml

@@ -0,0 +1,3 @@
+# Uplink decoder decodes binary data uplink into a JSON object (optional)
+uplinkDecoder:
+ fileName: cortugenesis.js

vendor/corssystem/cortugenesis-profile.yaml

@@ -0,0 +1,17 @@
+# LoRaWAN MAC version: 1.0, 1.0.1, 1.0.2, 1.0.3, 1.0.4 or 1.1
+macVersion: '1.0.3'
+regionalParametersVersion: 'RP001-1.0.3-RevA'
+
+# Whether the end device supports join (OTAA) or not (ABP)
+supportsJoin: true
+
+# Maximum EIRP
+maxEIRP: 16
+# Whether the end device supports 32-bit frame counters
+supports32bitFCnt: false
+
+# Whether the end device supports class B
+supportsClassB: false
+
+# Whether the end device supports class C
+supportsClassC: false

vendor/corssystem/cortugenesis.js

@@ -0,0 +1,174 @@
+
+//CorTU Payload Formatter
+function parseIncomingData(data) {
+ const delimiter = "\n";
+ // No need to use TextDecoder as data is already a string
+ const dataSets = data.split(delimiter).filter(Boolean);
+ return dataSets.map(dataSet => {
+ const [huffmanCodesStr, encodedData] = dataSet.split("|");
+ const huffmanCodesArray = huffmanCodesStr.trim().split(';'); // Assuming ';' separates the codes
+ const huffmanCodes = {};
+ for (let i = 0; i <(huffmanCodesArray.length)-1; i++) {
+ const [key, value] = huffmanCodesArray[i].split(':');
+ huffmanCodes[key] = value;
+ }
+ return {
+ huffmanCodes,
+ encodedData
+ };
+ });
+}
+// Function to decode a Huffman-encoded bit stream using the provided codes
+function decodeHuffman(encodedData, huffmanCodes) {
+ let decodedMessage = [];
+ let currentCode = "";
+ // Iterate over each bit in the encoded data
+ for (let bit of encodedData) {
+ currentCode += bit;
+ // Check if the current code matches any entry in the Huffman codes
+ if (currentCode in huffmanCodes) {
+ // Append the corresponding character to the decoded message
+ decodedMessage.push(huffmanCodes[currentCode]);
+ // Reset the current code
+ currentCode = "";
+ }
+ }
+ // Return the decoded message as a string
+ return decodedMessage.join('');
+}
+function lppDecode(bytes) {
+ var sensor_types = {
+ 0 : {'size': 1, 'name': 'digital_in', 'signed': false, 'divisor': 1},
+ 1 : {'size': 1, 'name': 'digital_out', 'signed': false, 'divisor': 1},
+ 2 : {'size': 2, 'name': 'analog_in', 'signed': true , 'divisor': 100},
+ 3 : {'size': 2, 'name': 'analog_out', 'signed': true , 'divisor': 100},
+ 100: {'size': 4, 'name': 'generic', 'signed': false, 'divisor': 1},
+ 101: {'size': 2, 'name': 'illuminance', 'signed': false, 'divisor': 1},
+ 102: {'size': 1, 'name': 'presence', 'signed': false, 'divisor': 1},
+ 103: {'size': 2, 'name': 'temperature', 'signed': true , 'divisor': 10},
+ 104: {'size': 1, 'name': 'humidity', 'signed': false, 'divisor': 2},
+ 113: {'size': 6, 'name': 'accelerometer', 'signed': true , 'divisor': 1000},
+ 115: {'size': 2, 'name': 'barometer', 'signed': false, 'divisor': 10},
+ 116: {'size': 2, 'name': 'voltage', 'signed': false, 'divisor': 100},
+ 117: {'size': 2, 'name': 'current', 'signed': false, 'divisor': 1000},
+ 118: {'size': 4, 'name': 'frequency', 'signed': false, 'divisor': 1},
+ 120: {'size': 1, 'name': 'percentage', 'signed': false, 'divisor': 1},
+ 121: {'size': 2, 'name': 'altitude', 'signed': true, 'divisor': 1},
+ 125: {'size': 2, 'name': 'concentration', 'signed': false, 'divisor': 1},
+ 128: {'size': 2, 'name': 'power', 'signed': false, 'divisor': 1},
+ 130: {'size': 4, 'name': 'distance', 'signed': false, 'divisor': 1000},
+ 131: {'size': 4, 'name': 'energy', 'signed': false, 'divisor': 1000},
+ 132: {'size': 2, 'name': 'direction', 'signed': false, 'divisor': 1},
+ 133: {'size': 4, 'name': 'time', 'signed': false, 'divisor': 1},
+ 134: {'size': 6, 'name': 'gyrometer', 'signed': true , 'divisor': 100},
+ 135: {'size': 3, 'name': 'colour', 'signed': false, 'divisor': 1},
+ 136: {'size': 9, 'name': 'gps', 'signed': true, 'divisor': [10000,10000,100]},
+ 142: {'size': 1, 'name': 'switch', 'signed': false, 'divisor': 1},
+ };
+ function arrayToDecimal(stream, is_signed, divisor) {
+ var value = 0;
+ for (var i = 0; i < stream.length; i++) {
+ if (stream[i] > 0xFF)
+ throw 'Byte value overflow!';
+ value = (value << 8) | stream[i];
+ }
+ if (is_signed) {
+ var edge = 1 << (stream.length) * 8; // 0x1000..
+ var max = (edge - 1) >> 1; // 0x0FFF.. >> 1
+ value = (value > max) ? value - edge : value;
+ }
+ value /= divisor;
+ return value;
+ }
+ var sensors = [];
+ var i = 0;
+ while (i < bytes.length) {
+ var s_no = bytes[i++];
+ var s_type = bytes[i++];
+ if (typeof sensor_types[s_type] == 'undefined') {
+ throw 'Sensor type error!: ' + s_type;
+ }
+ var s_value = 0;
+ var type = sensor_types[s_type];
+ switch (s_type) {
+ case 113: // Accelerometer
+ case 134: // Gyrometer
+ s_value = {
+ 'x': arrayToDecimal(bytes.slice(i+0, i+2), type.signed, type.divisor),
+ 'y': arrayToDecimal(bytes.slice(i+2, i+4), type.signed, type.divisor),
+ 'z': arrayToDecimal(bytes.slice(i+4, i+6), type.signed, type.divisor)
+ };
+ break;
+ case 136: // GPS Location
+ s_value = {
+ 'latitude': arrayToDecimal(bytes.slice(i+0, i+3), type.signed, type.divisor[0]),
+ 'longitude': arrayToDecimal(bytes.slice(i+3, i+6), type.signed, type.divisor[1]),
+ 'altitude': arrayToDecimal(bytes.slice(i+6, i+9), type.signed, type.divisor[2])
+ };
+ break;
+ case 135: // Colour
+ s_value = {
+ 'r': arrayToDecimal(bytes.slice(i+0, i+1), type.signed, type.divisor),
+ 'g': arrayToDecimal(bytes.slice(i+1, i+2), type.signed, type.divisor),
+ 'b': arrayToDecimal(bytes.slice(i+2, i+3), type.signed, type.divisor)
+ };
+ break;
+ default: // All the rest
+ s_value = arrayToDecimal(bytes.slice(i, i + type.size), type.signed, type.divisor);
+ break;
+ }
+ sensors.push({
+ 'channel': s_no,
+ 'type': s_type,
+ 'name': type.name,
+ 'value': s_value
+ });
+ i += type.size;
+ }
+ return sensors;
+}
+// Convert hex string to byte array
+function hexStringToByteArray(hexString) {
+var bytes = [];
+for (var i = 0; i < hexString.length; i += 2) {
+ bytes.push(parseInt(hexString.substr(i, 2), 16));
+}
+return bytes;
+}
+function decodeUplink(input)
+{
+// Convert decimal bytes to ASCII string
+var dataString = '';
+for (var i = 0; i < input.bytes.length; i++) {
+ dataString += String.fromCharCode(input.bytes[i]);
+}
+//Separate the Huffman codes from the encoded data
+let dataset = parseIncomingData(dataString);
+// Initialize an object to store all Huffman codes
+let allHuffmanCodes = {};
+// Merge all Huffman codes into one object
+dataset.forEach(item => {
+Object.assign(allHuffmanCodes, item.huffmanCodes);
+});
+//String to store encoded (compressed) data
+let allencodedData = dataset.map(item => item.encodedData).join('');
+//Decoding the data
+let decodedData = decodeHuffman(allencodedData, allHuffmanCodes);
+//Converting string data output from Huffman encode to hex byte array hex
+let bytes = hexStringToByteArray(decodedData);
+// flat output (like original Cayenne lpp decoder):
+var response = {};
+lppDecode(bytes, 1).forEach(function(field) {
+ response[field.name + '_' + field.channel] = field.value;
+ });
+return {
+ data: {
+ bytes: input.bytes,
+ decoded: {
+ message: response
+ }
+ },
+ warnings: [],
+ errors: []
+};
+}

vendor/corssystem/index.yaml

@@ -0,0 +1,2 @@
+endDevices:
+ - cortu-gen-2

vendor/index.yaml

@@ -2070,6 +2070,15 @@ vendors:
  linkedin: https://www.linkedin.com/company/cicicom-ltd
  facebook: https://www.facebook.com/cicicom
 
+ - id: corssystem
+ name: Cors System Technologies
+ description: Cors System Technologies is a Nigerian digital transformation company, with a focus in bringing existing industries into Industry 4.0.
+ logo: corssystem.png
+ website: https://corssystem.com/
+ social:
+ linkedin: https://www.linkedin.com/company/cors-system/
+ github: corssystem
+
  - id: atomsenses
  name: Atomsenses
  description: Atomsenses is a specialist IoT solution provider focusing on Lorawan sensors for indoor air quality monitoring, our vision is to transform how we manage and maintain healthy indoor environments.