NodeManagerLibrary.ino

/*
 * NodeManager Library
 */
 
/***************************************
   PowerManager
*/

#if FEATURE_POWER_MANAGER == ON
PowerManager::PowerManager(int ground_pin, int vcc_pin, int wait_time) {
  setPowerPins(ground_pin, vcc_pin, wait_time);
}

// set the vcc and ground pin the sensor is connected to
void PowerManager::setPowerPins(int ground_pin, int vcc_pin, int wait_time) {
  _ground_pin = ground_pin;
  _vcc_pin = vcc_pin;
  #ifdef NODEMANAGER_DEBUG
    Serial.print(F("PWR G="));
    Serial.print(_ground_pin);
    Serial.print(F(" V="));
    Serial.println(_vcc_pin);
  #endif
  if (_ground_pin > 0) {
    // configure the ground pin as output and initialize to low
    pinMode(_ground_pin, OUTPUT);
    digitalWrite(_ground_pin, LOW);
  }
  if (_vcc_pin > 0) {
    // configure the vcc pin as output and initialize to high (power on)
    pinMode(_vcc_pin, OUTPUT);
    digitalWrite(_vcc_pin, HIGH);
  }
  // save wait time
  _wait = wait_time;
}

// turn on the sensor by activating its power pins
void PowerManager::powerOn() {
  if (_vcc_pin == -1) return;
  #ifdef NODEMANAGER_DEBUG
    Serial.print(F("ON P="));
    Serial.println(_vcc_pin);
  #endif
  // power on the sensor by turning high the vcc pin
  digitalWrite(_vcc_pin, HIGH);
  // wait a bit for the device to settle down
  if (_wait > 0) wait(_wait);
}

// turn off the sensor
void PowerManager::powerOff() {
  if (_vcc_pin == -1) return;
  #ifdef NODEMANAGER_DEBUG
    Serial.print(F("OFF P="));
    Serial.println(_vcc_pin);
  #endif
  // power off the sensor by turning low the vcc pin
  digitalWrite(_vcc_pin, LOW);
}
#endif

/******************************************
    Timer
*/

Timer::Timer(NodeManager* node_manager) {
  _node = node_manager;
}

// start the timer
void Timer::start(int target, int unit) {
  set(target,unit);
  start();
}
void Timer::start() {
  if (_is_configured) _is_running = true;
#if FEATURE_TIME == ON
  // keep track of the time the timer has started
  _last = now();
#endif
}

// stop the timer
void Timer::stop() {
  _is_running = false;
}

// reset the timer
void Timer::reset() {
  // reset the timer
  _elapsed = 0;
  _last = 0;
}

// restart the timer
void Timer::restart() {
  if (! isRunning()) return;
  stop();
  reset();
  // if using millis(), keep track of the current timestamp for calculating the difference
  if (! _node->isSleepingNode()) _last = millis();
  start();
}

// setup the timer
void Timer::set(int target, int unit) {
  reset();
  // save the settings
  _target = target;
  if (unit == MINUTES) _target = _target * 60;
  else if (unit == HOURS) _target = _target * 60 *60;
  else if (unit == DAYS) _target = _target * 60 * 60 *24;
  _is_running = false;
  _is_configured = true;
}

// unset the timer
void Timer::unset() {
  stop();
  _is_configured = true;
}

// update the timer at every cycle
void Timer::update() {
  if (! isRunning()) return;
#if FEATURE_TIME == ON
  // system time is available so use now() to calculated the elapsed time
  _elapsed = (long)(now() - _last);
#else
#if FEATURE_SLEEP == ON
  if (_node->isSleepingNode()) {
    // millis() is not reliable while sleeping so calculate how long a sleep cycle would last in seconds and update the elapsed time
    _elapsed += _node->getSleepSeconds();
  }
#endif
  if (! _node->isSleepingNode()) {
    // use millis() to calculate the elapsed time in seconds
    _elapsed = (long)((millis() - _last)/1000);
  }
#endif
  _first_run = false;
}

// return true if the time is over
bool Timer::isOver() {
  if (! isRunning()) return false;
  // time has elapsed
  if (_elapsed >= _target) return true;
  // millis has started over
  if (_elapsed < 0 ) return true;
  return false;
}

// return true if the timer is running
bool Timer::isRunning() {
  if (! isConfigured()) return false;
  return _is_running;
}

// return true if the time is configured
bool Timer::isConfigured() {
  return _is_configured;
}

// return true if this is the first time the timer runs
bool Timer::isFirstRun() {
  return _first_run;
}

// return elapsed seconds so far
float Timer::getElapsed() {
  return _elapsed;
}


/******************************************
    Request
*/

// contructor, tokenize a request in the format "child_id,function,value"
Request::Request(int recipient_child_id, const char* string) {
  _recipient_child_id = recipient_child_id;
  char* ptr;
  // tokenize the string and get child id
  _child_id = atoi(strtok_r(const_cast<char*>(string), ",", &ptr));
  // tokenize the string and get function id
  _function = atoi(strtok_r(NULL, ",", &ptr));
  // tokenize the string and get the value
  _value = atof(strtok_r(NULL, ",", &ptr));
  #ifdef NODEMANAGER_DEBUG
    Serial.print(F("REQ C="));
    Serial.print(_child_id);
    Serial.print(F(" F="));
    Serial.print(_function);
    Serial.print(F(" V="));
    Serial.println(_value);
  #endif
}

// return the child id
int Request::getRecipientChildId() {
  return _recipient_child_id;
}

// return the child id
int Request::getChildId() {
  return _child_id;
}

// return the parsed function
int Request::getFunction() {
  return _function;
}

// return the value as an int
int Request::getValueInt() {
  return (int)_value;
  
}

// return the value as a float
float Request::getValueFloat() {
  return _value;
}

/******************************************
    Sensors
*/

/*
 Child class
 */

Child::Child() {

}

// constructor
Child::Child(Sensor* __sensor, int _child_id, int _presentation, int _type, const char* _description) {
  child_id = _child_id;
  presentation = _presentation;
  type = _type;
  description = _description;
  _sensor = __sensor;
  _sensor->registerChild(this);
#if FEATURE_CONDITIONAL_REPORT == ON
  force_update_timer = new Timer(_sensor->_node);
#endif
}
// set a value, implemented by the subclasses
void Child::sendValue() {
}
// Print the child's value (variable type depending on the child class) to the given output
void Child::printOn(Print& p) {
}
#if FEATURE_CONDITIONAL_REPORT == ON
// check if it is an updated value, implemented by the subclasses
bool Child::isNewValue() {
}
#endif

/*
 ChildInt class
*/

// ChildInt class
ChildInt::ChildInt(Sensor* sensor, int child_id, int presentation, int type, const char* description): Child(sensor, child_id, presentation, type, description)  {
}

// store a new value and update the total
void ChildInt::setValueInt(int value) {
  _total = _total + value;
  _samples++;
  _value = (int) (_total / _samples);
}

// return the value
int ChildInt::getValueInt() {
  return _value;
}

// send the value back to the controller
void ChildInt::sendValue() {
  if (_samples == 0) return;
#if FEATURE_CONDITIONAL_REPORT == ON
  // if below or above the thresholds, do not send the value
  if (_value < min_threshold || _value > max_threshold) return;
#endif
  _sensor->_node->sendMessage(child_id,type,_value);
#if FEATURE_CONDITIONAL_REPORT == ON
  _last_value = _value;
#endif
  _total = 0;
  _samples = 0;
}

// Print the child's value (variable type depending on the child class) to the given output
void ChildInt::printOn(Print& p) {
  p.print(_value);
}

#if FEATURE_CONDITIONAL_REPORT == ON
// check if it is an updated value
bool ChildInt::isNewValue() {
  return _last_value != _value;
}
#endif

/*
 ChildFloat class
*/

// ChildFloat class
ChildFloat::ChildFloat(Sensor* sensor, int child_id, int presentation, int type, const char* description): Child(sensor, child_id, presentation, type, description)  {
}

// store a new value and update the total
void ChildFloat::setValueFloat(float value) {
  _total = _total + value;
  _samples++;
  _value = _total / _samples;
}

// return the value
float ChildFloat::getValueFloat() {
  return _value;
}

// send the value back to the controller
void ChildFloat::sendValue() {
  if (_samples == 0) return;
#if FEATURE_CONDITIONAL_REPORT == ON
  // if below or above the thresholds, do not send the value
  if (_value < min_threshold || _value > max_threshold) return;
#endif
  _sensor->_node->sendMessage(child_id,type,_value);
#if FEATURE_CONDITIONAL_REPORT == ON
  _last_value = _value;
#endif
  _total = 0;
  _samples = 0;
}

// Print the child's value (variable type depending on the child class) to the given output
void ChildFloat::printOn(Print& p) {
  p.print(_value);
}

#if FEATURE_CONDITIONAL_REPORT == ON
// check if it is an updated value
bool ChildFloat::isNewValue() {
  return _last_value != _value;
}
#endif

/*
 ChildDouble class
*/

// ChildDouble class
ChildDouble::ChildDouble(Sensor* sensor, int child_id, int presentation, int type, const char* description): Child(sensor, child_id, presentation, type, description)  {
}

// store a new value and update the total
void ChildDouble::setValueDouble(double value) {
  _total = _total + value;
  _samples++;
  _value = _total / _samples;
}

// return the value
double ChildDouble::getValueDouble() {
  return _value;
}

// send the value back to the controller
void ChildDouble::sendValue() {
  if (_samples == 0) return;
#if FEATURE_CONDITIONAL_REPORT == ON
  // if below or above the thresholds, do not send the value
  if (_value < min_threshold || _value > max_threshold) return;
#endif
  _sensor->_node->sendMessage(child_id,type,_value);
#if FEATURE_CONDITIONAL_REPORT == ON
  _last_value = _value;
#endif
  _total = 0;
  _samples = 0;
}

// Print the child's value (variable type depending on the child class) to the given output
void ChildDouble::printOn(Print& p) {
  p.print(_value);
}

#if FEATURE_CONDITIONAL_REPORT == ON
// check if it is an updated value
bool ChildDouble::isNewValue() {
  return _last_value != _value;
}
#endif

/*
 ChildString class
*/

// ChildString class
ChildString::ChildString(Sensor* sensor, int child_id, int presentation, int type, const char* description): Child(sensor, child_id, presentation, type, description)  {
}

// store a new value and update the total
void ChildString::setValueString(const char* value) {
  _value = value;
}

// return the value
const char* ChildString::getValueString() {
  return _value;
}

// send the value back to the controller
void ChildString::sendValue() {
  _sensor->_node->sendMessage(child_id,type,_value);
#if FEATURE_CONDITIONAL_REPORT == ON
  _last_value = _value;
#endif
  _value = "";
}

// Print the child's value (variable type depending on the child class) to the given output
void ChildString::printOn(Print& p) {
  p.print(_value);
}

#if FEATURE_CONDITIONAL_REPORT == ON
// check if it is an updated value
bool ChildString::isNewValue() {
  return strcmp(_value, _last_value) != 0;
}
#endif

/*
   Sensor class
*/
// constructor
Sensor::Sensor() {  
}
Sensor::Sensor(NodeManager& node_manager, int pin) {
  _node = &node_manager;
  _pin = pin;
  _report_timer = new Timer(_node);
  _node->registerSensor(this);
}

// return the name of the sensor
const char* Sensor::getName() {
  return _name;
}

// setter/getter
void Sensor::setPin(int value) {
  _pin = value;
}
int Sensor::getPin() {
  return _pin;
}
void Sensor::setSamples(int value) {
  _samples = value;
}
void Sensor::setSamplesInterval(int value) {
  _samples_interval = value;
}
#if FEATURE_CONDITIONAL_REPORT == ON
void Sensor::setTrackLastValue(bool value) {
  _track_last_value = value;
}
void Sensor::setForceUpdateMinutes(int value) {
  for (List<Child*>::iterator itr = children.begin(); itr != children.end(); ++itr) {
    Child* child = *itr;
    child->force_update_timer->start(value,MINUTES);
  }
}
#endif
#if FEATURE_POWER_MANAGER == ON
void Sensor::setPowerPins(int ground_pin, int vcc_pin, int wait_time) {
  if (_powerManager == nullptr) return;
  _powerManager->setPowerPins(ground_pin, vcc_pin, wait_time);
}
void Sensor::powerOn() {
  if (_powerManager == nullptr) return;
  _powerManager->powerOn();
}
void Sensor::powerOff() {
  if (_powerManager == nullptr) return;
  _powerManager->powerOff();
}
#endif
#if FEATURE_INTERRUPTS == ON
int Sensor::getInterruptPin() {
  return _interrupt_pin;
}
#endif

// After how many seconds the sensor will report back its measure
void Sensor::setReportIntervalSeconds(int value) {
  _report_timer->start(value,SECONDS);
}

// After how many minutes the sensor will report back its measure 
void Sensor::setReportIntervalMinutes(int value) {
  _report_timer->start(value,MINUTES);
}

// After how many minutes the sensor will report back its measure 
void Sensor::setReportIntervalHours(int value) {
  _report_timer->start(value,HOURS);
}

// After how many minutes the sensor will report back its measure 
void Sensor::setReportIntervalDays(int value) {
  _report_timer->start(value,DAYS);
}


// return true if the report interval has been already configured
bool Sensor::isReportIntervalConfigured() {
  return _report_timer->isConfigured();
}

#if FEATURE_INTERRUPTS == ON
// listen for interrupts on the given pin so interrupt() will be called when occurring
void Sensor::setInterrupt(int pin, int mode, int initial) {
  _interrupt_pin = pin;
  _node->setInterrupt(pin,mode,initial);
}
#endif

// register a child
void Sensor::registerChild(Child* child) {
  children.push(child);
}

// present the sensor to the gateway and controller
void Sensor::presentation() {
  for (List<Child*>::iterator itr = children.begin(); itr != children.end(); ++itr) {
    Child* child = *itr;
    #ifdef NODEMANAGER_DEBUG
      Serial.print(F("PRES I="));
      Serial.print(child->child_id);
      Serial.print(F(" T="));
      Serial.print(child->presentation);
      Serial.print(F(" D="));
      Serial.println(child->description);
    #endif
    present(child->child_id, child->presentation, child->description, _node->getAck());
  }

}

// call the sensor-specific implementation of before
void Sensor::before() {
  onBefore();
  for (List<Child*>::iterator itr = children.begin(); itr != children.end(); ++itr) {
    Child* child = *itr;
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" P="));
      Serial.print(child->presentation);
      Serial.print(F(" T="));
      Serial.println(child->type);
    #endif
  }
}

// call the sensor-specific implementation of setup
void Sensor::setup() {
  onSetup();
}

// call the sensor-specific implementation of loop
void Sensor::loop(MyMessage* message) {
  // update the timers if within a loop cycle
  if (message == nullptr) {
    if (_report_timer->isRunning()) {
      // keep track if it is the first time
      bool first_run = _report_timer->isFirstRun();
      // update the timer
      _report_timer->update();
      // if it is not the time yet to report a new measure, just return (unless it is the first time)
      if (! _report_timer->isOver() && ! first_run) return;
    }
  }
  // turn the sensor on
#if FEATURE_POWER_MANAGER == ON
  powerOn();
#endif
  // iterates over all the children
  for (List<Child*>::iterator itr = children.begin(); itr != children.end(); ++itr) {
    Child* child = *itr;
#if FEATURE_CONDITIONAL_REPORT == ON
    // update the force update timer if running
    if (child->force_update_timer->isRunning()) child->force_update_timer->update();
#endif
    // if a specific child is requested, skip all the others
    if (message != nullptr && message->sensor != child->child_id) continue;
    // collect multiple samples if needed
    for (int i = 0; i < _samples; i++) {
      // we've been called from receive(), pass the message along
      if (message != nullptr) onReceive(message);
      // we'be been called from loop()
      else onLoop(child);
      // wait between samples
      if (_samples_interval > 0) _node->sleepOrWait(_samples_interval);
    }
#if FEATURE_CONDITIONAL_REPORT == ON
    // process the result and send a response back if 1) is not a loop 2) not tracking last value 3) tracking last value and there is a new value 4) tracking last value and timer is over
    if (
      message != nullptr
      || ! _track_last_value || 
      _track_last_value && child->isNewValue() || 
      _track_last_value && child->force_update_timer->isRunning() && child->force_update_timer->isOver()
      ) 
#endif
        child->sendValue();
  }
  // turn the sensor off
#if FEATURE_POWER_MANAGER == ON
  powerOff();
#endif
  // if called from loop(), restart the report timer if over
  if (message == nullptr && _report_timer->isRunning() && _report_timer->isOver()) _report_timer->restart();
}

#if FEATURE_INTERRUPTS == ON
// receive and handle an interrupt
void Sensor::interrupt() {
  // call the implementation of onInterrupt()
  onInterrupt();
}
#endif

#if FEATURE_RECEIVE == ON
// receive a message from the radio network
void Sensor::receive(MyMessage* message) {
  // a request would make the sensor executing its main task passing along the message
  loop(message);
}
#endif

// return the requested child 
Child* Sensor::getChild(int child_id) {
  for (List<Child*>::iterator itr = children.begin(); itr != children.end(); ++itr) {
    Child* child = *itr;
    if (child->child_id == child_id) return child;
  }
  return nullptr;
}

#if FEATURE_POWER_MANAGER == ON
void Sensor::setPowerManager(PowerManager& powerManager) {
  _powerManager = &powerManager;
}
#endif

// virtual functions
void Sensor::onBefore() {}
void Sensor::onSetup(){}
void Sensor::onLoop(Child* child){}
void Sensor::onReceive(MyMessage* message){}
void Sensor::onInterrupt(){}

/*
   SensorBattery
*/
#ifndef MY_GATEWAY_ESP8266
// contructor
SensorBattery::SensorBattery(NodeManager& node_manager, int child_id): Sensor(node_manager) {
  _name = "BATTERY";
  children.allocateBlocks(1);
  new ChildFloat(this,child_id,S_MULTIMETER,V_VOLTAGE,_name);
  // report battery level every 60 minutes by default
  setReportIntervalMinutes(60);
}
void SensorBattery::setMinVoltage(float value) {
  _battery_min = value;
}
void SensorBattery::setMaxVoltage(float value) {
  _battery_max = value;
}
void SensorBattery::setBatteryInternalVcc(bool value) {
  _battery_internal_vcc = value;
}
void SensorBattery::setBatteryPin(int value) {
  _battery_pin = value;
}
void SensorBattery::setBatteryVoltsPerBit(float value) {
  _battery_volts_per_bit = value;
}

