#define NoDevelopment   A5
#define MAXSENSORS      10
#define MAXITERATIONS   5
// This #include statement was automatically added by the Particle IDE.
#include "lib1.h"
// Use this include for the Web IDE:
#include "OneWire/OneWire.h"

// Use this include for Particle Dev where everything is in one directory.
// #include "OneWire.h"


TCPClient httpClient;
byte server[] = { 1, 2, 3, 4 }; // IP-Adresse des Servers


void sendOneSensor(char *addr, float celsius)
{
  if (httpClient.connect(server, 80)) {
    httpClient.print("GET /cgi-Pfad/cgi-name?");
    httpClient.print(addr);
    httpClient.print(":");
    httpClient.print(celsius);
    httpClient.println(" HTTP/1.0");
    httpClient.println("Connection: close");
    httpClient.println("Host: host.domain");
    httpClient.println("Accept: text/html, text/plain");
    httpClient.println();
    }

  else
  {
    Spark.publish("status", "connection failed");
    httpClient.stop();
  }

  while (httpClient.connected())
  {
    while (httpClient.available())
    {
      char c = httpClient.read();
      //Serial.print(c);
    }
  }

  httpClient.flush();
  httpClient.stop();

}


char line[240];
OneWire ds(D5);  // on pin D5 (a 4.7K resistor is necessary)

void setup(void) {
    pinMode(NoDevelopment, INPUT_PULLUP); 
}

void loop(void) {
  byte i,iteration;
  byte present = 0;
  byte type_s;
  byte data[12];
  byte addr[8];
  byte count=0;
  float celsius,sensorvalue[MAXITERATIONS][MAXSENSORS];
  char address[MAXSENSORS][20],deviceType[MAXSENSORS][100];;
  ds.reset_search();
  while(ds.search(addr) && (count<MAXSENSORS) ){
    if (OneWire::crc8(addr, 7) != addr[7]) {
        Particle.publish("Messung", "CRC is not valid!", 1000);
        continue;
    };
      // the first ROM byte indicates which chip
    switch (addr[0]) {
      case 0x10:
        sprintf(deviceType[count],"DS18S20");  // or old DS1820
        type_s = 1;
        break;
      case 0x28:
        sprintf(deviceType[count],"DS18B20");
        type_s = 0;
        break;
      case 0x22:
        sprintf(deviceType[count],"DS1822");
        type_s = 0;
        break;
      default:
        sprintf(deviceType[count],"Device %02x is not a DS18x20 family device.",addr[0]);
        Particle.publish("Messung", deviceType[count], 1000);
        continue;
    }; // switch
    // 
    sprintf(address[count],"%02x%02x-%02x%02x-%02x%02x-%02x%02x",addr[0],addr[1],addr[2],addr[3],addr[4],addr[5],addr[6],addr[7]);
    for(iteration=0;iteration<MAXITERATIONS;iteration++){
      ds.reset();
      ds.select(addr);
      ds.write(0x44, 1);        // start conversion, with parasite power on at the end

      delay(1000);     // maybe 750ms is enough, maybe not
      // we might do a ds.depower() here, but the reset will take care of it.

      present = ds.reset();
      ds.select(addr);
      ds.write(0xBE);         // Read Scratchpad

      for ( i = 0; i < 9; i++) {           // we need 9 bytes
        data[i] = ds.read();
      };
      // Convert the data to actual temperature
      // because the result is a 16 bit signed integer, it should
      // be stored to an "int16_t" type, which is always 16 bits
      // even when compiled on a 32 bit processor.
      int16_t raw = (data[1] << 8) | data[0];
      if (type_s) {
        raw = raw << 3; // 9 bit resolution default
        if (data[7] == 0x10) {
          // "count remain" gives full 12 bit resolution
          raw = (raw & 0xFFF0) + 12 - data[6];
        }
      } else {
        byte cfg = (data[4] & 0x60);
        // at lower res, the low bits are undefined, so let's zero them
              if (cfg == 0x00) raw = raw & ~7;  // 9 bit resolution, 93.75 ms
         else if (cfg == 0x20) raw = raw & ~3; // 10 bit res, 187.5 ms
        else if (cfg == 0x40) raw = raw & ~1; // 11 bit res, 375 ms
        //// default is 12 bit resolution, 750 ms conversion time
      };
      celsius = (float)raw / 16.0;
      sensorvalue[iteration][count]=celsius;
    };
    count++;
  };
  // alle Sensordaten liegen vor. Streiche min/max und mittele den Rest
  for(i=0;i<count;i++){ // fuer alle Sensoren
    int j;
    byte minpos,maxpos;
    float min=10000.0,max=-10000.0,sum;
    sum=0.0;
    for(j=0;j<MAXITERATIONS;j++){
        if(sensorvalue[j][i]<min){minpos=j;min=sensorvalue[j][i];};
        if(sensorvalue[j][i]>max){maxpos=j;max=sensorvalue[j][i];};
    };
    for(j=0;j<MAXITERATIONS;j++){
        if( (j!=minpos) && (j!=maxpos) ){sum+=sensorvalue[j][i];};
    };
    if(minpos==maxpos)celsius=sensorvalue[0][i]; else celsius=sum/(MAXITERATIONS-2);
    sendOneSensor(address[i],celsius);
    sprintf(line,"%2d %s %s %4.1f %lu",i,address[i],deviceType[i],celsius,millis()/1000);
    Particle.publish("Messung", line, 10000);
  };
  delay(1000);
  if( (digitalRead(NoDevelopment))  )System.sleep(SLEEP_MODE_DEEP,600);
  else delay(600);
}