Code toegevoegd voor de sgp32 sensor zodat deze wordt geïnitialiseerd

src/Arduino/Sensors/Sensors.ino

@@ -3,6 +3,9 @@
 #include "Adafruit_SGP30.h"
 #include <WiFi.h>
 #include <PubSubClient.h>
+#include <ArduinoWebsockets.h>
+
+using namespace websockets;
 
 Adafruit_SGP30 sgp;
 
@@ -18,86 +21,86 @@ Adafruit_SGP30 sgp;
 DHT dht(DHTPIN, DHTTYPE);
 
 // WiFi en MQTT instellingen
-const char* ssid = "iotroam";
+const char* ssid = "";
-const char* password = "6LAFiQVnUO";
+const char* password = "";
-const char* mqtt_server = "Ip adres rasperry pi";
+
+const char* mqtt_server = "192.168.68.104";
+const int mqtt_port = 8080; //websocket-poort
 const char* mqtt_topic = "sensors/data";
 
 // MQTT client
 WiFiClient espClient;
+WebsocketsClient websocket;
 PubSubClient client(espClient);
 
 // Functie om verbinding te maken met WiFi
 void setup_wifi() {
-  delay(10);
+  Serial.print("Verbinden met WiFi...");
-  Serial.println("Verbinden met WiFi...");
   WiFi.begin(ssid, password);
-
   while (WiFi.status() != WL_CONNECTED) {
     delay(500);
     Serial.print(".");
   }
-  Serial.println("\nWiFi verbonden!");
+  Serial.println("Verbonden!");
 }
 
-// Callback voor MQTT (niet gebruikt in deze toepassing, maar vereist)
+void reconnectMQTT() {
-void callback(char* topic, byte* payload, unsigned int length) {
+  while (!client.connected()) {
-  // Hier kun je reageren op inkomende MQTT-berichten
+    Serial.print("Verbinding maken met MQTT via WebSockets...");
+    if (client.connect("ESP32Client")) {
+      Serial.println("Verbonden!");
+    } else {
+      Serial.print("Fout: ");
+      Serial.print(client.state());
+      delay(5000);
+    }
+  }
 }
+
 void setup() {
   // Start de seriële monitor
   Serial.begin(9600);
   
   dht.begin();
   
-  pinMode(MQ5_PIN, INPUT);
+   pinMode(MQ5_PIN, INPUT);
  
-  Wire.begin(SDA_PIN, SCL_PIN);
+   Wire.begin(SDA_PIN, SCL_PIN);
   Serial.println("SGP30 test");
 
+  // SGP30 initialiseren
+  if (!sgp.begin()) {
+    Serial.println("SGP30 sensor niet gevonden :(");
+    while (1);
+  }
+  if (!sgp.IAQinit()) {
+    Serial.println("SGP30 IAQ-initialisatie mislukt!");
+    while (1);
+  }
+
   // Verbind met WiFi en MQTT-broker
   setup_wifi();
-  client.setServer(mqtt_server, 1883);
+  // Stel MQTT-broker in met websockets
-  client.setCallback(callback);
+  client.setServer(mqtt_server, mqtt_port);
-}
+  reconnectMQTT();
-
-void reconnect() {
-  // Herstel verbinding met MQTT-broker
-  while (!client.connected()) {
-    Serial.print("Verbinding maken met MQTT...");
-    if (client.connect("ArduinoClient")) {
-      Serial.println("Verbonden!");
-    } else {
-      Serial.print("Fout, rc=");
-      Serial.print(client.state());
-      Serial.println(" Probeer opnieuw over 5 seconden...");
-      delay(5000);
-    }
-  }
 }
 
 void loop() {
-  // Zorg ervoor dat MQTT verbonden blijft
+  // Zorgt ervoor dat MQTT verbonden blijft
   if (!client.connected()) {
-    reconnect();
+    reconnectMQTT();
   }
   client.loop();
 
   float h = dht.readHumidity();
   float t = dht.readTemperature();
-  
   int mq5Value = analogRead(MQ5_PIN);
 
-  // Check of de sensorwaarden geldig zijn
+   // Check of de sensorwaarden geldig zijn
-  if (isnan(h) || isnan(t) || isnan(mq5Value)) {
+   if (isnan(h) || isnan(t) || mq5Value < 0) {
-    Serial.println("Fout bij het lezen van de sensors!");
+     Serial.println("Fout bij het lezen van de sensors!");
-    return;
+     return;
-  }
+   }
-
-   if (! sgp.IAQmeasure()) {
-    Serial.println("Measurement failed");
-    return;
-  }
 
    // Maak een JSON-payload
   String payload = "{";