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

#ifndef _DM_MESSAGE_H_
#define _DM_MESSAGE_H_

#include "iotx_dm_internal.h"

#define DM_MSG_KEY_ID                 "id"
#define DM_MSG_KEY_VERSION            "version"
#define DM_MSG_KEY_METHOD             "method"
#define DM_MSG_KEY_PARAMS             "params"
#define DM_MSG_KEY_CODE               "code"
#define DM_MSG_KEY_DATA               "data"
#define DM_MSG_KEY_MESSAGE            "message"

#define DM_MSG_VERSION                "1.0"

#define DM_MSG_KEY_FAILURES           "failures"
#define DM_MSG_KEY_SUCCESSES          "successes"
#define DM_MSG_KEY_ERRORDETAIL        "errorDetail"
#define DM_MSG_KEY_CODE               "code"
#define DM_MSG_KEY_PRODUCT_KEY        "productKey"
#define DM_MSG_KEY_DEVICE_NAME        "deviceName"
#define DM_MSG_KEY_DEVICE_SECRET      "deviceSecret"
#define DM_MSG_KEY_TIME               "time"

#define DM_MSG_SIGN_METHOD_SHA256     "Sha256"
#define DM_MSG_SIGN_METHOD_HMACMD5    "hmacMd5"
#define DM_MSG_SIGN_METHOD_HMACSHA1   "hmacSha1"
#define DM_MSG_SIGN_METHOD_HMACSHA256 "hmacSha256"

typedef enum {
    DM_MSG_DEST_CLOUD = 0x01,
    DM_MSG_DEST_LOCAL = 0x02,
    DM_MSG_DEST_ALL = 0x03
} dm_msg_dest_type_t;

typedef struct {
    const char *uri;
    unsigned char *payload;
    unsigned int payload_len;
    void *context;
} dm_msg_source_t;

typedef struct {
    const char *uri_name;
} dm_msg_dest_t;

typedef struct {
    lite_cjson_t id;
    lite_cjson_t version;
    lite_cjson_t method;
    lite_cjson_t params;
} dm_msg_request_payload_t;

typedef struct {
    lite_cjson_t id;
    lite_cjson_t code;
    lite_cjson_t data;
    lite_cjson_t message;
} dm_msg_response_payload_t;

typedef struct {
    int msgid;
    int devid;
    const char *service_prefix;
    const char *service_name;
    char product_key[IOTX_PRODUCT_KEY_LEN + 1];
    char device_name[IOTX_DEVICE_NAME_LEN + 1];
    char *params;
    int params_len;
    char *method;
    iotx_cm_data_handle_cb callback;
} dm_msg_request_t;

typedef struct {
    const char *service_prefix;
    const char *service_name;
    char product_key[IOTX_PRODUCT_KEY_LEN + 1];
    char device_name[IOTX_DEVICE_NAME_LEN + 1];
    iotx_dm_error_code_t code;
} dm_msg_response_t;

typedef struct {
    int id;
} dm_msg_ctx_t;

int dm_msg_init(void);
int dm_msg_deinit(void);
int _dm_msg_send_to_user(iotx_dm_event_types_t type, char *message);
int dm_msg_send_msg_timeout_to_user(int msg_id, int devid,
                                    iotx_dm_event_types_t type);
int dm_msg_uri_parse_pkdn(_IN_ char *uri, _IN_ int uri_len, _IN_ int start_deli,
                          _IN_ int end_deli,
                          _OU_ char product_key[IOTX_PRODUCT_KEY_LEN + 1],
                          _OU_ char device_name[IOTX_DEVICE_NAME_LEN + 1]);
int dm_msg_request_parse(_IN_ char *payload, _IN_ int payload_len,
                         _OU_ dm_msg_request_payload_t *request);
int dm_msg_response_parse(_IN_ char *payload, _IN_ int payload_len,
                          _OU_ dm_msg_response_payload_t *response);
