//
|
// TuyaSmartMQTTChannel.h
|
// TuyaSmart
|
//
|
// Created by xucheng on 15/5/30.
|
// Copyright (c) 2015年 Tuya. All rights reserved.
|
//
|
|
#import <Foundation/Foundation.h>
|
#import "TuyaSmartMQTTConfigModel.h"
|
|
@interface TuyaSmartPublishMessageModel : NSObject
|
|
@property (nonatomic, strong) NSString *devId;
|
|
@property (nonatomic, assign) NSTimeInterval time; // time stamp
|
@property (nonatomic, assign) NSInteger protocol; // protocol
|
@property (nonatomic, assign) double pv; // version
|
@property (nonatomic, strong) NSDictionary *body; // body
|
@property (nonatomic, strong) NSString *localKey; // local key
|
@property (nonatomic, assign) NSInteger publishS;// sequence
|
@property (nonatomic, assign) NSInteger publishR;// publish Id
|
|
@end
|
|
@interface TuyaSmartResponseMessageModel : NSObject
|
|
@property (nonatomic, strong) NSString *devId;
|
@property (nonatomic, strong) id message; // mesh array
|
@property (nonatomic, assign) NSInteger protocol; // protocol
|
@property (nonatomic, strong) NSString *type;
|
@property (nonatomic, assign) NSInteger responseS;// sequence
|
@property (nonatomic, assign) NSInteger responseR;// response Id
|
@property (nonatomic, assign) NSTimeInterval time;
|
|
@end
|
|
@class TuyaSmartMQTTChannel;
|
|
/**
|
mqtt connect state
|
*/
|
typedef NS_ENUM (NSInteger, TuyaSmartMqttConnectState){
|
TuyaSmartMqttConnectStateCreated,
|
TuyaSmartMqttConnectStateConnecting,
|
TuyaSmartMqttConnectStateConnected,
|
TuyaSmartMqttConnectStateDisconnecting,
|
TuyaSmartMqttConnectStateClose,
|
TuyaSmartMqttConnectStateError,
|
};
|
|
@protocol TuyaSmartMQTTChannelDelegate <NSObject>
|
|
@optional
|
|
/**
|
* mqtt connection channel state changes
|
* mqtt 连接的状态改变回调
|
*/
|
- (void)mqttChannel:(TuyaSmartMQTTChannel *)mqttChannel connectState:(TuyaSmartMqttConnectState)connectState error:(NSError *)error;
|
|
/**
|
* Receive mqtt data
|
* 收到mqtt消息上报
|
*/
|
- (void)mqttChannel:(TuyaSmartMQTTChannel *)mqttChannel didReceiveMessage:(TuyaSmartResponseMessageModel *)message topic:(NSString *)topic;
|
|
@end
|
|
|
@interface TuyaSmartMQTTChannel : NSObject
|
|
+ (instancetype)sharedInstance;
|
|
/**
|
* connect mqtt host
|
* 建立 mqtt 连接
|
*
|
* @param mqttConfig mqttConfig
|
*/
|
- (void)startConnectToHostWithMqttConfig:(TuyaSmartMQTTConfigModel *)mqttConfig;
|
|
/**
|
* close mqtt host
|
* 关闭mqtt连接
|
*/
|
- (void)close;
|
|
/**
|
* mqtt connect state
|
* mqtt 连接状态
|
*/
|
- (TuyaSmartMqttConnectState)connectState;
|
|
/**
|
* subscribe topic
|
* 订阅主题
|
*
|
* @param topic Topic
|
* @param success Success block
|
* @param failure Failure block
|
*/
|
- (void)subscribeToTopic:(NSString *)topic
|
devInfo:(NSDictionary *)devInfo
|
success:(TYSuccessHandler)success
|
failure:(TYFailureError)failure;
|
|
/**
|
* unsubscribe topic
|
* 取消订阅主题
|
*
|
* @param topic Topic
|
* @param success Success block
|
* @param failure Failure block
|
*/
|
- (void)unsubscribeToTopic:(NSString *)topic
|
success:(TYSuccessHandler)success
|
failure:(TYFailureError)failure;
|
|
/**
|
* 推送mqtt消息
|
* publish mqtt data
|
*
|
* @param data Data
|
* @param topic Topic
|
* @param success Success block
|
* @param failure Failure block
|
* @return the Message Identifier of the publish message. Zero if qos 0. If qos 1 or 2, zero was publish faliure
|
*/
|
- (UInt16)publishMessage:(NSData *)data
|
topic:(NSString *)topic
|
success:(TYSuccessHandler)success
|
failure:(TYFailureError)failure;
|
|
/**
|
* 推送mqtt消息
|
* publish mqtt data
|
*
|
* @param messageModel MessageModel
|
* @param topic Topic
|
* @param success Success block
|
* @param failure Failure block
|
*/
|
- (void)publishMessageWithMessageModel:(TuyaSmartPublishMessageModel *)messageModel
|
topic:(NSString *)topic
|
success:(TYSuccessHandler)success
|
failure:(TYFailureError)failure;
|
|
/**
|
* add mqtt channel delegate
|
* 添加mqtt长连接的代理
|
*
|
* @param delegate Delegate
|
*/
|
- (void)addDelegate:(id<TuyaSmartMQTTChannelDelegate>)delegate;
|
|
/**
|
* remove mqtt channel delegate
|
* 删除mqtt长连接的代理
|
*
|
* @param delegate Delegate
|
*/
|
- (void)removeDelegate:(id<TuyaSmartMQTTChannelDelegate>)delegate;
|
|
@end
|
