Projek Pengering Baju IoT

/*
  Projek Pengering Baru dengan IoT
  Pengarang: https://denshie.com/
*/

#include <ArduinoMqttClient.h>
#include <WiFi.h>
#include <NewPing.h>
#include <ArduinoJson.h>
#include "DHT.h"
#include <Ticker.h>

//+++++++++++++++++++change only below this part+++++++++++++++++++++++++++++++++++++++++
char ssid[] = "wifi_faiz";  // your network SSID (name)
char pass[] = "w1f1fa12";  // your network password (use for WPA, or use as key for WEP)
const char broker[] = "broker.hivemq.com"; //mqtt broket that use
int port = 1883;  // mqtt port
const char topicSub[] = "projekCmd/pengeringBajuIoT";  //topic to receive message
const char topicPub[] = "projekSensor/pengeringBajuIoT";  //topic to send message
//+++++++++++++++++++change only up this part++++++++++++++++++++++++++++++++++++++++++++

#define DHTPIN 22  // Digital pin connected to the DHT sensor

// Uncomment whatever type you're using!
//#define DHTTYPE DHT11   // DHT 11
#define DHTTYPE DHT22  // DHT 22  (AM2302), AM2321
//#define DHTTYPE DHT21   // DHT 21 (AM2301)

#define TRIGGER_PIN 19    // Arduino pin tied to trigger pin on the ultrasonic sensor.
#define ECHO_PIN 18       // Arduino pin tied to echo pin on the ultrasonic sensor.
#define MAX_DISTANCE 200  // Maximum distance we want to ping for (in centimeters). Maximum sensor distance is rated at 400-500cm.

#define relay 13
NewPing sonar(TRIGGER_PIN, ECHO_PIN, MAX_DISTANCE);  // NewPing setup of pins and maximum distance.

DHT dht(DHTPIN, DHTTYPE);

// To connect with SSL/TLS:
// 1) Change WiFiClient to WiFiSSLClient.
// 2) Change port value from 1883 to 8883.
// 3) Change broker value to a server with a known SSL/TLS root certificate
//    flashed in the WiFi module.

WiFiClient wifiClient;
MqttClient mqttClient(wifiClient);
Ticker periodicTicker;

void setup() {
  //Initialize serial and wait for port to open:
  Serial.begin(9600);
  while (!Serial) {
    ;  // wait for serial port to connect. Needed for native USB port only
  }
  Serial.println(F("DHTxx test!"));

  dht.begin();

  // attempt to connect to WiFi network:
  Serial.print("Attempting to connect to WPA SSID: ");
  Serial.println(ssid);
  WiFi.begin(ssid, pass);

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

  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());

  // You can provide a unique client ID, if not set the library uses Arduino-millis()
  // Each client must have a unique client ID
  // mqttClient.setId("clientId");

  // You can provide a username and password for authentication
  // mqttClient.setUsernamePassword("username", "password");

  Serial.print("Attempting to connect to the MQTT broker: ");
  Serial.println(broker);

  if (!mqttClient.connect(broker, port)) {
    Serial.print("MQTT connection failed! Error code = ");
    Serial.println(mqttClient.connectError());

    while (1)
      ;
  }

  Serial.println("You're connected to the MQTT broker!");
  Serial.println();

  // set the message receive callback
  mqttClient.onMessage(onMqttMessage);

  Serial.print("Subscribing to topic: ");
  Serial.println(topicSub);
  Serial.println();

  // subscribe to a topic
  mqttClient.subscribe(topicSub);

  // topics can be unsubscribed using:
  // mqttClient.unsubscribe(topic);

  Serial.print("Waiting for messages on topic: ");
  Serial.println(topicSub);
  Serial.println();
  pinMode(relay, OUTPUT);
  periodicTicker.attach_ms(5000, readSensor);
}

void loop() {
  // call poll() regularly to allow the library to receive MQTT messages and
  // send MQTT keep alives which avoids being disconnected by the broker
  mqttClient.poll();
}

void onMqttMessage(int messageSize) {
  // we received a message, print out the topic and contents
  Serial.println("Received a message with topic '");
  Serial.print(mqttClient.messageTopic());
  Serial.print("', length ");
  Serial.print(messageSize);
  Serial.println(" bytes:");

  // use the Stream interface to print the contents
  while (mqttClient.available()) {
    char cmd = (char)mqttClient.read();
    if (cmd == '1') {
      digitalWrite(relay, 1);
      Serial.println("Relay ON");
    }
    if (cmd == '0') {
      digitalWrite(relay, 0);
      Serial.println("Relay OFF");
    }
    Serial.print((char)mqttClient.read());
  }
  Serial.println();

  Serial.println();
}

void readSensor() {
  // Reading temperature or humidity takes about 250 milliseconds!
  // Sensor readings may also be up to 2 seconds 'old' (its a very slow sensor)
  float h = dht.readHumidity();
  // Read temperature as Celsius (the default)
  float t = dht.readTemperature();
  float d = sonar.ping_cm();
  int r = digitalRead(relay);

  // Check if any reads failed and exit early (to try again).
  if (isnan(h) || isnan(t)) {
    h = 0.0;
    t = 0.0;
  }

  // Allocate the JSON document
  JsonDocument doc;

  // Add values in the document
  doc["kelembapan"] = h;
  doc["suhu"] = t;
  doc["jarak"] = d;
  doc["relay"] = r;


  // Generate the minified JSON and send it to the Serial port
  mqttClient.beginMessage(topicPub);
  serializeJson(doc, mqttClient);
  mqttClient.endMessage();
  // The above line prints:
  // {"kelembapan":123,"suhu":135, "jarak":234, "relay":1}
}