MqttSessionExample.m

Go to the documentation of this file.

#import <Foundation/Foundation.h>
#import "NCNavigineSdk.h"
#import "NCLocationManager.h"
#import "NCNavigationManager.h"
#import "NCMqttSession.h"
#import "NCMqttSessionListener.h"

@interface MqttSessionExample : NSObject <NCMqttSessionListener>
 
@property (nonatomic, strong) NCNavigineSdk *sdk;
@property (nonatomic, strong) NCLocationManager *locationManager;
@property (nonatomic, strong) NCNavigationManager *navigationManager;
@property (nonatomic, strong) NCMqttSession *mqttSession;
 
@end
 
@implementation MqttSessionExample
 
- (instancetype)init {
    self = [super init];
    if (self) {
        [self initializeSdk];
    }
    return self;
}

- (void)initializeSdk {
    @try {
        // [objc_NavigineSdk_getInstance]
        // Get SDK instance
        self.sdk = [NCNavigineSdk getInstance];
        // [objc_NavigineSdk_getInstance]
 
        // [objc_NavigineSdk_setUserHash]
        // Set user hash
        [self.sdk setUserHash:@"USER-HASH-HERE"];
        // [objc_NavigineSdk_setUserHash]
 
        // [objc_NavigineSdk_setServer]
        // Set server URL (optional)
        [self.sdk setServer:@"https://custom.navigine.com"];
        // [objc_NavigineSdk_setServer]
 
        // [objc_NavigineSdk_getLocationManager]
        // Get LocationManager for working with locations
        self.locationManager = [self.sdk getLocationManager];
        // [objc_NavigineSdk_getLocationManager]
 
        // [objc_NavigineSdk_getNavigationManager]
        // Get NavigationManager for working with navigation
        self.navigationManager = [self.sdk getNavigationManager:self.locationManager];
        // [objc_NavigineSdk_getNavigationManager]
 
        // [objc_NavigineSdk_getMqttSession]
        // Create MQTT session for publishing position data
        self.mqttSession = [self.sdk getMqttSession:self.navigationManager];
        // [objc_NavigineSdk_getMqttSession]
 
        if (self.mqttSession != nil) {
            NSLog(@"MqttSession successfully initialized");
        }
    } @catch (NSException *exception) {
        NSLog(@"Error initializing SDK: %@", exception.reason);
    }
}

- (void)demonstrateMqttSessionMethods {
    if (self.mqttSession == nil) {
        NSLog(@"MqttSession not initialized");
        return;
    }
 
    // [objc_MqttSession_addListener]
    // Add MQTT session listener
    [self.mqttSession addListener:self];
    // [objc_MqttSession_addListener]
 
    // [objc_MqttSession_setSubTopic]
    // Set MQTT sub-topic for publishing position data
    // Final topic will be "navigine/mobile/positions/" + subTopic + "/" + deviceId
    [self.mqttSession setSubTopic:@"location1"];
    // [objc_MqttSession_setSubTopic]
 
    // [objc_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
    [self.mqttSession connect:@"mqtt.example.com" port:1883 username:@"username" password:@"password"];
    // [objc_MqttSession_connect]
 
    // Wait for connection
    [NSThread sleepForTimeInterval:2.0];
 
    // [objc_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
    NSString *customTopic = @"custom/device/status";
    NSString *customMessage = [NSString stringWithFormat:@"{\"status\": \"online\", \"timestamp\": %lld}", (long long)([[NSDate date] timeIntervalSince1970] * 1000)];
    [self.mqttSession publish:customTopic message:customMessage];
    // [objc_MqttSession_publish]
}

- (void)demonstrateMqttSessionConfigurations {
    if (self.mqttSession == nil) {
        NSLog(@"MqttSession not initialized");
        return;
    }
 
    NSLog(@"=== MQTT Session Configurations ===");
 
    // Example 1: Connect with default port
    // [objc_MqttSession_setSubTopic]
    // Set sub-topic. Final topic will be "navigine/mobile/positions/location1/{deviceId}"
    [self.mqttSession setSubTopic:@"location1"];
    // [objc_MqttSession_setSubTopic]
    // [objc_MqttSession_connect]
    // Connect to MQTT broker with default port 1883
    [self.mqttSession connect:@"mqtt.example.com" port:1883 username:@"user" password:@"pass"];
    // [objc_MqttSession_connect]
 
    // Wait a bit
    [NSThread sleepForTimeInterval:1.0];
 
    // Disconnect before reconnecting with different config
    // [objc_MqttSession_disconnect]
    // Disconnect from MQTT broker
    [self.mqttSession disconnect];
    // [objc_MqttSession_disconnect]
 
    // Example 2: Connect with SSL port
    // [objc_MqttSession_setSubTopic]
    // Set sub-topic. Final topic will be "navigine/mobile/positions/building-a/{deviceId}"
    [self.mqttSession setSubTopic:@"building-a"];
    // [objc_MqttSession_setSubTopic]
    // [objc_MqttSession_connect]
    // Connect to MQTT broker with SSL port 8883
    [self.mqttSession connect:@"mqtt-secure.example.com" port:8883 username:@"user" password:@"pass"];
    // [objc_MqttSession_connect]
 
    // Wait a bit
    [NSThread sleepForTimeInterval:1.0];
 
    // Example 3: Connect with different sub-topic
    // [objc_MqttSession_setSubTopic]
    // Set different sub-topic. Final topic will be "navigine/mobile/positions/floor_2/{deviceId}"
    [self.mqttSession setSubTopic:@"floor_2"];
    // [objc_MqttSession_setSubTopic]
    // [objc_MqttSession_connect]
    // Connect to MQTT broker
    [self.mqttSession connect:@"mqtt.example.com" port:1883 username:@"user" password:@"pass"];
    // [objc_MqttSession_connect]
}