// what to do during setup
void SensorBattery::onSetup() {
  // when measuring the battery from a pin, analog reference must be internal
  if (! _battery_internal_vcc && _battery_pin > -1)
#if defined(__AVR_ATmega1280__) || defined(__AVR_ATmega2560__)
    analogReference(INTERNAL1V1);
#else
    analogReference(INTERNAL);
#endif
}

// what to do during loop
void SensorBattery::onLoop(Child* child) {
  // measure the board vcc
  float volt = 0;
  if (_battery_internal_vcc || _battery_pin == -1) volt = _node->getVcc();
  else volt = analogRead(_battery_pin) * _battery_volts_per_bit;
  // calculate the percentage
  int percentage = ((volt - _battery_min) / (_battery_max - _battery_min)) * 100;
  if (percentage > 100) percentage = 100;
  if (percentage < 0) percentage = 0;
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" V="));
    Serial.print(volt);
    Serial.print(F(" %="));
    Serial.println(percentage);
  #endif
  ((ChildFloat*)child)->setValueFloat(volt);
  // report battery level percentage
  sendBatteryLevel(percentage);
}

// what to do as the main task when receiving a message
void SensorBattery::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}
#endif

#ifdef MY_SIGNAL_REPORT_ENABLED
/*
   SensorSignal
*/
#ifndef MY_GATEWAY_ESP8266
// contructor
SensorSignal::SensorSignal(NodeManager& node_manager, int child_id): Sensor(node_manager) {
  _name = "SIGNAL";
  children.allocateBlocks(1);
  new ChildInt(this,child_id,S_SOUND,V_LEVEL,_name);
  // report signal level every 60 minutes by default
  setReportIntervalMinutes(60);
}
// setter/getter
void SensorSignal::setSignalCommand(int value) {
  _signal_command = value;
}

// what to do during loop
void SensorSignal::onLoop(Child* child) {
  int16_t value = transportGetSignalReport((signalReport_t)_signal_command);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" V="));
    Serial.println(value);
  #endif
  ((ChildInt*)child)->setValueInt(value);
}

// what to do as the main task when receiving a message
void SensorSignal::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}
#endif
#endif

#ifdef USE_ANALOG_INPUT
/*
   SensorAnalogInput
*/

// contructor
SensorAnalogInput::SensorAnalogInput(NodeManager& node_manager, int pin, int child_id): Sensor(node_manager, pin) {
  _name = "ANALOG_I";
  children.allocateBlocks(1);
  new ChildInt(this,_node->getAvailableChildId(child_id),S_CUSTOM,V_CUSTOM,_name);
}

// setter/getter
void SensorAnalogInput::setReference(int value) {
  _reference = value;
}
void SensorAnalogInput::setReverse(bool value) {
  _reverse = value;
}
void SensorAnalogInput::setOutputPercentage(bool value) {
  _output_percentage = value;
}
void SensorAnalogInput::setRangeMin(int value) {
  _range_min = value;
}
void SensorAnalogInput::setRangeMax(int value) {
  _range_max = value;
}

// what to do during setup
void SensorAnalogInput::onSetup() {
  // prepare the pin for input
  pinMode(_pin, INPUT);
}

// what to do during loop
void SensorAnalogInput::onLoop(Child* child) {
  // read the input
  int adc = _getAnalogRead();
  // calculate the percentage
  int percentage = 0;
  if (_output_percentage) percentage = _getPercentage(adc);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" V="));
    Serial.print(adc);
    Serial.print(F(" %="));
    Serial.println(percentage);
  #endif
  // store the result
  ((ChildInt*)child)->setValueInt(_output_percentage ? percentage : adc);
}

// what to do during loop
void SensorAnalogInput::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}

// read the analog input
int SensorAnalogInput::_getAnalogRead() {
#ifndef MY_GATEWAY_ESP8266
  // set the reference
  if (_reference != -1) {
    analogReference(_reference);
    wait(100);
  }
#endif
  // read and return the value
  int value = analogRead(_pin);
  if (_reverse) value = _range_max - value;
  return value;
}

// return a percentage from an analog value
int SensorAnalogInput::_getPercentage(int adc) {
  float value = (float)adc;
  // restore the original value
  if (_reverse) value = _range_max - value;
  // scale the percentage based on the range provided
  float percentage = ((value - _range_min) / (_range_max - _range_min)) * 100;
  if (_reverse) percentage = 100 - percentage;
  if (percentage > 100) percentage = 100;
  if (percentage < 0) percentage = 0;
  return (int)percentage;
}

/*
   SensorLDR
*/

// contructor
SensorLDR::SensorLDR(NodeManager& node_manager, int pin, int child_id): SensorAnalogInput(node_manager, pin, child_id) {
  _name = "LDR";
  children.get(1)->presentation = S_LIGHT_LEVEL;
  children.get(1)->type = V_LIGHT_LEVEL;
  children.get(1)->description = _name;
}

// what to do during setup
void SensorLDR::onSetup() {
  setReverse(true);
}

/*
   SensorRain
*/

// contructor
SensorRain::SensorRain(NodeManager& node_manager, int pin, int child_id): SensorAnalogInput(node_manager, pin, child_id) {
  _name = "RAIN";
  children.get(1)->presentation = S_RAIN;
  children.get(1)->type = V_RAINRATE;
  children.get(1)->description = _name;
}

// what to do during setup
void SensorRain::onSetup() {
  setReference(DEFAULT);
  setOutputPercentage(true);
  setReverse(true);
  setRangeMin(100);
}

/*
   SensorSoilMoisture
*/

// contructor
SensorSoilMoisture::SensorSoilMoisture(NodeManager& node_manager, int pin, int child_id): SensorAnalogInput(node_manager, pin, child_id) {
  _name = "SOIL";
  children.get(1)->presentation = S_MOISTURE;
  children.get(1)->type = V_LEVEL;
  children.get(1)->description = _name;
}

// what to do during setup
void SensorSoilMoisture::onSetup() {
  setReverse(true);
  setReference(DEFAULT);
  setOutputPercentage(true);
  setReverse(true);
  setRangeMin(100);
}
#endif

#ifdef USE_THERMISTOR
/*
   SensorThermistor
*/

// contructor
SensorThermistor::SensorThermistor(NodeManager& node_manager, int pin, int child_id): Sensor(node_manager, pin) {
  _name = "THERMISTOR";
  children.allocateBlocks(1);
  new ChildFloat(this,_node->getAvailableChildId(child_id),S_TEMP,V_TEMP,_name);
}

// setter/getter
void SensorThermistor::setNominalResistor(long value) {
  _nominal_resistor = value;
}
void SensorThermistor::setNominalTemperature(int value) {
  _nominal_temperature = value;
}
void SensorThermistor::setBCoefficient(int value) {
  _b_coefficient = value;
}
void SensorThermistor::setSeriesResistor(long value) {
  _series_resistor = value;
}
void SensorThermistor::setOffset(float value) {
  _offset = value;
}

// what to do during setup
void SensorThermistor::onSetup() {
  // set the pin as input
  pinMode(_pin, INPUT);
}

// what to do during loop
void SensorThermistor::onLoop(Child* child) {
  // read the voltage across the thermistor
  float adc = analogRead(_pin);
  // calculate the temperature
  float reading = (1023 / adc)  - 1;
  reading = _series_resistor / reading;
  float temperature;
  temperature = reading / _nominal_resistor;     // (R/Ro)
  temperature = log(temperature);                  // ln(R/Ro)
  temperature /= _b_coefficient;                   // 1/B * ln(R/Ro)
  temperature += 1.0 / (_nominal_temperature + 273.15); // + (1/To)
  temperature = 1.0 / temperature;                 // Invert
  temperature -= 273.15;                         // convert to C
  temperature = _node->celsiusToFahrenheit(temperature);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" V="));
    Serial.print(adc);
    Serial.print(F(" T="));
    Serial.println(temperature);
  #endif
  // store the value
  if (! isnan(temperature)) ((ChildFloat*)child)->setValueFloat(temperature);
}

// what to do as the main task when receiving a message
void SensorThermistor::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}
#endif

#ifdef USE_ML8511
/*
   SensorML8511
*/

// contructor
SensorML8511::SensorML8511(NodeManager& node_manager, int pin, int child_id = -255): Sensor(node_manager, pin) {
  _name = "ML8511";
  children.allocateBlocks(1);
  new ChildFloat(this,_node->getAvailableChildId(child_id),S_UV,V_UV,_name);
}

// what to do during setup
void SensorML8511::onSetup() {
  // set the pin as input
  pinMode(_pin, INPUT);
}

// what to do during loop
void SensorML8511::onLoop(Child* child) {
  // read the voltage 
  int uvLevel = analogRead(_pin);
  int refLevel = _node->getVcc()*1024/3.3;
  //Use the 3.3V power pin as a reference to get a very accurate output value from sensor
  float outputVoltage = 3.3 / refLevel * uvLevel;
  //Convert the voltage to a UV intensity level
  float uvIntensity = _mapfloat(outputVoltage, 0.99, 2.8, 0.0, 15.0); 
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" V="));
    Serial.print(outputVoltage);
    Serial.print(F(" I="));
    Serial.println(uvIntensity);
  #endif
  // store the value
  ((ChildFloat*)child)->setValueFloat(uvIntensity);
}

// what to do as the main task when receiving a message
void SensorML8511::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}

// The Arduino Map function but for floats
float SensorML8511::_mapfloat(float x, float in_min, float in_max, float out_min, float out_max) {
  return (x - in_min) * (out_max - out_min) / (in_max - in_min) + out_min;
}
#endif

#ifdef USE_ACS712
/*
   SensorACS712
*/

// contructor
SensorACS712::SensorACS712(NodeManager& node_manager, int pin, int child_id): Sensor(node_manager, pin) {
  _name = "ACS712";
  children.allocateBlocks(1);
  new ChildFloat(this,_node->getAvailableChildId(child_id),S_MULTIMETER,V_CURRENT,_name);
}

// setter/getter
void SensorACS712::setmVPerAmp(int value) {
  _mv_per_amp = value;
}
void SensorACS712::setOffset(int value) {
  _ACS_offset = value;
}

// what to do during setup
void SensorACS712::onSetup() {
  // set the pin as input
  pinMode(_pin, INPUT);
}

// what to do during loop
void SensorACS712::onLoop(Child* child) {
  int value = analogRead(_pin);
  // convert the analog read in mV
  double voltage = (value / 1024.0) * 5000; 
  // convert voltage in amps
  float value_float = ((voltage - _ACS_offset) / _mv_per_amp);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" A="));
    Serial.println(value_float);
  #endif
  ((ChildFloat*)child)->setValueFloat(value_float);
}

// what to do as the main task when receiving a message
void SensorACS712::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}

#endif

#ifdef USE_DIGITAL_INPUT
/*
   SensorDigitalInput
*/

// contructor
SensorDigitalInput::SensorDigitalInput(NodeManager& node_manager, int pin, int child_id): Sensor(node_manager, pin) {
  _name = "DIGITAL_I";
  children.allocateBlocks(1);
  new ChildInt(this,_node->getAvailableChildId(child_id),S_CUSTOM,V_CUSTOM,_name);
}

// what to do during setup
void SensorDigitalInput::onSetup() {
  // set the pin for input
  pinMode(_pin, INPUT);
}

// what to do during loop
void SensorDigitalInput::onLoop(Child* child) {
  // read the value
  int value = digitalRead(_pin);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" P="));
    Serial.print(_pin);
    Serial.print(F(" V="));
    Serial.println(value);
  #endif
  // store the value
  ((ChildInt*)child)->setValueInt(value);
}

// what to do as the main task when receiving a message
void SensorDigitalInput::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}
#endif


#ifdef USE_DIGITAL_OUTPUT
/*
   SensorDigitalOutput
*/

SensorDigitalOutput::SensorDigitalOutput(NodeManager& node_manager, int pin, int child_id): Sensor(node_manager, pin) {
  _name = "DIGITAL_O";
  children.allocateBlocks(1);
  new ChildInt(this,_node->getAvailableChildId(child_id),S_CUSTOM,V_CUSTOM,_name);
}

// what to do during setup
void SensorDigitalOutput::onSetup() {
  _setupPin(children.get(1), _pin);
  _safeguard_timer = new Timer(_node);
}

// setter/getter
void SensorDigitalOutput::setOnValue(int value) {
  _on_value = value;
}
void SensorDigitalOutput::setLegacyMode(bool value) {
  _legacy_mode = value;
}
void SensorDigitalOutput::setSafeguard(int value) {
  _safeguard_timer->set(value,MINUTES);
}
int SensorDigitalOutput::getStatus() {
  return _status;
}
void SensorDigitalOutput::setInputIsElapsed(bool value) {
  _input_is_elapsed = value;
}
void SensorDigitalOutput::setWaitAfterSet(int value) {
  _wait_after_set = value;
}

// main task
void SensorDigitalOutput::onLoop(Child* child) {
  // if a safeguard is set, check if it is time for it
  if (_safeguard_timer->isRunning()) {
    // update the timer
    _safeguard_timer->update();
    // if the time is over, turn the output off
    if (_safeguard_timer->isOver()) setStatus(child,OFF);
  }
}

// what to do as the main task when receiving a message
void SensorDigitalOutput::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  // by default handle a SET message but when legacy mode is set when a REQ message is expected instead
  if ( (message->getCommand() == C_SET && ! _legacy_mode) || (message->getCommand() == C_REQ && _legacy_mode)) {
    // switch the output
    setStatus(child, message->getInt());
  }
  if (message->getCommand() == C_REQ && ! _legacy_mode) {
    // just return the current status
    ((ChildInt*)child)->setValueInt(_status);
  }
}

// write the value to the output
void SensorDigitalOutput::setStatus(Child* child, int value) {
  // pre-process the input value
  if (_input_is_elapsed) {
    // the input provided is an elapsed time
    if (value == OFF) {
      // turning it off, no need for a safeguard anymore, stop the timer
      _safeguard_timer->stop();
    } 
    else if (value == ON) {
      // configure and start the timer
      _safeguard_timer->start(value,MINUTES);
      // if the input is an elapsed time, unless the value is OFF, the output will be always ON
      value = ON;
    }
  } else {
    // if turning the output on and a safeguard timer is configured, start it
    if (value == ON && _safeguard_timer->isConfigured() && ! _safeguard_timer->isRunning()) _safeguard_timer->start();
  }
  _setStatus(child, value);
  // wait if needed for relay drawing a lot of current
  if (_wait_after_set > 0) _node->sleepOrWait(_wait_after_set);
  // store the new status so it will be sent to the controller
  _status = value;
  ((ChildInt*)child)->setValueInt(value);
}

// setup the provided pin for output
void SensorDigitalOutput::_setupPin(Child* child, int pin) {
  // set the pin as output and initialize it accordingly
  pinMode(pin, OUTPUT);
  // setup the pin in a off status
  _status = ! _on_value;
  digitalWrite(pin, _status);
  // the initial value is now the current value
  ((ChildInt*)child)->setValueInt(_status);
}

// switch to the requested status
void SensorDigitalOutput::_setStatus(Child* child, int value) {
  int value_to_write = _getValueToWrite(value);
  // set the value to the pin
  digitalWrite(_pin, value_to_write);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" P="));
    Serial.print(_pin);
    Serial.print(F(" V="));
    Serial.println(value_to_write);
  #endif
}

// reverse the value if needed based on the _on_value
int SensorDigitalOutput::_getValueToWrite(int value) {
  int value_to_write = value;
  if (_on_value == LOW) {
    // if the "on" value is LOW, reverse the value
    if (value == ON) value_to_write = LOW;
    if (value == OFF) value_to_write = HIGH;
  }
  return value_to_write;
}

/*
   SensorRelay
*/

// contructor
SensorRelay::SensorRelay(NodeManager& node_manager, int pin, int child_id): SensorDigitalOutput(node_manager, pin, child_id) {
  _name = "RELAY";
  children.get(1)->presentation = S_BINARY;
  children.get(1)->type = V_STATUS;
  children.get(1)->description = _name;
}

/*
   SensorLatchingRelay
*/

// contructor
SensorLatchingRelay::SensorLatchingRelay(NodeManager& node_manager, int pin, int child_id): SensorRelay(node_manager, pin, child_id) {
  _name = "LATCHING";
  // set the "off" pin to the provided pin and the "on" pin to the provided pin + 1
  _pin_on = pin;
  _pin_off = pin + 1;
  children.get(1)->description = _name;
}

// setter/getter
void SensorLatchingRelay::setPulseWidth(int value) {
  _pulse_width = value;
}
void SensorLatchingRelay::setPinOn(int value) {
  _pin_on = value;
}
void SensorLatchingRelay::setPinOff(int value) {
  _pin_off = value;
}

// what to do during setup
void SensorLatchingRelay::onSetup() {
  _setupPin(children.get(1),_pin_on);
  _setupPin(children.get(1),_pin_off);
}

// switch to the requested status
void SensorLatchingRelay::_setStatus(Child* child, int value) {
  // select the right pin to send the pulse to
  int pin = value == OFF ? _pin_off : _pin_on;
  // set the value
  digitalWrite(pin, _on_value);
  // wait for the given time before restoring the value to the original value after the pulse
  _node->sleepOrWait(_pulse_width);
  digitalWrite(pin, ! _on_value);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(F("LAT I="));
    Serial.print(child->child_id);
    Serial.print(F(" P="));
    Serial.print(pin);
    Serial.print(F(" S="));
    Serial.print(value);
    Serial.print(F(" V="));
    Serial.print(_on_value);
    Serial.print(F(" P="));
    Serial.println(_pulse_width);
  #endif
}

#endif

#ifdef USE_DHT
/*
   SensorDHT
*/

// contructor
SensorDHT::SensorDHT(NodeManager& node_manager, int pin, int child_id): Sensor(node_manager, pin) {
  _name = "DHT";
  _dht_type = DHT::DHT11;
  children.allocateBlocks(2);
  new ChildFloat(this,_node->getAvailableChildId(child_id),S_TEMP,V_TEMP,_name);
  new ChildFloat(this,_node->getAvailableChildId(child_id+1),S_HUM,V_HUM,_name);
}

// what to do during setup
void SensorDHT::onSetup() {
  // store the dht object
  _dht = new DHT();
  // initialize the dht library
  _dht->setup(_pin,(DHT::DHT_MODEL_t)_dht_type);
}

// what to do during loop
void SensorDHT::onLoop(Child* child) {
  _node->sleepOrWait(_dht->getMinimumSamplingPeriod());
  _dht->readSensor(true);
  // temperature sensor
  if (child->type == V_TEMP) {
    // read the temperature
    float temperature = _dht->getTemperature();
    if (! _node->getIsMetric()) temperature = _dht->toFahrenheit(temperature);
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" T="));
      Serial.println(temperature);
    #endif
    // store the value
    if (! isnan(temperature)) ((ChildFloat*)child)->setValueFloat(temperature);
  }
  // humidity sensor
  else if (child->type == V_HUM) {
    // read humidity
    float humidity = _dht->getHumidity();
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" H="));
      Serial.println(humidity);
    #endif
    // store the value
    if (! isnan(humidity)) ((ChildFloat*)child)->setValueFloat(humidity);
  }
}

