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



#ifndef _IOT_EXPORT_ALCS_BACKUP_H_
#define _IOT_EXPORT_ALCS_BACKUP_H_

#define IOTX_ALCS_ROLE_CLIENT (0x01)
#define IOTX_ALCS_ROLE_SERVER (0x02)

#define ALCS_MSG_MAX_TOKEN_LEN (8)

typedef enum {

    /*iotx_alcs_send Message Result And Receive Message*/
    IOTX_ALCS_EVENT_MSG_SEND_MESSAGE_SUCCESS,
    IOTX_ALCS_EVENT_MSG_SEND_MESSAGE_RESP_TIMEOUT,
    IOTX_ALCS_EVENT_MSG_RECV_MESSAGE,
    /*Its data type is @iotx_alcs_transfer_msg_t and see detail at the declare of this type.*/

} iotx_alcs_event_type_t;

typedef struct iotx_alcs_event_msg_st {

    /* Specify the event type */
    iotx_alcs_event_type_t  event_type;

    void *msg;
} iotx_alcs_event_msg_t, *iotx_alcs_event_msg_pt;

typedef struct iotx_alcs_transfer_msg_st {
    char *ip;
    uint16_t port;
    char *uri;
    uint8_t token_len;
    uint8_t *token;
    uint16_t payload_len;
    uint8_t *payload;
} iotx_alcs_transfer_msg_t, *iotx_alcs_transfer_msg_pt;

typedef void (*iotx_alcs_event_handle_func_fpt)(void *pcontext, void *phandle, iotx_alcs_event_msg_t *msg);

typedef struct {
    iotx_alcs_event_handle_func_fpt h_fp;
    void *pcontext;
} iotx_alcs_event_handle_t;

typedef struct iotx_alcs_param_st {
    uint8_t role;                  /*can be client, server or both*/

    uint8_t        send_maxcount;  /*list maximal count*/
    uint8_t        obs_maxcount;   /*observe maximal count*/
    uint16_t       port;           /* Local port */
    char           *group;         /* Multicast address */
    uint32_t       waittime;
    uint8_t        res_maxcount;

    iotx_alcs_event_handle_t *handle_event;
} iotx_alcs_param_t, *iotx_alcs_param_pt;

#define ITOX_ALCS_COAP_MSG_CODE_DEF(N) (((N)/100 << 5) | (N)%100)

