Menu.ino

byte readLine(int timeout, Stream *stream);
void onESPvESPrino();
void sendNow();

bool espStopOnReady = false;

void processUserInput() {
  if (Serial.available()) {
    if (readLine(30000, &Serial) > 0) {
      handleCommand(FROM_SERIAL);
      //Serial <<"rtrttt" << endl;
    }
  }
  //Serial <<"next" << endl;
  int i=0, k=0;
  //esp.listen();
  if (espIsOn && esp.available()) {
      //Serial <<"aloooo" << endl;

    //String rcv;
    espLastActivity = millis();
    while (espIsOn && esp.available() && readLine(1000, &esp) > 0) {
      //i++;
     // k+= strlen(line);
      //rcv += line;
      //rcv += "|";
      handleCommand(FROM_ESP);
      //Serial <<" hmmm" << endl;
    }
   // Serial << "Received:" << i << "lines, " << k << " bytes" << endl;
    //Serial << rcv << endl;
  }
}

byte readLine(int timeout, Stream *stream) {
  unsigned long deadline = millis() + timeout;
  byte i = 0;
  while (millis() < deadline) {
    if (stream->available()) {
      line[i++] = (char) stream->read();
      //Serial << (int)line[i-1];
      if      (line[i-1] == '\r')  i--;   
      else if (i == LINE_LEN - 1)  break; 
      else if (line[i-1] == '\n')  {i--; break;}
    }
  }
  line[i] = 0;
  return i;
}


void handleCommand(CommandSource cs) {
  String x = String(line);
  if (cs == FROM_SERIAL) {
    Serial << line << endl;
    //if      (x.startsWith(F("wifi"))) doConnect();
    if (x.startsWith(F( "lt" ))) menuEnterColorRanges(trim(&line[2]));
    else if (x.startsWith(F("debug"))) switchDebugInfoPrint();
    else if (x.startsWith(F("factory"))) menuMainFactoryReset();
    else if (x.startsWith(F("sendNow"))) sendNow();
    
   // else if (x.startsWith(F("tskey"))) saveLineToEE(trim(&line[5]), EE_40B_TSKEY);
   // else if (x.startsWith(F("ubik")))  saveLineToEE(trim(&line[4]), EE_40B_UBIKEY);
   // else if (x.startsWith(F("ubiv")))  saveLineToEE(trim(&line[4]), EE_40B_UBIVAR);
  //  else if (x.startsWith(F("test")))  sendToThingSpeak(567);
  #ifdef BRG
    else if (x.startsWith(F("brg"  ))) menuEnterLedBrightness(trim(&line[3]));
  #endif
    else if (x.startsWith(F("brf"  ))) EEPROM.put(EE_1B_BRG_FACTOR, (byte)(atoi(&line[4])));
  //  else if (x.startsWith(F("gray" ))) switchGrayBox();
    else if (x.startsWith(F("sim"  ))) simulateCO2();
    //else if (x.startsWith(F("ota"  ))) espOTA();
  //  else if (x.startsWith(F("ping" ))) espPing();
    else if (x.startsWith(F("proxy"))) startSerialProxy();
    else if (x.startsWith(F("ppm"  ))) setPPM(trim(&line[3]));
  #ifdef TGS4161
    else if (x.startsWith(F("ppg"  ))) setPPG(trim(&line[3]));
    else if (x.startsWith(F("ppx"  ))) setPPX(trim(&line[3]));
    else if (x.startsWith(F("heat"  ))) testHeating(true);
    else if (x.startsWith(F("cool"  ))) testHeating(false);
  #endif
    else if (x.startsWith(F("rco"  ))) resetCO2();
    else if (x.startsWith(F("wsi"  ))) setWifiSendInterval(trim(&line[3]));
    else if (x.startsWith(F("eoff"  ))) espOFF();
    else if (x.startsWith(F("test"  ))) processSendData();
    
  //  else if (x.startsWith(F("esp"  ))) onlyESP();
//    else if (x.startsWith(F("sap "))) EEPROM.put(EE_1B_HASSAPCFG, (byte)(line[4]-'0'));
    //else if (x.startsWith(F("ccc"))) Serial << rawReadCM1106_CO2() << endl;
    else if (x.startsWith(F("esp"))) esp << &x[4] << endl;
    else if (x.indexOf(F("LED##")) > -1) onLED(x); 
    Serial << F(">") << endl;
  } else {
   // Serial << F("e:") << line[0] << endl;  
    if (x.indexOf(F("vESPrino")) > -1) onESPvESPrino(); 
    if (x.startsWith(F("wifi.ssid="))) espWifiConfigured = true; 
    if (x.indexOf(F("Device ini")) > -1) onESPDeviceInitialized(); 
    if (x.indexOf(F("GOT IP")) > -1) espWifiConnected = true; 
    if (x.indexOf(F("ready")) > -1) onESPReady(); 
    if (x.indexOf(F("LED##")) > -1) onLED(x); 
    if (x.startsWith(F("ppm##"  ))) setPPM(&line[5]));
    Serial << F("e:") << line << endl;  
  }
}

void onESPDeviceInitialized() {
  sendNow();
  if (espWasTurnedOff) {
    espStopOnReady = true;
  }
}

void onESPReady() {
  if (espStopOnReady) {
    espStopOnReady = false;
    espOFF();
  }
}