// what to do as the main task when receiving a message
void SensorDHT::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}

/*
   SensorDHT11
*/

// contructor
SensorDHT11::SensorDHT11(NodeManager& node_manager, int pin, int child_id): SensorDHT(node_manager, pin, child_id) {
  _name = "DHT11";
  _dht_type = DHT::DHT11;
  children.get(1)->description = _name;
  children.get(2)->description = _name;
}

/*
   SensorDHT11
*/

// contructor
SensorDHT22::SensorDHT22(NodeManager& node_manager, int pin, int child_id): SensorDHT(node_manager, pin, child_id) {
  _name = "DHT22";
  _dht_type = DHT::DHT22;
  children.get(1)->description = _name;
  children.get(2)->description = _name;
}
#endif

/*
   SensorSHT21
*/
#ifdef USE_SHT21
// contructor
SensorSHT21::SensorSHT21(NodeManager& node_manager, int child_id): Sensor(node_manager) {
  _name = "SHT21";
  children.allocateBlocks(2);
  new ChildFloat(this,_node->getAvailableChildId(child_id),S_TEMP,V_TEMP,_name);
  new ChildFloat(this,_node->getAvailableChildId(child_id+1),S_HUM,V_HUM,_name);
}

// what to do during setup
void SensorSHT21::onSetup() {
  // initialize the library
  Wire.begin();
}

// what to do during loop
void SensorSHT21::onLoop(Child* child) {
  // temperature sensor
  if (child->type == V_TEMP) {
    // read the temperature
    float temperature = SHT2x.GetTemperature();
    // convert it
    temperature = _node->celsiusToFahrenheit(temperature);
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" T="));
      Serial.println(temperature);
    #endif
    // store the value
    if (! isnan(temperature)) ((ChildFloat*)child)->setValueFloat(temperature);
  }
  // Humidity Sensor
  else if (child->type == V_HUM) {
    // read humidity
    float humidity = SHT2x.GetHumidity();
    if (isnan(humidity)) return;
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" H="));
      Serial.println(humidity);
    #endif
    // store the value
   if (! isnan(humidity)) ((ChildFloat*)child)->setValueFloat(humidity);
  }
}

// what to do as the main task when receiving a message
void SensorSHT21::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}

/*
 * SensorHTU21D
 */
 // constructor
SensorHTU21D::SensorHTU21D(NodeManager& nodeManager, int child_id): SensorSHT21(nodeManager, child_id) {
  _name = "HTU21";
  children.get(1)->description = _name;
  children.get(2)->description = _name;
}
#endif 

#ifdef USE_INTERRUPT
/*
 * SensorInterrupt
 */
SensorInterrupt::SensorInterrupt(NodeManager& node_manager, int pin, int child_id): Sensor(node_manager, pin) {
  _name = "INTERRUPT";
  children.allocateBlocks(1);
  new ChildInt(this,_node->getAvailableChildId(child_id),S_CUSTOM,V_CUSTOM,_name);
}

// setter/getter
void SensorInterrupt::setMode(int value) {
  _mode = value;
}
void SensorInterrupt::setDebounce(int value) {
  _debounce = value;
}
void SensorInterrupt::setTriggerTime(int value) {
  _trigger_time = value;
}
void SensorInterrupt::setInitial(int value) {
  _initial = value;
}
void SensorInterrupt::setActiveState(int value) {
  _active_state = value;
}

// what to do during setup
void SensorInterrupt::onSetup() {
  // set the interrupt pin so it will be called only when waking up from that interrupt
  setInterrupt(_pin,_mode,_initial);
  // report immediately
  _report_timer->unset();
}

// what to do during loop
void SensorInterrupt::onLoop(Child* child) {
}

// what to do as the main task when receiving a message
void SensorInterrupt::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == V_STATUS) {
    // return current status
    ((ChildInt*)child)->setValueInt(digitalRead(_pin));
  }
}

// what to do when receiving an interrupt
void SensorInterrupt::onInterrupt() {
  Child* child = children.get(1);
  // wait to ensure the the input is not floating
  if (_debounce > 0) _node->sleepOrWait(_debounce);
  // read the value of the pin
  int value = _node->getLastInterruptValue();
  // process the value
  if ( (_mode == RISING && value == HIGH ) || (_mode == FALLING && value == LOW) || (_mode == CHANGE) )  {
    // invert the value if Active State is set to LOW
    if (_active_state == LOW) value = !value;
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" P="));
      Serial.print(_pin);
      Serial.print(F(" V="));
      Serial.println(value);
    #endif
    ((ChildInt*)child)->setValueInt(value);
    // allow the signal to be restored to its normal value
    if (_trigger_time > 0) _node->sleepOrWait(_trigger_time);
  } else {
    // invalid
    ((ChildInt*)child)->setValueInt(-255);
  }
}

/*
 * SensorDoor
 */
SensorDoor::SensorDoor(NodeManager& node_manager, int pin, int child_id): SensorInterrupt(node_manager, pin, child_id) {
  _name = "DOOR";
  children.get(1)->presentation = S_DOOR;
  children.get(1)->type = V_TRIPPED;
  children.get(1)->description = _name;
}

/*
 * SensorMotion
 */
SensorMotion::SensorMotion(NodeManager& node_manager, int pin, int child_id): SensorInterrupt(node_manager, pin, child_id) {
  _name = "MOTION";
  children.get(1)->presentation = S_MOTION;
  children.get(1)->type = V_TRIPPED;
  children.get(1)->description = _name;
}

// what to do during setup
void SensorMotion::onSetup() {
  SensorInterrupt::onSetup();
  // set initial value to LOW
  setInitial(LOW);
}
#endif

/*
   SensorDs18b20
*/
#ifdef USE_DS18B20
// contructor
SensorDs18b20::SensorDs18b20(NodeManager& node_manager, int pin, int child_id): Sensor(node_manager, pin) {
  _name = "DS18B20";
  // initialize the library
  OneWire* oneWire = new OneWire(_pin);
  _sensors = new DallasTemperature(oneWire);
  // initialize the sensors
  _sensors->begin();
  // register a new child for each sensor on the bus
  for(int i = 0; i < _sensors->getDeviceCount(); i++) {
    new ChildFloat(this,_node->getAvailableChildId(child_id+i),S_TEMP,V_TEMP,_getAddress(i));
  }
}

// what to do during setup
void SensorDs18b20::onSetup() {
  for (int i = 1; i <= children.size(); i++) {
    children.get(i);
    _node->sendMessage(children.get(i)->child_id,V_ID,_getAddress(i-1));
  }
}

// what to do during loop
void SensorDs18b20::onLoop(Child* child) {
  int index = -1;
  // get the index of the requested child
  for (int i = 1; i <= children.size(); i++) {
    if (children.get(i) == child) index = i-1;
  }
  // do not wait for conversion, will sleep manually during it
  if (_sleep_during_conversion) _sensors->setWaitForConversion(false);
  // request the temperature
  _sensors->requestTemperaturesByIndex(index);
  if (_sleep_during_conversion) {
    // calculate conversion time and sleep
    int16_t conversion_time = _sensors->millisToWaitForConversion(_sensors->getResolution());
    sleep(conversion_time);
  }
  // read the temperature
  float temperature = _sensors->getTempCByIndex(index);
  if (temperature == -127.00 || temperature == 85.00) return;
  // convert it
  temperature = _node->celsiusToFahrenheit(temperature);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" T="));
    Serial.println(temperature);
  #endif
  // store the value
  if (! isnan(temperature)) ((ChildFloat*)child)->setValueFloat(temperature);
}

// what to do as the main task when receiving a message
void SensorDs18b20::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}

// returns the sensor's resolution in bits
int SensorDs18b20::getResolution() {
  return _sensors->getResolution();
}

// set the sensor's resolution in bits
void SensorDs18b20::setResolution(int value) {
  _sensors->setResolution(value);
}

// sleep while DS18B20 calculates temperature
void SensorDs18b20::setSleepDuringConversion(bool value) {
   _sleep_during_conversion = value;
}

// return the address of a device
char* SensorDs18b20::_getAddress(int index) {
  char* charAddr = "                ";
  DeviceAddress device_address;
  _sensors->getAddress(device_address,index);
  String strAddr = String(device_address[0], HEX);
  byte first ;
  int j = 0;
  for (uint8_t i = 1; i < 8; i++) {
    if (device_address[i] < 16) strAddr = strAddr + 0;
    strAddr = strAddr + String(device_address[i], HEX);
    strAddr.toUpperCase();
  }
  for (int j = 0; j < 16; j++) charAddr[j] = strAddr[j];
  return charAddr;
}
#endif

/*
   SensorBH1750
*/
#ifdef USE_BH1750
// contructor
SensorBH1750::SensorBH1750(NodeManager& node_manager, int child_id): Sensor(node_manager) {
  _name = "BH1750";
  children.allocateBlocks(1);
  new ChildInt(this,_node->getAvailableChildId(child_id),S_LIGHT_LEVEL,V_LEVEL,_name);
}
// setter/getter
void SensorBH1750::setMode(uint8_t mode) {
  _lightSensor->configure(mode);
}

// what to do during setup
void SensorBH1750::onSetup() {
  _lightSensor = new BH1750();
  _lightSensor->begin();
}

// what to do during loop
void SensorBH1750::onLoop(Child* child) {
  // request the light level
  int value = _lightSensor->readLightLevel();
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" L="));
    Serial.println(value);
  #endif
  ((ChildInt*)child)->setValueInt(value);
}

// what to do as the main task when receiving a message
void SensorBH1750::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}
#endif

/*
   SensorMLX90614
*/
#ifdef USE_MLX90614
// contructor
SensorMLX90614::SensorMLX90614(NodeManager& node_manager, int child_id): Sensor(node_manager) {
  _name = "MLX90614";
  children.allocateBlocks(2);
  new ChildFloat(this,_node->getAvailableChildId(child_id),S_TEMP,V_TEMP,_name);
  new ChildFloat(this,_node->getAvailableChildId(child_id+1),S_TEMP,V_TEMP,_name);
}

// what to do during setup
void SensorMLX90614::onSetup() {
  // initialize the library
  _mlx = new Adafruit_MLX90614();
  _mlx->begin();
}

// what to do during loop
void SensorMLX90614::onLoop(Child* child) {
  float temperature;
  // the first child is the ambient temperature, the second the object temperature
  if (children.get(1) == child) temperature = _mlx->readAmbientTempC();
  else temperature = _mlx->readObjectTempC();
  // convert it
  temperature = _node->celsiusToFahrenheit(temperature);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(F("MLX I="));
    Serial.print(child->child_id);
    Serial.print(F(" T="));
    Serial.println(temperature);
  #endif
  if (! isnan(temperature)) ((ChildFloat*)child)->setValueFloat(temperature);
}

// what to do as the main task when receiving a message
void SensorMLX90614::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}
#endif

/*
   SensorBosch
*/
#if defined(USE_BME280) || defined(USE_BMP085) || defined(USE_BMP280)
// contructor
SensorBosch::SensorBosch(NodeManager& node_manager, int child_id = -255): Sensor(node_manager) {
  _name = "BOSCH";
  // initialize the forecast samples array
  _forecast_samples = new float[_forecast_samples_count];
}

// setter/getter
void SensorBosch::setForecastSamplesCount(int value) {
  _forecast_samples_count = value;
}

// what to do as the main task when receiving a message
void SensorBosch::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}

// calculate and send the forecast back
char* SensorBosch::_forecast(float pressure) {
  if (isnan(pressure)) return "";
  // Calculate the average of the last n minutes.
  int index = _minute_count % _forecast_samples_count;
  _forecast_samples[index] = pressure;
  _minute_count++;
  if (_minute_count > 185) _minute_count = 6;
  if (_minute_count == 5) _pressure_avg = _getLastPressureSamplesAverage();
  else if (_minute_count == 35) {
    float last_pressure_avg = _getLastPressureSamplesAverage();
    float change = (last_pressure_avg - _pressure_avg) * 0.1;
    // first time initial 3 hour
    if (_first_round) _dP_dt = change * 2; // note this is for t = 0.5hour
    else _dP_dt = change / 1.5; // divide by 1.5 as this is the difference in time from 0 value.
  }
  else if (_minute_count == 65) {
    float last_pressure_avg = _getLastPressureSamplesAverage();
    float change = (last_pressure_avg - _pressure_avg) * 0.1;
    //first time initial 3 hour
    if (_first_round) _dP_dt = change; //note this is for t = 1 hour
    else _dP_dt = change / 2; //divide by 2 as this is the difference in time from 0 value
  }
  else if (_minute_count == 95) {
    float last_pressure_avg = _getLastPressureSamplesAverage();
    float change = (last_pressure_avg - _pressure_avg) * 0.1;
    // first time initial 3 hour
    if (_first_round)_dP_dt = change / 1.5; // note this is for t = 1.5 hour
    else _dP_dt = change / 2.5; // divide by 2.5 as this is the difference in time from 0 value
  }
  else if (_minute_count == 125) {
    float last_pressure_avg = _getLastPressureSamplesAverage();
    // store for later use.
    _pressure_avg2 = last_pressure_avg; 
    float change = (last_pressure_avg - _pressure_avg) * 0.1;
    if (_first_round) _dP_dt = change / 2; // note this is for t = 2 hour
    else _dP_dt = change / 3; // divide by 3 as this is the difference in time from 0 value
  }
  else if (_minute_count == 155) {
    float last_pressure_avg = _getLastPressureSamplesAverage();
    float change = (last_pressure_avg - _pressure_avg) * 0.1;
    if (_first_round) _dP_dt = change / 2.5; // note this is for t = 2.5 hour
    else _dP_dt = change / 3.5; // divide by 3.5 as this is the difference in time from 0 value
  }
  else if (_minute_count == 185) {
    float last_pressure_avg = _getLastPressureSamplesAverage();
    float change = (last_pressure_avg - _pressure_avg) * 0.1;
    if (_first_round) _dP_dt = change / 3; // note this is for t = 3 hour
    else _dP_dt = change / 4; // divide by 4 as this is the difference in time from 0 value
  }
  // Equating the pressure at 0 to the pressure at 2 hour after 3 hours have past.
  _pressure_avg = _pressure_avg2; 
  // flag to let you know that this is on the past 3 hour mark. Initialized to 0 outside main loop.
  _first_round = false; 
  // calculate the forecast (STABLE = 0, SUNNY = 1, CLOUDY = 2, UNSTABLE = 3, THUNDERSTORM = 4, UNKNOWN = 5)
  int forecast = 5;
  //if time is less than 35 min on the first 3 hour interval.
  if (_minute_count < 35 && _first_round) forecast = 5;
  else if (_dP_dt < (-0.25)) forecast = 5;
  else if (_dP_dt > 0.25) forecast = 4;
  else if ((_dP_dt > (-0.25)) && (_dP_dt < (-0.05))) forecast = 2;
  else if ((_dP_dt > 0.05) && (_dP_dt < 0.25)) forecast = 1;
  else if ((_dP_dt >(-0.05)) && (_dP_dt < 0.05)) forecast = 0;
  else forecast = 5;
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" M="));
    Serial.print(_minute_count);
    Serial.print(F(" dP="));
    Serial.print(_dP_dt);
    Serial.print(F(" F="));
    Serial.println(_weather[forecast]);
  #endif
  return _weather[forecast];
}

// returns the average of the latest pressure samples
float SensorBosch::_getLastPressureSamplesAverage() {
  float avg = 0;
  for (int i = 0; i < _forecast_samples_count; i++) avg += _forecast_samples[i];
  avg /= _forecast_samples_count;
  return avg;
}

// search for a given chip on i2c bus
uint8_t SensorBosch::GetI2CAddress(uint8_t chip_id) {
  uint8_t addresses[] = {0x77, 0x76};
  uint8_t register_address = 0xD0;
  for (int i = 0; i <= sizeof(addresses); i++) { 
    uint8_t i2c_address = addresses[i];
    uint8_t value;
    Wire.beginTransmission((uint8_t)i2c_address);
    Wire.write((uint8_t)register_address);
    Wire.endTransmission();
    Wire.requestFrom((uint8_t)i2c_address, (byte)1);
    value = Wire.read();
    if (value == chip_id) {
      #ifdef NODEMANAGER_DEBUG
        Serial.print(F("I2C=")); 
        Serial.println(i2c_address);
      #endif
      return i2c_address;
    }
  }
  return addresses[0]; 
}
#endif

/*
 * SensorBME280
 */
#ifdef USE_BME280
SensorBME280::SensorBME280(NodeManager& node_manager, int child_id): SensorBosch(node_manager, child_id) {
  _name = "BME280";
  children.allocateBlocks(4);
  new ChildFloat(this,_node->getAvailableChildId(child_id),S_TEMP,V_TEMP,_name);
  new ChildFloat(this,_node->getAvailableChildId(child_id+1),S_HUM,V_HUM,_name);
  new ChildFloat(this,_node->getAvailableChildId(child_id+2),S_BARO,V_PRESSURE,_name);
  new ChildString(this,_node->getAvailableChildId(child_id+3),S_BARO,V_FORECAST,_name);
}

// what to do during setup
void SensorBME280::onSetup() {
  _bm = new Adafruit_BME280();
  if (! _bm->begin(SensorBosch::GetI2CAddress(0x60))) {
    #ifdef NODEMANAGER_DEBUG
      Serial.println(F("ERR"));
    #endif
  }
}

void SensorBME280::onLoop(Child* child) {
  // temperature sensor
  if (child->type == V_TEMP) {
    // read the temperature
    float temperature = _bm->readTemperature();
    // convert it
    temperature = _node->celsiusToFahrenheit(temperature);
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" T="));
      Serial.println(temperature);
    #endif
    // store the value
    if (! isnan(temperature)) ((ChildFloat*)child)->setValueFloat(temperature);
  }
  // Humidity Sensor
  else if (child->type == V_HUM) {
    // read humidity
    float humidity = _bm->readHumidity();
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" H="));
      Serial.println(humidity);
    #endif
    // store the value
    if (! isnan(humidity)) ((ChildFloat*)child)->setValueFloat(humidity);
  }
  // Pressure Sensor
  else if (child->type == V_PRESSURE) {
    // read pressure
    float pressure = _bm->readPressure() / 100.0F;
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" P="));
      Serial.println(pressure);
    #endif
    // store the value
    if (! isnan(pressure)) ((ChildFloat*)child)->setValueFloat(pressure);
  }
  // Forecast Sensor
  else if (child->type == V_FORECAST) {
    float pressure = _bm->readPressure() / 100.0F;
    _forecast(pressure);
  }
}
#endif

