Event door/window Modul BLE

/* ============================= Config CHANGE HERE =============================== */
let mqttID = "shellyBLU"; //MQTT Topic ID, (behind topicPrefix)
let sendMQTT = false; //send Button Data also per MQTT, true/false 
let topicPrefix = ""; //Here you can set your own mqtt Topic Prefix
let vSwitch = false; // create MQTT virtual Switch states, ture/false
let debug = true; //show debug msg in log, true/false, warning setting this to 'true' will delay reaktion speed a lot
/* ============================== STOP CHANGING HERE =============================== */

//========= Skript Setup =========
let activeScan = true; //active or passiv Bluetooth Scan, true/false
let _cid = "0ba9"; //Allterco, Company ID(MFD)
let uuid = "fcd2"; //BTHome, Service ID
let devID1 = "SBBT"; // BluButton1, deviceID, --> SBBT-002C evt. 002C = charge?
let devID2 = "SBDW"; // Blu Door/Window, deviceID
let bthObjectIDs = []; //Used BTHome Service.Payload ObjectID List for BluButton1,(here you can find a full List --> " https://bthome.io/format ")
bthObjectIDs[0x00] = { key: 'pid', dataType: 'uint8' };
bthObjectIDs[0x01] = { key: 'battery', dataType: 'uint8', unit: '%' };
bthObjectIDs[0x3a] = { key: 'buttonID', dataType: 'uint8' };
bthObjectIDs[0x05] = { key: 'illuminance', dataType: 'uint24', factor: 0.01 };
bthObjectIDs[0x1a] = { key: 'doorStateID', dataType: 'uint8' };
bthObjectIDs[0x20] = { key: 'moistureLvl', dataType: 'uint8' };
bthObjectIDs[0x2d] = { key: 'windowStateID', dataType: 'uint8' };
bthObjectIDs[0x3f] = { key: 'rotationLvl', dataType: 'int16', factor: 0.1 };
let vSwitchCache = {}, last_packet_id = 0x100, last_addr = 0, scanDuration = BLE.Scanner.INFINITE_SCAN;
//=========== End Setup ===========
function SendMQTTmsg(mac,event){
    if(MQTT.isConnected()){
        let mainTopic = mqttID +'-'+ mac + '/', inputID = JSON.stringify(event.info.data.inputID);
        if(topicPrefix.length !== 0) mainTopic = topicPrefix +'/'+ mqttID +'-'+ mac + '/';
        if(inputID !== '0' && inputID !== '254' && vSwitch){ // do not trigger virtual switch logik for beacon or hold events.
            if(vSwitchCache['s'+inputID] === undefined || vSwitchCache['s'+inputID] === 'false'){
                vSwitchCache['s'+inputID] = 'true';
            }else{
                vSwitchCache['s'+inputID] = 'false';
            }
        }
        if(debug) print('MQTT Publishing: _Topic: ', mainTopic, 'events/rpc _Payload: ', JSON.stringify(event));
        MQTT.publish(mainTopic + 'events/rpc', JSON.stringify(event), 1, false);
        MQTT.publish(mainTopic + 'status/input:' + inputID, JSON.stringify(event.info.ts), 1, false);
        if(inputID !== '0' && inputID !== '254' && vSwitch) MQTT.publish(mainTopic + 'status/switch:' + inputID, vSwitchCache['s'+inputID], 1, false);
        MQTT.publish(mainTopic + 'info/battery', JSON.stringify(event.info.data.battery_value), 1, true);
        MQTT.publish(mainTopic + 'info/rssi', JSON.stringify(event.info.data.rssi), 1, true);
        MQTT.publish(mainTopic + 'info/lastTimeStamp', JSON.stringify(event.info.ts), 1, true);
        MQTT.publish(mainTopic + 'info/lastAktion', event.info.event, 1, true);
        MQTT.publish(mainTopic + 'info/lastAktionID', inputID, 1, true);
        MQTT.publish(mainTopic + 'info/mac', event.info.data.mac, 1, true);
        MQTT.publish(mainTopic + 'info/device', event.info.data.device, 1, true);
        MQTT.publish(mainTopic + 'info/encryption', JSON.stringify(event.info.data.encryption), 1, true);
        MQTT.publish(mainTopic + 'info/gateway', event.info.data.gateway, 1, true); 
    }else{
        print('Error: MQTT is still not ready, cant send msg');
    }
}
function FilterEvents(obj){
    if(obj.info === undefined || obj.info.data === undefined || obj.info.data.generation !== 'BLU') return;
    SendMQTTmsg(obj.info.data.mac,obj);
}
let BTHomeDecoder = {
    UInt_To_Int: function (uint, bitsz) {
        let mask = 1 << (bitsz - 1); //create mask to filter last bit
        if (uint & mask) {
            return uint - (1 << bitsz); //convert uint to negative int
        } else {
            return uint; //uint is positive, no change needed.
        }
    },
    GetMaxBytes: function (dataType) {
        if (dataType === 'uint8' || dataType === 'int8') return 1;
        if (dataType === 'uint16' || dataType === 'int16') return 2;
        if (dataType === 'uint24' || dataType === 'int24') return 3;
        return 255;
    },
    GetValue: function (dataType, buffer) {
        let maxBytes = this.GetMaxBytes(dataType);
        if (buffer.length < maxBytes) {
            print('Error: ValueBuffer has, ', buffer.length, ' Bytes with DataType, ', dataType);
            return null;
        }
        let data = null;
        let _1stByte = buffer.at(0); //get 1.Byte of Buffer
        let _2ndByte = null;
        if (maxBytes > 1) _2ndByte = buffer.at(1); //get 2.Byte of Buffer
        let _3rdByte = null;
        if (maxBytes > 2) _3rdByte = buffer.at(2); //get 3.Byte of Buffer
        if (dataType === 'uint8') data = _1stByte;
        if (dataType === 'int8') data = this.UInt_To_Int(_1stByte, 8);
        if (dataType === 'uint16') data = 0xffff & ((_2ndByte << 8) | _1stByte);
        if (dataType === 'int16') data = this.UInt_To_Int(0xffff & ((_2ndByte << 8) | _1stByte), 16);
        if (dataType === 'uint24') data = 0x00ffffff & ((_3rdByte << 16) | (_2ndByte << 8) | _1stByte);
        if (dataType === 'int24') data = this.UInt_To_Int(0x00ffffff & ((_3rdByte << 16) | (_2ndByte << 8) | _1stByte), 24);
        return data;
    },
    Unpack: function (payload) {
        if (typeof payload !== "string" || payload.length === 0) return null;
        let btHomeObj = {}, byte = payload.at(0), value, objectID; //byte = payload.at(0) --> get 1.Byte of Payload
        if (byte & 0x1) {
            btHomeObj['encryption'] = true; //analyze 1. Bit and set btHomeObj encryption boolean
        } else {
            btHomeObj['encryption'] = false;
        }
        btHomeObj['version'] = byte >> 5; //cut,move to 6.Bit, save the rest as version   
        if (btHomeObj['version'] !== 2) return null; //analyse the rest Bits 6,7,8 inside version, exit if BTHome Version is not 2
        if (btHomeObj['encryption']) return btHomeObj; //exit if payload is encrypted
        payload = payload.slice(1); //remove used 1.Byte from payload
        while (payload.length > 0) {
            byte = payload.at(0); //get 1.Byte of Payload
            objectID = bthObjectIDs[byte]; //compare 1.Byte with known BTHome objectIds list, add parameter if known object
            if (typeof objectID === 'undefined') {
                print('Error: Unknown BThome Object, decimal_ID: ', byte, ' convert to hex and compare hex_ID "0x.." with full objID list --> https://bthome.io/format');
                break; //exit loop, if objectID is unknown
            }
            payload = payload.slice(1); //remove used 1.Byte from payload
            value = this.GetValue(objectID.dataType, payload);
            if (value === null) break; //exit loof, if value null
            if (typeof objectID.factor !== 'undefined') value = (value * objectID.factor); //add factor
            btHomeObj[objectID.key] = value;
            if (typeof objectID.unit !== 'undefined') value = (JSON.stringify(value) + objectID.unit); //add unit
            if (typeof objectID.unit !== 'undefined') btHomeObj[(objectID.key+"String")] = value;
            payload = payload.slice(this.GetMaxBytes(objectID.dataType)); //remove used value Bytes from payload
        }
        return btHomeObj;
    },
};
function ScanCB(status, response) {
    if (status !== BLE.Scanner.SCAN_RESULT) return; //exit if Scan status is stopped or unknown
    if (response.service_data === undefined || response.service_data[uuid] === undefined) return; //Filter only BThome Responses
    let BTHomeObj = BTHomeDecoder.Unpack(response.service_data[uuid]); //decode Sevice Data
    if (BTHomeObj === null) {print('Error: Failed to Unpack service_data of, ', response.addr); return;}
    if (last_packet_id === BTHomeObj.pid && last_addr === response.addr) return; //exit if packet is already known.
    if (debug) print('Received packet, raw Data:', JSON.stringify(response));
    if (response.local_name !== undefined) BTHomeObj.device = 'Unknown-Device--> ' + response.local_name;
    if (response.local_name !== undefined && response.local_name.indexOf(devID1) >= 0) BTHomeObj.device = 'Blu Button1'; //search for Blu Button1
    if (response.local_name !== undefined && response.local_name.indexOf(devID2) >= 0) BTHomeObj.device = 'Blu Door/Window'; //search for Blu Door/Window
    if (response.local_name === undefined) BTHomeObj.device = 'Hidden-Device';
    last_packet_id = BTHomeObj.pid, last_addr = response.addr, BTHomeObj.addr = response.addr, BTHomeObj.rssi = response.rssi, BTHomeObj.gateway = Shelly.getDeviceInfo().id;
    if (debug) print('Received BTHome packet: ', JSON.stringify(BTHomeObj));
    if (typeof BTHomeObj.buttonID === 'number' && BTHomeObj.illuminance === undefined) { //somehow filter for blu Button
        let buttonEventMap = ['wake_up','single_push','double_push','triple_push','long_push','pairing_push','default_reset_push'], buttonInput = BTHomeObj.buttonID;
        if(buttonInput > 6 && buttonInput !== 254)buttonInput = 'unknown_push';
        if(buttonInput < 7)buttonInput = buttonEventMap[buttonInput];
        if(buttonInput === 254)buttonInput = 'hold_push';
        Shelly.emitEvent(buttonInput, {
            generation: 'BLU',
            gateway: BTHomeObj.gateway,
            device: BTHomeObj.device,
            battery_value: BTHomeObj.battery,
            battery_string: BTHomeObj.batteryString,
            inputID: BTHomeObj.buttonID,
            mac: BTHomeObj.addr,
            rssi: BTHomeObj.rssi,
            pid: BTHomeObj.pid,
            encryption: BTHomeObj.encryption
        });
    }
    if (typeof BTHomeObj.illuminance === 'number'){ //somehow, filter for blu door/window
         Shelly.emitEvent('blu_DW_ChangedStatus', {
            generation: 'BLU',
            gateway: BTHomeObj.gateway,
            device: BTHomeObj.device,
            battery_value: BTHomeObj.battery,
            battery_string: BTHomeObj.batteryString,
            doorStateID: BTHomeObj.doorStateID,
            windowStateID: BTHomeObj.windowStateID,
            illuminance: BTHomeObj.illuminance,
            moistureLvl: BTHomeObj.moistureLvl,
            rotationLvl: BTHomeObj.rotationLvl,
            buttonID: BTHomeObj.buttonID,
            mac: BTHomeObj.addr,
            rssi: BTHomeObj.rssi,
            pid: BTHomeObj.pid,
            encryption: BTHomeObj.encryption
        });
    }
}
function Start_BLE_Scan() {
    let bleScanStarted = BLE.Scanner.Start({ duration_ms: scanDuration, active: activeScan }, ScanCB);
    if (bleScanStarted === false) {
        print('Error: BTHome Scanner could not be started, will try again in 5sek.');
        Timer.set(5000, false, Start_BLE_Scan);
    } else {
        let scanType = 'Passiv';
        if (activeScan) scanType = 'Active';
        print('Success: BTHome ', scanType, ' Scanner running in Background');
    }
}
//__Main__
Start_BLE_Scan();
if(sendMQTT) Shelly.addEventHandler(FilterEvents);