/*CoAP Message codes*/
typedef enum {
    /* CoAP Empty Message */
    ITOX_ALCS_COAP_MSG_CODE_EMPTY_MESSAGE                  = ITOX_ALCS_COAP_MSG_CODE_DEF(0),  /* Mapping to CoAP code 0.00 */

    /* CoAP Method Codes */
    ITOX_ALCS_COAP_MSG_CODE_GET                            = ITOX_ALCS_COAP_MSG_CODE_DEF(1),  /* CoAP Get method */
    ITOX_ALCS_COAP_MSG_CODE_POST                           = ITOX_ALCS_COAP_MSG_CODE_DEF(2),  /* CoAP Post method */
    ITOX_ALCS_COAP_MSG_CODE_PUT                            = ITOX_ALCS_COAP_MSG_CODE_DEF(3),  /* CoAP Put method */
    ITOX_ALCS_COAP_MSG_CODE_DELETE                         = ITOX_ALCS_COAP_MSG_CODE_DEF(4),  /* CoAP Delete method */

    /* CoAP Success Response Codes */
    ITOX_ALCS_COAP_MSG_CODE_201_CREATED                    = ITOX_ALCS_COAP_MSG_CODE_DEF(201),  /* Mapping to CoAP code 2.01, Hex:0x41, Created */
    ITOX_ALCS_COAP_MSG_CODE_202_DELETED                    = ITOX_ALCS_COAP_MSG_CODE_DEF(202),  /* Mapping to CoAP code 2.02, Hex:0x42, Deleted*/
    ITOX_ALCS_COAP_MSG_CODE_203_VALID                      = ITOX_ALCS_COAP_MSG_CODE_DEF(203),  /* Mapping to CoAP code 2.03, Hex:0x43, Valid*/
    ITOX_ALCS_COAP_MSG_CODE_204_CHANGED                    = ITOX_ALCS_COAP_MSG_CODE_DEF(204),  /* Mapping to CoAP code 2.04, Hex:0x44, Changed*/
    ITOX_ALCS_COAP_MSG_CODE_205_CONTENT                    = ITOX_ALCS_COAP_MSG_CODE_DEF(205),  /* Mapping to CoAP code 2.05, Hex:0x45, Content*/
    ITOX_ALCS_COAP_MSG_CODE_231_CONTINUE                   = ITOX_ALCS_COAP_MSG_CODE_DEF(231),  /* Mapping to CoAP code 2.31, Hex:0x5F, Continue*/

    /* CoAP Client Error Response Codes */
    ITOX_ALCS_COAP_MSG_CODE_400_BAD_REQUEST                = ITOX_ALCS_COAP_MSG_CODE_DEF(400),  /* Mapping to CoAP code 4.00, Hex:0x80, Bad Request */
    ITOX_ALCS_COAP_MSG_CODE_401_UNAUTHORIZED               = ITOX_ALCS_COAP_MSG_CODE_DEF(401),  /* Mapping to CoAP code 4.01, Hex:0x81, Unauthorized */
    ITOX_ALCS_COAP_MSG_CODE_402_BAD_OPTION                 = ITOX_ALCS_COAP_MSG_CODE_DEF(402),  /* Mapping to CoAP code 4.02, Hex:0x82, Bad Option */
    ITOX_ALCS_COAP_MSG_CODE_403_FORBIDDEN                  = ITOX_ALCS_COAP_MSG_CODE_DEF(403),  /* Mapping to CoAP code 4.03, Hex:0x83, Forbidden */
    ITOX_ALCS_COAP_MSG_CODE_404_NOT_FOUND                  = ITOX_ALCS_COAP_MSG_CODE_DEF(404),  /* Mapping to CoAP code 4.04, Hex:0x84, Not Found */
    ITOX_ALCS_COAP_MSG_CODE_405_METHOD_NOT_ALLOWED         = ITOX_ALCS_COAP_MSG_CODE_DEF(405),  /* Mapping to CoAP code 4.05, Hex:0x85, Method Not Allowed */
    ITOX_ALCS_COAP_MSG_CODE_406_NOT_ACCEPTABLE             = ITOX_ALCS_COAP_MSG_CODE_DEF(406),  /* Mapping to CoAP code 4.06, Hex:0x86, Not Acceptable */
    ITOX_ALCS_COAP_MSG_CODE_408_REQUEST_ENTITY_INCOMPLETE  = ITOX_ALCS_COAP_MSG_CODE_DEF(408),  /* Mapping to CoAP code 4.08, Hex:0x88, Request Entity Incomplete */
    ITOX_ALCS_COAP_MSG_CODE_412_PRECONDITION_FAILED        = ITOX_ALCS_COAP_MSG_CODE_DEF(412),  /* Mapping to CoAP code 4.12, Hex:0x8C, Precondition Failed */
    ITOX_ALCS_COAP_MSG_CODE_413_REQUEST_ENTITY_TOO_LARGE   = ITOX_ALCS_COAP_MSG_CODE_DEF(413),  /* Mapping to CoAP code 4.13, Hex:0x8D, Request Entity Too Large */
    ITOX_ALCS_COAP_MSG_CODE_415_UNSUPPORTED_CONTENT_FORMAT = ITOX_ALCS_COAP_MSG_CODE_DEF(415),  /* Mapping to CoAP code 4.15, Hex:0x8F, Unsupported Content-Format */

    /* CoAP Server Error Response Codes */
    ITOX_ALCS_COAP_MSG_CODE_500_INTERNAL_SERVER_ERROR      = ITOX_ALCS_COAP_MSG_CODE_DEF(500),  /* Mapping to CoAP code 5.00, Hex:0xA0, Internal Server Error */
    ITOX_ALCS_COAP_MSG_CODE_501_NOT_IMPLEMENTED            = ITOX_ALCS_COAP_MSG_CODE_DEF(501),  /* Mapping to CoAP code 5.01, Hex:0xA1, Not Implemented */
    ITOX_ALCS_COAP_MSG_CODE_502_BAD_GATEWAY                = ITOX_ALCS_COAP_MSG_CODE_DEF(502),  /* Mapping to CoAP code 5.02, Hex:0xA2, Bad Gateway */
    ITOX_ALCS_COAP_MSG_CODE_503_SERVICE_UNAVAILABLE        = ITOX_ALCS_COAP_MSG_CODE_DEF(503),  /* Mapping to CoAP code 5.03, Hex:0xA3, Service Unavailable */
    ITOX_ALCS_COAP_MSG_CODE_504_GATEWAY_TIMEOUT            = ITOX_ALCS_COAP_MSG_CODE_DEF(504),  /* Mapping to CoAP code 5.04, Hex:0xA4, Gateway Timeout */
    ITOX_ALCS_COAP_MSG_CODE_505_PROXYING_NOT_SUPPORTED     = ITOX_ALCS_COAP_MSG_CODE_DEF(505)   /* Mapping to CoAP code 5.05, Hex:0xA5, Proxying Not Supported */

} iotx_alcs_message_code_t;