- (void)demonstrateListenerManagement {
    if (self.mqttSession == nil) {
        NSLog(@"MqttSession not initialized");
        return;
    }
 
    NSLog(@"=== Listener Management ===");
 
    // Create listener objects
    MqttSessionListenerImpl *listener1 = [[MqttSessionListenerImpl alloc] initWithName:@"Listener 1"];
    MqttSessionListenerImpl *listener2 = [[MqttSessionListenerImpl alloc] initWithName:@"Listener 2"];
 
    // [objc_MqttSession_addListener]
    // Add first listener
    [self.mqttSession addListener:listener1];
    // [objc_MqttSession_addListener]
 
    // [objc_MqttSession_addListener]
    // Add second listener
    [self.mqttSession addListener:listener2];
    // [objc_MqttSession_addListener]
 
    // Connect to trigger callbacks
    // [objc_MqttSession_setSubTopic]
    [self.mqttSession setSubTopic:@"location1"];
    // [objc_MqttSession_setSubTopic]
    // [objc_MqttSession_connect]
    [self.mqttSession connect:@"mqtt.example.com" port:1883 username:@"user" password:@"pass"];
    // [objc_MqttSession_connect]
 
    // Wait for connection
    [NSThread sleepForTimeInterval:2.0];
 
    // [objc_MqttSession_publish]
    // Publish custom messages to different topics
    [self.mqttSession publish:@"custom/events" message:@"{\"event\": \"user_action\"}"];
    [self.mqttSession publish:@"custom/logs" message:@"Application started"];
    // [objc_MqttSession_publish]
 
    // Wait for messages to be published
    [NSThread sleepForTimeInterval:1.0];
 
    // [objc_MqttSession_removeListener]
    // Remove first listener
    [self.mqttSession removeListener:listener1];
    // [objc_MqttSession_removeListener]
 
    // [objc_MqttSession_removeListener]
    // Remove second listener
    [self.mqttSession removeListener:listener2];
    // [objc_MqttSession_removeListener]
}

- (void)cleanup {
    if (self.mqttSession != nil) {
        // [objc_MqttSession_removeListener]
        // Remove MQTT session listener
        [self.mqttSession removeListener:self];
        // [objc_MqttSession_removeListener]
 
        // [objc_MqttSession_disconnect]
        // Disconnect from MQTT broker
        [self.mqttSession disconnect];
        // [objc_MqttSession_disconnect]
    }
}

- (void)runExample {
    NSLog(@"=== MqttSession Example ===");
 
    [self demonstrateMqttSessionMethods];
    [self demonstrateMqttSessionConfigurations];
    [self demonstrateListenerManagement];
 
    // Wait a bit for connection events
    [NSThread sleepForTimeInterval:3.0];
 
    [self cleanup];
    NSLog(@"=== Example completed ===");
}
 
#pragma mark - NCMqttSessionListener
 
// [objc_MqttSessionListener_onConnected]
- (void)onConnected {
    NSLog(@"MQTT session connected successfully");
}
// [objc_MqttSessionListener_onConnected]
 
// [objc_MqttSessionListener_onError]
- (void)onError:(NSError *)error {
    NSLog(@"MQTT session error: %@", error.localizedDescription);
}
// [objc_MqttSessionListener_onError]
 
// [objc_MqttSessionListener_onMessagePublished]
- (void)onMessagePublished {
    NSLog(@"Message published successfully");
}
// [objc_MqttSessionListener_onMessagePublished]
 
@end

@interface MqttSessionListenerImpl : NSObject <NCMqttSessionListener>
 
@property (nonatomic, strong) NSString *name;
 
- (instancetype)initWithName:(NSString *)name;
 
@end
 
@implementation MqttSessionListenerImpl
 
- (instancetype)initWithName:(NSString *)name {
    self = [super init];
    if (self) {
        self.name = name;
    }
    return self;
}
 
- (void)onConnected {
    NSLog(@"%@: Connected", self.name);
}
 
- (void)onError:(NSError *)error {
    NSLog(@"%@: Error - %@", self.name, error.localizedDescription);
}
 
- (void)onMessagePublished {
    NSLog(@"%@: Message published", self.name);
}
 
@end

int main(int argc, const char * argv[]) {
    @autoreleasepool {
        MqttSessionExample *example = [[MqttSessionExample alloc] init];
        [example runExample];
    }
    return 0;
}