config.cpp

#include "GrowduinoFirmware.h"
#include <Arduino.h>

#include "config.h"

/*
   Config object
   Stores network data
*/


Config::Config() {
  // Simplest possible defaults
  use_dhcp = 1;
  mac_aton("de:ad:be:ef:55:44", mac);
  ntp = IPAddress(195, 113, 56, 8);
  mail_from = NULL;
  sys_name = (char *) malloc(10);
  strlcpy(sys_name, "growduino", 10);
  smtp_port = 25;
  time_zone = 2;
  //ups_trigger_level = 255;
  co2_400 = CO2_400;
  co2_40k = CO2_40k;
  ph_4 = PH_4;
  ph_7 = PH_7;
  ec_low_ion = EC_LOW_ION;
  ec_high_ion = EC_HIGH_ION;
  ec_offset = EC_OFFSET;
}

void Config::load(aJsonObject * json) {
  //loads values from json. Values not in json are not touched
  byte tmpmac[6];
  char debug_out[32];
  IPAddress tmpip;
  int json_strlen;

  aJsonObject* cnfobj = aJson.getObjectItem(json, "use_dhcp");
  if (cnfobj) {
    if (strcmp(cnfobj->valuestring, "0") == 0 || cnfobj->valueint == 0) {
      use_dhcp = 0;
    } else {
      use_dhcp = 1;
    }
  }

  cnfobj = aJson.getObjectItem(json, "mac");
  if (cnfobj && cnfobj->type == aJson_String && mac_aton(cnfobj->valuestring, tmpmac) == 1) {
    mac_aton(cnfobj->valuestring, mac);
    SERIAL.print(F("mac "));
    mac_ntoa(mac, debug_out);
    SERIAL.println(debug_out);

  }

  if (use_dhcp == 0) {  // Static IP config
    cnfobj = aJson.getObjectItem(json, "ip");
    if (cnfobj && cnfobj->type == aJson_String && inet_aton(cnfobj->valuestring, tmpip) == 1) {
      inet_aton(cnfobj->valuestring, ip);
      SERIAL.print(F("ip "));
      inet_ntoa(ip, debug_out);
      SERIAL.println(debug_out);
    }

    cnfobj = aJson.getObjectItem(json, "netmask");
    if (cnfobj && cnfobj->type == aJson_String && inet_aton(cnfobj->valuestring, tmpip) == 1) {
      inet_aton(cnfobj->valuestring, netmask);
      SERIAL.print(F("netmask "));
      inet_ntoa(netmask, debug_out);
      SERIAL.println(debug_out);
    }

    cnfobj = aJson.getObjectItem(json, "gateway");
    if (cnfobj && cnfobj->type == aJson_String && inet_aton(cnfobj->valuestring, tmpip) == 1) {
      inet_aton(cnfobj->valuestring, gateway);
      SERIAL.print(F("gateway "));
      inet_ntoa(gateway, debug_out);
      SERIAL.println(debug_out);
    }
  }

  cnfobj = aJson.getObjectItem(json, "smtp");
  if (cnfobj && cnfobj->type == aJson_String && inet_aton(cnfobj->valuestring, tmpip) == 1) {
    inet_aton(cnfobj->valuestring, smtp);
    SERIAL.print(F("smtp "));
    inet_ntoa(smtp, debug_out);
    SERIAL.println(debug_out);
  }

  cnfobj = aJson.getObjectItem(json, "smtp_port");
  if (cnfobj) {
    sscanf(cnfobj->valuestring, "%d", &smtp_port);
  } else {
    smtp_port = 25;
  }

  cnfobj = aJson.getObjectItem(json, "mail_from");
  if (cnfobj->type == aJson_String)  {
    if (mail_from != NULL) {
      free(mail_from);
      mail_from = NULL;
    }
    json_strlen = strnlen(cnfobj->valuestring, 31);
    mail_from = (char *) malloc(json_strlen + 1);
    if (mail_from == NULL) {
      SERIAL.println(F("OOM on config load (mail_from)"));
    } else {
      strlcpy(mail_from, cnfobj->valuestring, json_strlen + 1);
    }


  }

  cnfobj = aJson.getObjectItem(json, "ntp");
  if (cnfobj && cnfobj->type == aJson_String && inet_aton(cnfobj->valuestring, tmpip) == 1) {
    inet_aton(cnfobj->valuestring, ntp);
    SERIAL.print(F("ntp "));
    inet_ntoa(ntp, debug_out);
    SERIAL.println(debug_out);
  }

  cnfobj = aJson.getObjectItem(json, "sys_name");
  if (cnfobj->type == aJson_String)  {
    if (sys_name != NULL) {
      free(sys_name);
      sys_name = NULL;
    }
    json_strlen = strnlen(cnfobj->valuestring, 31);
    sys_name = (char *) malloc(json_strlen + 1);
    if (sys_name == NULL) {
      SERIAL.println(F("OOM on config load (sys_name)"));
    } else {
      strlcpy(sys_name, cnfobj->valuestring, json_strlen + 1);
    }
  }
  cnfobj = aJson.getObjectItem(json, "time_zone");
  if (cnfobj) {
    sscanf(cnfobj->valuestring, "%d", &time_zone);
  } else {
    time_zone = 2;
  }
  /*
    cnfobj = aJson.getObjectItem(json, "ups_trigger_level");
    if (cnfobj) {
      sscanf(cnfobj->valuestring, "%d", &ups_trigger_level);
    } else {
      ups_trigger_level = 255;
    }
  */

}