void onESPvESPrino() {
  hasESP = true;
  if (espSentInit) return;
  espSentInit = true;
  //Serial << "detected ESP" << endl;
  String s = String(F("***prop_setr \"send.interval\",\"0\"***prop_setr \"logger.slow\",\"1\"***prop_list wifi.ssid***prop_jsetr \"serial.dump\"0***\r\n"));
  if (espWasTurnedOff) {
    s = String(F("***slave")) + s;
  }
  espSend(s.c_str());
  s = "prop_jsetr \"led.ard\"1";
  espSend(s.c_str());
  //espSend(String(F("prop_list\r\n")).c_str());
}


//
//void makeBeep() {
////  Serial << F("BEEP\n");
//  
//  for (int i=0; i<1; i++) {
//    tone(A4, 200, 50);
//    delay(200);
//    tone(A4, 150, 50);
//    delay(200);
//    tone(A4, 100, 50);
//    delay(200);
//    tone(A4, 70, 50);
//    delay(200);
//  }
//
//}
//

void saveLineToEE(const char *str, int address) {
  while (*str)  EEPROM.put(address++, (byte)*(str++));
  EEPROM.put(address, 0);
}

char* trim(const char *str) {
  while (*str == ' ') str++;
  return (char*)str;
}
//
void setPPM(char *val) {
  sPPM = String(val).toInt();
  processColors();
  oledCO2Level();
}
void setWifiSendInterval(char *val) {
  EEPROM.put(EE_2B_WIFI_SND_INT_S, atoi(val));
}
#ifdef TGS4161
void setPPX(char *val) {
  currentCO2MaxMv = getTGSEstMaxMv(atoi(val), raCO2mv.getAverage());
  currentMaxMvTemp = raTempC.getAverage();
  storeABC();
}
void setPPG(char *val) {
  //int realPPM = atoi(val);
  double mv = getCO2MaxMv() - raCO2mv.getAverage();
  findAndStoreCorrectGradient(mv, 200000L);
//  currentCO2MaxMv = getTGSEstMaxMv(atoi(val), raCO2mv.getAverage());
//  storeCurrentCO2MaxMv();  
}

void testHeating(bool turnOn) {
  if (turnOn) espON();
  else espOFF();
  ledHeat(turnOn);
  float startMv = raCO2mvNoTempCorr.getAverage();
  float startTemp = raTempC.getAverage();
  for (int i=0; i < 250; i++) {
    char s[100];
    float diffMv = startMv - raCO2mvNoTempCorr.getAverage();
    float diffTemp = startTemp - raTempC.getAverage();
    Serial << i << ", mvDiff: " << diffMv << ", tempDiff:" << diffTemp << ", mvNow:" << raCO2mvNoTempCorr.getAverage() << ", tempNow:" << raTempC.getAverage() << endl;
//    sprintf(s, "%d, mv %d.%d, temp:%d,%2d\n", i, (int)diffMv, getFloat(diffMv), (int)diffTemp, getFloat(diffTemp));
//    displayDebugInfo();
//    Serial << s;
    if ((i%5) == 0 && turnOn) espToggle();
     processCO2();
    delay(4000);
  }

}

#endif

void resetCO2() {
#ifdef TGS4161
  EEPROM.put(EE_FLT_CURRENT_PERIOD_CO2_HIGHESTMV, (double)0);
  EEPROM.put(EE_FLT_PREV_PERIOD_CO2_HIGHESTMV,    (double)0);
  prevCO2MaxMv = currentCO2MaxMv = 0;
#else
  Serial << F("Put the device at fresh air. Once it worked for 7 minutes after it startted it will start the calibration procedure, which is 2 minutes. ") << endl;
  EEPROM.put(EE_1B_RESET_CO2, (byte)1);
  softwareReset();
#endif
}

//void onlyESP() {
//  pinMode(ESP_RX, INPUT);
//  pinMode(ESP_TX, INPUT);
//  espToggle();
//}

int menuEnterLedBrightness(const char *str) {
  int res = atoi(str);
  if (res < 255) res = constrain(res, 0, 150);
  overrideBrightness = res;
  Serial << F("New Brightness value: ") << overrideBrightness << endl;
  EEPROM.write(EE_1B_BRG, overrideBrightness);
  //menuHandler = menuPrintMain;
  return 0;
}

void menuEnterColorRanges(char *s) {
  storeColorRanges(s);
  processNeopixels();
  Serial << F("Done\n");
}

int menuMainFactoryReset() {
  clearEEPROM();
  Serial << F("\nConfiguration reset...\n");
  softwareReset();
  return 0;
}

#ifdef GRAY
int switchGrayBox() {
  byte val = EEPROM.read(EE_1B_ISGRAY);
  if (val == 255) val = 1;
  else val = 255;
  EEPROM.update(EE_1B_ISGRAY, val);
  Serial << F("\nBox:");
  if (val == 1) Serial << F("G\n");
  else Serial << F("W\n");
  //Serial << endl;
  return 0;
}
#endif

int switchDebugInfoPrint() {
  //DEBUG=true;
  dumpDebuggingInfo = !dumpDebuggingInfo;
  Serial << endl  << F("Debug Info is: ") << dumpDebuggingInfo << endl;
  if (dumpDebuggingInfo) displayDebugInfo();
  return 0;
}
//
int simulateCO2() {
  for (int i = 400; i <=3000; i+=100) {
    sPPM = i;
    processNeopixels();
    oledCO2Level();
    delay(250);
  }
}