/*
   SensorBMP085
*/
#ifdef USE_BMP085
// contructor
SensorBMP085::SensorBMP085(NodeManager& node_manager, int child_id): SensorBosch(node_manager, child_id) {
  _name = "BMP085";
  children.allocateBlocks(3);
  new ChildFloat(this,_node->getAvailableChildId(child_id),S_TEMP,V_TEMP,_name);
  new ChildFloat(this,_node->getAvailableChildId(child_id+1),S_BARO,V_PRESSURE,_name);
  new ChildString(this,_node->getAvailableChildId(child_id+2),S_BARO,V_FORECAST,_name);
}

// what to do during setup
void SensorBMP085::onSetup() {
  _bm = new Adafruit_BMP085();
  if (! _bm->begin(SensorBosch::GetI2CAddress(0x55))) {
    #ifdef NODEMANAGER_DEBUG
      Serial.println(F("ERR"));
    #endif
  }
}

// what to do during loop
void SensorBMP085::onLoop(Child* child) {
  // temperature sensor
  if (child->type == V_TEMP) {
    // read the temperature
    float temperature = _bm->readTemperature();
    // convert it
    temperature = _node->celsiusToFahrenheit(temperature);
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" T="));
      Serial.println(temperature);
    #endif
    // store the value
    if (! isnan(temperature)) ((ChildFloat*)child)->setValueFloat(temperature);
  }
  // Pressure Sensor
  else if (child->type == V_PRESSURE) {
    // read pressure
    float pressure = _bm->readPressure() / 100.0F;
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" P="));
      Serial.println(pressure);
    #endif
    // store the value
    if (! isnan(pressure)) ((ChildFloat*)child)->setValueFloat(pressure);
  }
  // Forecast Sensor
  else if (child->type == V_FORECAST) {
    float pressure = _bm->readPressure() / 100.0F;
    _forecast(pressure);
  }
}
#endif

/*
 * SensorBMP280
 */
#ifdef USE_BMP280
SensorBMP280::SensorBMP280(NodeManager& node_manager, int child_id): SensorBosch(node_manager, child_id) {
  _name = "BMP280";
  children.allocateBlocks(3);
  new ChildFloat(this,_node->getAvailableChildId(child_id),S_TEMP,V_TEMP,_name);
  new ChildFloat(this,_node->getAvailableChildId(child_id+1),S_BARO,V_PRESSURE,_name);
  new ChildString(this,_node->getAvailableChildId(child_id+2),S_BARO,V_FORECAST,_name);

}

// what to do during setup
void SensorBMP280::onSetup() {
  _bm = new Adafruit_BMP280();
  if (! _bm->begin(SensorBosch::GetI2CAddress(0x58))) {
    #ifdef NODEMANAGER_DEBUG
      Serial.println(F("ERR"));
    #endif
  }
}

void SensorBMP280::onLoop(Child* child) {
  // temperature sensor
  if (child->type == V_TEMP) {
    // read the temperature
    float temperature = _bm->readTemperature();
    // convert it
    temperature = _node->celsiusToFahrenheit(temperature);
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" T="));
      Serial.println(temperature);
    #endif
    // store the value
    if (! isnan(temperature)) ((ChildFloat*)child)->setValueFloat(temperature);
  }
  // Pressure Sensor
  else if (child->type == V_PRESSURE) {
    // read pressure
    float pressure = _bm->readPressure() / 100.0F;
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" P="));
      Serial.println(pressure);
    #endif
    // store the value
    if (! isnan(pressure)) ((ChildFloat*)child)->setValueFloat(pressure);
  }
  // Forecast Sensor
  else if (child->type == V_FORECAST) {
    float pressure = _bm->readPressure() / 100.0F;
    _forecast(pressure);
  }
}
#endif

/*
   SensorSonoff
*/
#ifdef USE_SONOFF
// contructor
SensorSonoff::SensorSonoff(NodeManager& node_manager, int child_id): Sensor(node_manager) {
  _name = "SONOFF";
  children.allocateBlocks(1);
  new ChildInt(this,_node->getAvailableChildId(child_id),S_BINARY,V_STATUS,_name);
} 

// setter/getter
void SensorSonoff::setButtonPin(int value) {
    _button_pin = value;
}
void SensorSonoff::setRelayPin(int value) {
    _relay_pin = value;
}
void SensorSonoff::setLedPin(int value) {
    _led_pin = value;
}

// what to do during setup
void SensorSonoff::onSetup() {
  // Setup the button
  pinMode(_button_pin, INPUT_PULLUP);
  // After setting up the button, setup debouncer
  _debouncer.attach(_button_pin);
  _debouncer.interval(5);
  // Make sure relays and LED are off when starting up
  digitalWrite(_relay_pin, _relay_off);
  digitalWrite(_led_pin, _led_off);
  // Then set relay pins in output mode
  pinMode(_relay_pin, OUTPUT);
  pinMode(_led_pin, OUTPUT);
  _blink();
}

// what to do during loop
void SensorSonoff::onLoop(Child* child) {
  _debouncer.update();
  // Get the update value from the button
  int value = _debouncer.read();
  if (value != _old_value && value == 0) {
    // button pressed, toggle the state
    _toggle(child);
  }
  _old_value = value;
}

// what to do as the main task when receiving a message
void SensorSonoff::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_SET) {
    // retrieve from the message the value to set
    int value = message->getInt();
    if (value != 0 && value != 1 || value == _state) return;
    // toggle the state
    _toggle(child);
  }
  if (message->getCommand() == C_REQ) {
    // return the current state
    ((ChildInt*)child)->setValueInt(_state);
  }
}

// toggle the state
void SensorSonoff::_toggle(Child* child) {
  // toggle the state
  _state = _state ? false : true;
  // Change relay state
  digitalWrite(_relay_pin, _state? _relay_on: _relay_off);
  // Change LED state
  digitalWrite(_led_pin, _state? _led_on: _led_off);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" V="));
    Serial.println(_state);
  #endif
  ((ChildInt*)child)->setValueInt(_state);
}

// blink the led
void SensorSonoff::_blink() {
  digitalWrite(_led_pin, digitalRead(_led_pin) ? _led_on : _led_off);
  wait(200);
  digitalWrite(_led_pin, digitalRead(_led_pin) ? _led_on : _led_off);
  wait(200);
  digitalWrite(_led_pin, digitalRead(_led_pin) ? _led_on : _led_off);
  wait(200);
  digitalWrite(_led_pin, digitalRead(_led_pin) ? _led_on : _led_off);
}
#endif

/*
   SensorHCSR04
*/
#ifdef USE_HCSR04
// contructor
SensorHCSR04::SensorHCSR04(NodeManager& node_manager, int pin, int child_id): Sensor(node_manager, pin) {
  _name = "HCSR04";
  _trigger_pin = pin;
  _echo_pin = pin;
  children.allocateBlocks(1);
  new ChildInt(this,_node->getAvailableChildId(child_id),S_DISTANCE,V_DISTANCE,_name);
}

// setter/getter
void SensorHCSR04::setTriggerPin(int value) {
  _trigger_pin = value;
}
void SensorHCSR04::setEchoPin(int value) {
  _echo_pin = value;
}
void SensorHCSR04::setMaxDistance(int value) {
  _max_distance = value;
}

// what to do during setup
void SensorHCSR04::onSetup() {
  // initialize the library
  _sonar = new NewPing(_trigger_pin,_echo_pin,_max_distance);
}

// what to do during loop
void SensorHCSR04::onLoop(Child* child) {
  int distance = _node->getIsMetric() ? _sonar->ping_cm() : _sonar->ping_in();
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" D="));
    Serial.println(distance);
  #endif
  ((ChildInt*)child)->setValueInt(distance);
}

// what to do as the main task when receiving a message
void SensorHCSR04::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}
#endif

/*
   SensorMCP9808
*/
#ifdef USE_MCP9808
// contructor
SensorMCP9808::SensorMCP9808(NodeManager& node_manager, int child_id): Sensor(node_manager) {
  _name = "MCP9808";
  children.allocateBlocks(1);
  new ChildFloat(this,_node->getAvailableChildId(child_id),S_TEMP,V_TEMP,_name);
}

// what to do during setup
void SensorMCP9808::onSetup() {
  _mcp = new Adafruit_MCP9808();
}

// what to do during loop
void SensorMCP9808::onLoop(Child* child) {
  float temperature = _mcp->readTempC();
  // convert it
  temperature = _node->celsiusToFahrenheit(temperature);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" T="));
    Serial.println(temperature);
  #endif
  // store the value
  if (! isnan(temperature)) ((ChildFloat*)child)->setValueFloat(temperature);
}

// what to do as the main task when receiving a message
void SensorMCP9808::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}
#endif

/*
 * SensorMQ
 */
#ifdef USE_MQ

float SensorMQ::_default_LPGCurve[3] = {2.3,0.21,-0.47};
float SensorMQ::_default_COCurve[3] = {2.3,0.72,-0.34};
float SensorMQ::_default_SmokeCurve[3] = {2.3,0.53,-0.44};

SensorMQ::SensorMQ(NodeManager& node_manager, int pin, int child_id): Sensor(node_manager, pin) {
  _name = "MQ";
  _LPGCurve = SensorMQ::_default_LPGCurve;
  _COCurve = SensorMQ::_default_COCurve;
  _SmokeCurve = SensorMQ::_default_SmokeCurve;
  children.allocateBlocks(1);
  new ChildInt(this,_node->getAvailableChildId(child_id),S_AIR_QUALITY,V_LEVEL,_name);
}

//setter/getter
void SensorMQ::setTargetGas(int value) {
  _target_gas = value;
}
void SensorMQ::setRlValue(float value) {
  _rl_value = value;
}
void SensorMQ::setRoValue(float value) {
  _ro = value;
}
void SensorMQ::setCleanAirFactor(float value) {
  _ro_clean_air_factor = value;
}
void SensorMQ::setCalibrationSampleTimes(int value) {
  _calibration_sample_times = value;
}
void SensorMQ::setCalibrationSampleInterval(int value){
  _calibration_sample_interval = value;
}
void SensorMQ::setReadSampleTimes(int value) {
  _read_sample_times = value;
}
void SensorMQ::setReadSampleInterval(int value) {
  _read_sample_interval = value;
}
void SensorMQ::setLPGCurve(float *value) {
  _LPGCurve = value;
}
void SensorMQ::setCOCurve(float *value) {
  _COCurve = value;
}
void SensorMQ::setSmokeCurve(float *value) {
  _SmokeCurve = value;
}

// what to do during setup
void SensorMQ::onSetup() {
  // prepare the pin for input
  pinMode(_pin, INPUT);
  _ro = _MQCalibration();
}

// what to do during loop
void SensorMQ::onLoop(Child* child) {
  // calculate rs/ro
  float mq = _MQRead()/_ro;
  // calculate the ppm
  float lpg = _MQGetGasPercentage(mq,_gas_lpg);
  float co = _MQGetGasPercentage(mq,_gas_co);
  float smoke = _MQGetGasPercentage(mq,_gas_smoke);
  // assign to the value the requested gas
  uint16_t value;
  if (_target_gas == _gas_lpg) value = lpg;
  if (_target_gas == _gas_co) value = co;
  if (_target_gas == _gas_smoke) value = smoke;
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" V="));
    Serial.print(value);
    Serial.print(F(" LPG="));
    Serial.print(lpg);
    Serial.print(F(" CO="));
    Serial.print(co);
    Serial.print(F(" SMOKE="));
    Serial.println(smoke);
  #endif
  // store the value
  ((ChildInt*)child)->setValueInt((int16_t)ceil(value));
}

// what to do as the main task when receiving a message
void SensorMQ::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}

// returns the calculated sensor resistance
float SensorMQ::_MQResistanceCalculation(int raw_adc) {
  return ( ((float)_rl_value*(1023-raw_adc)/raw_adc));
}

//  This function assumes that the sensor is in clean air
float SensorMQ::_MQCalibration() {
  int i;
  float val=0;
  //take multiple samples
  for (i=0; i< _calibration_sample_times; i++) {  
    val += _MQResistanceCalculation(analogRead(_pin));
    wait(_calibration_sample_interval);
  }
  //calculate the average value
  val = val/_calibration_sample_times;                   
  //divided by RO_CLEAN_AIR_FACTOR yields the Ro
  val = val/_ro_clean_air_factor;
  //according to the chart in the datasheet
  return val;
}

// This function use MQResistanceCalculation to caculate the sensor resistenc (Rs).
float SensorMQ::_MQRead() {
  int i;
  float rs=0;
  for (i=0; i<_read_sample_times; i++) {
    rs += _MQResistanceCalculation(analogRead(_pin));
    wait(_read_sample_interval);
  }
  rs = rs/_read_sample_times;
  return rs;
}

// This function passes different curves to the MQGetPercentage function which calculates the ppm (parts per million) of the target gas.
int SensorMQ::_MQGetGasPercentage(float rs_ro_ratio, int gas_id) {
  if ( gas_id == _gas_lpg ) {
    return _MQGetPercentage(rs_ro_ratio,_LPGCurve);
  } else if ( gas_id == _gas_co) {
    return _MQGetPercentage(rs_ro_ratio,_COCurve);
  } else if ( gas_id == _gas_smoke) {
    return _MQGetPercentage(rs_ro_ratio,_SmokeCurve);
  }
  return 0;
}

// returns ppm of the target gas
int SensorMQ::_MQGetPercentage(float rs_ro_ratio, float *pcurve) {
  return (pow(10,( ((log10(rs_ro_ratio)-pcurve[1])/pcurve[2]) + pcurve[0])));
}
#endif



/*
   SensorMHZ19
*/
#ifdef USE_MHZ19
// contructor
SensorMHZ19::SensorMHZ19(NodeManager& node_manager, int rxpin, int txpin, int child_id): Sensor(node_manager, rxpin) {
  _name = "MHZ19";
  _rx_pin = rxpin;
  _tx_pin = txpin;
  children.allocateBlocks(1);
  new ChildInt(this,_node->getAvailableChildId(child_id),S_AIR_QUALITY,V_LEVEL,_name);
}

// what to do during setup
void SensorMHZ19::onSetup() {
  _ser = new SoftwareSerial(_rx_pin, _tx_pin);
  _ser->begin(9600);
  delay(2000);
  // clear CO2 buffer
  while (_ser->read()!=-1) {};  
}

// what to do during loop
void SensorMHZ19::onLoop(Child* child) {
  // Read the ppm value
  int co2ppm = _readCO2(); 
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" ppm="));
    Serial.println(co2ppm);
  #endif
  // store the value
  ((ChildInt*)child)->setValueInt(co2ppm);
}


// what to do as the main task when receiving a message
void SensorMHZ19::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}

// Read out the CO2 data
int SensorMHZ19::_readCO2() {
  while (_ser->read() != -1) {};  //clear serial buffer
  unsigned char response[9]; // for answer
  byte cmd[9] = {0xFF, 0x01, 0x86, 0x00, 0x00, 0x00, 0x00, 0x00, 0x79};
  // Command to ask for data.
  _ser->write(cmd, 9); //request PPM CO2
  // Then for 1 second listen for 9 bytes of data.
  _ser->readBytes(response, 9);
  #ifdef NODEMANAGER_DEBUG
  for (int i=0; i<9; i++) {
    Serial.print(response[i], HEX);
    Serial.print(F("-"));
  }
  Serial.println(F("END"));
  #endif
  if (response[0] != 0xFF) {
    Serial.println(F("ERR byte"));
    return -1;
  }
  if (response[1] != 0x86) {
    Serial.println(F("ERR command"));
    return -1;
  }
  int responseHigh = (int) response[2];
  int responseLow = (int) response[3];
  int ppm = (256 * responseHigh) + responseLow;
  return ppm;
}

#endif

/*
   SensorAM2320
*/
#ifdef USE_AM2320
// constructor
SensorAM2320::SensorAM2320(NodeManager& node_manager, int child_id): Sensor(node_manager) {
  _name = "AM2320";
  children.allocateBlocks(2);
  new ChildFloat(this,_node->getAvailableChildId(child_id),S_TEMP,V_TEMP,_name);
  new ChildFloat(this,_node->getAvailableChildId(child_id+1),S_HUM,V_HUM,_name);
}

// what do to during setup
void SensorAM2320::onSetup() {
  _th = new AM2320();
}

// what do to during loop
void SensorAM2320::onLoop(Child* child) {
  // read data from the sensor
  int status = _th->Read();
  if (status != 0) return;
  // temperature sensor
  if (child->type == V_TEMP) {
    float temperature = _th->t;
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" T="));
      Serial.println(temperature);
    #endif
    // store the value
    if (! isnan(temperature)) ((ChildFloat*)child)->setValueFloat(temperature);
  }
  // Humidity Sensor
  else if (child->type == V_HUM) {
    // read humidity
    float humidity = _th->h;
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" T="));
      Serial.println(humidity);
    #endif
    // store the value
    if (! isnan(humidity)) ((ChildFloat*)child)->setValueFloat(humidity);
  }
}

// what do to as the main task when receiving a message
void SensorAM2320::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}
#endif

/*
   SensorTSL2561
*/
#ifdef USE_TSL2561
// contructor
SensorTSL2561::SensorTSL2561(NodeManager& node_manager, int child_id): Sensor(node_manager) {
  _name = "TSL2561";
  children.allocateBlocks(1);
  new ChildInt(this,_node->getAvailableChildId(child_id),S_LIGHT_LEVEL,V_LEVEL,_name);
}

// setter/getter
void SensorTSL2561::setGain(int value) {
  _tsl_gain = value;
}
void SensorTSL2561::setTiming(int value) {
  _tsl_timing = value;
}
void SensorTSL2561::setSpectrum(int value) {
  _tsl_spectrum = value;
}
void SensorTSL2561::setAddress(int value) {
  _tsl_address = value;
}

// what do to during setup
void SensorTSL2561::onSetup() {
   switch (_tsl_address) {
    case SensorTSL2561::ADDR_FLOAT:
      _tsl = new TSL2561(TSL2561_ADDR_FLOAT);
      break;
    case SensorTSL2561::ADDR_LOW:
      _tsl = new TSL2561(TSL2561_ADDR_LOW);
      break;   
    case SensorTSL2561::ADDR_HIGH:
      _tsl = new TSL2561(TSL2561_ADDR_HIGH);
      break;   
  }
  if (_tsl->begin()) {
    switch (_tsl_gain) {
      case SensorTSL2561::GAIN_0X:
        _tsl->setGain(TSL2561_GAIN_0X);
        break; 
      case SensorTSL2561::GAIN_16X:
        _tsl->setGain(TSL2561_GAIN_16X);
        break;      
    }
    switch (_tsl_timing) {
      case SensorTSL2561::INTEGRATIONTIME_13MS:
        _tsl->setTiming(TSL2561_INTEGRATIONTIME_13MS);
        break; 
      case SensorTSL2561::INTEGRATIONTIME_101MS:
        _tsl->setTiming(TSL2561_INTEGRATIONTIME_101MS); 
        break; 
      case SensorTSL2561::INTEGRATIONTIME_402MS:
        _tsl->setTiming(TSL2561_INTEGRATIONTIME_402MS); 
        break;
    }
  }
  else {
    #ifdef NODEMANAGER_DEBUG
      Serial.println(F("ERROR"));
    #endif
  } 
}

// what do to during loop
void SensorTSL2561::onLoop(Child* child) {
  // request the light level
   switch (_tsl_spectrum) {
    case SensorTSL2561::VISIBLE:
      ((ChildInt*)child)->setValueInt(_tsl->getLuminosity(TSL2561_VISIBLE));
      break; 
    case SensorTSL2561::FULLSPECTRUM:
      ((ChildInt*)child)->setValueInt(_tsl->getLuminosity(TSL2561_FULLSPECTRUM));
      break; 
    case SensorTSL2561::INFRARED:
      ((ChildInt*)child)->setValueInt(_tsl->getLuminosity(TSL2561_INFRARED));
      break; 
    case SensorTSL2561::FULL:
      // request the full light level
      uint32_t lum = _tsl->getFullLuminosity(); 
      uint16_t ir, full;
      ir = lum >> 16;
      full = lum & 0xFFFF;
      ((ChildInt*)child)->setValueInt(_tsl->calculateLux(full, ir));
      #ifdef NODEMANAGER_DEBUG
        Serial.print(_name);
        Serial.print(F(" I="));
        Serial.print(child->child_id);
        Serial.print(F(" LUX="));
        Serial.print(((ChildInt*)child)->getValueInt());
        Serial.print(F(" IR="));
        Serial.print(ir);
        Serial.print(F(" FULL="));
        Serial.print(full);
        Serial.print(F(" VIS="));
        Serial.println(full-ir);
      #endif
      break; 
  }
  #ifdef NODEMANAGER_DEBUG
    if (_tsl_spectrum < 3) {
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" L="));
      Serial.println(((ChildInt*)child)->getValueInt());
    }
  #endif
}

// what do to as the main task when receiving a message
void SensorTSL2561::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}
#endif

/*
   SensorPT100
*/
#ifdef USE_PT100
// contructor
SensorPT100::SensorPT100(NodeManager& node_manager, int pin, int child_id): Sensor(node_manager, pin) {
  _name = "PT100";
  children.allocateBlocks(1);
  new ChildFloat(this,_node->getAvailableChildId(child_id),S_TEMP,V_TEMP,_name);
}

// setter/getter
void SensorPT100::setVoltageRef(float value) {
   _voltageRef = value;
}

// what to do during setup
void SensorPT100::onSetup() {
  _PT100 = new DFRobotHighTemperature(_voltageRef); 
  // set the pin as input
  pinMode(_pin, INPUT);

}

// what to do during loop
void SensorPT100::onLoop(Child* child) {
  // read the PT100 sensor
  int temperature = _PT100->readTemperature(_pin);  
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" T="));
    Serial.println(temperature);
  #endif
  // store the value
  if (! isnan(temperature)) ((ChildFloat*)child)->setValueFloat(temperature);
}

// what to do as the main task when receiving a message
void SensorPT100::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}
#endif

/*
   SensorDimmer
*/

#ifdef USE_DIMMER
// contructor
SensorDimmer::SensorDimmer(NodeManager& node_manager, int pin, int child_id): Sensor(node_manager, pin) {
  _name = "DIMMER";
  children.allocateBlocks(1);
  new ChildInt(this,_node->getAvailableChildId(child_id),S_DIMMER,V_PERCENTAGE,_name);
}

// setter/getter
void SensorDimmer::setEasing(int value) {
  _easing = value;
}
void SensorDimmer::setDuration(int value) {
  _duration = value*1000;
}
void SensorDimmer::setStepDuration(int value) {
  _duration = value;
}

// what to do during setup
void SensorDimmer::onSetup() {
  pinMode(_pin, OUTPUT);
}

// what to do during loop
void SensorDimmer::onLoop(Child* child) {
}

// what to do as the main task when receiving a message
void SensorDimmer::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_SET && message->type == child->type) {
    int percentage = message->getInt();
    // normalize the provided percentage
    if (percentage < 0) percentage = 0;
    if (percentage > 100) percentage = 100;
    _fadeTo(child,percentage);
    ((ChildInt*)child)->setValueInt(_percentage);
  }
  if (message->getCommand() == C_REQ) {
    // return the current status
    ((ChildInt*)child)->setValueInt(_percentage);
  }
}

// fade to the provided value
void SensorDimmer::_fadeTo(Child* child, int target_percentage) {
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" V="));
    Serial.println(target_percentage);
  #endif
  // count how many steps we need to do
  int steps = _duration / _step_duration;
  // for each step
  for (int current_step = 1; current_step <= steps; current_step++) {
    // calculate the delta between the target value and the current
    int delta = target_percentage - _percentage;
    // calculate the smooth transition and adjust it in the 0-255 range
    int value_to_write = (int)(_getEasing(current_step,_percentage,delta,steps) / 100. * 255);
    // write to the PWM output
    analogWrite(_pin,value_to_write);
    // wait at the end of this step
    wait(_step_duration);
  }
  _percentage = target_percentage;
}

// for smooth transitions. t: current time, b: beginning value, c: change in value, d: duration
float SensorDimmer::_getEasing(float t, float b, float c, float d) {
  if (_easing == EASE_INSINE) return -c * cos(t/d * (M_PI/2)) + c + b;
  else if (_easing == EASE_OUTSINE) return c * sin(t/d * (M_PI/2)) + b;
  else if (_easing == EASE_INOUTSINE) return -c/2 * (cos(M_PI*t/d) - 1) + b;
  else return c*t/d + b;
}
#endif

/*
   SensorPulseMeter
*/
#ifdef USE_PULSE_METER
// contructor
SensorPulseMeter::SensorPulseMeter(NodeManager& node_manager, int pin, int child_id): Sensor(node_manager, pin) {
  _name = "PULSE";
}

// setter/getter
void SensorPulseMeter::setPulseFactor(float value) {
  _pulse_factor = value;
}
void SensorPulseMeter::setInitialValue(int value) {
  _initial_value = value;
}
void SensorPulseMeter::setInterruptMode(int value) {
  _interrupt_mode = value;
}

// what to do during setup
void SensorPulseMeter::onSetup() {
  // configure the interrupt pin so onInterrupt() will be called on tip
  setInterrupt(_pin,_interrupt_mode,_initial_value);
}

// what to do during loop
void SensorPulseMeter::onLoop(Child* child) {
  // do not report anything if called by an interrupt
  if (_node->getLastInterruptPin() == _interrupt_pin) return;
  // time to report the accumulated value so far
  _reportTotal(child);
  // reset the counter
  _count = 0;
}

// what to do as the main task when receiving a message
void SensorPulseMeter::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) {
    // report the total the last period
    _reportTotal(child);
  }
}

// what to do when receiving an interrupt
void SensorPulseMeter::onInterrupt() {
  // increase the counter
  _count++;
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.println(F("+"));
  #endif
}

// return the total based on the pulses counted
void SensorPulseMeter::_reportTotal(Child* child) {
  ((ChildFloat*)child)->setValueFloat(_count / _pulse_factor);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" V="));
    Serial.println(((ChildFloat*)child)->getValueFloat());
  #endif
}

/*
   SensorRainGauge
*/
// contructor
SensorRainGauge::SensorRainGauge(NodeManager& node_manager, int pin, int child_id): SensorPulseMeter(node_manager, pin, child_id) {
  _name = "RAIN_GAUGE";
  children.allocateBlocks(1);
  new ChildFloat(this,_node->getAvailableChildId(child_id),S_RAIN,V_RAIN,_name);
  setPulseFactor(9.09);
}

/*
   SensorPowerMeter
*/
// contructor
SensorPowerMeter::SensorPowerMeter(NodeManager& node_manager, int pin, int child_id): SensorPulseMeter(node_manager, pin, child_id) {
  _name = "POWER";
  children.allocateBlocks(1);
  new ChildDouble(this,_node->getAvailableChildId(child_id),S_POWER,V_KWH,_name);
  setPulseFactor(1000);
}

// return the total based on the pulses counted
void SensorPowerMeter::_reportTotal(Child* child) {
  ((ChildDouble*)child)->setValueDouble(_count / _pulse_factor);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" V="));
    Serial.println(((ChildDouble*)child)->getValueDouble());
    Serial.println(_count);
  #endif
}

/*
   SensorWaterMeter
*/
// contructor
SensorWaterMeter::SensorWaterMeter(NodeManager& node_manager, int pin, int child_id): SensorPulseMeter(node_manager, pin, child_id) {
  _name = "WATER";
  children.allocateBlocks(1);
  new ChildDouble(this,_node->getAvailableChildId(child_id),S_WATER,V_VOLUME,_name);
  setPulseFactor(1000);
}

// return the total based on the pulses counted
void SensorWaterMeter::_reportTotal(Child* child) {
  ((ChildDouble*)child)->setValueDouble(_count / _pulse_factor);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" V="));
    Serial.println(((ChildDouble*)child)->getValueDouble());
  #endif
}
#endif

/*
   SensorPlantowerPMS
*/
#ifdef USE_PMS
// contructor
SensorPlantowerPMS::SensorPlantowerPMS(NodeManager& node_manager, int rxpin, int txpin, int child_id): Sensor(node_manager, rxpin) {
  _name = "PMS";
  _rx_pin = rxpin;
  _tx_pin = txpin;
  children.allocateBlocks(3);
  // register the child
  new ChildInt(this, _node->getAvailableChildId(child_id), S_DUST, V_LEVEL, "PM1.0");
  new ChildInt(this, _node->getAvailableChildId(child_id+1), S_DUST, V_LEVEL, "PM2.5");
  new ChildInt(this, _node->getAvailableChildId(child_id+2), S_DUST, V_LEVEL, "PM10.0");
}

// what to do during setup
void SensorPlantowerPMS::onSetup() {
  _ser = new SoftwareSerial(_rx_pin, _tx_pin);
  _pms = new PMS(*_ser);
  _ser->begin(9600);
}

// what to do during loop
void SensorPlantowerPMS::onLoop(Child* child) {
  if (child == children.get(1)) {
    _valuesRead = false;
    _valuesReadError = false;
  }
  // Read the ppm values
  if (!_valuesRead || _valuesReadError) {
    _valuesReadError = !_pms->read(_data, 1000);
    if (_valuesReadError) {
      Serial.println(F("ERR PMS read"));
      return;
    }
    _valuesRead = true;
  }
  int val = 0;
  if (child == children.get(1)) {
    // PM1.0 values
    val = _data.PM_AE_UG_1_0;
  } else if (child == children.get(2)) {
    // PM 2.5 values
    val = _data.PM_AE_UG_2_5;
  } else if (child == children.get(3)) {
    // PM 10.0 values
    val = _data.PM_AE_UG_10_0;
  } else {
    Serial.println(F("ERR child"));
    return;
  }
  // store the value
  ((ChildInt*)child)->setValueInt(val);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" µg/m³="));
    Serial.println(val);
  #endif
}

// what to do as the main task when receiving a message
void SensorPlantowerPMS::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}
#endif

/*
 * VL53L0X Laser distance sensor
 */
#ifdef USE_VL53L0X
// constructor
SensorVL53L0X::SensorVL53L0X(NodeManager& node_manager, int xshut_pin, int child_id): Sensor(node_manager, xshut_pin) {
  _name = "VL53L0X";
  children.allocateBlocks(1);
  new ChildInt(this, _node->getAvailableChildId(child_id), S_DISTANCE, V_DISTANCE,_name);
}

// what to do during setup
void SensorVL53L0X::onSetup() {
  if (_pin > 0) {
    pinMode(_pin, OUTPUT); // Put sensor in deep sleep until the loop
    digitalWrite(_pin, LOW);
  }
  _lox = new VL53L0X();
  if (_lox) {
    Wire.begin();
  }
}

// what to do during loop
void SensorVL53L0X::onLoop(Child *child) {
  int val = _getDistance();
  ((ChildInt*)child)->setValueInt(val);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" D="));
    if (val>=0) {
      Serial.print(val);
      Serial.println(F("mm"));
    } else {
      Serial.println(F("OOR"));
    }
  #endif
}

// what to do as the main task when receiving a message
void SensorVL53L0X::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}

// measure the distance
int SensorVL53L0X::_getDistance() {
  int distance = -1;
  if (_lox) {
    // The XSHUT pin puts the sensor into deep sleep when pulled to LOW;
    // To wake up, do NOT write HIGH (=3.3V or 5V) to the pin, as the sensor
    // uses only 2.8V and is not 5V-tolerant. Instead, set the pin to INPUT.
    if (_pin >= 0) {
      pinMode(_pin, INPUT);
      sleep(5); // Transition from HW standby to SW standby might take up to 1.5 ms => use 5ms to be on the safe side
    }
    _lox->init();
    _lox->setTimeout(500);
    distance = _lox->readRangeSingleMillimeters();
    if (_pin >= 0) {
      digitalWrite(_pin, LOW);
      pinMode(_pin, OUTPUT);
    }
  }
  //  if (measure.RangeStatus == 0) {  // only 0  data
  if (_lox->timeoutOccurred()) {
    distance = -1;
  }
  return distance;
}
#endif

/*
 * Display
 */
#if defined(USE_SSD1306) || defined(USE_HD44780)
// constructor
Display::Display(NodeManager& node_manager, int child_id): Sensor(node_manager) {
  _name = "";
  // We don't need any sensors, but we need a child, otherwise the loop will never be executed
  children.allocateBlocks(1);
  new ChildString(this, _node->getAvailableChildId(child_id), S_INFO, V_TEXT,_name);
}
// setter/getter
void Display::setCaption(const char* value) {
  _caption = value;
}

// what to do during setup
void Display::onSetup() {
}

// display specific function. Subclassess have to implement
void Display::printCaption(const char* value) {}
void Display::print(const char* value) {}
void Display::println(const char* value) {}
void Display::printChild(Child* child) {}
void Display::clear() {}
void Display::setCursor(int col,int row) {}

// what to do during loop
void Display::onLoop(Child*child) {
  // clear the screen
  clear();  
  // print caption
  printCaption(_caption);
  // cycle through all the sensors and children
  for (List<Sensor*>::iterator itr = _node->sensors.begin(); itr != _node->sensors.end(); ++itr) {
    Sensor* sensor = *itr;
    // skip this display sensor
    if (sensor == this) continue;
    // Loop through all children and show name, value (and type)
    for (List<Child*>::iterator chitr = sensor->children.begin(); chitr != sensor->children.end(); ++chitr) {
      Child* ch = *chitr;
      // print description if any
      if (strlen(ch->description) > 0) {
        print(ch->description);
        print(": ");
      }
      // print value
      printChild(ch);
      // print type
      if (ch->type == V_TEMP) {
        if (_node->getIsMetric()) print("C");
        else print("F");
      }
      else if (ch->type == V_HUM || ch->type == V_PERCENTAGE) print("%");
      else if (ch->type == V_PRESSURE) print("Pa");
      else if (ch->type == V_WIND || ch->type == V_GUST) print("Km/h");
      else if (ch->type == V_VOLTAGE) print("V");
      else if (ch->type == V_CURRENT) print("A");
      else if (ch->type == V_LEVEL && ch->presentation == S_SOUND) print("dB");
      else if (ch->type == V_LIGHT_LEVEL && ch->presentation == S_LIGHT_LEVEL) print("%");
      else if (ch->type == V_RAINRATE) print("%");
      else if (ch->type == V_LEVEL && ch->presentation == S_MOISTURE) print("%");
      println(nullptr);
    }
  }
}

// what to do as the main task when receiving a message
void Display::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_SET && message->type == child->type) {
    int text_start = 0;
    // if the string contains a "," at the second position, it means the first char is the row number
    if (strncmp(message->getString()+1,",",1) == 0) {
      setCursor(0,atoi(message->getString()));
      // text starts at position 2
      text_start = 2;
    }
    // print the received text
    print(message->getString()+text_start);
  }
}
#endif

/*
 * DisplaySSD1306 OLED displays (I²C)
 */
#ifdef USE_SSD1306
// constructor
DisplaySSD1306::DisplaySSD1306(NodeManager& node_manager, int child_id): Display(node_manager, child_id) {
  _name = "SSD1306";
  children.get(1)->description = _name;
}

// setter/getter
void DisplaySSD1306::setDev(const DevType* dev) {
  _dev = dev;
}
void DisplaySSD1306::setI2CAddress(uint8_t i2caddress) {
  _i2caddress = i2caddress;
}
// [101] set text font (default: Adafruit5x7)
void DisplaySSD1306::setFont(const uint8_t* value) {
  _font = value;
}
// [102] set the contrast of the display
void DisplaySSD1306::setContrast(uint8_t value) {
  _contrast = value;
}
// [104] Rotate the display 180 degree
void DisplaySSD1306::rotateDisplay(bool rotate) {
  if (rotate) {
    _oled->ssd1306WriteCmd(SSD1306_SEGREMAP);
    _oled->ssd1306WriteCmd(SSD1306_COMSCANINC);
  } else {
    _oled->ssd1306WriteCmd(SSD1306_SEGREMAP | 0x01);
    _oled->ssd1306WriteCmd(SSD1306_COMSCANDEC);
  }
}
// [105] Text font size (possible are 1 and 2; default is 1)
void DisplaySSD1306::setFontSize(int fontsize) {
  _fontsize = (fontsize>=2) ? 2 : 1;
}
// [106] Text caption font size (possible are 1 and 2; default is 2)
void DisplaySSD1306::setCaptionFontSize(int fontsize) {
  _caption_fontsize = (fontsize>=2) ? 2 : 1;
}
// [107] Invert display (black text on color background)
void DisplaySSD1306::invertDisplay(bool invert) {
  if (invert) {
    _oled->ssd1306WriteCmd(SSD1306_INVERTDISPLAY);
  } else {
    _oled->ssd1306WriteCmd(SSD1306_NORMALDISPLAY);
  }
}

