void onBleReceived(BLECharacteristic *pCharacteristic) {
std::string rxValue = pCharacteristic->getValue();
static String bleInputString = "";
if (rxValue.length() > 0) {
for (int i = 0; i < rxValue.length(); i++) {
bleInputString += rxValue[i];
if (rxValue[i] == '\n') {
enterMessageQueue(bleInputString);
bleInputString = "";
}
}
}
}
void onWiFiCmdReceived(WiFiClient *client) {
static String wifiInputString = "";
while (client->available()) {
char rv[1024];
int ret = client->read((uint8_t *)rv, sizeof(rv));
for (int i = 0; i < ret; i++) {
wifiInputString += rv[i];
if (rv[i] == '\n') {
Serial.print(wifiInputString);
enterMessageQueue(wifiInputString);
wifiInputString = "";
}
}
}
}
void onWiFiCmdTrasmit(WiFiClient *client) {
if (!mqTx.isEmpty()) {
client->write(mqTx.out().c_str());
}
}
void enterMessageQueue(String msg) {
Serial.print("msg : ");
Serial.print(msg);
switch (msg.charAt(0)) {
case ACTION_INSTALLATION:
case ACTION_CALIBRATE:
case ACTION_UP_DOWN: