import serial
import paho.mqtt.client as mqtt

SERIAL_PORT = "COM3"
SERIAL_SPEED = 9600          # 調べて変更する事

MQTT_HOST = "192.168.1.20"   # MQTT BrokerのIP
MQTT_PORT = 1883
MQTT_TOPIC = "sensor/uno01/environment"

client = mqtt.Client(
    mqtt.CallbackAPIVersion.VERSION2,
    client_id="win-serial2mqtt"
)

client.connect(MQTT_HOST, MQTT_PORT, 60)
client.loop_start()

with serial.Serial(SERIAL_PORT, SERIAL_SPEED, timeout=5) as ser:
    while True:
        line = ser.readline()

        if not line:
            continue

        try:
            text = line.decode("utf-8").strip()
        except UnicodeDecodeError:
            continue

        if not text:
            continue

        print("serial:", text)

        client.publish(
            MQTT_TOPIC,
            text,
            qos=0,
            retain=False
        )