Uzaktan eyleyiciler ve canlı pano

#include <WiFi.h>
#include <PubSubClient.h>
#include <ArduinoJson.h>

const int RELAY = 26;           // IRF540 kapısı ya da röle modülü girişi
WiFiClient net;
PubSubClient mqtt(net);
uint32_t lastCmdId = 0;         // aynı kimliği ikinci kez uygulama

void report(bool on) {
  // Bildirilen durum kalıcı (retained): yeni bağlanan pano hemen görür
  mqtt.publish("sera/01/fan/state", on ? "{\"on\":true}" : "{\"on\":false}", true);
}

void onMsg(char* topic, byte* data, unsigned int len) {
  JsonDocument doc;
  if (deserializeJson(doc, data, len)) return;    // bozuk JSON: yok say
  uint32_t id = doc["id"] | 0;
  if (id != 0 && id <= lastCmdId) return;         // yinelenen ya da eski komut
  lastCmdId = id;
  bool on = doc["on"] | false;                    // SET: mutlak değer, toggle değil
  digitalWrite(RELAY, on ? HIGH : LOW);
  report(on);                                     // gerçekten uygulanan durumu bildir
}

void setup() {
  pinMode(RELAY, OUTPUT);
  digitalWrite(RELAY, LOW);                       // güvenli varsayılan: kapalı
  mqtt.setCallback(onMsg);
}

void loop() {
  if (!mqtt.connected() && mqtt.connect("sera-01")) mqtt.subscribe("sera/01/fan/set", 1);
  mqtt.loop();
}

import json
from machine import Pin, PWM, I2C
from umqtt.simple import MQTTClient
import ssd1306

servo = PWM(Pin(18), freq=50)                  # SG90: 50 Hz, 0,5 ile 2,5 ms darbe
oled = ssd1306.SSD1306_I2C(128, 64, I2C(0, scl=Pin(22), sda=Pin(21)))
buf, cap, head = [0.0] * 128, 128, 0           # halka tampon: sabit bellek

def on_msg(topic, msg):
    global head
    m = json.loads(msg)
    if topic == b"sera/01/pencere/set":
        aci = max(0, min(90, m["aci"]))        # sınırla: mekanik sonu zorlama
        servo.duty_ns(500_000 + aci * 2_000_000 // 180)
    elif topic == b"sera/01/telemetri":
        buf[head] = m["t"]; head = (head + 1) % cap   # en eski değer ezilir
        oled.fill(0)
        for x in range(cap):
            v = buf[(head + x) % cap]
            oled.pixel(x, 63 - int((v - 10) * 2), 1)  # 10..40 °C ekrana
        oled.show()

c = MQTTClient("pano-01", "broker.local")
c.set_callback(on_msg); c.connect()
c.subscribe(b"sera/01/#")
while True:
    c.wait_msg()