typedef enum {
    IOTX_ALCS_MESSAGE_TYPE_CON = 0,
    IOTX_ALCS_MESSAGE_TYPE_NON = 1,
    IOTX_ALCS_MESSAGE_TYPE_ACK = 2,
    IOTX_ALCS_MESSAGE_TYPE_RST = 3
} iotx_alcs_message_type_t;

typedef enum {
    IOTX_ALCS_MESSAGE_PERM_NONE    = 0x0000,
    IOTX_ALCS_MESSAGE_PERM_GET     = 0x0001,
    IOTX_ALCS_MESSAGE_PERM_POST    = 0x0002,
    IOTX_ALCS_MESSAGE_PERM_PUT     = 0x0004,
    IOTX_ALCS_MESSAGE_PERM_DEL     = 0x0008,
    IOTX_ALCS_MESSAGE_PERM_OBSERVE = 0x0100
} iotx_alcs_message_perm_t;

typedef enum {
    IOTX_ALCS_MESSAGE_CT_TEXT_PLAIN                = 0,    /* text/plain (UTF-8) */
    IOTX_ALCS_MESSAGE_CT_APP_LINK_FORMAT           = 40,   /* application/link-format */
    IOTX_ALCS_MESSAGE_CT_APP_XML                   = 41,   /* application/xml */
    IOTX_ALCS_MESSAGE_CT_APP_OCTET_STREAM          = 42,   /* application/octet-stream */
    IOTX_ALCS_MESSAGE_CT_APP_RDF_XML               = 43,   /* application/rdf+xml */
    IOTX_ALCS_MESSAGE_CT_APP_EXI                   = 47,   /* application/exi  */
    IOTX_ALCS_MESSAGE_CT_APP_JSON                  = 50,   /* application/json  */
    IOTX_ALCS_MESSAGE_CT_APP_CBOR                  = 60   /* application/cbor  */
} iotx_alcs_message_content_type_t;

typedef struct iotx_alcs_msg_st {
    uint16_t group_id; /*multicast group id, used as unicast when 0*/
    char *ip;   /*dotted decimal notation, max len 16*/
    uint16_t port;
    iotx_alcs_message_code_t msg_code;
    iotx_alcs_message_type_t msg_type;
    char *uri;
    uint32_t payload_len;
    uint8_t *payload;
} iotx_alcs_msg_t, *iotx_alcs_msg_pt;