// display specific function
void DisplaySSD1306::printCaption(const char* value) {
  // set caption font size
  if (_caption_fontsize >= 2) _oled->set2X();
  // print caption
  print(value);
  _oled->println();
  // if using a small font add an empty line
  if (_caption_fontsize == 1) _oled->println();
  // restore small font
  _oled->set1X();
}

void DisplaySSD1306::print(const char* value) {
  // set the font size
  if (_fontsize >= 2 && _oled->magFactor() != 2) _oled->set2X();
  // print the string
  _oled->print(value);
  _oled->clearToEOL();
}

void DisplaySSD1306::println(const char* value) {
  if (value != nullptr) print(value);
  _oled->println();
}

void DisplaySSD1306::printChild(Child* child) {
  child->printOn(*_oled);
}

void DisplaySSD1306::clear() {
  _oled->clear();
}

void DisplaySSD1306::setCursor(int col,int row) {
  _oled->setCursor(col,row);
}

// what to do during setup
void DisplaySSD1306::onSetup() {
  _oled = new SSD1306AsciiAvrI2c();
  _oled->begin(_dev, _i2caddress);
  _oled->setFont(_font);
  if (_contrast > -1) _oled->setContrast(_contrast);
  clear();
}
#endif

/*
   SensorSHT31
*/
#ifdef USE_SHT31
// contructor
SensorSHT31::SensorSHT31(NodeManager& node_manager, int child_id): Sensor(node_manager) {
  _name = "SHT31";
  children.allocateBlocks(2);
  new ChildFloat(this,_node->getAvailableChildId(child_id),S_TEMP,V_TEMP,_name);
  new ChildFloat(this,_node->getAvailableChildId(child_id+1),S_HUM,V_HUM,_name);
}

// what to do during setup
void SensorSHT31::onSetup() {
  _sht31 = new Adafruit_SHT31();
  // Set to 0x45 for alternate i2c addr
  _sht31->begin(0x44); 
}

// what to do during loop
void SensorSHT31::onLoop(Child* child) {
  // temperature sensor
  if (child->type == V_TEMP) {
    // read the temperature
    float temperature = _sht31->readTemperature();
    // convert it
    temperature = _node->celsiusToFahrenheit(temperature);
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" T="));
      Serial.println(temperature);
    #endif
    // store the value
    if (! isnan(temperature)) ((ChildFloat*)child)->setValueFloat(temperature);
  }
  // Humidity Sensor
  else if (child->type == V_HUM) {
    // read humidity
    float humidity = _sht31->readHumidity();
    if (isnan(humidity)) return;
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" H="));
      Serial.println(humidity);
    #endif
    // store the value
   if (! isnan(humidity)) ((ChildFloat*)child)->setValueFloat(humidity);
  }
}

// what to do as the main task when receiving a message
void SensorSHT31::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}
#endif

/*
   SensorSI7021
*/
#ifdef USE_SI7021
// contructor
SensorSI7021::SensorSI7021(NodeManager& node_manager, int child_id): Sensor(node_manager) {
  _name = "SI7021";
  children.allocateBlocks(2);
  new ChildFloat(this,_node->getAvailableChildId(child_id),S_TEMP,V_TEMP,_name);
  new ChildFloat(this,_node->getAvailableChildId(child_id+1),S_HUM,V_HUM,_name);
}

// what to do during setup
void SensorSI7021::onSetup() {
  _si7021 = new Weather();
  _si7021->begin();
}

// what to do during loop
void SensorSI7021::onLoop(Child* child) {
  // temperature sensor
  if (child->type == V_TEMP) {
    // read the temperature
    float temperature = _si7021->getTemp();
    // convert it
    temperature = _node->celsiusToFahrenheit(temperature);
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" T="));
      Serial.println(temperature);
    #endif
    // store the value
    if (! isnan(temperature)) ((ChildFloat*)child)->setValueFloat(temperature);
  }
  // Humidity Sensor
  else if (child->type == V_HUM) {
    // read humidity
    float humidity = _si7021->getRH();
    if (isnan(humidity)) return;
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" H="));
      Serial.println(humidity);
    #endif
    // store the value
   if (! isnan(humidity)) ((ChildFloat*)child)->setValueFloat(humidity);
  }
}

// what to do as the main task when receiving a message
void SensorSI7021::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}
#endif

/*
   SensorChirp
*/
#ifdef USE_CHIRP
// contructor
SensorChirp::SensorChirp(NodeManager& node_manager, int child_id): Sensor(node_manager) {
  _name = "CHIRP";
  children.allocateBlocks(3);
  new ChildFloat(this,_node->getAvailableChildId(child_id),S_HUM,V_HUM,_name);
  new ChildFloat(this,_node->getAvailableChildId(child_id+1),S_TEMP,V_TEMP,_name);
  new ChildFloat(this,_node->getAvailableChildId(child_id+2),S_LIGHT_LEVEL,V_LIGHT_LEVEL,_name);
}
// setter/getter
void SensorChirp::setMoistureOffset(int value) {
  _chirp_moistureoffset = value;
}
void SensorChirp::setMoistureRange(int value) {
  _chirp_moisturerange = value;
}
void SensorChirp::setReturnMoistureNormalized(bool value) {
  _chirp_moisturenormalized = value;  
} 
void SensorChirp::setReturnLightReversed(bool value) {
  _chirp_lightreversed = value;  
} 

// what to do during setup
void SensorChirp::onSetup() {
  // initialize the library
  Wire.begin();
  _chirp->begin();
  wait(1000);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(" A=");
    Serial.print(_chirp->getAddress(),HEX);
    Serial.print(" F=");
    Serial.println(_chirp->getVersion(),HEX);
  #endif
}

// what to do during loop
void SensorChirp::onLoop(Child* child) {
  while (_chirp->isBusy()) wait(50);
  // temperature sensor
  if (child->type == V_TEMP) {
    // read the temperature
    float temperature = _chirp->getTemperature()/(float)10;
    // convert it
    temperature = _node->celsiusToFahrenheit(temperature);
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" T="));
      Serial.println(temperature);
    #endif
    // store the value
    if (! isnan(temperature)) ((ChildFloat*)child)->setValueFloat(temperature);
  }
  // Humidity Sensor
  else if (child->type == V_HUM) {
    // request the SoilMoisturelevel
    float capacitance = _chirp->getCapacitance();
    float capacitance_orig = capacitance;
    float cap_offsetfree = capacitance - _chirp_moistureoffset;
    if (cap_offsetfree < 0) cap_offsetfree = 0;
    if (_chirp_moisturenormalized == true && _chirp_moistureoffset > 0 && _chirp_moisturerange > 0) {
      capacitance = ((cap_offsetfree/_chirp_moisturerange)*100);
      if (capacitance > 100) { capacitance = 100; }
      int tmp_cap = (int)(capacitance+0.5);
      capacitance = (float)tmp_cap;
    }    
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" H="));
      Serial.println(capacitance);
    #endif
    // store the value
   if (! isnan(capacitance)) ((ChildFloat*)child)->setValueFloat(capacitance);
  }
  else if (child->type == V_LIGHT_LEVEL) {
    // read light
    float light = _chirp->getLight(true);
    if ( _chirp_lightreversed ) light = 65535 - light;
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" L="));
      Serial.println(light);
    #endif
    // store the value
   if (! isnan(light)) ((ChildFloat*)child)->setValueFloat(light);
  }
}

// what to do as the main task when receiving a message
void SensorChirp::onReceive(MyMessage* message) {
}
#endif

/*
 * Hitachi HD44780 display
 */
#ifdef USE_HD44780
// constructor
DisplayHD44780::DisplayHD44780(NodeManager& node_manager, int child_id): Display(node_manager, child_id) {
  _name = "HD44780";
  children.get(1)->description = _name;
}

// setter/getter
void DisplayHD44780::setI2CAddress(uint8_t i2caddress) {
  _i2caddress = i2caddress;
}
void DisplayHD44780::setBacklight(uint8_t value) {
  _lcd->setBacklight(value);
}

// display specific function
void DisplayHD44780::printCaption(const char* value) {
  if (strlen(value) > 0) println(value);
}

void DisplayHD44780::print(const char* value) {
  // print the string
  _lcd->print(value);
}

void DisplayHD44780::println(const char* value) {
  if (value != nullptr) print(value);
  _column = _column + 1;
  setCursor(0,_column);
}

void DisplayHD44780::printChild(Child* child) {
  child->printOn(*_lcd);
}

void DisplayHD44780::clear() {
  _column = 0;
  _lcd->clear();
}

void DisplayHD44780::setCursor(int col,int row) {
  _lcd->setCursor(col,row);
}

// what to do during setup
void DisplayHD44780::onSetup() {
  _lcd = new LiquidCrystal_I2C(_i2caddress, 2, 1, 0, 4, 5, 6, 7, 3, POSITIVE);
  _lcd->begin(16,2);
  _lcd->home();
  clear();
}
#endif

/*
   SensorTTP
*/
#ifdef USE_TTP
// contructor
SensorTTP::SensorTTP(NodeManager& node_manager, int child_id): Sensor(node_manager) {
  _name = "TTP";
  children.allocateBlocks(1);
  new ChildInt(this,_node->getAvailableChildId(child_id),S_INFO,V_TEXT,_name);
}
// setter/getter
void SensorTTP::setPasscodeLength(int value) {
  _passcode_length = value;
}
void SensorTTP::setClockPin(int value) {
  _clock_pin = value;
}
void SensorTTP::setSdoPin(int value) {
  _sdo_pin = value;
}
void SensorTTP::setDvPin(int value) {
  _dv_pin = value;
}
void SensorTTP::setRstPin(int value) {
  _rst_pin = value;
}

// what to do during setup
void SensorTTP::onSetup() {
  // setup passcode array  
  _passcode.allocateBlocks(_passcode_length);
  // initialize pins
  pinMode(_dv_pin, INPUT);
  pinMode(_sdo_pin, INPUT);
  pinMode(_rst_pin, OUTPUT); 
  pinMode(_clock_pin, OUTPUT);
  // set the interrupt on the DV pin
  setInterrupt(_dv_pin,RISING,LOW);
  // report immediately
  _report_timer->unset();
  digitalWrite(_rst_pin, LOW);
}

// what to do during loop
void SensorTTP::onLoop(Child* child) {
}

// what to do when receiving an interrupt
void SensorTTP::onInterrupt() {
  Child* child = children.get(1);
  // fetch the key pressed from the keypad
  int value = _fetchData();
  // invalid value, return
  if (value == 0) return;
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" D="));
    Serial.println(value);
  #endif
  // add the value to the passcode array
  _passcode.push(value);
  Serial.println(_passcode.size());
  // time to send the passcode back
  if (_passcode.size() == _passcode_length) {
    int passcode = 0;
    // build up the passcode
    for (int i = 1; i <= _passcode.size(); i++) {
      passcode *= 10;
      passcode += (int) _passcode.get(i);
    }
    #ifdef NODEMANAGER_DEBUG
      Serial.print(_name);
      Serial.print(F(" I="));
      Serial.print(child->child_id);
      Serial.print(F(" V="));
      Serial.println(passcode);
    #endif
    // store it in the child so it will be sent back 
    ((ChildInt*)child)->setValueInt(passcode);
    // clear the passcode array
    _passcode.clear();
  }
}

// what to do as the main task when receiving a message
void SensorTTP::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_REQ && message->type == child->type) onLoop(child);
}

// fetch data from the keypad
int SensorTTP::_fetchData() {
  int Key = 0;
  int Ziro = 0;
  // Send 8 clock pulses and check each data bit as it arrives
  for(int i = 1; i < 9; i++) {       
    digitalWrite(_clock_pin,1);
    delayMicroseconds(1000);
    // If data bit, high, then that key was pressed.
    if(digitalRead(_sdo_pin) == HIGH)  
      Key=i; 
    else 
      Ziro++;
    digitalWrite(_clock_pin,0);
    // Don't use delay(1) as it will mess up interrupts
    delayMicroseconds(1000);  
  }
  if(Key>0 && Ziro==7) return Key;
  return 0;
}
#endif

/*
 * SensorServo
 */
#ifdef USE_SERVO
// constructor
SensorServo::SensorServo(NodeManager& node_manager, int pin, int child_id): Sensor(node_manager, pin) {
  _name = "SERVO";
  children.allocateBlocks(1);
  new ChildInt(this, _node->getAvailableChildId(child_id), S_DIMMER, V_PERCENTAGE ,_name);
}

// what to do during setup
void SensorServo::onSetup() {
  _servo.attach(_pin);
}

// what to do during loop
void SensorServo::onLoop(Child *child) {
}

// what to do as the main task when receiving a message
void SensorServo::onReceive(MyMessage* message) {
  Child* child = getChild(message->sensor);
  if (child == nullptr) return;
  if (message->getCommand() == C_SET) setPercentage(message->getInt());
  if (message->getCommand() == C_REQ) ((ChildInt*)child)->setValueInt(_value);
}

// set the servo to the given percentage
void SensorServo::setPercentage(int value) {
   _value = value;
  // set the servo to the given value
  _servo.write(map(_value,0,100,0,180));
  // set the value so to send it back
  Child* child = children.get(1);
  if (child == nullptr) return;
  ((ChildInt*)child)->setValueInt(_value);
  #ifdef NODEMANAGER_DEBUG
    Serial.print(_name);
    Serial.print(F(" I="));
    Serial.print(child->child_id);
    Serial.print(F(" P="));
    Serial.print(_pin);
    Serial.print(F(" V="));
    Serial.println(_value);
  #endif
}
#endif

/*
   SensorConfiguration
*/
// contructor
SensorConfiguration::SensorConfiguration(NodeManager& node_manager): Sensor(node_manager) {
  _name = "CONFIG";
}

// what to do during before
void SensorConfiguration::onBefore() {
  new ChildInt(this,CONFIGURATION_CHILD_ID,S_CUSTOM,V_CUSTOM);
}

// what to do during setup
void SensorConfiguration::onSetup() {

}

// what to do during loop
void SensorConfiguration::onLoop(Child* child) {
}

