Téléverser les fichiers vers "/"

mqtt_client.php

@@ -0,0 +1,47 @@
+<?php
+require_once 'config.php';
+require_once 'vendor/autoload.php';
+
+use PhpMqtt\Client\MqttClient;
+use PhpMqtt\Client\ConnectionSettings;
+
+function insert_climate($data) {
+    $db = get_db();
+    $stmt = $db->prepare("INSERT INTO climate_data (temperature, humidity, pressure, luminosity) VALUES (?, ?, ?, ?)");
+    $stmt->bind_param("dddd",
+        $data['temperature'],
+        $data['humidity'],
+        $data['pressure'],
+        $data['luminosity']
+    );
+    $stmt->execute();
+    $db->close();
+    echo "Donnée climatique insérée : " . json_encode($data) . "\n";
+}
+
+function insert_security($data) {
+    $db = get_db();
+    $stmt = $db->prepare("INSERT INTO security_events (event_type, location) VALUES (?, ?)");
+    $stmt->bind_param("ss", $data['event_type'], $data['location']);
+    $stmt->execute();
+    $db->close();
+    echo "Événement sécurité inséré : " . json_encode($data) . "\n";
+}
+
+$mqtt = new MqttClient(MQTT_BROKER, MQTT_PORT);
+$settings = (new ConnectionSettings())->setKeepAliveInterval(60);
+$mqtt->connect($settings);
+echo "Connecté au broker MQTT\n";
+
+$mqtt->subscribe(MQTT_TOPIC_CLIMATE, function($topic, $message) {
+    $data = json_decode($message, true);
+    insert_climate($data);
+}, 0);
+
+$mqtt->subscribe(MQTT_TOPIC_SECURITY, function($topic, $message) {
+    $data = json_decode($message, true);
+    insert_security($data);
+}, 0);
+
+$mqtt->loop(true);
+?>