/*
 * Copyright (C) 2015-2018 Alibaba Group Holding Limited
 */

#ifndef _IOTX_CM_INTERNAL_H_
#define _IOTX_CM_INTERNAL_H_

#include <string.h>

#include "linkkit/infra/infra_config.h"
#include "linkkit/infra/infra_types.h"
#include "linkkit/infra/infra_defs.h"
#include "linkkit/infra/infra_list.h"
#include "linkkit/infra/infra_compat.h"
#include "linkkit/infra/infra_timer.h"

#include "linkkit/wrappers/wrappers.h"
#include "linkkit/mqtt_api.h"

#include "iotx_cm.h"

#ifdef INFRA_MEM_STATS
#include "linkkit/infra/infra_mem_stats.h"
#define cm_malloc(size) LITE_malloc(size, MEM_MAGIC, "cm")
#define cm_free(ptr)    LITE_free(ptr)
#else
#define cm_malloc(size) HAL_Malloc(size)
#define cm_free(ptr)           \
    {                          \
        HAL_Free((void *)ptr); \
        ptr = NULL;            \
    }
#endif

#ifdef INFRA_LOG
#include "linkkit/infra/infra_log.h"
#define cm_debug(...)   log_debug("CM", __VA_ARGS__)
#define cm_info(...)    log_info("CM", __VA_ARGS__)
#define cm_warning(...) log_warning("CM", __VA_ARGS__)
#define cm_err(...)     log_err("CM", __VA_ARGS__)
#else
#define cm_debug(...)            \
    do {                         \
        HAL_Printf(__VA_ARGS__); \
        HAL_Printf("\r\n");      \
    } while (0)
#define cm_info(...)             \
    do {                         \
        HAL_Printf(__VA_ARGS__); \
        HAL_Printf("\r\n");      \
    } while (0)
#define cm_warning(...)          \
    do {                         \
        HAL_Printf(__VA_ARGS__); \
        HAL_Printf("\r\n");      \
    } while (0)
#define cm_err(...)              \
    do {                         \
        HAL_Printf(__VA_ARGS__); \
        HAL_Printf("\r\n");      \
    } while (0)
#endif

typedef int (*iotx_cm_connect_fp)(uint32_t timeout);
typedef int (*iotx_cm_yield_fp)(unsigned int timeout);
typedef int (*iotx_cm_sub_fp)(iotx_cm_ext_params_t *params, const char *topic,
                              iotx_cm_data_handle_cb topic_handle_func,
                              void *pcontext);
typedef int (*iotx_cm_unsub_fp)(const char *topic);
typedef int (*iotx_cm_pub_fp)(iotx_cm_ext_params_t *params, const char *topic,
                              const char *payload, unsigned int payload_len);
typedef int (*iotx_cm_close_fp)();

typedef struct iotx_connection_st {
    int fd;
    void *open_params;
    void *context;
    void *list_lock;
    iotx_cm_protocol_types_t protocol_type;
    iotx_cm_connect_fp connect_func;
    iotx_cm_sub_fp sub_func;
    iotx_cm_unsub_fp unsub_func;
    iotx_cm_pub_fp pub_func;
    iotx_cm_yield_fp yield_func;
    iotx_cm_close_fp close_func;
    iotx_cm_event_handle_cb event_handler;
    void *cb_data;

} iotx_cm_connection_t;

#include "iotx_cm_mqtt.h"

extern const char ERR_INVALID_PARAMS[];
#endif /* _LINKKIT_CM_H_ */