// what to do as the main task when receiving a message
void SensorConfiguration::onReceive(MyMessage* message) {
  // expect a REQ, V_CUSTOM message
  if (message->getCommand() != C_REQ && message->type != V_CUSTOM) return;
  // parse the request
  Request request = Request(message->sensor,message->getString());
  int function = request.getFunction();
  int child_id = request.getChildId();
  // if the message is for the board itself
  if (child_id == 0) {
    switch(function) {
      case 1: _node->hello(); break;
#if FEATURE_SLEEP == ON
      case 3: _node->setSleepSeconds(request.getValueInt()); break;
      case 4: _node->setSleepMinutes(request.getValueInt()); break;
      case 5: _node->setSleepHours(request.getValueInt()); break;
      case 29: _node->setSleepDays(request.getValueInt()); break;
      case 20: _node->setSleepBetweenSend(request.getValueInt()); break;
      case 9: _node->wakeup(); break;
#endif
#ifndef MY_GATEWAY_ESP8266
      case 6: _node->reboot(); return;
#endif
#if FEATURE_EEPROM == ON
      case 7: _node->clearEeprom(); break;
      case 27: _node->saveToMemory(0,request.getValueInt()); break;
      case 40: _node->setSaveSleepSettings(request.getValueInt()); break;
#endif
      case 8: _node->sendMessage(CONFIGURATION_CHILD_ID,V_CUSTOM,VERSION); return;
      case 10: _node->setRetries(request.getValueInt()); break;
#if FEATURE_INTERRUPTS == ON
      case 19: _node->setSleepInterruptPin(request.getValueInt()); break;
      case 28: _node->setInterruptMinDelta(request.getValueInt()); break;
#endif
      case 21: _node->setAck(request.getValueInt()); break;
      case 22: _node->setIsMetric(request.getValueInt()); break;
#if FEATURE_POWER_MANAGER == ON
      case 24: _node->powerOn(); break;
      case 25: _node->powerOff(); break;
#endif
      case 30: _node->setSleepOrWait(request.getValueInt()); break;
      case 31: _node->setRebootPin(request.getValueInt()); break;
      case 32: _node->setADCOff(); break;
      case 36: _node->setReportIntervalSeconds(request.getValueInt()); break;
      case 37: _node->setReportIntervalMinutes(request.getValueInt()); break;
      case 38: _node->setReportIntervalHours(request.getValueInt()); break;
      case 39: _node->setReportIntervalDays(request.getValueInt()); break;
#if FEATURE_TIME == ON
      case 41: _node->syncTime(); break;
      case 42: _node->sendMessage(CONFIGURATION_CHILD_ID,V_CUSTOM,(int)_node->getTime()); return;
#endif
      default: return; 
    }
  // the request is for a sensor
  } else {
    // retrieve the sensor the child is belonging to
    Sensor* sensor = _node->getSensorWithChild(child_id);
    if (sensor == nullptr) return;
    // if the message is for a function common to all the sensors
    if (request.getFunction() < 100) {
      switch(function) {
        case 1: sensor->setPin(request.getValueInt()); break;
        case 5: sensor->setSamples(request.getValueInt()); break;
        case 6: sensor->setSamplesInterval(request.getValueInt()); break;
#if FEATURE_CONDITIONAL_REPORT == ON
        case 7: sensor->setTrackLastValue(request.getValueInt()); break;
        case 9: sensor->setForceUpdateMinutes(request.getValueInt()); break;
#endif
#if FEATURE_POWER_MANAGER == ON
        case 13: sensor->powerOn(); break;
        case 14: sensor->powerOff(); break;
#endif
        case 16: sensor->setReportIntervalMinutes(request.getValueInt()); break;
        case 17: sensor->setReportIntervalSeconds(request.getValueInt()); break;
        case 19: sensor->setReportIntervalHours(request.getValueInt()); break;
        case 20: sensor->setReportIntervalDays(request.getValueInt()); break;
        default: return;
      }
    } else {
      #ifndef MY_GATEWAY_ESP8266
      // the message is for a function specific to a sensor
      if (strcmp(sensor->getName(),"BATTERY") == 0) {
        SensorBattery* custom_sensor = (SensorBattery*)sensor;
        switch(function) {
          case 102: custom_sensor->setMinVoltage(request.getValueFloat()); break;
          case 103: custom_sensor->setMaxVoltage(request.getValueFloat()); break;
          case 104: custom_sensor->setBatteryInternalVcc(request.getValueInt()); break;
          case 105: custom_sensor->setBatteryPin(request.getValueInt()); break;
          case 106: custom_sensor->setBatteryVoltsPerBit(request.getValueFloat()); break;
          default: return;
        }
      }
      #ifdef MY_SIGNAL_REPORT_ENABLED
      if (strcmp(sensor->getName(),"SIGNAL") == 0) {
        SensorSignal* custom_sensor = (SensorSignal*)sensor;
        switch(function) {
          case 101: custom_sensor->setSignalCommand(request.getValueInt()); break;
          default: return;
        }
      }
      #endif
      #endif
      #ifdef USE_ANALOG_INPUT
      if (strcmp(sensor->getName(),"ANALOG_I") == 0 || strcmp(sensor->getName(),"LDR") == 0 || strcmp(sensor->getName(),"RAIN") == 0 || strcmp(sensor->getName(),"SOIL") == 0) {
        SensorAnalogInput* custom_sensor = (SensorAnalogInput*)sensor;
        switch(function) {
          case 101: custom_sensor->setReference(request.getValueInt()); break;
          case 102: custom_sensor->setReverse(request.getValueInt()); break;
          case 103: custom_sensor->setOutputPercentage(request.getValueInt()); break;
          case 104: custom_sensor->setRangeMin(request.getValueInt()); break;
          case 105: custom_sensor->setRangeMax(request.getValueInt()); break;
          default: return;
        }
      }
      #endif
      #ifdef USE_THERMISTOR
      if (strcmp(sensor->getName(),"THERMISTOR") == 0) {
        SensorThermistor* custom_sensor = (SensorThermistor*)sensor;
        switch(function) {
          case 101: custom_sensor->setNominalResistor((long)request.getValueInt()); break;
          case 102: custom_sensor->setNominalTemperature(request.getValueInt()); break;
          case 103: custom_sensor->setBCoefficient(request.getValueInt()); break;
          case 104: custom_sensor->setSeriesResistor((long)request.getValueInt()); break;
          case 105: custom_sensor->setOffset(request.getValueFloat()); break;
          default: return;
        }
      }
      #endif
      #ifdef USE_ACS712
      if (strcmp(sensor->getName(),"ACS712") == 0) {
        SensorACS712* custom_sensor = (SensorACS712*)sensor;
        switch(function) {
          case 100: custom_sensor->setmVPerAmp(request.getValueInt()); break;
          case 102: custom_sensor->setOffset(request.getValueInt()); break;
          default: return;
        }
      }
      #endif
      #ifdef USE_DIGITAL_OUTPUT
      if (strcmp(sensor->getName(),"DIGITAL_O") == 0 || strcmp(sensor->getName(),"RELAY") == 0 || strcmp(sensor->getName(),"LATCHING") == 0) {
        SensorDigitalOutput* custom_sensor = (SensorDigitalOutput*)sensor;
        switch(function) {
            case 103: custom_sensor->setOnValue(request.getValueInt()); break;
            case 104: custom_sensor->setLegacyMode(request.getValueInt()); break;
            case 105: custom_sensor->setSafeguard(request.getValueInt()); break;
            case 106: custom_sensor->setInputIsElapsed(request.getValueInt()); break;
            case 107: custom_sensor->setWaitAfterSet(request.getValueInt()); break;
          default: return;
        }
        if (function > 200 && strcmp(sensor->getName(),"LATCHING") == 0) {
          SensorLatchingRelay* custom_sensor_2 = (SensorLatchingRelay*)sensor;
          switch(function) {
            case 201: custom_sensor_2->setPulseWidth(request.getValueInt()); break;
            case 202: custom_sensor_2->setPinOff(request.getValueInt()); break;
            case 203: custom_sensor_2->setPinOn(request.getValueInt()); break;
            default: return;
          }
        }
      }
      #endif
      #ifdef USE_SWITCH
      if (strcmp(sensor->getName(),"INTERRUPT") == 0 || strcmp(sensor->getName(),"DOOR") == 0 || strcmp(sensor->getName(),"MOTION") == 0) {
        SensorInterrupt* custom_sensor = (SensorInterrupt*)sensor;
        switch(function) {
          case 101: custom_sensor->setMode(request.getValueInt()); break;
          case 102: custom_sensor->setDebounce(request.getValueInt()); break;
          case 103: custom_sensor->setTriggerTime(request.getValueInt()); break;
          case 104: custom_sensor->setInitial(request.getValueInt()); break;
          case 105: custom_sensor->setActiveState(request.getValueInt()); break;
          default: return;
        }
      }
      #endif
      #ifdef USE_DS18B20
      if (strcmp(sensor->getName(),"DS18B20") == 0) {
        SensorDs18b20* custom_sensor = (SensorDs18b20*)sensor;
        switch(function) {
          case 101: custom_sensor->setResolution(request.getValueInt()); break;
          case 102: custom_sensor->setSleepDuringConversion(request.getValueInt()); break;
          default: return;
        }
      }
      #endif
      #ifdef USE_BH1750
      if (strcmp(sensor->getName(),"BH1750") == 0) {
        SensorBH1750* custom_sensor = (SensorBH1750*)sensor;
        switch(function) {
          case 101: custom_sensor->setMode(request.getValueInt()); break;
          default: return;
        }
      }
      #endif
      #if defined(USE_BME280) || defined(USE_BMP085) || defined(USE_BMP280)
      if (strcmp(sensor->getName(),"BMP085") == 0 || strcmp(sensor->getName(),"BME280") == 0 || strcmp(sensor->getName(),"BMP280") == 0) {
        SensorBosch* custom_sensor = (SensorBosch*)sensor;
        switch(function) {
          case 101: custom_sensor->setForecastSamplesCount(request.getValueInt()); break;
          default: return;
        }
      }
      #endif
      #ifdef USE_SONOFF
      if (strcmp(sensor->getName(),"SONOFF") == 0) {
        SensorSonoff* custom_sensor = (SensorSonoff*)sensor;
        switch(function) {
          case 101: custom_sensor->setButtonPin(request.getValueInt()); break;
          case 102: custom_sensor->setRelayPin(request.getValueInt()); break;
          case 103: custom_sensor->setLedPin(request.getValueInt()); break;
          default: return;
        }
      }
      #endif
      #ifdef USE_HCSR04
      if (strcmp(sensor->getName(),"HCSR04") == 0) {
        SensorHCSR04* custom_sensor = (SensorHCSR04*)sensor;
        switch(function) {
          case 101: custom_sensor->setTriggerPin(request.getValueInt()); break;
          case 102: custom_sensor->setEchoPin(request.getValueInt()); break;
          case 103: custom_sensor->setMaxDistance(request.getValueInt()); break;
          default: return;
        }
      }
      #endif
      #ifdef USE_MQ
      if (strcmp(sensor->getName(),"MQ") == 0) {
        SensorMQ* custom_sensor = (SensorMQ*)sensor;
        switch(function) {
          case 101: custom_sensor->setTargetGas(request.getValueInt()); break;
          case 102: custom_sensor->setRlValue(request.getValueFloat()); break;
          case 103: custom_sensor->setRoValue(request.getValueFloat()); break;
          case 104: custom_sensor->setCleanAirFactor(request.getValueFloat()); break;
          case 105: custom_sensor->setCalibrationSampleTimes(request.getValueInt()); break;
          case 106: custom_sensor->setCalibrationSampleInterval(request.getValueInt()); break;
          case 107: custom_sensor->setReadSampleTimes(request.getValueInt()); break;
          case 108: custom_sensor->setReadSampleInterval(request.getValueInt()); break;
          default: return;
        }
      }
      #endif
      #ifdef USE_TSL2561
      if (strcmp(sensor->getName(),"TSL2561") == 0) {
        SensorTSL2561* custom_sensor = (SensorTSL2561*)sensor;
        switch(function) {
          case 101: custom_sensor->setGain(request.getValueInt()); break;
          case 102: custom_sensor->setTiming(request.getValueInt()); break;
          case 103: custom_sensor->setSpectrum(request.getValueInt()); break;
          case 104: custom_sensor->setAddress(request.getValueInt()); break;
          default: return;
        }
      }
      #endif
      #ifdef USE_PT100
      if (strcmp(sensor->getName(),"PT100") == 0) {
        SensorPT100* custom_sensor = (SensorPT100*)sensor;
        switch(function) {
          case 101: custom_sensor->setVoltageRef(request.getValueFloat()); break;
          default: return;
        }
      }
      #endif
      #ifdef USE_DIMMER
      if (strcmp(sensor->getName(),"DIMMER") == 0) {
        SensorDimmer* custom_sensor = (SensorDimmer*)sensor;
        switch(function) {
          case 101: custom_sensor->setEasing(request.getValueInt()); break;
          case 102: custom_sensor->setDuration(request.getValueInt()); break;
          case 103: custom_sensor->setStepDuration(request.getValueInt()); break;
          default: return;
        }
      }
      #endif
      #ifdef USE_PULSE_METER
      if (strcmp(sensor->getName(),"RAIN_GAUGE") == 0 || strcmp(sensor->getName(),"POWER") == 0 || strcmp(sensor->getName(),"WATER") == 0) {
        SensorPulseMeter* custom_sensor = (SensorPulseMeter*)sensor;
        switch(function) {
          case 102: custom_sensor->setPulseFactor(request.getValueFloat()); break;
          default: return;
        }
      }
      #endif
      #ifdef USE_SSD1306
      if (strcmp(sensor->getName(),"SSD1306") == 0) {
        DisplaySSD1306* display_SSD1306 = (DisplaySSD1306*)sensor;
        switch(function) {
          case 102: display_SSD1306->setContrast((uint8_t)request.getValueInt()); break;
          case 104: display_SSD1306->rotateDisplay((bool)request.getValueInt()); break;
          case 105: display_SSD1306->setFontSize(request.getValueInt()); break;
          case 106: display_SSD1306->setCaptionFontSize(request.getValueInt()); break;
          case 107: display_SSD1306->invertDisplay((bool)request.getValueInt()); break;
          default: return;
        }
      }
      #endif
      #ifdef USE_CHIRP
      if (strcmp(sensor->getName(),"CHIRP") == 0) {
        SensorChirp* custom_sensor = (SensorChirp*)sensor;
        switch(function) {
          case 101: custom_sensor->setMoistureOffset(request.getValueInt()); break;
          case 102: custom_sensor->setMoistureRange(request.getValueInt()); break;
          case 103: custom_sensor->setReturnMoistureNormalized(request.getValueInt()); break;
          case 104: custom_sensor->setReturnLightReversed(request.getValueInt()); break;
          default: return;
        }
      }
      #endif
    }
  }
  _node->sendMessage(CONFIGURATION_CHILD_ID,V_CUSTOM,function);
}

/*******************************************
   NodeManager
*/

// initialize the node manager
NodeManager::NodeManager(int sensorcount) {
  // setup the message container
  _message = MyMessage();
  if (sensorcount>0) {
    sensors.allocateBlocks(sensorcount);
  }
}

#if FEATURE_INTERRUPTS == ON
int NodeManager::_last_interrupt_pin = -1;
int NodeManager::_last_interrupt_value = LOW;
long NodeManager::_last_interrupt_1 = millis();
long NodeManager::_last_interrupt_2 = millis();
long NodeManager::_interrupt_min_delta = 100;
#endif

// setter/getter
void NodeManager::setRetries(int value) {
  _retries = value;
}
int NodeManager::getRetries() {
  return _retries;
}
#if FEATURE_SLEEP == ON
void NodeManager::setSleepSeconds(int value) {
  // set the status to AWAKE if the time provided is 0, SLEEP otherwise
  if (value == 0) _status = AWAKE;
  else _status = SLEEP;
  // store the time
  _sleep_time = value;
#if FEATURE_EEPROM == ON
  // save sleep settings to eeprom
  if (_save_sleep_settings) _saveSleepSettings();
#endif
}
void NodeManager::setSleepMinutes(int value) {
  setSleepSeconds(value*60);
}
void NodeManager::setSleepHours(int value) {
  setSleepMinutes(value*60);
}
void NodeManager::setSleepDays(int value) {
  setSleepHours(value*24);
}
long NodeManager::getSleepSeconds() {
  return _sleep_time;
}
void NodeManager::setSleepBetweenSend(int value) {
  _sleep_between_send = value;
}
#endif
#if FEATURE_INTERRUPTS == ON
void NodeManager::setSleepInterruptPin(int value) {
  _sleep_interrupt_pin = value;
}
void NodeManager::setInterrupt(int pin, int mode, int initial) {
  if (pin == INTERRUPT_PIN_1) {
    _interrupt_1_mode = mode;
    _interrupt_1_initial = initial;
  }
  if (pin == INTERRUPT_PIN_2) { 
    _interrupt_2_mode = mode;
    _interrupt_2_initial = initial;
  }
}
void NodeManager::setInterruptMinDelta(long value) {
  _interrupt_min_delta = value;
}
#endif
#if FEATURE_POWER_MANAGER == ON
void NodeManager::setPowerPins(int ground_pin, int vcc_pin, int wait_time) {
  if (_powerManager == nullptr) return;
  _powerManager->setPowerPins(ground_pin, vcc_pin, wait_time);
}
void NodeManager::powerOn() {
  if (_powerManager == nullptr) return;
  _powerManager->powerOn();
}
void NodeManager::powerOff() {
  if (_powerManager == nullptr) return;
  _powerManager->powerOff();
}
#endif
void NodeManager::setAck(bool value) {
    _ack = value;
}
bool NodeManager::getAck() {
    return _ack;
}
void NodeManager::setGetControllerConfig(bool value) {
  _get_controller_config = value;
}
void NodeManager::setIsMetric(bool value) {
  _is_metric = value;
}
bool NodeManager::getIsMetric() {
  return _is_metric;
}
#if FEATURE_EEPROM == ON
void NodeManager::setSaveSleepSettings(bool value) {
  _save_sleep_settings = value;
}
#endif

// Convert a temperature from celsius to fahrenheit depending on how isMetric is set
float NodeManager::celsiusToFahrenheit(float temperature) {
  if (_is_metric) return temperature;
  // convert the temperature from C to F
  return temperature * 1.8 + 32;
}

// return true if sleep or wait is configured and hence this is a sleeping node
bool NodeManager::isSleepingNode() {
  if (_status == SLEEP) return true;
  return false;
}

// register a sensor against NodeManager
void NodeManager::registerSensor(Sensor* sensor) {
  sensors.push(sensor);
}

// setup NodeManager
void NodeManager::before() {
  // print out the version
  #ifdef NODEMANAGER_DEBUG
    Serial.print(F("NodeManager v"));
    Serial.println(VERSION);
  #endif
  // setup the reboot pin if needed
  if (_reboot_pin > -1) {
    #ifdef NODEMANAGER_DEBUG
      Serial.print("REB P=");
      Serial.println(_reboot_pin);
    #endif
    pinMode(_reboot_pin, OUTPUT);
    digitalWrite(_reboot_pin, HIGH);
  }
  // print out MySensors' library capabilities
  #ifdef NODEMANAGER_DEBUG
    Serial.print(F("LIB V="));
    Serial.print(MYSENSORS_LIBRARY_VERSION);
    Serial.print(F(" R="));
    Serial.print(MY_CAP_RADIO);
    #ifdef MY_CAP_ENCR
      Serial.print(F(" E="));
      Serial.print(MY_CAP_ENCR);
    #endif
    Serial.print(F(" T="));
    Serial.print(MY_CAP_TYPE);
    Serial.print(F(" A="));
    Serial.print(MY_CAP_ARCH);
    Serial.print(F(" S="));
    Serial.print(MY_CAP_SIGN);
    Serial.print(F(" B="));
    Serial.println(MY_CAP_RXBUF);
  #endif
#if FEATURE_EEPROM == ON
  // restore the sleep settings saved in the eeprom
  if (_save_sleep_settings) _loadSleepSettings();
#endif
  // setup individual sensors
  for (List<Sensor*>::iterator itr = sensors.begin(); itr != sensors.end(); ++itr) {
    Sensor* sensor = *itr;
    // configure reporting interval
    if (! sensor->isReportIntervalConfigured()) sensor->setReportIntervalSeconds(_report_interval_seconds);
    // call each sensor's before()
    sensor->before();
  }
  #ifdef NODEMANAGER_DEBUG
    Serial.print(F("RADIO..."));
  #endif
}

// present NodeManager and its sensors
void NodeManager::presentation() {
  #ifdef NODEMANAGER_DEBUG
    Serial.println(F("OK"));
  #endif
  // Send the sketch version information to the gateway and Controller
  _sleepBetweenSend();
  sendSketchInfo(SKETCH_NAME,SKETCH_VERSION);
  _sleepBetweenSend();
  // present each sensor
  for (List<Sensor*>::iterator itr = sensors.begin(); itr != sensors.end(); ++itr) {
    Sensor* sensor = *itr;
    // call each sensor's presentation()
    sensor->presentation();
    _sleepBetweenSend();
  }
  #ifdef NODEMANAGER_DEBUG
    Serial.println(F("READY"));
    Serial.println("");
  #endif
  // wait a bit before leaving this function
  _sleepBetweenSend();
  _sleepBetweenSend();
  _sleepBetweenSend();
}


// setup NodeManager
void NodeManager::setup() {
  // retrieve and store isMetric from the controller
  if (_get_controller_config) _is_metric = getControllerConfig().isMetric;
  #ifdef NODEMANAGER_DEBUG
    Serial.print(F("MY I="));
    Serial.print(getNodeId());
    Serial.print(F(" M="));
    Serial.println(_is_metric);
  #endif
#if FEATURE_TIME == ON
  // sync the time with the controller
  syncTime();
#endif
#if FEATURE_SD == ON
  // initialize connection to the SD card
  if (sd_card.init(SPI_HALF_SPEED)) {
    #ifdef NODEMANAGER_DEBUG
      Serial.print(F("SD T="));
      switch(sd_card.type()) {
        case SD_CARD_TYPE_SD1:
          Serial.println("SD1"); break;
        case SD_CARD_TYPE_SD2:
          Serial.println("SD2"); break;
        case SD_CARD_TYPE_SDHC:
        Serial.println("SDHC"); break;
        default:
        Serial.println("Unknown");
      }
    #endif
    // initialize the volume
    sd_volume.init(sd_card);
    // open up the volume
    sd_root.openRoot(sd_volume);
  }
#endif
  // run setup for all the registered sensors
  for (List<Sensor*>::iterator itr = sensors.begin(); itr != sensors.end(); ++itr) {
    Sensor* sensor = *itr;
    // call each sensor's setup()
    sensor->setup();
  }
#if FEATURE_INTERRUPTS == ON
  // setup the interrupt pins
  setupInterrupts();
#endif
}

