jeans/Tasmota
jeans/Tasmota
1
0
Fork 0
mirror of https://github.com/arendst/Tasmota.git synced 2025-07-23 10:46:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

many updates ,prevent bootloop

Browse Source
This commit is contained in:
Staars 2022-03-16 08:41:04 +01:00
parent 4f54753739
commit 966de34f9c
2 changed files with 152 additions and 120 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
tasmota/xsns_62_esp32_mi.h
View File

@ -99,12 +99,9 @@ struct encPacket_t{
struct berryAdvPacket_t{ struct berryAdvPacket_t{
uint8_t MAC[6]; uint8_t MAC[6];
uint8_t addressType; uint8_t addressType;
uint16_t svcUUID;
uint8_t RSSI; uint8_t RSSI;
uint8_t length; // length of svcData uint8_t length; // length of payload
uint8_t svcData[40]; // only a pointer to the address, size is variable uint8_t payload[32]; // only a pointer to the address, size is 0-31 bytes
// the last array contains manufacturer data if present, if svcData is not present
// format: svcData[0] = length, svcData[1...length] = payload
}; };
@ -150,7 +147,8 @@ struct ATCPacket_t{ //and PVVX
struct MI32connectionContextBerry_t{ struct MI32connectionContextBerry_t{
NimBLEUUID serviceUUID; NimBLEUUID serviceUUID;
NimBLEUUID charUUID; NimBLEUUID charUUID;
uint8_t * MAC; uint16_t returnCharUUID;
uint8_t MAC[6];
uint8_t * buffer; uint8_t * buffer;
uint8_t operation; uint8_t operation;
uint8_t addrType; uint8_t addrType;
@ -177,7 +175,6 @@ struct {
uint32_t shallTriggerTele:1; uint32_t shallTriggerTele:1;
uint32_t triggeredTele:1; uint32_t triggeredTele:1;
uint32_t shallClearResults:1; // BLE scan results
uint32_t shallShowStatusInfo:1; // react to amount of found sensors via RULES uint32_t shallShowStatusInfo:1; // react to amount of found sensors via RULES
uint32_t didGetConfig:1; uint32_t didGetConfig:1;
uint32_t didStartHAP:1; uint32_t didStartHAP:1;
@ -194,6 +191,7 @@ struct {
uint32_t noSummary:1; // no sensor values at TELE-period uint32_t noSummary:1; // no sensor values at TELE-period
uint32_t directBridgeMode:1; // send every received BLE-packet as a MQTT-message in real-time uint32_t directBridgeMode:1; // send every received BLE-packet as a MQTT-message in real-time
uint32_t showRSSI:1; uint32_t showRSSI:1;
uint32_t activeScan:1;
uint32_t ignoreBogusBattery:1; uint32_t ignoreBogusBattery:1;
uint32_t minimalSummary:1; // DEPRECATED!! uint32_t minimalSummary:1; // DEPRECATED!!
} option; } option;
@ -386,7 +384,7 @@ const char * kMI32DeviceType[] PROGMEM = {kMI32DeviceType1,kMI32DeviceType2,kMI3
const char kMI32_ConnErrorMsg[] PROGMEM = "no Error|could not connect|got no service|got no characteristic|can not read|can not notify|can not write|did not write|notify time out"; const char kMI32_ConnErrorMsg[] PROGMEM = "no Error|could not connect|got no service|got no characteristic|can not read|can not notify|can not write|did not write|notify time out";
const char kMI32_BLEInfoMsg[] PROGMEM = "Scan ended|Got Notification|Did connect|Did disconnect|Start scanning"; const char kMI32_BLEInfoMsg[] PROGMEM = "Scan ended|Got Notification|Did connect|Did disconnect|Still connected|Start scanning";
const char kMI32_HKInfoMsg[] PROGMEM = "HAP core started|HAP core did not start!!|HAP controller disconnected|HAP controller connected|HAP outlet added"; const char kMI32_HKInfoMsg[] PROGMEM = "HAP core started|HAP core did not start!!|HAP controller disconnected|HAP controller connected|HAP outlet added";
@ -402,36 +400,37 @@ enum MI32_Commands { // commands useable in console or rules
}; };
enum MI32_TASK { enum MI32_TASK {
MI32_TASK_SCAN = 0, MI32_TASK_SCAN = 0,
MI32_TASK_CONN = 1, MI32_TASK_CONN = 1,
}; };
enum MI32_ConnErrorMsg { enum MI32_ConnErrorMsg {
MI32_CONN_NO_ERROR = 0, MI32_CONN_NO_ERROR = 0,
MI32_CONN_NO_CONNECT, MI32_CONN_NO_CONNECT,
MI32_CONN_NO_SERVICE, MI32_CONN_NO_SERVICE,
MI32_CONN_NO_CHARACTERISTIC, MI32_CONN_NO_CHARACTERISTIC,
MI32_CONN_CAN_NOT_READ, MI32_CONN_CAN_NOT_READ,
MI32_CONN_CAN_NOT_NOTIFY, MI32_CONN_CAN_NOT_NOTIFY,
MI32_CONN_CAN_NOT_WRITE, MI32_CONN_CAN_NOT_WRITE,
MI32_CONN_DID_NOT_WRITE, MI32_CONN_DID_NOT_WRITE,
MI32_CONN_NOTIFY_TIMEOUT MI32_CONN_NOTIFY_TIMEOUT
}; };
enum MI32_BLEInfoMsg { enum MI32_BLEInfoMsg {
MI32_SCAN_ENDED = 1, MI32_SCAN_ENDED = 1,
MI32_GOT_NOTIFICATION, MI32_GOT_NOTIFICATION,
MI32_DID_CONNECT, MI32_DID_CONNECT,
MI32_DID_DISCONNECT, MI32_DID_DISCONNECT,
MI32_START_SCANNING MI32_STILL_CONNECTED,
MI32_START_SCANNING
}; };
enum MI32_HKInfoMsg { enum MI32_HKInfoMsg {
MI32_HAP_DID_START = 1, MI32_HAP_DID_START = 1,
MI32_HAP_DID_NOT_START, MI32_HAP_DID_NOT_START,
MI32_HAP_CONTROLLER_DISCONNECTED, MI32_HAP_CONTROLLER_DISCONNECTED,
MI32_HAP_CONTROLLER_CONNECTED, MI32_HAP_CONTROLLER_CONNECTED,
MI32_HAP_OUTLET_ADDED MI32_HAP_OUTLET_ADDED
}; };
/*********************************************************************************************\ /*********************************************************************************************\

213
tasmota/xsns_62_esp32_mi.ino
View File

@ -22,6 +22,8 @@
-------------------------------------------------------------------------------------------- --------------------------------------------------------------------------------------------
Version yyyymmdd Action Description Version yyyymmdd Action Description
-------------------------------------------------------------------------------------------- --------------------------------------------------------------------------------------------
0.9.5.3 20220315 changed - reworked Berry part, active scanning and holding active connections possible, new format of advertisement buffer
-------
0.9.5.1 20220209 changed - rename YEERC to YLYK01, add dimmer YLKG08 (incl. YLKG07), change button report scheme 0.9.5.1 20220209 changed - rename YEERC to YLYK01, add dimmer YLKG08 (incl. YLKG07), change button report scheme
------- -------
0.9.5.0 20211016 changed - major rewrite, added mi32cfg (file and command), Homekit-Bridge, 0.9.5.0 20211016 changed - major rewrite, added mi32cfg (file and command), Homekit-Bridge,
@ -117,40 +119,25 @@ class MI32AdvCallbacks: public NimBLEAdvertisedDeviceCallbacks {
MI32_ReverseMAC(addr); MI32_ReverseMAC(addr);
size_t ServiceDataLength = 0; size_t ServiceDataLength = 0;
if (advertisedDevice->getServiceDataCount() == 0) {
if(MI32.beAdvCB != nullptr && MI32.mode.triggerBerryAdvCB == 0){
berryAdvPacket_t *_packet = (berryAdvPacket_t *)MI32.beAdvBuf;
memcpy(_packet->MAC,addr,6);
_packet->addressType = advertisedDevice->getAddressType();
_packet->svcUUID = 0;
_packet->RSSI = (uint8_t)RSSI;
_packet->length = ServiceDataLength;
_packet->svcData[0] = 0; //guarantee it is zero!!
if(advertisedDevice->haveManufacturerData()){
std::string _md = advertisedDevice->getManufacturerData();
_packet->svcData[0] = _md.size();
memcpy((_packet->svcData)+ServiceDataLength+1,_md.data(), _md.size());
}
MI32.mode.triggerBerryAdvCB = 1;
}
_mutex = false;
return;
}
uint16_t UUID = advertisedDevice->getServiceDataUUID(0).getNative()->u16.value;
ServiceDataLength = advertisedDevice->getServiceData(0).length();
if(MI32.beAdvCB != nullptr && MI32.mode.triggerBerryAdvCB == 0){ if(MI32.beAdvCB != nullptr && MI32.mode.triggerBerryAdvCB == 0){
berryAdvPacket_t *_packet = (berryAdvPacket_t *)MI32.beAdvBuf; berryAdvPacket_t *_packet = (berryAdvPacket_t *)MI32.beAdvBuf;
memcpy(_packet->MAC,addr,6); memcpy(_packet->MAC,addr,6);
_packet->addressType = advertisedDevice->getAddressType(); _packet->addressType = advertisedDevice->getAddressType();
_packet->svcUUID = UUID;
_packet->RSSI = (uint8_t)RSSI; _packet->RSSI = (uint8_t)RSSI;
_packet->length = ServiceDataLength; uint8_t *_payload = advertisedDevice->getPayload();
memcpy(_packet->svcData,advertisedDevice->getServiceData(0).data(),ServiceDataLength); _packet->length = advertisedDevice->getPayloadLength();
memcpy(_packet->payload,_payload, _packet->length);
MI32.mode.triggerBerryAdvCB = 1; MI32.mode.triggerBerryAdvCB = 1;
} }
if (advertisedDevice->getServiceDataCount() == 0) {
_mutex = false;
return;
}
uint16_t UUID = advertisedDevice->getServiceDataUUID(0).getNative()->u16.value;
ServiceDataLength = advertisedDevice->getServiceData(0).length();
if(UUID==0xfe95) { if(UUID==0xfe95) {
MI32ParseResponse((char*)advertisedDevice->getServiceData(0).data(),ServiceDataLength, addr, RSSI); MI32ParseResponse((char*)advertisedDevice->getServiceData(0).data(),ServiceDataLength, addr, RSSI);
} }
@ -160,9 +147,6 @@ class MI32AdvCallbacks: public NimBLEAdvertisedDeviceCallbacks {
else if(UUID==0x181a) { //ATC and PVVX else if(UUID==0x181a) { //ATC and PVVX
MI32ParseATCPacket((char*)advertisedDevice->getServiceData(0).data(),ServiceDataLength, addr, RSSI); MI32ParseATCPacket((char*)advertisedDevice->getServiceData(0).data(),ServiceDataLength, addr, RSSI);
} }
// else {
// MI32Scan->erase(advertisedDevice->getAddress());
// }
_mutex = false; _mutex = false;
}; };
}; };
@ -182,9 +166,11 @@ void MI32scanEndedCB(NimBLEScanResults results){
} }
void MI32notifyCB(NimBLERemoteCharacteristic* pRemoteCharacteristic, uint8_t* pData, size_t length, bool isNotify){ void MI32notifyCB(NimBLERemoteCharacteristic* pRemoteCharacteristic, uint8_t* pData, size_t length, bool isNotify){
if(MI32.mode.triggerBerryConnCB) return; //discard data, if we did not pass the old to Berry yet
MI32.infoMsg = MI32_GOT_NOTIFICATION; MI32.infoMsg = MI32_GOT_NOTIFICATION;
MI32.conCtx->buffer[0] = (uint8_t)length; MI32.conCtx->buffer[0] = (uint8_t)length;
memcpy(MI32.conCtx->buffer + 1, pData, length); memcpy(MI32.conCtx->buffer + 1, pData, length);
MI32.conCtx->returnCharUUID = pRemoteCharacteristic->getUUID().getNative()->u16.value;
MI32.mode.triggerBerryConnCB = 1; MI32.mode.triggerBerryConnCB = 1;
MI32.mode.readingDone = 1; MI32.mode.readingDone = 1;
} }
@ -647,11 +633,10 @@ void MI32Init(void) {
} }
if (!MI32.mode.init) { if (!MI32.mode.init) {
NimBLEDevice::init("MI32"); NimBLEDevice::init("");
AddLog(LOG_LEVEL_INFO,PSTR("M32: Init BLE device")); AddLog(LOG_LEVEL_INFO,PSTR("M32: Init BLE device"));
MI32.mode.init = 1; MI32.mode.init = 1;
MI32StartTask(MI32_TASK_SCAN); // Let's get started !!
MI32StartScanTask(); // Let's get started !!
} }
#ifdef USE_MI_EXT_GUI #ifdef USE_MI_EXT_GUI
#ifdef USE_MI_ESP32_ENERGY #ifdef USE_MI_ESP32_ENERGY
@ -668,8 +653,9 @@ extern "C" {
bool MI32runBerryConnection(uint8_t operation){ bool MI32runBerryConnection(uint8_t operation){
if(MI32.conCtx != nullptr){ if(MI32.conCtx != nullptr){
MI32.conCtx->operation = operation%100; MI32.conCtx->oneOp = (operation > 9);
AddLog(LOG_LEVEL_DEBUG,PSTR("M32: Berry connection op: %d, addrType: %d"),MI32.conCtx->operation, MI32.conCtx->addrType); MI32.conCtx->operation = operation%10;
AddLog(LOG_LEVEL_INFO,PSTR("M32: Berry connection op: %d, addrType: %d, oneOp: %u"),MI32.conCtx->operation, MI32.conCtx->addrType, MI32.conCtx->oneOp);
MI32StartConnectionTask(); MI32StartConnectionTask();
return true; return true;
} }
@ -689,7 +675,6 @@ extern "C" {
if(MI32.conCtx != nullptr){ if(MI32.conCtx != nullptr){
MI32.conCtx->serviceUUID = NimBLEUUID(Svc); MI32.conCtx->serviceUUID = NimBLEUUID(Svc);
AddLog(LOG_LEVEL_INFO,PSTR("M32: SVC: %s"),MI32.conCtx->serviceUUID.toString().c_str()); AddLog(LOG_LEVEL_INFO,PSTR("M32: SVC: %s"),MI32.conCtx->serviceUUID.toString().c_str());
// AddLog(LOG_LEVEL_INFO,PSTR("M32: SVC: %s"),Svc);
return true; return true;
} }
return false; return false;
@ -699,7 +684,9 @@ extern "C" {
if(MI32.conCtx != nullptr){ if(MI32.conCtx != nullptr){
MI32.conCtx->charUUID = NimBLEUUID(Chr); MI32.conCtx->charUUID = NimBLEUUID(Chr);
AddLog(LOG_LEVEL_INFO,PSTR("M32: CHR: %s"),MI32.conCtx->charUUID.toString().c_str()); AddLog(LOG_LEVEL_INFO,PSTR("M32: CHR: %s"),MI32.conCtx->charUUID.toString().c_str());
// AddLog(LOG_LEVEL_INFO,PSTR("M32: CHR: %s"),Chr); uint16_t _uuid = MI32.conCtx->charUUID.getNative()->u16.value; //if not "notify op" -> present requested characteristic as return UUID
MI32.conCtx->returnCharUUID = _uuid;
AddLog(LOG_LEVEL_INFO,PSTR("M32: return UUID: %04x"),MI32.conCtx->returnCharUUID);
return true; return true;
} }
return false; return false;
@ -707,7 +694,7 @@ extern "C" {
bool MI32setBerryCtxMAC(uint8_t *MAC, uint8_t type){ bool MI32setBerryCtxMAC(uint8_t *MAC, uint8_t type){
if(MI32.conCtx != nullptr){ if(MI32.conCtx != nullptr){
MI32.conCtx->MAC = MAC; memcpy(MI32.conCtx->MAC,MAC,6);
if(type<4) MI32.conCtx->addrType = type; if(type<4) MI32.conCtx->addrType = type;
else MI32.conCtx->addrType = 0; else MI32.conCtx->addrType = 0;
return true; return true;
@ -989,15 +976,17 @@ void MI32suspendScanTask(void){
} }
void MI32StartTask(uint32_t task){ void MI32StartTask(uint32_t task){
if (MI32.mode.willConnect == 1) return; // we are in the middle of connecting to something ... do not interrupt this.
switch(task){ switch(task){
case MI32_TASK_SCAN: case MI32_TASK_SCAN:
if (MI32.mode.willConnect == 1) return; if (MI32.mode.connected == 1) return;
if (MI32.mode.runningScan == 1 || MI32.mode.connected == 1) return; if(MI32.option.activeScan){
AddLog(LOG_LEVEL_INFO,PSTR("M32: Scan mode: active!")); // may have negative side effects!!
}
MI32StartScanTask(); MI32StartScanTask();
break; break;
case MI32_TASK_CONN: case MI32_TASK_CONN:
if (MI32.mode.canConnect == 0 || MI32.mode.willConnect == 1 ) return; if (MI32.mode.canConnect == 0) return;
if (MI32.mode.connected == 1) return;
MI32StartConnectionTask(); MI32StartConnectionTask();
break; break;
default: default:
@ -1005,25 +994,6 @@ void MI32StartTask(uint32_t task){
} }
} }
bool MI32ConnectActiveSensor(){ // only use inside a task !!
NimBLEAddress _address = NimBLEAddress(MI32.conCtx->MAC, MI32.conCtx->addrType);
MI32Client = nullptr;
if(NimBLEDevice::getClientListSize()) {
MI32Client = NimBLEDevice::getClientByPeerAddress(_address);
}
if (!MI32Client){
MI32Client = NimBLEDevice::createClient(_address);
MI32Client->setClientCallbacks(&MI32SensorCB , false);
}
if (!MI32Client->connect(false)) {
MI32.mode.willConnect = 0;
NimBLEDevice::deleteClient(MI32Client);
// AddLog(LOG_LEVEL_ERROR,PSTR("M32: did not connect client"));
return false;
}
return true;
}
void MI32StartScanTask(){ void MI32StartScanTask(){
if (MI32.mode.connected) return; if (MI32.mode.connected) return;
if(MI32.ScanTask!=nullptr) vTaskDelete(MI32.ScanTask); if(MI32.ScanTask!=nullptr) vTaskDelete(MI32.ScanTask);
@ -1047,7 +1017,7 @@ void MI32ScanTask(void *pvParameters){
MI32Scan->setInterval(70); MI32Scan->setInterval(70);
MI32Scan->setWindow(50); MI32Scan->setWindow(50);
MI32Scan->setAdvertisedDeviceCallbacks(&MI32ScanCallbacks,true); MI32Scan->setAdvertisedDeviceCallbacks(&MI32ScanCallbacks,true);
MI32Scan->setActiveScan(false); MI32Scan->setActiveScan(MI32.option.activeScan);
MI32Scan->setMaxResults(0); MI32Scan->setMaxResults(0);
MI32Scan->start(0, MI32scanEndedCB, true); // never stop scanning, will pause automatically while connecting MI32Scan->start(0, MI32scanEndedCB, true); // never stop scanning, will pause automatically while connecting
MI32.infoMsg = MI32_START_SCANNING; MI32.infoMsg = MI32_START_SCANNING;
@ -1059,6 +1029,41 @@ void MI32ScanTask(void *pvParameters){
vTaskDelete( NULL ); vTaskDelete( NULL );
} }
bool MI32ConnectActiveSensor(){ // only use inside a task !!
NimBLEAddress _address = NimBLEAddress(MI32.conCtx->MAC, MI32.conCtx->addrType);
if(MI32Client != nullptr){
if(MI32Client->isConnected() && MI32.mode.connected == 1){ //we only accept a "clean" state without obvious packet losses
if(MI32.conCtx->operation == 5){ //5 is the disconnect operation
NimBLEDevice::deleteClient(MI32Client); // disconnect the old
return false; // request disconnect
}
if(MI32Client->getPeerAddress() == _address){
MI32.infoMsg = MI32_STILL_CONNECTED;
return true; // still connected -> keep it
}
else{
// AddLog(LOG_LEVEL_ERROR,PSTR("M32: disconnect %s"),MI32Client->getPeerAddress().toString().c_str());
NimBLEDevice::deleteClient(MI32Client); // disconnect the old and connect the new
}
}
}
MI32Client = nullptr;
if(NimBLEDevice::getClientListSize()) {
MI32Client = NimBLEDevice::getClientByPeerAddress(_address);
}
if (!MI32Client){
MI32Client = NimBLEDevice::createClient(_address);
MI32Client->setClientCallbacks(&MI32SensorCB , false);
}
if (!MI32Client->connect(false)) {
MI32.mode.willConnect = 0;
NimBLEDevice::deleteClient(MI32Client);
// AddLog(LOG_LEVEL_ERROR,PSTR("M32: did not connect client"));
return false;
}
return true;
}
bool MI32StartConnectionTask(){ bool MI32StartConnectionTask(){
if(MI32.conCtx == nullptr) return false; if(MI32.conCtx == nullptr) return false;
@ -1078,7 +1083,9 @@ bool MI32StartConnectionTask(){
} }
void MI32ConnectionTask(void *pvParameters){ void MI32ConnectionTask(void *pvParameters){
MI32.mode.connected = 0; NimBLEDevice::setOwnAddrType(BLE_OWN_ADDR_RANDOM,false); //seems to be important for i.e. xbox controller, hopefully not breaking other things
NimBLEDevice::setSecurityAuth(true, true, true);
MI32.conCtx->error = MI32_CONN_NO_ERROR; MI32.conCtx->error = MI32_CONN_NO_ERROR;
if (MI32ConnectActiveSensor()){ if (MI32ConnectActiveSensor()){
MI32.mode.readingDone = 0; MI32.mode.readingDone = 0;
@ -1109,7 +1116,7 @@ void MI32ConnectionTask(void *pvParameters){
} }
if (pChr){ if (pChr){
switch(MI32.conCtx->operation){ switch(MI32.conCtx->operation){
case 11: case 1:
if(pChr->canRead()) { if(pChr->canRead()) {
std::string _val = pChr->readValue(); std::string _val = pChr->readValue();
MI32.conCtx->buffer[0] = (uint8_t)_val.size(); MI32.conCtx->buffer[0] = (uint8_t)_val.size();
@ -1120,15 +1127,7 @@ void MI32ConnectionTask(void *pvParameters){
MI32.conCtx->error = MI32_CONN_CAN_NOT_READ; MI32.conCtx->error = MI32_CONN_CAN_NOT_READ;
} }
break; break;
case 13: case 2:
if(pChr->canNotify()) {
if(pChr->subscribe(true,MI32notifyCB,false)) AddLog(LOG_LEVEL_DEBUG,PSTR("M32: subscribe"));
}
else{
MI32.conCtx->error = MI32_CONN_CAN_NOT_NOTIFY;
}
break;
case 12:
if(pChr->canWrite()) { if(pChr->canWrite()) {
uint8_t len = MI32.conCtx->buffer[0]; uint8_t len = MI32.conCtx->buffer[0];
if(pChr->writeValue(MI32.conCtx->buffer + 1,len,true)) { // true is important ! if(pChr->writeValue(MI32.conCtx->buffer + 1,len,true)) { // true is important !
@ -1143,6 +1142,14 @@ void MI32ConnectionTask(void *pvParameters){
} }
MI32.mode.readingDone = 1; MI32.mode.readingDone = 1;
break; break;
case 3:
if(pChr->canNotify()) {
if(pChr->subscribe(true,MI32notifyCB,false)) AddLog(LOG_LEVEL_DEBUG,PSTR("M32: subscribe"));
}
else{
MI32.conCtx->error = MI32_CONN_CAN_NOT_NOTIFY;
}
break;
default: default:
break; break;
} }
@ -1152,24 +1159,31 @@ void MI32ConnectionTask(void *pvParameters){
} }
timer = 0; timer = 0;
while (timer<150){ while (timer<150){
if (MI32.mode.readingDone){ if (MI32.mode.readingDone){
break; break;
}
else{
if (MI32.conCtx->operation==3 && MI32.conCtx->oneOp) {
MI32.conCtx->error = MI32_CONN_NOTIFY_TIMEOUT; //did not read on notify - timeout only for one-shot op
} }
else{ }
MI32.conCtx->error = MI32_CONN_NOTIFY_TIMEOUT; //did not read on notify - timeout timer++;
} vTaskDelay(100/ portTICK_PERIOD_MS);
timer++; }
vTaskDelay(100/ portTICK_PERIOD_MS); MI32.mode.readingDone = 0;
if(MI32.conCtx->oneOp){
MI32Client->disconnect();
MI32.mode.connected = 0;
DEBUG_SENSOR_LOG(PSTR("M32: requested disconnect"));
MI32StartTask(MI32_TASK_SCAN);
} }
MI32Client->disconnect();
DEBUG_SENSOR_LOG(PSTR("M32: requested disconnect"));
} }
else{ else{
MI32.conCtx->error = MI32_CONN_NO_CONNECT; // not connected MI32.conCtx->error = MI32_CONN_NO_CONNECT; // not connected
MI32.mode.connected = 0;
MI32StartTask(MI32_TASK_SCAN);
} }
MI32.mode.connected = 0;
MI32.mode.triggerBerryConnCB = 1; MI32.mode.triggerBerryConnCB = 1;
MI32StartTask(MI32_TASK_SCAN); MI32StartTask(MI32_TASK_SCAN);
vTaskDelete( NULL ); vTaskDelete( NULL );
@ -1539,18 +1553,32 @@ void MI32Every50mSecond(){
} }
if(MI32.mode.triggerBerryAdvCB == 1){ if(MI32.mode.triggerBerryAdvCB == 1){
if(MI32.beAdvCB != nullptr){ if(MI32.beAdvCB != nullptr){
void (*func_ptr)(void) = (void (*)(void))MI32.beAdvCB; // AddLogBuffer(LOG_LEVEL_DEBUG,MI32.beAdvBuf,40);
func_ptr(); uint8_t _index = 9; // is the first byte of payload in the advertisement buffer
int _svc = 0;
int _manu = 0;
while(_index < 9 + MI32.beAdvBuf[8]){ //index of payload + _packet->length
if(MI32.beAdvBuf[_index+1] == 0x16){
_svc = _index + 2;
}
else if(MI32.beAdvBuf[_index+1] == 0xff){
_manu = _index + 2;
}
_index += MI32.beAdvBuf[_index] + 1;
}
// AddLog(LOG_LEVEL_DEBUG,PSTR("M32: svc:%u , manu:%u"),_svc,_manu);
void (*func_ptr)(int,int) = (void (*)(int,int))MI32.beAdvCB;
func_ptr(_svc,_manu);
} }
MI32.mode.triggerBerryAdvCB = 0; MI32.mode.triggerBerryAdvCB = 0;
} }
if(MI32.mode.triggerBerryConnCB == 1){ if(MI32.mode.triggerBerryConnCB == 1){
if(MI32.beConnCB != nullptr){ if(MI32.beConnCB != nullptr){
void (*func_ptr)(int) = (void (*)(int))MI32.beConnCB; void (*func_ptr)(int, int, int) = (void (*)(int, int, int))MI32.beConnCB;
char _message[32]; char _message[32];
GetTextIndexed(_message, sizeof(_message), MI32.conCtx->error, kMI32_ConnErrorMsg); GetTextIndexed(_message, sizeof(_message), MI32.conCtx->error, kMI32_ConnErrorMsg);
AddLog(LOG_LEVEL_DEBUG,PSTR("M32: %s"),_message); AddLog(LOG_LEVEL_DEBUG,PSTR("M32: %s"),_message);
func_ptr(MI32.conCtx->error); func_ptr(MI32.conCtx->error, MI32.conCtx->operation , MI32.conCtx->returnCharUUID);
} }
MI32.mode.triggerBerryConnCB = 0; MI32.mode.triggerBerryConnCB = 0;
} }
@ -1639,6 +1667,12 @@ void CmndMi32Option(void){
case 3: case 3:
MI32.mode.didGetConfig = onOff; MI32.mode.didGetConfig = onOff;
break; break;
case 4:
if(MI32.option.activeScan != onOff){
MI32.option.activeScan = onOff;
MI32StartTask(MI32_TASK_SCAN);
}
break;
} }
ResponseCmndDone(); ResponseCmndDone();
} }
@ -1785,7 +1819,7 @@ void MI32sendWidget(uint32_t slot){
else { else {
WSContentSend_P(PSTR("<p>Dimmer Steps pressed: %d</p>"),_sensor.dimmer); WSContentSend_P(PSTR("<p>Dimmer Steps pressed: %d</p>"),_sensor.dimmer);
} }
WSContentSend_P(PSTR("<p>Long: %u</p>"),_sensor.longpress); WSContentSend_P(PSTR("<p>Hold: %u</p>"),_sensor.longpress);
} }
if(_sensor.feature.Btn){ if(_sensor.feature.Btn){
char _message[16]; char _message[16];
@ -1889,7 +1923,6 @@ void MI32Show(bool json)
#endif //USE_HOME_ASSISTANT #endif //USE_HOME_ASSISTANT
if(!MI32.mode.triggeredTele){ if(!MI32.mode.triggeredTele){
// MI32.mode.shallClearResults=1;
if(MI32.option.noSummary) return; // no message at TELEPERIOD if(MI32.option.noSummary) return; // no message at TELEPERIOD
} }
MI32suspendScanTask(); MI32suspendScanTask();