typedef struct iotx_alcs_res_st {
    char *uri;
    int32_t need_auth;
    iotx_alcs_message_perm_t msg_perm;
    iotx_alcs_message_content_type_t msg_ct;
    uint32_t maxage;  /*0~60*/
    CoAPRecvMsgHandler callback;
} iotx_alcs_res_t, *iotx_alcs_res_pt;

/**
 * @brief Construct the ALCS handle
 *        This function initialize the data structures, initialize ALCS information.
 *
 * @param [in] params: specify the ALCS initialize parameter.
 *
 * @retval     NULL : Construct failed.
 * @retval NOT_NULL : The handle of ALCS.
 * @see None.
 */
void *iotx_alcs_construct(iotx_alcs_param_t *params);

/**
 * @brief Init Cloud Part
 *        This function initialize the cloud part.
 *
 * @param [in] params: specify the ALCS initialize parameter.
 *
 * @retval     NULL : Construct failed.
 * @retval NOT_NULL : The handle of ALCS.
 * @see None.
 */
int iotx_alcs_cloud_init(void *handle);

/**
 * @brief Deconstruct the ALCS handle
 *        This function distroy ALCS handle and release the related resource.
 *
 * @param [in] phandle: pointer of handle, specify the MQTT client.
 *
 * @retval  0 : Deconstruct success.
 * @retval -1 : Deconstruct failed.
 * @see None.
 */
int iotx_alcs_destroy(void **phandle);

/**
 * @brief Handle ALCS message from specific udp port
 *
 * @param [in] handle: specify the ALCS handle.
 *
 * @return status.
 * @see None.
 */
int iotx_alcs_yield(void *handle);

/**
 * @brief Send Message To Secific Deivce
 *
 * @param [in] handle: specify the ALCS handle.
 *
 * @return status.
 * @see None.
 */
int iotx_alcs_send(void *handle, iotx_alcs_msg_t *msg);

/**
 * @brief Send Response Message To Secific Deivce
 *
 * @param [in] handle: specify the ALCS handle.
 *
 * @return status.
 * @see None.
 */
int iotx_alcs_send_Response(void *handle, iotx_alcs_msg_t *msg, uint8_t token_len, uint8_t *token);

/**
 * @brief Register Resource
 *
 * @param [in] handle: specify the ALCS handle.
 * @param [in] handle: the resource need to be registered.
 *
 * @return status.
 * @see None.
 */
int iotx_alcs_register_resource(void *handle, iotx_alcs_res_t *resource);

/**
 * @brief ALCS Observe Notify
 *
 * @param [in] handle: specify the ALCS handle.
 * @param [in] uri: the resource need to notify.
 *
 * @return status.
 * @see None.
 */
int iotx_alcs_observe_notify(void *handle, const char *uri, uint32_t payload_len, uint8_t *payload);

/**
 * @brief Unregister Resource
 *
 * @param [in] handle: specify the ALCS handle.
 * @param [in] handle: the resource need to be registered.
 *
 * @return status.
 * @see None.
 */
int iotx_alcs_unregister_resource(void *handle, char *uri);

/**
 * @brief Add sub device
 *
 * @param [in] handle: specify the ALCS handle.
 * @param [in] pk: the productkey of device.
 * @param [in] dn: the deviceName of device.
 *
 * @return status.
 * @see None.
 */
int iotx_alcs_add_sub_device(void *handle, const char *pk, const char *dn);

/**
 * @brief remove sub device
 *
 * @param [in] handle: specify the ALCS handle.
 * @param [in] pk: the productkey of device.
 * @param [in] dn: the deviceName of device.
 *
 * @return status.
 * @see None.
 */
int iotx_alcs_remove_sub_device(void *handle, const char *pk, const char *dn);

#ifdef ALCS_GROUP_COMM_ENABLE
    #ifdef DM_UNIFIED_SERVICE_POST
    int iotx_alcs_localgroup_rsp(const char *payload, int payload_len, int msg_from);
    #endif
#endif
#endif
