#ifndef _DM_CLIENT_H_
#define _DM_CLIENT_H_

typedef struct {
    const char *uri_name;
    const char *uri_prefix;
    int dev_type;
    void *callback;
} dm_client_uri_map_t;

void dm_client_event_handle(int fd, iotx_cm_event_msg_t *event, void *context);

int dm_client_subscribe_all(int devid,
                            char product_key[IOTX_PRODUCT_KEY_LEN + 1],
                            char device_name[IOTX_DEVICE_NAME_LEN + 1],
                            int dev_type);

void dm_client_thing_model_down_raw(int fd, const char *topic,
                                    const char *payload,
                                    unsigned int payload_len, void *context);
void dm_client_thing_model_up_raw_reply(int fd, const char *topic,
                                        const char *payload,
                                        unsigned int payload_len,
                                        void *context);

#if !defined(DEVICE_MODEL_RAWDATA_SOLO)
void dm_client_thing_event_notify(int fd, const char *topic,
                                  const char *payload, unsigned int payload_len,
                                  void *context);
void dm_client_thing_property_desired_get_reply(int fd, const char *topic,
                                                const char *payload,
                                                unsigned int payload_len,
                                                void *context);
void dm_client_thing_property_desired_delete_reply(int fd, const char *topic,
                                                   const char *payload,
                                                   unsigned int payload_len,
                                                   void *context);
void dm_client_thing_service_property_set(int fd, const char *topic,
                                          const char *payload,
                                          unsigned int payload_len,
                                          void *context);
void dm_client_thing_service_property_get(int fd, const char *topic,
                                          const char *payload,
                                          unsigned int payload_len,
                                          void *context);
void dm_client_thing_service_property_post(int fd, const char *topic,
                                           const char *payload,
                                           unsigned int payload_len,
                                           void *context);
void dm_client_thing_event_property_post_reply(int fd, const char *topic,
                                               const char *payload,
                                               unsigned int payload_len,
                                               void *context);
void dm_client_thing_deviceinfo_update_reply(int fd, const char *topic,
                                             const char *payload,
                                             unsigned int payload_len,
                                             void *context);
void dm_client_thing_deviceinfo_delete_reply(int fd, const char *topic,
                                             const char *payload,
                                             unsigned int payload_len,
                                             void *context);
void dm_client_thing_dynamictsl_get_reply(int fd, const char *topic,
                                          const char *payload,
                                          unsigned int payload_len,
                                          void *context);
void dm_client_thing_service_request(int fd, const char *topic,
                                     const char *payload,
                                     unsigned int payload_len, void *context);
void dm_client_thing_event_post_reply(int fd, const char *topic,
                                      const char *payload,
                                      unsigned int payload_len, void *context);
void dm_client_rrpc_request_wildcard(int fd, const char *topic,
                                     const char *payload,
                                     unsigned int payload_len, void *context);
void dm_client_ntp_response(int fd, const char *topic, const char *payload,
                            unsigned int payload_len, void *context);
void dm_client_ext_error(int fd, const char *topic, const char *payload,
                         unsigned int payload_len, void *context);
#endif

#ifdef DEVICE_MODEL_GATEWAY
int dm_client_subdev_unsubscribe(char product_key[IOTX_PRODUCT_KEY_LEN + 1],
                                 char device_name[IOTX_DEVICE_NAME_LEN + 1]);
void dm_client_thing_topo_add_notify(int fd, const char *topic,
                                     const char *payload,
                                     unsigned int payload_len, void *context);
void dm_client_thing_disable(int fd, const char *topic, const char *payload,
                             unsigned int payload_len, void *context);
void dm_client_thing_enable(int fd, const char *topic, const char *payload,
                            unsigned int payload_len, void *context);
void dm_client_thing_delete(int fd, const char *topic, const char *payload,
                            unsigned int payload_len, void *context);
void dm_client_thing_gateway_permit(int fd, const char *topic,
                                    const char *payload,
                                    unsigned int payload_len, void *context);
void dm_client_thing_sub_register_reply(int fd, const char *topic,
                                        const char *payload,
                                        unsigned int payload_len,
                                        void *context);
void dm_client_thing_proxy_product_register_reply(int fd, const char *topic,
                                                  const char *payload,
                                                  unsigned int payload_len,
                                                  void *context);
void dm_client_thing_sub_unregister_reply(int fd, const char *topic,
                                          const char *payload,
                                          unsigned int payload_len,
                                          void *context);
void dm_client_thing_topo_add_reply(int fd, const char *topic,
                                    const char *payload,
                                    unsigned int payload_len, void *context);
void dm_client_thing_topo_delete_reply(int fd, const char *topic,
                                       const char *payload,
                                       unsigned int payload_len, void *context);
void dm_client_thing_topo_get_reply(int fd, const char *topic,
                                    const char *payload,
                                    unsigned int payload_len, void *context);
void dm_client_thing_list_found_reply(int fd, const char *topic,
                                      const char *payload,
                                      unsigned int payload_len, void *context);
void dm_client_combine_login_reply(int fd, const char *topic,
                                   const char *payload,
                                   unsigned int payload_len, void *context);
void dm_client_combine_logout_reply(int fd, const char *topic,
                                    const char *payload,
                                    unsigned int payload_len, void *context);
#endif
#endif