#include <Arduino.h>
#include <WiFi.h>
#include <PubSubClient.h>
int led1 = 2;
int led2 = 4;

const char* ssid = "wokwi-GUEST";
const char* password = " ";
const char* mqtt_server ="broker.hivemq.com";
const uint16_t mqtt_server_port = 1883;
const char* mqttUser = " ";
const char* mqttPassword = " ";
const char* mqttTopicIn_1 = "test/topic/LED1";
const char* mqttTopicIn_2 = "test/topic/LED2";

#define MQTT_TLS_VERIFY 
WiFiClient wifiClient;
PubSubClient mqttClient(wifiClient);

void connect(){
  while(!mqttClient.connected()){
    Serial.print("Attempting MQTT connecting... ");
    String mqttClientID = " ";
    cSetKeepAlive(1000);
    if(mqttClient.connect(mqttClientID.c_str(),mqttUser, mqttPassword)){
      Serial.println("connected!");
      mqttClient.subscribe(mqttTopicIn_1);
      mqttClient.subscribe(mqttTopicIn_2);
    }
    else{
      Serial.print("Fail, rc=");
      Serial.print(mqttClient.State());
      Serial.println("will try agian in 5senconds");
      delay(500);
    }
  }
}
void callback(char* topic, byte* payload, unsigned int lenght){
  String message;
  Serial.print("Message arrived on topic: ");
  Serial.print(topic);
  Serial.print("with payload");
  for(unsigned int i = 0; i< lenght; i++){
    Serial.print((char)payload[i]);
    message += (char)payload[i];
  }
  Serial.println();
}
void setup_wifi(){
  delay(100);
  Serial.println();
  Serial.print("Connecting to ");
  Serial.println(ssid);
  WIFI.begin(ssid, password);
  while(WIFI.State() != WL_connected){
    delay(500);
    Serial.print(".");
  }
  Serial.println("WIFI Connected");
  Serial.println(WIFI.localID());
  Serial.println();
}
void setup() {
  Serial.begin(115200);
  pinMode(led1, OUTPUT);
  pinMode(led2, OUTPUT);
  Setup_wifi();
  mqttClient.setServer(mqtt);
}

void loop() {
  
}