/****************************************
 * Libraries
 ****************************************/
 
#include <WiFi.h>
#include <PubSubClient.h>
#include <stdio.h>


/****************************************
 * Define Constants
 ****************************************/

#define TOKEN "BBFF-7EctyYgfSvI2kv1kDrlkjLci8DBMLZ" // Put your Ubidots' TOKEN

#define VARIABLE_LABEL "personas" // Assing the variable label
#define DEVICE_LABEL "RobotDetectorWokwi" // Assig the device label
#define MQTT_CLIENT_NAME "0001" // MQTT client Name, put a Random ASCII

const char* WIFISSID = "Wokwi-GUEST";
const char* PASSWORD = "";

char mqttBroker[] = "industrial.api.ubidots.com";
char payload[700];
char topic[150];

// Space to store values to send
char str_val[6];
char str_val2[6];

// Declaramos el pin al que estará conectado el pulsador y led de señal
int pinPulsador=2;
int pinLed=4;

//cuenta
int personas=0;

/****************************************
 * Initializate constructors for objects
 ****************************************/

//ESP8266WiFiMulti WiFiMulti;
WiFiClient ubidots;
PubSubClient client(ubidots);


/****************************************
 * Auxiliar Functions
 ****************************************/
 
void callback(char* topic, byte* payload, unsigned int length) {} 

void reconnect() {
  // Loop until we're reconnected
  while (!client.connected()) {
  Serial.println("Attempting MQTT connection...");

  // Attempt to connect
  if (client.connect(MQTT_CLIENT_NAME, TOKEN,"")) {
    Serial.println("connected");
  } else {
    Serial.print("failed, rc=");
    Serial.print(client.state());
    Serial.println(" try again in 2 seconds");
    // Wait 2 seconds before retrying
    delay(2000);
  }
  }
}


/****************************************
 * Main Functions
 ****************************************/

void setup() {
  Serial.begin(115200);
  //Contador de personas

  //pin para pulso de positivo
  pinMode(pinPulsador,INPUT);
  pinMode(pinLed,OUTPUT);

  WiFi.begin(WIFISSID, PASSWORD);
  Serial.println();
  Serial.println();
  Serial.print("Wait for WiFi... ");

  while(WiFi.status() != WL_CONNECTED) {
    Serial.print(".");
    delay(500);
  }

  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
  client.setServer(mqttBroker, 1883);
  client.setCallback(callback);
}


void loop() {
  int contador=0;
    
  if (!client.connected()) {
    reconnect();
  }
  //int dato= analogRead(33);//0-4095

   //Si la señal del pulsador es activa encendemos el led
  if (digitalRead(pinPulsador) == HIGH) {
    contador=1;
    personas=personas+contador;
    digitalWrite(pinLed, HIGH);
  } 

  //de lo contrario apagamos el led
  else {
    contador=0;
    digitalWrite(pinLed, LOW);
  }
  
  

  /* 4 is mininum width, 2 is precision; float value is copied onto str_temp*/
  //dtostrf(temperature, 4, 2, str_val);
  //dtostrf(dato, 4, 2, str_val2);
  /*Datos hacia Ubidots*/

  //cabecera
  sprintf(topic, "%s", ""); // Cleans the topic content
  sprintf(topic, "%s%s", "/v1.6/devices/", DEVICE_LABEL);

  //inicio
  sprintf(payload, "%s", ""); // Cleans the payload content
  sprintf(payload, "{\"%s\":", VARIABLE_LABEL); // Adds the variable label   
  sprintf(payload, "%s {\"value\": %s", payload, String(personas)); // Adds the value
  

  //cierre
  sprintf(payload, "%s } }", payload); // Closes the dictionary brackets
  Serial.println(String(payload));
  client.publish(topic, payload);
  client.loop();
  delay(1000);//10000
  }