function readName(bytes, i) {
    return bytes.slice(i, i + 6);
}

function readValue(len, bytes, i) {
    if (len <= 0) {
        return [];
    }
    return bytes.slice(i, i + len);
}

function toHexString(byteArray) {
    var s = '';
    byteArray.forEach(function (byte) {
        s += ('0' + (byte & 0xFF).toString(16)).slice(-2);
    });
    return s;
}

function parse_sint16(bytes, idx) {
    bytes = bytes.slice(idx || 0);
    var t = bytes[0] << 8 | bytes[1] << 0;
    if( (t & 1<<15) > 0){ // temp is negative (16bit 2's complement)
        t = ((~t)& 0xffff)+1; // invert 16bits & add 1 => now positive value
        t=t*-1;
    }
    return t;
}

function parse_uint16(bytes, idx) {
    bytes = bytes.slice(idx || 0);
    var t = bytes[0] << 8 | bytes[1] << 0;
    return t;
}


function signed(val, bits) {
    if ((val & 1 << (bits - 1)) > 0) { // value is negative (16bit 2's complement)
        var mask = Math.pow(2, bits) - 1;
        val = (~val & mask) + 1; // invert all bits & add 1 => now positive value
        val = val * -1;
    }
    return val;
}
function uint40_BE(bytes, idx) {
    bytes = bytes.slice(idx || 0);
    return bytes[0] << 32 |
        bytes[1] << 24 | bytes[2] << 16 | bytes[3] << 8 | bytes[4] << 0;
}
function uint16_BE(bytes, idx) {
    bytes = bytes.slice(idx || 0);
    return bytes[0] << 8 | bytes[1] << 0;
}
function int40_BE(bytes, idx) {return signed(uint40_BE(bytes, idx), 40);}
function int16_BE(bytes, idx) {return signed(uint16_BE(bytes, idx), 16);}
function int8(bytes, idx) {return signed(bytes[idx || 0], 8);}

function toNumber(bytes) {
    var res = 0;

    for (var i = bytes.length-1; i >= 0 ; i--) {
        res *= 256;
        res += bytes[i];
    }
    
    return res;
}

function readVersion(bytes) {
    if (bytes.length<3) {
        return null;
    }
    return "v" + bytes[0] + "." + bytes[1] + "." + bytes[2];
}

function decodeStatus(bytes) {
    var decoded = {
        "version":readVersion(bytes),
        "flags": bytes[3],
        "vBat": uint16_BE(bytes, 4) / 1000,
        "temp": int16_BE(bytes, 6) / 10,
    };

    if (Device) {
        Device.setProperty("version", decoded.version);
        Device.setProperty("voltage", decoded.vBat);
        Device.setProperty("temperature", decoded.temp);
        Device.setProperty("status_flags", decoded.flags);
    }

    return decoded;
}

function decodeSmlValuesV1(bytes) {
    var decoded = {
        values: [],
    };

    if (bytes.length === 1) {
        // No Data! Read error?
        return decoded;
    }

    var pos = 0;
    while (pos < bytes.length) {
        var name = readName(bytes, pos);
        pos += 6;
        var len = bytes[pos];
        pos += 1;
        var value = readValue(len, bytes, pos);
        pos += len;

        var val = {
            nameHex: toHexString(name),
            len: len,
            value: toNumber(value),
            valueHex: toHexString(value)
        };

        decoded.values.push(val);
    }

    return decoded;
}

function decodeSmlValuesV2(bytes) {
    var decoded = {
        values: [],
    };

    if (bytes.length === 1) {
        // No Data! Read error?
        return decoded;
    }

    var pos = 0;
    var headNo = bytes[0];
    decoded.headNo = headNo;
    pos += 1;
    while (pos < bytes.length) {
        var name = readName(bytes, pos);
        pos += 6;
        var len = bytes[pos];
        pos += 1;
        var value = readValue(len, bytes, pos);
        pos += len;
        if (len > 0) {
            var exponent = int8(bytes, pos);
            pos += 1;
        }
        if (len > 0) {
            var unit = int8(bytes, pos);
            pos += 1;
        }
        var val;
        if (len > 0) {
            val = {
                obiscode: name[0] + "-" + name[1] +":" + name[2] + "." + name[3] + "." +name[4] + "*" +name[5],
                //len: len,
                value: toNumber(value) * Math.pow(10, exponent),
                unit: toNumber(unit),
                //valueHex: toHexString(value),
            }
        } else {
            val = {
                obiscode: name[0] + "-" + name[1] +":" + name[2] + "." + name[3] + "." +name[4] + "*" +name[5],
                //len: len,
                value: toNumber(value),
                unit: toNumber(unit),
                //valueHex: toHexString(value),
            }
        }

        decoded.values.push(val);
    }
    return decoded;
}

function decodeSmlValuesV3(bytes) {
      var decoded = {
        values: [],
    };

    if (bytes.length === 1) {
        // No Data! Read error?
        return decoded;
    }

    var pos = 0;
    var headNo = bytes[0];
    decoded.headNo = headNo;
    pos += 1;
    
    decoded.time = int40_BE(bytes, 1) * 1000;
    pos+=5;
    
    while (pos < bytes.length) {
        var name = readName(bytes, pos);
        pos += 6;
        var len = bytes[pos];
        pos += 1;
        var value = readValue(len, bytes, pos);
        pos += len;
        if (len > 0) {
            var exponent = int8(bytes, pos);
            pos += 1;
        }
        if (len > 0) {
            var unit = int8(bytes, pos);
            pos += 1;
        }
        var val;
        if (len > 0) {
            val = {
                obiscode: name[0] + "-" + name[1] +":" + name[2] + "." + name[3] + "." +name[4] + "*" +name[5],
                //nameHex: toHexString(name),
                //len: len,
                value: toNumber(value) * Math.pow(10, exponent),
                //valueHex: toHexString(value),
                unit: toNumber(unit),
            }
        }
        else {
            val = {
                obiscode: name[0] + "-" + name[1] +":" + name[2] + "." + name[3] + "." +name[4] + "*" +name[5],
                //len: len,
                value: toNumber(value),
                //valueHex: toHexString(value),
                unit: toNumber(unit),
            }
        }

        decoded.values.push(val);
    }
    return decoded;
}

