mqtt_session_example.dart

Go to the documentation of this file.

import 'dart:async';
import 'package:navigine_sdk/navigine_sdk.dart';

class MqttSessionExample {
  NavigineSdk? _sdk;
  LocationManager? _locationManager;
  NavigationManager? _navigationManager;
  MqttSession? _mqttSession;
  MqttSessionListener? _mqttSessionListener;
 
  MqttSessionExample() {
    _initializeSdk();
    _setupMqttSessionListener();
  }

  void _initializeSdk() {
    try {
      // [dart_NavigineSdk_getInstance]
      // Get SDK instance
      _sdk = NavigineSdk.getInstance();
      // [dart_NavigineSdk_getInstance]
 
      // [dart_NavigineSdk_setUserHash]
      // Set user hash
      _sdk?.setUserHash("USER-HASH-HERE");
      // [dart_NavigineSdk_setUserHash]
 
      // [dart_NavigineSdk_setServer]
      // Set server URL (optional)
      _sdk?.setServer("https://custom.navigine.com");
      // [dart_NavigineSdk_setServer]
 
      // [dart_NavigineSdk_getLocationManager]
      // Get LocationManager for working with locations
      _locationManager = _sdk?.getLocationManager();
      // [dart_NavigineSdk_getLocationManager]
 
      // [dart_NavigineSdk_getNavigationManager]
      // Get NavigationManager for working with navigation
      _navigationManager = _sdk?.getNavigationManager(_locationManager!);
      // [dart_NavigineSdk_getNavigationManager]
 
      // [dart_NavigineSdk_getMqttSession]
      // Create MQTT session for publishing position data
      _mqttSession = _sdk?.getMqttSession(_navigationManager!);
      // [dart_NavigineSdk_getMqttSession]
 
      if (_mqttSession != null) {
        print("MqttSession successfully initialized");
      }
    } catch (e) {
      print("Error initializing SDK: $e");
    }
  }

  void _setupMqttSessionListener() {
    _mqttSessionListener = MqttSessionListener(
      // [dart_MqttSessionListener_onConnected]
      onConnected: () {
        print("MQTT session connected successfully");
      },
      // [dart_MqttSessionListener_onConnected]
      // [dart_MqttSessionListener_onError]
      onError: (Error error) {
        print("MQTT session error: ${error.message}");
      },
      // [dart_MqttSessionListener_onError]
      // [dart_MqttSessionListener_onMessagePublished]
      onMessagePublished: () {
        print("Message published successfully");
      },
      // [dart_MqttSessionListener_onMessagePublished]
    );
  }

  Future<void> demonstrateMqttSessionMethods() async {
    if (_mqttSession == null) {
      print("MqttSession not initialized");
      return;
    }
 
    if (_mqttSessionListener == null) return;
 
    // [dart_MqttSession_addListener]
    // Add MQTT session listener
    _mqttSession!.addListener(_mqttSessionListener!);
    // [dart_MqttSession_addListener]
 
    // [dart_MqttSession_setSubTopic]
    // Set MQTT sub-topic for publishing position data
    // Final topic will be "navigine/mobile/positions/" + subTopic + "/" + deviceId
    _mqttSession!.setSubTopic("location1");
    // [dart_MqttSession_setSubTopic]
 
    // [dart_MqttSession_connect]
    // Connect to MQTT broker
    // Server: MQTT broker hostname or IP address
    // Port: MQTT broker port (typically 1883 for non-SSL, 8883 for SSL)
    // Username: MQTT broker username for authentication
    // Password: MQTT broker password for authentication
    _mqttSession!.connect("mqtt.example.com", 1883, "username", "password");
    // [dart_MqttSession_connect]
 
    // Wait for connection
    await Future.delayed(Duration(seconds: 2));
 
    // [dart_MqttSession_publish]
    // Publish a custom message to a specific MQTT topic
    // The message will be sent asynchronously and the result will be notified through listener callbacks
    String customTopic = "custom/device/status";
    String customMessage = '{"status": "online", "timestamp": ${DateTime.now().millisecondsSinceEpoch}}';
    _mqttSession!.publish(customTopic, customMessage);
    // [dart_MqttSession_publish]
  }