// run the main function for all the register sensors
void NodeManager::loop() {
#if FEATURE_TIME == ON
  // if the time was last updated more than 60 minutes ago, update it
  if (_time_is_valid && (now() - _time_last_sync) > 60*60) syncTime();
#endif
  // turn on the pin powering all the sensors
#if FEATURE_POWER_MANAGER == ON
  powerOn();
#endif
  // run loop for all the registered sensors
  for (List<Sensor*>::iterator itr = sensors.begin(); itr != sensors.end(); ++itr) {
    Sensor* sensor = *itr;
#if FEATURE_INTERRUPTS == ON
    if (_last_interrupt_pin != -1 && sensor->getInterruptPin() == _last_interrupt_pin) {
      // if there was an interrupt for this sensor, call the sensor's interrupt() and then loop()
      _message.clear();
      sensor->interrupt();
      sensor->loop(nullptr);
        // reset the last interrupt pin
      _last_interrupt_pin = -1;
    }
    else if (_last_interrupt_pin == -1) {
#else
    if (true) {
#endif
      // if just at the end of a cycle, call the sensor's loop() 
      _message.clear();
      sensor->loop(nullptr);
    }
  }
  // turn off the pin powering all the sensors
#if FEATURE_POWER_MANAGER == ON
  powerOff();
#endif
#if FEATURE_SLEEP == ON
  // continue/start sleeping as requested
  if (isSleepingNode()) _sleep();
#endif
}

#if FEATURE_RECEIVE == ON
// dispacth inbound messages
void NodeManager::receive(const MyMessage &message) {
  #ifdef NODEMANAGER_DEBUG
    Serial.print(F("RECV S="));
    Serial.print(message.sender);
    Serial.print(F(" I="));
    Serial.print(message.sensor);
    Serial.print(F(" C="));
    Serial.print(message.getCommand());
    Serial.print(F(" T="));
    Serial.print(message.type);
    Serial.print(F(" P="));
    Serial.println(message.getString());
  #endif
  // dispatch the message to the registered sensor
  Sensor* sensor = getSensorWithChild(message.sensor);
  if (sensor != nullptr) {
    // turn on the pin powering all the sensors
    #if FEATURE_POWER_MANAGER == ON
      powerOn();
    #endif
    // call the sensor's receive()
    sensor->receive(&message);
    // turn off the pin powering all the sensors
    #if FEATURE_POWER_MANAGER == ON
      powerOff();
    #endif
  }
}
#endif

#if FEATURE_TIME == ON
// receive the time from the controller and save it
void NodeManager::receiveTime(unsigned long ts) {
  #ifdef NODEMANAGER_DEBUG
    Serial.print(F("TIME T="));
    Serial.println(ts);
  #endif
  // time is now valid
  _time_is_valid = true;
#if FEATURE_RTC == ON
  // set the RTC time to the time received from the controller
  RTC.set(ts);
  // sync the system time with the RTC
  setSyncProvider(RTC.get);
#else
  // set the current system time to the received time
  setTime(ts);
#endif
  _time_last_sync = now();
}
#endif

// Send a hello message back to the controller
void NodeManager::hello() {
  // do nothing, the request will be echoed back
}

// reboot the board
void NodeManager::reboot() {
  #ifndef MY_GATEWAY_ESP8266
  #ifdef NODEMANAGER_DEBUG
    Serial.println(F("REBOOT"));
  #endif
  if (_reboot_pin > -1) {
    // reboot the board through the reboot pin which is connected to RST by setting it to low
    digitalWrite(_reboot_pin, LOW);
  } else {
    // Software reboot with watchdog timer. Enter Watchdog Configuration mode:
    WDTCSR |= (1<<WDCE) | (1<<WDE);
    // Reset enable
    WDTCSR= (1<<WDE);
    // Infinite loop until watchdog reset after 16 ms
    while(true){}
  }
  #endif
}

#if FEATURE_EEPROM == ON
// clear the EEPROM
void NodeManager::clearEeprom() {
  #ifdef NODEMANAGER_DEBUG
    Serial.println(F("CLEAR"));
  #endif
  for (uint16_t i=0; i<EEPROM_LOCAL_CONFIG_ADDRESS; i++) saveState(i, 0xFF);
}

// return the value stored at the requested index from the EEPROM
int NodeManager::loadFromMemory(int index) {
  return loadState(index+EEPROM_USER_START);
}

// save the given index of the EEPROM the provided value
void NodeManager::saveToMemory(int index, int value) {
  saveState(index+EEPROM_USER_START, value);
}
#endif

#if FEATURE_SLEEP
// wake up the board
void NodeManager::wakeup() {
  #ifdef NODEMANAGER_DEBUG
    Serial.println(F("WAKEUP"));
  #endif
  _status = AWAKE;
}
#endif

// return vcc in V
float NodeManager::getVcc() {
  #ifndef MY_GATEWAY_ESP8266
    // Measure Vcc against 1.1V Vref
    #if defined(__AVR_ATmega32U4__) || defined(__AVR_ATmega1280__) || defined(__AVR_ATmega2560__)
      ADMUX = (_BV(REFS0) | _BV(MUX4) | _BV(MUX3) | _BV(MUX2) | _BV(MUX1));
    #elif defined (__AVR_ATtiny24__) || defined(__AVR_ATtiny44__) || defined(__AVR_ATtiny84__)
      ADMUX = (_BV(MUX5) | _BV(MUX0));
    #elif defined (__AVR_ATtiny25__) || defined(__AVR_ATtiny45__) || defined(__AVR_ATtiny85__)
      ADMUX = (_BV(MUX3) | _BV(MUX2));
    #else
      ADMUX = (_BV(REFS0) | _BV(MUX3) | _BV(MUX2) | _BV(MUX1));
    #endif
    // Vref settle
    wait(70);
    // Do conversion
    ADCSRA |= _BV(ADSC);
    while (bit_is_set(ADCSRA, ADSC)) {};
    // return Vcc in mV
    return (float)((1125300UL) / ADC) / 1000;
  #else
    return (float)0;
  #endif
}

#if FEATURE_INTERRUPTS == ON
// setup the interrupt pins
void NodeManager::setupInterrupts() {
  // configure wakeup pin if needed
  if (_sleep_interrupt_pin > -1) {
    // set the interrupt when the pin is connected to ground
    setInterrupt(_sleep_interrupt_pin,FALLING,HIGH);
  }
  // setup the interrupt pins
  if (_interrupt_1_mode != MODE_NOT_DEFINED) {
    pinMode(INTERRUPT_PIN_1,INPUT);
    if (_interrupt_1_initial > -1) digitalWrite(INTERRUPT_PIN_1,_interrupt_1_initial);
    // for non sleeping nodes, we need to handle the interrupt by ourselves  
    if (_status != SLEEP) attachInterrupt(digitalPinToInterrupt(INTERRUPT_PIN_1), _onInterrupt_1, _interrupt_1_mode);
  }
  if (_interrupt_2_mode != MODE_NOT_DEFINED) {
    pinMode(INTERRUPT_PIN_2, INPUT);
    if (_interrupt_2_initial > -1) digitalWrite(INTERRUPT_PIN_2,_interrupt_2_initial);
    // for non sleeping nodes, we need to handle the interrupt by ourselves  
    if (_status != SLEEP) attachInterrupt(digitalPinToInterrupt(INTERRUPT_PIN_2), _onInterrupt_2, _interrupt_2_mode);
  }
  #ifdef NODEMANAGER_DEBUG
    Serial.print(F("INT P="));
    Serial.print(INTERRUPT_PIN_1);
    Serial.print(F(" M="));
    Serial.println(_interrupt_1_mode);
    Serial.print(F("INT P="));
    Serial.print(INTERRUPT_PIN_2);
    Serial.print(F(" M="));
    Serial.println(_interrupt_2_mode);
  #endif
}

// return the pin from which the last interrupt came
int NodeManager::getLastInterruptPin() {
  return _last_interrupt_pin;
}

// return the value of the pin from which the last interrupt came
int NodeManager::getLastInterruptValue() {
  return _last_interrupt_value;
}
#endif

// set the default interval in seconds all the sensors will report their measures
void NodeManager::setReportIntervalSeconds(int value) {
  _report_interval_seconds = value;
}

// set the default interval in minutes all the sensors will report their measures
void NodeManager::setReportIntervalMinutes(int value) {
  _report_interval_seconds = value*60;
}

// set the default interval in hours all the sensors will report their measures
void NodeManager::setReportIntervalHours(int value) {
  _report_interval_seconds = value*60*60;
}

// set the default interval in days all the sensors will report their measures
void NodeManager::setReportIntervalDays(int value) {
  _report_interval_seconds = value*60*60*24;
}

// if set and when the board is battery powered, sleep() is always called instead of wait()
void NodeManager::setSleepOrWait(bool value) {
  _sleep_or_wait = value;
}

// set which pin is connected to RST of the board to reboot the board when requested. If not set the software reboot is used instead (default: -1)
void NodeManager::setRebootPin(int value) {
  _reboot_pin = value;
}

// turn the ADC off so to save 0.2 mA
void NodeManager::setADCOff() {
  #ifndef MY_GATEWAY_ESP8266
    // Disable the ADC by setting the ADEN bit (bit 7) to zero
    ADCSRA = ADCSRA & B01111111;
    // Disable the analog comparator by setting the ACD bit (bit 7) to one
    ACSR = B10000000;
  #endif
}

// sleep if the node is a battery powered or wait if it is not for the given number of milliseconds 
void NodeManager::sleepOrWait(long value) {
  // if the node is sleeping, sleep-or-wait is enabled and we need to sleep for a decent amount of time, call sleep() otherwise wait()
  if (isSleepingNode() && _sleep_or_wait && value > 200) sleep(value);
  else wait(value);
}

// return the next available child_id
int NodeManager::getAvailableChildId(int child_id) {
  if (child_id > -1) return child_id;
  for (int i = 1; i < 255; i++) {
    if (i == CONFIGURATION_CHILD_ID || i == BATTERY_CHILD_ID || i == SIGNAL_CHILD_ID) continue;
    Child* child = getChild(i);
    if (child == nullptr) return i;
  }
  return 254;
}

#if FEATURE_INTERRUPTS == ON
// handle an interrupt
void NodeManager::_onInterrupt_1() {
  long now = millis();
  if ( (now - _last_interrupt_1 > _interrupt_min_delta) || (now < _last_interrupt_1) ) {
    _last_interrupt_pin = INTERRUPT_PIN_1;
    _last_interrupt_value = digitalRead(INTERRUPT_PIN_1);
    #ifdef NODEMANAGER_DEBUG
      Serial.print(F("INT P="));
      Serial.print(INTERRUPT_PIN_1);
      Serial.print(" V=");
      Serial.println(_last_interrupt_value);
    #endif
    _last_interrupt_1 = now;
  }
}
void NodeManager::_onInterrupt_2() {
  long now = millis();
  if ( (now - _last_interrupt_2 > _interrupt_min_delta) || (now < _last_interrupt_2) ) {
    _last_interrupt_pin = INTERRUPT_PIN_2;
    _last_interrupt_value = digitalRead(INTERRUPT_PIN_2);
    #ifdef NODEMANAGER_DEBUG
      Serial.print(F("INT P="));
      Serial.print(INTERRUPT_PIN_2);
      Serial.print(" V=");
      Serial.println(_last_interrupt_value);
    #endif
    _last_interrupt_2 = now;
  }
}
#endif

// send a message by providing the source child, type of the message and value
void NodeManager::sendMessage(int child_id, int type, int value) {
  _message.clear();
  _message.set(value);
  _sendMessage(child_id,type);
}
void NodeManager::sendMessage(int child_id, int type, float value) {
  _message.clear();
  _message.set(value,2);
  _sendMessage(child_id,type);
}
void NodeManager::sendMessage(int child_id, int type, double value) {
  _message.clear();
  _message.set(value,4);
  _sendMessage(child_id,type);
}
void NodeManager::sendMessage(int child_id, int type, const char* value) {
  _message.clear();
  _message.set(value);
  _sendMessage(child_id,type);
}

// send a message to the network
void NodeManager::_sendMessage(int child_id, int type) {
  // prepare the message
  _message.setSensor(child_id);
  _message.setType(type);
  // send the message, multiple times if requested
  for (int i = 0; i < _retries; i++) {
    #ifdef NODEMANAGER_DEBUG
      Serial.print(F("SEND D="));
      Serial.print(_message.destination);
      Serial.print(F(" I="));
      Serial.print(_message.sensor);
      Serial.print(F(" C="));
      Serial.print(_message.getCommand());
      Serial.print(F(" T="));
      Serial.print(_message.type);
      Serial.print(F(" S="));
      Serial.print(_message.getString());
      Serial.print(F(" I="));
      Serial.print(_message.getInt());
      Serial.print(F(" F="));
      Serial.println(_message.getFloat());
    #endif
    send(_message, _ack);
    // if configured, sleep beetween each send
    _sleepBetweenSend();
  }
}

#if FEATURE_POWER_MANAGER == ON
void NodeManager::setPowerManager(PowerManager& powerManager) {
  _powerManager = &powerManager;
}
#endif

// return the requested child 
Child* NodeManager::getChild(int child_id) {
  Sensor* sensor = getSensorWithChild(child_id);
  if (sensor == nullptr) return nullptr;
  return sensor->getChild(child_id);
}

// return the sensor with the requested child 
Sensor* NodeManager::getSensorWithChild(int child_id) {
  for (List<Sensor*>::iterator itr = sensors.begin(); itr != sensors.end(); ++itr) {
    Sensor* sensor = *itr;
    Child* child = sensor->getChild(child_id);
    if (child != nullptr) return sensor;
  }
  return nullptr;  
}

#if FEATURE_TIME == ON
// sync the time with the controller
void NodeManager::syncTime() {
  _time_is_valid = false;
  int retries = 10;
  // ask the controller for the time up to 10 times until received
  while ( ! _time_is_valid && retries >= 0) {
    #ifdef NODEMANAGER_DEBUG
      Serial.println(F("REQ TIME"));
    #endif
    requestTime();
    wait(1000);
    retries = retries - 1;
  }
}

// returns the current system time
long NodeManager::getTime() {
  return now();
}
#endif

#if FEATURE_SLEEP == ON
// wrapper of smart sleep
void NodeManager::_sleep() {
  long sleep_time = _sleep_time;
#if FEATURE_TIME == ON
  // if there is time still to sleep, sleep for that timeframe only
  if (_remainder_sleep_time > 0) sleep_time = _remainder_sleep_time;
#endif
  #ifdef NODEMANAGER_DEBUG
    Serial.print(F("SLEEP "));
    Serial.print(sleep_time);
    Serial.println(F("s"));
    // print a new line to separate the different cycles
    Serial.println("");
  #endif
  // go to sleep
  int interrupt = -1;
#if FEATURE_INTERRUPTS == ON
  // setup interrupt pins
  int interrupt_1_pin = _interrupt_1_mode == MODE_NOT_DEFINED ? INTERRUPT_NOT_DEFINED  : digitalPinToInterrupt(INTERRUPT_PIN_1);
  int interrupt_2_pin = _interrupt_2_mode == MODE_NOT_DEFINED ? INTERRUPT_NOT_DEFINED  : digitalPinToInterrupt(INTERRUPT_PIN_2);
  // enter smart sleep for the requested sleep interval and with the configured interrupts
  interrupt = sleep(interrupt_1_pin,_interrupt_1_mode,interrupt_2_pin,_interrupt_2_mode,sleep_time*1000, true);
  if (interrupt > -1) {
    // woke up by an interrupt
    int pin_number = -1;
    int interrupt_mode = -1;
    // map the interrupt to the pin
    if (digitalPinToInterrupt(INTERRUPT_PIN_1) == interrupt) {
      pin_number = INTERRUPT_PIN_1;
      interrupt_mode = _interrupt_1_mode;
    }
    if (digitalPinToInterrupt(INTERRUPT_PIN_2) == interrupt) {
      pin_number = INTERRUPT_PIN_2;
      interrupt_mode = _interrupt_2_mode;
    }
    _last_interrupt_pin = pin_number;
    _last_interrupt_value = digitalRead(pin_number);
    #ifdef NODEMANAGER_DEBUG
      Serial.print(F("INT P="));
      Serial.print(pin_number);
      Serial.print(F(", M="));
      Serial.print(interrupt_mode);
      Serial.print(F(", V="));
      Serial.println(_last_interrupt_value);
    #endif
    // when waking up from an interrupt on the wakup pin, stop sleeping
    if (_sleep_interrupt_pin == pin_number) _status = AWAKE;
  }
#else
  sleep(INTERRUPT_NOT_DEFINED,MODE_NOT_DEFINED,INTERRUPT_NOT_DEFINED,MODE_NOT_DEFINED,sleep_time*1000, true);
#endif
  // coming out of sleep
  #ifdef NODEMANAGER_DEBUG
    Serial.println(F("AWAKE"));
  #endif
#if FEATURE_TIME == ON
  // keep track of the old time so to calculate the amount of time slept
  long old_time = now();
#if FEATURE_RTC == ON
  // sync the time with the RTC
  setSyncProvider(RTC.get);
#else
  // sync the time with the controller
  syncTime();
#endif
  // calculate the remainder time to sleep if woken up by an interrupt
  if (interrupt > -1) {
    if (_remainder_sleep_time == -1) _remainder_sleep_time = _sleep_time;
    _remainder_sleep_time = _remainder_sleep_time - (now() - old_time);
  }
  else _remainder_sleep_time = -1;
#endif
}

#endif

#if FEATURE_EEPROM == ON
// load the configuration stored in the eeprom
void NodeManager::_loadSleepSettings() {
  if (loadState(EEPROM_SLEEP_SAVED) == 1) {
    // load sleep settings
    int bit_1 = loadState(EEPROM_SLEEP_1);
    int bit_2 = loadState(EEPROM_SLEEP_2);
    int bit_3 = loadState(EEPROM_SLEEP_3);
    _sleep_time = bit_3*255*255 + bit_2*255 + bit_1;
    #ifdef NODEMANAGER_DEBUG
      Serial.print(F("LOADSLP T="));
      Serial.println(_sleep_time);
    #endif
  }
}

// save the configuration in the eeprom
void NodeManager::_saveSleepSettings() {
  if (_sleep_time == 0) return;
  // encode the sleep time in 3 bits
  int bit_1, bit_2, bit_3 = 0;
  bit_1 = _sleep_time;
  if (bit_1 >= 255) {
    bit_2 = (int)bit_1/255;
    bit_1 = bit_1 - bit_2*255;
  }
  if (bit_2 >= 255) {
    bit_3 = (int)bit_2/255;
    bit_2 = bit_2 - bit_3*255;
  }
  // save the 3 bits
  saveState(EEPROM_SLEEP_SAVED,1);
  saveState(EEPROM_SLEEP_1,bit_1);
  saveState(EEPROM_SLEEP_2,bit_2);
  saveState(EEPROM_SLEEP_3,bit_3);
}
#endif

// sleep between send()
void NodeManager::_sleepBetweenSend() {
  if (_sleep_between_send > 0) sleep(_sleep_between_send);
}