Backyard Aquaponics
A place to discuss aquaponics

#include <SPI.h>
#include <Ethernet.h>
#include <EthernetUdp.h>
#include <Twitter.h>
#include <HTTPClient.h>
#include <Avviso.h>

byte mac[] = {
  0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0xED };
unsigned int localPort = 8888;
const int pingPin = 7;
IPAddress timeServer(192, 43, 244, 18);
const int NTP_PACKET_SIZE= 48;
byte packetBuffer[ NTP_PACKET_SIZE];
EthernetUDP Udp;


long Lastprowl = 0;
long Lasttwitter = 0;
Twitter twitter("Secret code"); // twitter
String dataString;

void setup()
{ 
  Serial.begin(9600);
  Serial.println("Connecting Nets");

  if (Ethernet.begin(mac) == 0)
  {
    Serial.println("Failed to configure Ethernet using DHCP");
    return;
  }
  Udp.begin(localPort);
  Avviso.begin();
  Avviso.setApplicationName("Belleye Aquaponics");
}

void loop()
{
  sendNTPpacket(timeServer); // send an NTP packet to a time server
  delay(1000); 
  if ( Udp.parsePacket() ) { 
    Udp.read(packetBuffer,NTP_PACKET_SIZE);  // read the packet into the buffer
    unsigned long highWord = word(packetBuffer[40], packetBuffer[41]);
    unsigned long lowWord = word(packetBuffer[42], packetBuffer[43]); 
    unsigned long secsSince1900 = highWord << 16 | lowWord; 
    secsSince1900 = secsSince1900 + (8*60*60);
    dataString = "";
    dataString += secsSince1900;
    dataString += (", air = ");
    long celsius = (analogRead(0) * 0.004882812 * 100) - 2.5 - 273.15; 
    dataString += celsius;
    dataString += (", water = ");
    celsius = (analogRead(1) * 0.004882812 * 100) - 2.5 - 273.15; 
    dataString += celsius;
    // ping
    float tempL;
    long duration, cm, litres;
    pinMode(pingPin, OUTPUT);
    digitalWrite(pingPin, LOW);
    delayMicroseconds(2);
    digitalWrite(pingPin, HIGH);
    delayMicroseconds(5);
    digitalWrite(pingPin, LOW);
    pinMode(pingPin, INPUT);
    duration = pulseIn(pingPin, HIGH);
    cm = microsecondsToCentimeters(duration);
    tempL = 100 - cm;
    tempL = tempL * 10;
    litres = tempL;
    dataString += (", ");
    dataString += litres;
    dataString += (" litres in IBC");
    // prowl
    if (cm > 90 and (secsSince1900 - Lastprowl) > 1800)
    {
      Avviso.setApiKey("Another secret code"); //this key found by logging into prowlapp via web browser
      Avviso.push("Warning", "Water level low", 0);
      Lastprowl = secsSince1900;
    }
    if ((secsSince1900 - Lasttwitter) > 3600)
    {
      Serial.println(dataString);
      char msg[125];
      String termTweet = dataString + "\0" ;// Terminate the tweet with a null
      int twtlen = (termTweet.length()+3);
      termTweet.toCharArray(msg,twtlen); // Convert it to an array called msg
      if (twitter.post(msg))
      {
        int status = twitter.wait(&Serial);
        if (status == 200)
        {
          Serial.println("OK.");
        }
        else
        {
          Serial.print("failed : code ");
          Serial.println(status);
        }
      }
      Lasttwitter = secsSince1900;
    }
  }
  for (int x = 1; x < 11; x++)
    {
      dataString = ("air = ");
      long celsius = (analogRead(0) * 0.004882812 * 100) - 2.5 - 273.15; 
      dataString += celsius;
      dataString += (", water = ");
      celsius = (analogRead(1) * 0.004882812 * 100) - 2.5 - 273.15; 
      dataString += celsius;
      Serial.println(dataString);
      delay(1000);
    }   
}
unsigned long sendNTPpacket(IPAddress& address)
{
  // set all bytes in the buffer to 0
  memset(packetBuffer, 0, NTP_PACKET_SIZE);
  // Initialize values needed to form NTP request
  // (see URL above for details on the packets)
  packetBuffer[0] = 0b11100011;   // LI, Version, Mode
  packetBuffer[1] = 0;     // Stratum, or type of clock
  packetBuffer[2] = 6;     // Polling Interval
  packetBuffer[3] = 0xEC;  // Peer Clock Precision
  // 8 bytes of zero for Root Delay & Root Dispersion
  packetBuffer[12]  = 49;
  packetBuffer[13]  = 0x4E;
  packetBuffer[14]  = 49;
  packetBuffer[15]  = 52;

  // all NTP fields have been given values, now
  // you can send a packet requesting a timestamp:          
  Udp.beginPacket(address, 123); //NTP requests are to port 123
  Udp.write(packetBuffer,NTP_PACKET_SIZE);
  Udp.endPacket();
}
long microsecondsToCentimeters(long microseconds)
{
  // The speed of sound is 340 m/s or 29 microseconds per centimeter.
  // The ping travels out and back, so to find the distance of the
  // object we take half of the distance travelled.
  return microseconds / 29 / 2;
}