smartfarming-mobile/agrilink_vocpro/lib/domain/service/mqtt_service.dart

import 'dart:convert';

import 'package:agrilink_vocpro/core/constant/app_constant.dart';
import 'package:agrilink_vocpro/core/state/result_state.dart';
import 'package:mqtt_client/mqtt_client.dart';
import 'package:mqtt_client/mqtt_server_client.dart';

class MQTTService {
  MqttServerClient? client;

  Future<ResultState> setupMqtt() async {
    client = MqttServerClient(AppConstant.mqttServer, '');
    client!.port = 1883;

    client!.connectionMessage = MqttConnectMessage()
        .authenticateAs(AppConstant.mqttUsername, AppConstant.mqttPassword)
        .withClientIdentifier('mobile_client_controller')
        .startClean() // reset session
        .withWillQos(MqttQos.atLeastOnce);

    try {
      print('MQTT: Connecting....');
      await client!.connect();
      print('MQTT: Connected');
      return ResultState.hasData;
    } catch (e) {
      print('MQTT: Error: $e');
      return ResultState.error;
    }
  }

  Future<ResultState> publishMessage(String topic, String message) async {
    final builder = MqttClientPayloadBuilder();

    try {
      final bool isConnected = await isMqttConnected(); // Cek apakah terhubung
      if (!isConnected) {
        print('MQTT: Tidak terhubung ke broker. Tidak bisa publish message.');
        return ResultState.error;
      }

      print('MQTT: Published message to $topic: $message');
      builder.addString(message);
      client!.publishMessage(topic, MqttQos.atMostOnce, builder.payload!);
      print('MQTT: Message published');
      return ResultState.hasData;
    } catch (e) {
      print('MQTT: Error: $e');
      return ResultState.error;
    }
  }

  Future<ResultState> disconnectMqtt() async {
    final bool isConnected = await isMqttConnected();
    if (isConnected) {
      print('Memutus koneksi dari broker...');

      client!.disconnect();

      await Future.delayed(const Duration(seconds: 1));
      print('Koneksi telah terputus.');
      return ResultState.hasData;
    } else {
      print('Tidak ada koneksi yang sedang aktif.');
      return ResultState.error;
    }
  }

  Future<bool> isMqttConnected() async {
    if (client != null &&
        client!.connectionStatus!.state == MqttConnectionState.connected) {
      return true; //connected
    } else {
      return false; //not connected
    }
  }

  Future<bool> subscribeToTopic(String topic) async {
    bool isActive = false;
    if (client != null &&
        client!.connectionStatus!.state == MqttConnectionState.connected) {
      try {
        print('MQTT: Subscribing to $topic');
        client!.subscribe(topic, MqttQos.atMostOnce);
        print('MQTT: Subscribed to $topic');

        // Tambahkan log ini untuk memastikan bahwa listener dijalankan
        if (client!.updates != null) {
          print('MQTT: Listening for updates...');
        } else {
          print('MQTT: No updates stream available');
        }

        client!.updates!.listen(
          (List<MqttReceivedMessage<MqttMessage?>>? messages) {
            print('MQTT: Subscribe Message received!');
            if (messages != null && messages.isNotEmpty) {
              final MqttPublishMessage recMessage =
                  messages[0].payload as MqttPublishMessage;
              final String payload = MqttPublishPayload.bytesToStringAsString(
                  recMessage.payload.message);
              print(
                  'MQTT: Subscribe Message received on topic ${messages[0].topic}: $payload');

              if (payload == 'ON') {
                isActive = true;
                // Update UI atau provider untuk menandakan relay ON
              } else if (payload == 'OFF') {
                isActive = false;
                // Update UI atau provider untuk menandakan relay OFF
              } else {
                print('MQTT: Invalid Subscribe message received');
              }
            } else {
              print('MQTT: No Subscribe messages received');
            }
          },
        );

        return isActive;
      } catch (e) {
        print('MQTT: Error subscribing to $topic: $e');
        return isActive;
      }
    } else {
      print('MQTT: Not connected, cannot subscribe.');
      return false;
    }
  }

  Future<ResultState> subscribeToRelayStatus() async {
    if (client != null &&
        client!.connectionStatus!.state == MqttConnectionState.connected) {
      try {
        print('MQTT: Subscribing to /smartfarming/getRelayStatus');
        client!.subscribe('smartfarming/getRelayStatus', MqttQos.atMostOnce);
        print('MQTT: Subscribed to /smartfarming/getRelayStatus');

        client!.updates!
            .listen((List<MqttReceivedMessage<MqttMessage?>>? messages) {
          if (messages != null && messages.isNotEmpty) {
            final MqttPublishMessage recMessage =
                messages[0].payload as MqttPublishMessage;
            final String payload = MqttPublishPayload.bytesToStringAsString(
                recMessage.payload.message);
            print(
                'MQTT: Message received on topic ${messages[0].topic}: $payload');

            // Parse the received JSON payload
            final Map<String, dynamic> relayStatus = jsonDecode(payload);

            print('MQTT: Relay status: $relayStatus');

            // Assuming you are using provider, notify it with new relay status
            // _updateRelayStatus(relayStatus);
          } else {
            print('MQTT: No messages received');
          }
        });
        return ResultState.hasData;
      } catch (e) {
        print('MQTT: Error subscribing: $e');
        return ResultState.error;
      }
    } else {
      print('MQTT: Not connected, cannot subscribe.');
      return ResultState.error;
    }
  }
}