171 lines
6.0 KiB
Dart
171 lines
6.0 KiB
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;
|
|
// }
|
|
// }
|
|
// }
|