#include <stdio.h>
#include <stdlib.h>
#include <sys/stat.h>
#include <sys/select.h>
#include <sys/time.h>
#include <sys/types.h>
#include <unistd.h>
#include "dy_utils/dy_common.h"
#include "common.h"
#include "dy_utils/cJSON.h"


static void external_subscribe_all(tianhang_var_t *var)
{
}

// 建立与broker之间的MQTT连接
int external_client_init(tianhang_var_t *var, char *filename)
{
    char clientId[MAX_CLIENT_ID_LEN] = {0};

    snprintf(clientId, MAX_CLIENT_ID_LEN, "tianhang_ext_%s", var->sn_str);
    var->session_ext = mqtt_session_new(clientId, (void *)var);
    if (var->session_ext == NULL) return -1;

    load_server_config(var->session_ext, filename);
    mqtt_session_set_opts(var->session_ext, DEFAULT_QOS, KEEPALIVEINTERVAL);
    mqtt_session_set_callbacks(var->session_ext, NULL, NULL);

    mqtt_session_start(var->session_ext);
    external_subscribe_all(var);
}