#include <SPI.h>
#include <Ethernet.h>
#include <PubSubClient.h>

#include <OneWire.h>
#include <DallasTemperature.h>
#include "ACS712.h"

//Konfiguracja ETHERNET
byte mac[] = { 0xDE, 0xED, 0xBA, 0xFE, 0xFE, 0xED };
IPAddress ip(192, 168, 0, 200);

//Konfiguracja MQTT
IPAddress server(192, 168, 0, 54);
IPAddress port(1883);
#define CLIENT_NAME "NOD - GNIAZDKO-KORYTARZ-1"
#define CLIENT_ID "korytarz/gniazdko/1"
#define LOGIN_MQTT "darevil"
#define HASLO_MQTT "darevil"

//Wyprowadzenia pinów
#define SSR_PRZYCISK    PB1
#define ACS712_PIN      PC0
#define SSR_PIN         PC2
#define ONE_WIRE_BUS    PD2
#define ETHERNET_LED    PD5
#define MQTT_LED        PD6
#define SSR_LED         PD7

//DS18B20
#define TEMPERATURE_PRECISION 10
OneWire oneWire(ONE_WIRE_BUS);
DallasTemperature sensors(&oneWire);

//ACS712
ACS712 sensor(ACS712_30A, ACS712_PIN);

void callback(char* topic, byte* payload, unsigned int length) {
  Serial.print("Wiadomość dotarła [");
  Serial.print(topic);
  Serial.print("] ");

  int i=0;
  for(i=0;i<length;i++) {
    Serial.print((char)payload[i]);
    message_buff[i] = payload[i];
  }
  message_buff[i] = '\0';
  String msgString = String(message_buff);

  if(msgString.equals("ON")) {
    digitalWrite(SSR_PIN, HIGH);
    digitalWrite(SSR_LED, HIGH);
    client.publish(CLIENT_ID"/command", "Przekaźnik włączony");
  }
  else if(msgString.equals("OFF")) {
    digitalWrite(SSR_PIN, LOW);
    digitalWrite(SSR_LED, LOW);
    client.publish(CLIENT_ID"/command", "Przekaźnik wyłączony");
  }
  Serial.println("");
}

EthernetClient ethClient;
PubSubClient client(ethClient);

long lastReconnectAttempt = 0;