function decode_status_code(code) {
  switch (code) {
    case 0:
      return "OK";
    default:
      return "UNKNOWN";
  }
}

function decode_reboot_reason(code) {
  // STM reboot code from our HAL:
  switch (code) {
    case 1:
      return "LOW_POWER_RESET";
    case 2:
      return "WINDOW_WATCHDOG_RESET";
    case 3:
      return "INDEPENDENT_WATCHDOG_RESET";
    case 4:
      return "SOFTWARE_RESET";
    case 5:
      return "POWER_ON_RESET";
    case 6:
      return "EXTERNAL_RESET_PIN_RESET";
    case 7:
      return "OBL_RESET";
    default:
      return "UNKNOWN";
  }
}

function DecoderPort64(bytes) {
  // legacy format, firmware 4.x
  // Decode an uplink message from a buffer
  // (array) of bytes to an object of fields.
  var firmware = String.fromCharCode.apply(null, bytes.slice(0, 3));
  var version = readVersion(bytes, 3);
  var status_code = bytes[6];
  var status_text = decode_status_code(status_code);
  var reboot_code = bytes[7];
  var reboot_reason = decode_reboot_reason(reboot_code);
  var final_code = bytes[8];
  var vcc = (parse_uint16(bytes, 9) / 1000) || 0.0;
  var temp = (parse_sint16(bytes, 11) / 10) || -0x8000;
  var error_state = bytes[13];
  
  Device.setProperty("firmware", firmware);
  Device.setProperty("version", version);
  Device.setProperty("status_code", status_code);
  Device.setProperty("status_text", status_text);
  Device.setProperty("reboot_code", reboot_code);
  Device.setProperty("reboot_reason", reboot_reason);
  Device.setProperty("final_code", final_code);
  Device.setProperty("error_state", error_state);
  Device.setProperty("temperature", temp);
  Device.setProperty("voltage", vcc);
  
  return {
    "firmware": firmware,
    "version": version,
    "status_code": status_code,
    "status_text": status_text,
    "reboot_code": reboot_code,
    "reboot_reason": reboot_reason,
    "final_code": final_code,
    "temperature": temp,
    "voltage": vcc,
    "error_state": error_state
  };
}

function Decoder(bytes, port) {
    // Decode an uplink message from a buffer
    // (array) of bytes to an object of fields.
    switch (port) {
        case 1:
            return decodeStatus(bytes);
        case 2:
            return decodeSmlValuesV1(bytes);
        case 3:
            return decodeSmlValuesV2(bytes);
        case 4:
            return decodeSmlValuesV3(bytes);
        case 64: 
            return DecoderPort64(bytes);
    }
}

function NB_ParseDeviceQuery(input) {
    for (var key in input.d) {
        var v = input.d[key];
        switch (key) {
            case "temperature":
                v = v / 10.0;
                break;
            case "vbat":
                v = v / 1000.0;
                //NB_SetBatteryStatus(v)
                break;
        }
        Device.setProperty("device." + key, v);
    }
    return null;
}

function NB_ParseConfigQuery(input) {
    for (var key in input.d) {
        Device.setConfig(key, input.d[key]);
    }
    return null;
}

function ParseV2(input) {
  var decoded = {
        values: [],
    };
  
  decoded.headNo = input.d.head;
  decoded.time = new Date(input.d.timestamp*1000).toISOString();
  
  
  //return toNumber(parseBase64(input.d.batch[0].value)) * Math.pow(10, input.d.batch[0].scaler);
  //decoded.payload = input.d;
  var val;
  
  if ((input.d.batch) && (input.d.batch.length > 0) ) {
    for( i = 0; i<input.d.batch.length; i++){
      val = {
          obiscode: input.d.batch[i].obiscode,
          value: input.d.batch[i].value * Math.pow(10, input.d.batch[i].scaler),
          //valueHex: toHexString(input.d.batch[i].value),
          unit: toNumber(input.d.batch[i].unit),
      }
      decoded.values.push(val);
    }
  }
  return decoded;
}

function NB_ParseStatusQuery(input) {
  for (var key in input.d) {
    var v = input.d[key];
      switch (key) {
          case "temperature":
              v = v / 10.0;
              break;
          case "vbat":
              v = v / 1000.0;
              //NB_SetBatteryStatus(v)
              continue;
      }
      Device.setProperty("device." + key, v);
  }
  return null;
}


function ParseNBiot(input) {
  var query = input.q || "data";
  var res = null;
  switch (query) {
        case "device":
            res = NB_ParseDeviceQuery(input); 
            break;
        case "config":
            res = NB_ParseConfigQuery(input); 
            break;
        case "data":
            res = ParseV2(input); 
            break;
        case "status":
            res = NB_ParseStatusQuery(input); 
            break;
              
        default:
            throw new Error("Unknown message type: '" + query + "'");
  }
  
  if (res != null) {
    res.addr = input.i; 
    res.fCnt = input.n; 
  }
  return res;
}

// Wrapper for Lobaro Platform
function Parse(input) {
    // Decode an incoming message to an object of fields.
    var b = bytes(atob(input.data));
    
    // NB-IoT
    if (input.d) {
      return ParseNBiot(input)
    }
    
    // LoRaWAN
    return Decoder(b, input.fPort);
}