  Future<void> demonstrateMqttSessionConfigurations() async {
    if (_mqttSession == null) {
      print("MqttSession not initialized");
      return;
    }
 
    print("=== MQTT Session Configurations ===");
 
    // Example 1: Connect with default port
    // [dart_MqttSession_setSubTopic1]
    // Set sub-topic. Final topic will be "navigine/mobile/positions/location1/{deviceId}"
    _mqttSession!.setSubTopic("location1");
    // [dart_MqttSession_setSubTopic1]
    // [dart_MqttSession_connect1]
    // Connect to MQTT broker with default port 1883
    _mqttSession!.connect("mqtt.example.com", 1883, "user", "pass");
    // [dart_MqttSession_connect1]
 
    // Wait a bit
    await Future.delayed(Duration(seconds: 1));
 
    // Disconnect before reconnecting with different config
    // [dart_MqttSession_disconnect]
    // Disconnect from MQTT broker
    _mqttSession!.disconnect();
    // [dart_MqttSession_disconnect]
 
    // Example 2: Connect with SSL port
    // [dart_MqttSession_setSubTopic2]
    // Set sub-topic. Final topic will be "navigine/mobile/positions/building-a/{deviceId}"
    _mqttSession!.setSubTopic("building-a");
    // [dart_MqttSession_setSubTopic2]
    // [dart_MqttSession_connect2]
    // Connect to MQTT broker with SSL port 8883
    _mqttSession!.connect("mqtt-secure.example.com", 8883, "user", "pass");
    // [dart_MqttSession_connect2]
 
    // Wait a bit
    await Future.delayed(Duration(seconds: 1));
 
    // Example 3: Connect with different sub-topic
    // [dart_MqttSession_setSubTopic3]
    // Set different sub-topic. Final topic will be "navigine/mobile/positions/floor_2/{deviceId}"
    _mqttSession!.setSubTopic("floor_2");
    // [dart_MqttSession_setSubTopic3]
    // [dart_MqttSession_connect3]
    // Connect to MQTT broker
    _mqttSession!.connect("mqtt.example.com", 1883, "user", "pass");
    // [dart_MqttSession_connect3]
  }

  Future<void> demonstrateListenerManagement() async {
    if (_mqttSession == null) {
      print("MqttSession not initialized");
      return;
    }
 
    print("=== Listener Management ===");
 
    // Add multiple listeners
    MqttSessionListener listener1 = MqttSessionListener(
      onConnected: () {
        print("Listener 1: Connected");
      },
      onError: (Error error) {
        print("Listener 1: Error - ${error.message}");
      },
      onMessagePublished: () {
        print("Listener 1: Message published");
      },
    );
 
    MqttSessionListener listener2 = MqttSessionListener(
      onConnected: () {
        print("Listener 2: Connected");
      },
      onError: (Error error) {
        print("Listener 2: Error - ${error.message}");
      },
      onMessagePublished: () {
        print("Listener 2: Message published");
      },
    );
 
    // [dart_MqttSession_addListener1]
    // Add first listener
    _mqttSession!.addListener(listener1);
    // [dart_MqttSession_addListener1]
 
    // [dart_MqttSession_addListener2]
    // Add second listener
    _mqttSession!.addListener(listener2);
    // [dart_MqttSession_addListener2]
 
    // Connect to trigger callbacks
    // [dart_MqttSession_setSubTopic4]
    _mqttSession!.setSubTopic("location1");
    // [dart_MqttSession_setSubTopic4]
    // [dart_MqttSession_connect4]
    _mqttSession!.connect("mqtt.example.com", 1883, "user", "pass");
    // [dart_MqttSession_connect4]
 
    // Wait for connection
    await Future.delayed(Duration(seconds: 2));
 
    // [dart_MqttSession_publish1]
    // Publish custom messages to different topics
    _mqttSession!.publish("custom/events", '{"event": "user_action"}');
    _mqttSession!.publish("custom/logs", "Application started");
    // [dart_MqttSession_publish1]
 
    // Wait for messages to be published
    await Future.delayed(Duration(seconds: 1));
 
    // [dart_MqttSession_removeListener]
    // Remove first listener
    _mqttSession!.removeListener(listener1);
    // [dart_MqttSession_removeListener]
 
    // [dart_MqttSession_removeListener1]
    // Remove second listener
    _mqttSession!.removeListener(listener2);
    // [dart_MqttSession_removeListener1]
  }

  void cleanup() {
    if (_mqttSession != null) {
      // [dart_MqttSession_removeListener2]
      // Remove MQTT session listener
      if (_mqttSessionListener != null) {
        _mqttSession!.removeListener(_mqttSessionListener!);
      }
      // [dart_MqttSession_removeListener2]
 
      // [dart_MqttSession_disconnect1]
      // Disconnect from MQTT broker
      _mqttSession!.disconnect();
      // [dart_MqttSession_disconnect1]
    }
  }

  Future<void> runExample() async {
    print("=== MqttSession Example ===");
 
    await demonstrateMqttSessionMethods();
    await demonstrateMqttSessionConfigurations();
    await demonstrateListenerManagement();
 
    // Wait a bit for connection events
    await Future.delayed(Duration(seconds: 3));
 
    cleanup();
    print("=== Example completed ===");
  }
}

Future<void> main() async {
  MqttSessionExample example = MqttSessionExample();
  await example.runExample();
}