import 'package:flutter/material.dart';
import 'mqtt_service.dart';
import 'package:mqtt_client/mqtt_client.dart';

void main() {
  runApp(MyApp());
}

class MyApp extends StatelessWidget {
  @override
  Widget build(BuildContext context) =>
      MaterialApp(home: SensorPage());
}

class SensorPage extends StatefulWidget {
  @override
  _SensorPageState createState() => _SensorPageState();
}

class _SensorPageState extends State<SensorPage> {
  late MqttService mqttService;
  String temp = '--';
  String hum = '--';

  @override
  void initState() {
    super.initState();
    mqttService = MqttService();
    mqttService.connect('آدرس_بروکر_MQTT', 'flutter_client').then((_) {
      mqttService.client.updates?.listen((List<MqttReceivedMessage<MqttMessage>> c) {
        final MqttPublishMessage recMess = c[0].payload as MqttPublishMessage;
        final message =
            MqttPublishPayload.bytesToStringAsString(recMess.payload.message);

        print('Received message: $message');
        // پیام JSON را پارس کن
        final map = jsonDecode(message);
        setState(() {
          temp = map['temp'].toString();
          hum = map['hum'].toString();
        });
      });
    });
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(title: Text('دما و رطوبت')),
      body: Center(
        child: Column(
          mainAxisAlignment: MainAxisAlignment.center,
          children: [
            Text('دما: $temp °C',
                style: TextStyle(fontSize: 24)),
            SizedBox(height: 16),
            Text('رطوبت: $hum %',
                style: TextStyle(fontSize: 24)),
          ],
        ),
      ),
    );
  }
}