int dm_msg_request(dm_msg_dest_type_t type, _IN_ dm_msg_request_t *request);
int dm_msg_response(dm_msg_dest_type_t type,
                    _IN_ dm_msg_request_payload_t *request,
                    _IN_ dm_msg_response_t *response, _IN_ char *data,
                    _IN_ int data_len, _IN_ void *user_data);
int dm_msg_thing_model_down_raw(_IN_ char product_key[IOTX_PRODUCT_KEY_LEN + 1],
                                _IN_ char device_name[IOTX_DEVICE_NAME_LEN + 1],
                                _IN_ char *payload, _IN_ int payload_len);
int dm_msg_thing_model_up_raw_reply(
    _IN_ char product_key[IOTX_PRODUCT_KEY_LEN + 1],
    _IN_ char device_name[IOTX_DEVICE_NAME_LEN + 1], char *payload,
    int payload_len);
#if !defined(DEVICE_MODEL_RAWDATA_SOLO)
int dm_msg_property_set(int devid, dm_msg_request_payload_t *request);
#ifndef DEPRECATED_LINKKIT
int dm_msg_property_get(_IN_ int devid, _IN_ dm_msg_request_payload_t *request,
                        _IN_ void *ctx);
#else
int dm_msg_property_get(_IN_ int devid, _IN_ dm_msg_request_payload_t *request,
                        _IN_ char **payload, _IN_ int *payload_len);
#endif
int dm_msg_thing_service_request(
    _IN_ char product_key[IOTX_PRODUCT_KEY_LEN + 1],
    _IN_ char device_name[IOTX_DEVICE_NAME_LEN + 1], char *identifier,
    int identifier_len, dm_msg_request_payload_t *request, _IN_ void *ctx);
int dm_msg_rrpc_request(_IN_ char product_key[IOTX_PRODUCT_KEY_LEN + 1],
                        _IN_ char device_name[IOTX_DEVICE_NAME_LEN + 1],
                        char *messageid, int messageid_len,
                        dm_msg_request_payload_t *request);
int dm_msg_thing_event_property_post_reply(dm_msg_response_payload_t *response);
int dm_msg_thing_event_post_reply(_IN_ char *identifier,
                                  _IN_ int identifier_len,
                                  _IN_ dm_msg_response_payload_t *response);
int dm_msg_thing_deviceinfo_update_reply(dm_msg_response_payload_t *response);
int dm_msg_thing_property_desired_get_reply(
    dm_msg_response_payload_t *response);
int dm_msg_thing_property_desired_delete_reply(
    dm_msg_response_payload_t *response);
int dm_msg_thing_deviceinfo_delete_reply(dm_msg_response_payload_t *response);
int dm_msg_thing_dsltemplate_get_reply(dm_msg_response_payload_t *response);
int dm_msg_thing_dynamictsl_get_reply(dm_msg_response_payload_t *response);
int dm_msg_ntp_response(char *payload, int payload_len);
int dm_msg_ext_error_response(char *payload, int payload_len);
#endif

#ifdef DEVICE_MODEL_GATEWAY
int dm_msg_topo_add_notify(_IN_ char *payload, _IN_ int payload_len);
int dm_msg_thing_disable(_IN_ char product_key[IOTX_PRODUCT_KEY_LEN + 1],
                         _IN_ char device_name[IOTX_DEVICE_NAME_LEN + 1]);
int dm_msg_thing_enable(_IN_ char product_key[IOTX_PRODUCT_KEY_LEN + 1],
                        _IN_ char device_name[IOTX_DEVICE_NAME_LEN + 1]);
int dm_msg_thing_delete(_IN_ char product_key[IOTX_PRODUCT_KEY_LEN + 1],
                        _IN_ char device_name[IOTX_DEVICE_NAME_LEN + 1]);
