# 设备SDK使用说明（CPP）

/**
* @brief 设备认证信息
*/
struct DeviceAuth
{
    std::string productKey;     ///产品key
    std::string deviceId;       ///设备ID
    std::string deviceSecret;   ///设备密钥
};

/**
* @brief 连接配置信息
*
*/
struct IoTConfig
{
    std::string     host;       ///broker地址
    std::string     version;    ///本地固件版本

    DeviceAuth      device;     ///设备认证信息
    OnConnectState  callback;   ///连接状态回调
};

/**
* @brief 基础信息
*
*/
struct TslBasic
{
    std::string traceId;        ///请求唯一ID
    std::string version;        ///协议版本
    std::string deviceId;       ///设备ID（请求时，如果是网关的子设备则需要填写）
};

/**
* @brief 请求参数
*
*/
struct TslRequest
{
    std::string method;         ///服务名
    std::string params;         ///参数 JSON Object
};

/**
* @brief 回应
*
*/
struct TslResponse
{
    std::string code    = "170000";  ///回应码，000000表示成功，17属于SDK段错误码
    std::string message = "null";    ///回应码描述
    std::string data    = "null";    ///响应 JSON Object
};

//构造及析构
IoTMqtt(const IoTConfig &config);
~IoTMqtt();

//MQTT连接及认证
//开始连接，失败会自动重连（min, max之间的间隔，第一次重连间隔为min，以后为min*2，直到max）
void Connect(int minRetryInterval = 2, int maxRetryInterval = 60);
bool IsConnected();

//上报日志到grail
void Postlog2Grail(const GrailLog &log);

//设置日志回调
static void SetLogCallback(const MLogCallBack &callback);

/************************************************************************/
/* 下行（云端 -> 设备）                                                   */
/************************************************************************/
void SetPropertySetCallback(const OnTslRequest &callback);  //设置设置属性回调
void SetPropertyGetCallback(const OnTslRequest &callback);  //设置获取属性回调
void SetServiceCallback(const OnTslRequest &callback);      //设置服务调用回调
bool SubscribeCustom(const std::string &topic, const OnCustomTopic &callback);  //订阅自定义主题

/************************************************************************/
/* 上行（设备 -> 云端）                                                   */
/************************************************************************/
bool PropertyPost(const TslBasic &basic, const TslRequest &req);                    //属性上报
bool EventPost(const TslBasic &basic, const TslRequest &req);                       //事件上报
bool PropertyGet(const TslBasic &basic, const TslRequest &req, TslResponse &res);   //上行属性获取
bool ServiceCall(const TslBasic &basic, const TslRequest &req, TslResponse &res);   //上行服务调用
bool PublishCustom(const std::string &topic, const std::string &traceId, const std::string &params); //发布自定义主题

/************************************************************************/
/* 网关类设备                                                            */
/************************************************************************/
bool GetSubDevice(const TslBasic &basic, std::list<DeviceAuth> &devs); //获取网关下挂子设备
bool AddSubDevice(const TslBasic &basic, const DeviceAuth &dev);       //添加网关子设备
bool DelSubDevice(const TslBasic &basic, const DeviceAuth &dev);       //删除网关子设备

bool OnlineSubDevice(const TslBasic &basic, const DeviceAuth &dev);    //上线子设备（包括认证）
bool OfflineSubDevice(const TslBasic &basic, const DeviceAuth &dev);   //下线子设备

#include <iostream>
#include <functional>
#include <stdio.h>
#include "../src/mqtt/iot_http.h"
#include "../src/mqtt/iot_mqtt.h"

#ifdef WIN32
#include <Windows.h>
#else
#include <unistd.h>
#endif

using namespace std;

void OnTslRequestCallback(const std::string &topic, const TslBasic &basic, const TslRequest &req, TslResponse &res)
{
    std::cout << "[mqtt]topic:" << topic << " traceid:" << basic.traceId << " method:" << req.method << " params:" << req.params << " version:" << basic.version << endl;
    //处理req返回res
}

void MyLogCallBack(const char *file, int line, const char *func, int severity, const char *content)
{
    std::cout << "[" << func << ":" << line << "]" << content << endl;
}

int main()
{
    //log
    IoTMqtt::SetLogCallback(MyLogCallBack);

    //注册
    IoTHttp http("http://iot.test.seewo.com/iot-platform-register-service/register");
    http.AddIdentifier("uid", { "xxx-1234","xxxx-2345" });
    ProductAuth product;
    product.productKey = "1_29232629e9a";
    product.productSecret = "95580bf558e94d84";
    DeviceAuth device;
    auto regRet = http.DeviceRegister(product, device);
    if (!regRet)
    {
        cerr << "register failed" << endl;
    }
    std::cout << "register successed:" << device.deviceId << endl;

    //认证
    IoTConfig config;
    config.host = "ssl://iot-broker.test.seewo.com:8883";
    config.device = { "1_29232629e9a","292485855732375552","b56ac88cabdc0f0d" };
    config.callback = nullptr;
    config.version = "1.0.0";

    IoTMqtt mqtt(config);
    auto conRet = mqtt.Connect();
    if (!conRet)
    {
        std::cout << "mqtt connect failed" << endl;
        return 2;
    }

    std::cout << "mqtt connect successed 1" << endl;
    mqtt.SetPropertyGetCallback(OnTslRequestCallback);
    mqtt.SetPropertySetCallback(OnTslRequestCallback);
    mqtt.SetServiceCallback(OnTslRequestCallback);

    std::cout << "mqtt connect successed 2" << endl;

    //发布
    TslRequest req;
    req.method = "thing.property.post";
    req.params = " {\"color\": \"red\",\"electricity\" : 30}";

    TslBasic basic;
    basic.version = "1.0.0";
    basic.traceId = "123456789";

    while (true)
    {
        auto postRet = mqtt.PropertyPost(basic, req);
        if (!postRet)
        {
            std::cout << "mqtt publish failed" << endl;
        }
        else
        {
            std::cout << "mqtt publish successed" << endl;
        }

#ifdef WIN32
        Sleep(3000);
#else
        sleep(3);
#endif
    }

    return 0;
}