svc_rpc.h

浏览该文件的文档.

 
#ifndef __SVC_RPC_H__
#define __SVC_RPC_H__
 
#include <stdint.h>
#include "tuya_cloud_com_defs.h"
 
#include "tuya_slist.h"
#include "rpc_base.h"
#include "json_rpc.h"
#include "tal_thread.h"
 
#ifdef __cplusplus
extern "C" {
#endif
 
#define OPRT_RPC_CALL_TIMEOUT       -10
#define OPRT_RPC_CALL_NOT_FOUND     -11
#define OPRT_RPC_CALL_ERROR         -11
#define TUYA_RPC_DEFAULT_BUFSZ      256
#define TUYA_RPC_ID_LEN             (GW_ID_LEN)
#define TUYA_RPC_KEY_LEN            (LOCAL_KEY_LEN)
 
typedef enum {
    TUYA_RPC_ENCRYPT,
    TUYA_RPC_DECRYPT,
    TUYA_RPC_FREECRYPT,
} tuya_rpc_crypt_mode_t;
 
typedef enum {
    RPC_BUFSIZE_SET_CMD,
} tuya_rpc_cmd_t;
 
typedef int (*rpc_crypt_cb)(uint8_t **data, uint32_t *len, uint8_t key[16], tuya_rpc_crypt_mode_t mode);
 
typedef struct {
    rpc_base_t      base;
    int             fd;
    uint32_t        flag;
    MUTEX_HANDLE    mutex;
    MUTEX_HANDLE    node_mutex;
    THREAD_HANDLE   thread;
    SLIST_HEAD      node_list;
    SLIST_HEAD      declare_list;
    SLIST_HEAD      publish_list;
    SLIST_HEAD      subscribe_list;
    rpc_crypt_cb    crypt_cb;
    char            id [TUYA_RPC_ID_LEN + 1];
    uint8_t         key[16];
    uint16_t        buffer_size;
    uint8_t        *buffer;
    uint8_t         default_buffer[TUYA_RPC_DEFAULT_BUFSZ];
    void           *pipe_recv_cb;
    void           *pipe_args;
} tuya_rpc_t;
 
typedef void (*rpc_method_cb)(jrpc_msg_t *request, void *arg, jrpc_msg_t *reply);
 
typedef void (*rpc_subscribe_cb)(jrpc_msg_t *request, void *arg);
 
typedef void (*rpc_async_cb)(jrpc_msg_t *result, void *arg);
 
int tuya_rpc_init(tuya_rpc_t *rpc, char *id, char *addr);
 
int tuya_rpc_control(tuya_rpc_t *rpc, uint8_t cmd, void *arg);
 
int tuya_rpc_run(tuya_rpc_t *rpc, uint32_t stack_size, uint32_t prio);
 
int tuya_rpc_call_async(tuya_rpc_t      *rpc,  char *id, jrpc_msg_t *requset, rpc_async_cb cb, void *arg, uint32_t sec);
 
int tuya_rpc_call_sync(tuya_rpc_t       *rpc, char *id, jrpc_msg_t *requset, jrpc_msg_t *reply, uint32_t sec);
 
int tuya_rpc_call_notify(tuya_rpc_t *rpc, char *id, jrpc_msg_t *requset);
 
int tuya_rpc_declare(tuya_rpc_t *rpc, char *name, rpc_method_cb cb, void *arg);
 
int tuya_rpc_undeclare(tuya_rpc_t *rpc, char *name);
 
int tuya_rpc_publish(tuya_rpc_t  *rpc, char *name, jrpc_msg_t *msg);
 
int tuya_rpc_subscribe(tuya_rpc_t *rpc, char *id, char *name, rpc_subscribe_cb cb, void *arg);
 
int tuya_rpc_unsubscribe(tuya_rpc_t *rpc, char *id, char *name);
 
int tuya_rpc_set_crypt(tuya_rpc_t *rpc, rpc_crypt_cb  crypt_cb, uint8_t key[TUYA_RPC_KEY_LEN]);
 
int tuya_rpc_set_crypt_key(tuya_rpc_t *rpc, uint8_t key[TUYA_RPC_KEY_LEN]);
 
int tuya_rpc_set_crypt_cb(tuya_rpc_t *rpc,  rpc_crypt_cb        crypt_cb);
 
 
#ifdef __cplusplus
}
#endif
 
#endif