void Config::loadcal(aJsonObject * json) {
  //loads values from json. Values not in json are not touched
  char debug_out[32];
  int json_strlen;

  aJsonObject* cnfobj;
#ifdef USE_CO2_SENSOR
  cnfobj = aJson.getObjectItem(json, "co2_400");
  if (cnfobj) {
    sscanf(cnfobj->valuestring, "%d", &co2_400);
  } else {
    co2_400 = CO2_400;
  }

  cnfobj = aJson.getObjectItem(json, "co2_40k");
  if (cnfobj) {
    sscanf(cnfobj->valuestring, "%d", &co2_40k);
  } else {
    co2_40k = CO2_40k;
  }
#endif

#ifdef USE_PH_SENSOR
  cnfobj = aJson.getObjectItem(json, "ph_4");
  if (cnfobj) {
    sscanf(cnfobj->valuestring, "%d", &ph_4);
  } else {
    ph_4 = PH_4;
  }

  cnfobj = aJson.getObjectItem(json, "ph_7");
  if (cnfobj) {
    sscanf(cnfobj->valuestring, "%d", &ph_7);
  } else {
    ph_7 = PH_7;
  }
#endif

#ifdef USE_EC_SENSOR
  cnfobj = aJson.getObjectItem(json, "ec_low_ion");
  if (cnfobj) {
    sscanf(cnfobj->valuestring, "%d", &ec_low_ion);
  } else {
    ec_low_ion = EC_LOW_ION;
  }

  cnfobj = aJson.getObjectItem(json, "ec_high_ion");
  if (cnfobj) {
    sscanf(cnfobj->valuestring, "%d", &ec_high_ion);
  } else {
    ec_high_ion = EC_HIGH_ION;
  }

  cnfobj = aJson.getObjectItem(json, "ec_offset");
  if (cnfobj) {
    sscanf(cnfobj->valuestring, "%d", &ec_offset);
  } else {
    ec_offset = EC_OFFSET;
  }
#endif
}

int Config::save() {
  char buffer[20];
  file_for_write("", "config.jso", &sd_file);

  sd_file.print(F("{"));

  sd_file.print(F("\"use_dhcp\":"));
  sd_file.print(use_dhcp);
  sd_file.print(F(","));

  mac_ntoa(mac, buffer);
  sd_file.print(F("\"mac\":\""));
  sd_file.print(buffer);
  sd_file.print(F("\","));

  inet_ntoa(ip, buffer);
  sd_file.print(F("\"ip\":\""));
  sd_file.print(buffer);
  sd_file.print(F("\","));

  inet_ntoa(netmask, buffer);
  sd_file.print(F("\"netmask\":\""));
  sd_file.print(buffer);
  sd_file.print(F("\","));

  inet_ntoa(gateway, buffer);
  sd_file.print(F("\"gateway\":\""));
  sd_file.print(buffer);
  sd_file.print(F("\","));

  inet_ntoa(ntp, buffer);
  sd_file.print(F("\"ntp\":\""));
  sd_file.print(buffer);
  sd_file.print(F("\","));

  inet_ntoa(smtp, buffer);
  sd_file.print(F("\"smtp\":\""));
  sd_file.print(buffer);
  sd_file.print(F("\","));

  sd_file.print(F("\"mail_from\":\""));
  sd_file.print(mail_from);
  sd_file.print(F("\","));

  sd_file.print(F("\"sys_name\":\""));
  sd_file.print(sys_name);
  sd_file.print(F("\","));

  sd_file.print(F("\"smtp_port\":\""));
  sd_file.print(smtp_port);
  sd_file.print(F("\","));

  sd_file.print(F("\"time_zone\":\""));
  sd_file.print(time_zone);
  /*sd_file.print(F("\","));

    sd_file.print(F("\"ups_trigger_level\":\""));
    sd_file.print(ups_trigger_level);*/
  sd_file.print(F("\""));


  sd_file.print(F("}"));
  sd_file.close();
  return 1;
}