int dm_msg_thing_gateway_permit(_IN_ char *payload, _IN_ int payload_len);
int dm_msg_thing_sub_register_reply(dm_msg_response_payload_t *response);
int dm_msg_thing_proxy_product_register_reply(
    dm_msg_response_payload_t *response);
int dm_msg_thing_sub_unregister_reply(dm_msg_response_payload_t *response);
int dm_msg_thing_topo_add_reply(dm_msg_response_payload_t *response);
int dm_msg_thing_topo_delete_reply(dm_msg_response_payload_t *response);
int dm_msg_topo_get_reply(dm_msg_response_payload_t *response);
int dm_msg_thing_list_found_reply(dm_msg_response_payload_t *response);
int dm_msg_combine_login_reply(dm_msg_response_payload_t *response);
int dm_msg_combine_logout_reply(dm_msg_response_payload_t *response);
#endif
#ifdef ALCS_ENABLED
int dm_msg_dev_core_service_dev(char **payload, int *payload_len);
#endif
int dm_msg_cloud_connected(void);
int dm_msg_cloud_disconnect(void);
int dm_msg_cloud_reconnect(void);
int dm_msg_register_result(_IN_ char *uri, _IN_ int result);

#ifdef DEVICE_MODEL_GATEWAY
int dm_msg_thing_sub_register(_IN_ char product_key[IOTX_PRODUCT_KEY_LEN + 1],
                              _IN_ char device_name[IOTX_DEVICE_NAME_LEN + 1],
                              _OU_ dm_msg_request_t *request);
int dm_msg_thing_proxy_product_register(
    _IN_ char product_key[IOTX_PRODUCT_KEY_LEN + 1],
    _IN_ char product_secret[IOTX_PRODUCT_SECRET_LEN + 1],
    _IN_ char device_name[IOTX_DEVICE_NAME_LEN + 1],
    _OU_ dm_msg_request_t *request);
int dm_msg_thing_sub_unregister(_IN_ char product_key[IOTX_PRODUCT_KEY_LEN + 1],
                                _IN_ char device_name[IOTX_DEVICE_NAME_LEN + 1],
                                _OU_ dm_msg_request_t *request);
int dm_msg_thing_topo_add(_IN_ char product_key[IOTX_PRODUCT_KEY_LEN + 1],
                          _IN_ char device_name[IOTX_DEVICE_NAME_LEN + 1],
                          _IN_ char device_secret[IOTX_DEVICE_SECRET_LEN + 1],
                          _OU_ dm_msg_request_t *request);
int dm_msg_thing_topo_delete(_IN_ char product_key[IOTX_PRODUCT_KEY_LEN + 1],
                             _IN_ char device_name[IOTX_DEVICE_NAME_LEN + 1],
                             _OU_ dm_msg_request_t *request);
int dm_msg_thing_topo_get(_OU_ dm_msg_request_t *request);
int dm_msg_thing_list_found(_IN_ char product_key[IOTX_PRODUCT_KEY_LEN + 1],
                            _IN_ char device_name[IOTX_DEVICE_NAME_LEN + 1],
                            _OU_ dm_msg_request_t *request);
int dm_msg_combine_login(_IN_ char product_key[IOTX_PRODUCT_KEY_LEN + 1],
                         _IN_ char device_name[IOTX_DEVICE_NAME_LEN + 1],
                         _IN_ char device_secret[IOTX_DEVICE_SECRET_LEN + 1],
                         _OU_ dm_msg_request_t *request);
int dm_msg_combine_logout(_IN_ char product_key[IOTX_PRODUCT_KEY_LEN + 1],
                          _IN_ char device_name[IOTX_DEVICE_NAME_LEN + 1],
                          _OU_ dm_msg_request_t *request);
#endif

int dm_msg_thing_model_user_sub(_IN_ char product_key[IOTX_PRODUCT_KEY_LEN],
                                _IN_ char device_name[IOTX_DEVICE_NAME_LEN],
                                _IN_ char *payload, _IN_ int payload_len);
#endif