int Config::savecal() {
  char buffer[20];
  file_for_write("", "calib.jso", &sd_file);

  sd_file.print(F("{"));

#ifdef USE_CO2_SENSOR
  sd_file.print(F("\"co2_400\":\""));
  sd_file.print(co2_400);
  sd_file.print(F("\","));

  sd_file.print(F("\"co2_40k\":\""));
  sd_file.print(co2_40k);
  sd_file.print(F("\","));
#endif

#ifdef USE_PH_SENSOR
  sd_file.print(F("\"ph_4\":\""));
  sd_file.print(ph_4);
  sd_file.print(F("\","));

  sd_file.print(F("\"ph_7\":\""));
  sd_file.print(ph_7);
  sd_file.print(F("\","));
#endif

#ifdef USE_EC_SENSOR
  sd_file.print(F("\"ec_low_ion\":\""));
  sd_file.print(ec_low_ion);
  sd_file.print(F("\","));

  sd_file.print(F("\"ec_high_ion\":\""));
  sd_file.print(ec_high_ion);
  sd_file.print(F("\","));

  sd_file.print(F("\"ec_offset\":\""));
  sd_file.print(ec_offset);
  sd_file.print(F("\""));
#endif

  sd_file.print(F("}"));
  sd_file.close();
  return 1;
}

int Config::inet_aton(const char* aIPAddrString, IPAddress& aResult) {
  unsigned int ares[4];
  int len = 0;
  ares[0] = 0;
  len = sscanf(aIPAddrString, "%d.%d.%d.%d", &ares[0], &ares[1], &ares[2], &ares[3]);

  if (len == 4) {
    // we matched 4 ints
    for (int i = 0; i < 4; i++) {
      if (ares[i] < 256) {
        // store parsed value in corresponding byte
        aResult[i] = (byte) ares[i];
      } else {
        // What we got will not fit in byte, so fail
        return 0;
      }
    }
    // now we have full address
    return 1;
  } else {
    // scanf fail
    return 0;
  }
}

char * Config::inet_ntoa(IPAddress addr, char * dest) {
  //creates string from IPAddress
  //sprintf(dest, "%d.%d.%d.%d", IPAddress[0], IPAddress[1], IPAddress[2], IPAddress[3]);
  sprintf(dest, "%d.%d.%d.%d", addr[0], addr[1], addr[2], addr[3]);
  return dest;
}


int Config::mac_aton(const char * MacAddr, byte (&macResult)[6]) {
  unsigned int ares[6];
  int len = 0;
  ares[0] = 0;
  len = sscanf(MacAddr, "%x:%x:%x:%x:%x:%x", &ares[0], &ares[1], &ares[2], &ares[3], &ares[4], &ares[5]);

  if (len == 6) {
    // we matched 6 ints
    for (int i = 0; i < 6; i++) {
      if (ares[i] < 256) {
        // store parsed value in corresponding byte
        macResult[i] = (byte) ares[i];
      } else {
        // What we got will not fit in byte, so fail
        return 0;
      }
    }
    // now we have full mac address
    return 1;
  } else {
    // scanf fail
    return 0;
  }
}


char * Config::mac_ntoa(byte addr[], char * dest) {
  sprintf(dest, "%02x:%02x:%02x:%02x:%02x:%02x", addr[0], addr[1], addr[2], addr[3], addr[4], addr[5]);


  return dest;
}