tuya_transporter.h

#ifndef __TRANSPORT_H__
#define __TRANSPORT_H__
 
#ifdef __cplusplus
extern "C" {
#endif
#include <stdio.h>
#include <stdint.h>
#include <string.h>
 
#include "tuya_cloud_types.h"
 
/*tuya transporter command definitions*/
#define TUYA_TRANSPORTER_SET_TLS_CERT               0x0001
#define TUYA_TRANSPORTER_GET_TCP_SOCKET             0x0002
#define TUYA_TRANSPORTER_SET_TCP_CONFIG             0x0003
#define TUYA_TRANSPORTER_SET_WEBSOCKET_CONFIG       0x0004
 
struct socket_config_t {
    uint8_t isBlock;
    uint8_t isReuse;
    uint8_t isDisableNagle;
    uint8_t isKeepAlive;
    uint16_t bindPort;
    TUYA_IP_ADDR_T bindAddr;
    uint32_t sendTimeoutMs;
    uint32_t recvTimeoutMs;
    uint32_t keepAliveIdleTime;
    uint32_t keepAliveInterval;
    uint32_t keepAliveCount;
};
 
typedef struct socket_config_t tuya_tcp_config_t;
 
 
//struct tuya_transport_array_handle;
// struct tuya_transporter_inter_t;
 
typedef struct tuya_transport_array_handle* tuya_transport_array_handle_t;
 
struct tuya_transporter_inter_t;
typedef struct tuya_transporter_inter_t* tuya_transporter_t;
 
 
tuya_transport_array_handle_t tuya_transport_array_create();
 
OPERATE_RET tuya_transport_array_destroy(tuya_transport_array_handle_t transport_handle);
 
OPERATE_RET tuya_transport_array_add_transporter(tuya_transport_array_handle_t transport_handle, tuya_transporter_t transporter, char* scheme);
 
OPERATE_RET tuya_transport_array_remove_transporter(tuya_transport_array_handle_t transport_handle, tuya_transporter_t transporter);
 
tuya_transporter_t tuya_transport_array_get_transporter(tuya_transport_array_handle_t transport_handle, char* scheme);
 
 
 
 
typedef uint8_t TUYA_TRANSPORT_TYPE_E;
 
#define TRANSPORT_TYPE_TCP         (1) //tcp transporter
#define TRANSPORT_TYPE_TLS         (2) //tls transporter
#define TRANSPORT_TYPE_WEBSOCKET   (3) //websocket transporter 
 
tuya_transporter_t tuya_transporter_create(TUYA_TRANSPORT_TYPE_E transport_type, tuya_transporter_t dependency);
 
OPERATE_RET tuya_transporter_destroy(tuya_transporter_t transporter);
 
OPERATE_RET tuya_transporter_connect(tuya_transporter_t transporter, const char* host, int port, int timeout_ms);
OPERATE_RET tuya_transporter_read(tuya_transporter_t transporter, uint8_t* buf, int len, int timeout_ms);
 
OPERATE_RET tuya_transporter_write(tuya_transporter_t transporter, uint8_t* buf, int len, int timeout_ms);
 
 
OPERATE_RET tuya_transporter_poll_read(tuya_transporter_t transporter, int timeout_ms);
OPERATE_RET tuya_transporter_close(tuya_transporter_t transporter);
 
OPERATE_RET tuya_transporter_ctrl(tuya_transporter_t transporter, uint32_t cmd, void* args);
 
typedef OPERATE_RET(*transporter_destroy_fn)(tuya_transporter_t t);
 
typedef OPERATE_RET(*transporter_connect_fn)(tuya_transporter_t transporter, const char* host, int port, int timeout_ms);
 
typedef OPERATE_RET(*transporter_read_fn)(tuya_transporter_t transporter, uint8_t* buf, int len, int timeout_ms);
 
typedef OPERATE_RET(*transporter_write_fn)(tuya_transporter_t transporter, uint8_t* buf, int len, int timeout_ms);
 
 
typedef OPERATE_RET(*transporter_poll_read_fn)(tuya_transporter_t transporter, int timeout_ms);
 
typedef OPERATE_RET(*transporter_poll_write_fn)(tuya_transporter_t transporter, int timeout_ms);
typedef OPERATE_RET(*transporter_close_fn)(tuya_transporter_t transporter);
 
typedef OPERATE_RET(*transporter_ctrl)(tuya_transporter_t transporter, uint32_t cmd, void* args);
 
OPERATE_RET tuya_transporter_set_func(tuya_transporter_t transporter,
                                             transporter_connect_fn connect, transporter_close_fn close,
                                             transporter_read_fn read, transporter_write_fn write, transporter_poll_read_fn poll_read,
                                             transporter_poll_read_fn poll_write, transporter_destroy_fn destroy, transporter_ctrl ctrl);
 
 
struct tuya_transporter_inter_t {
    char* scheme;
    transporter_connect_fn f_connect;
    transporter_read_fn f_read;
    transporter_write_fn f_write;
    transporter_poll_read_fn f_poll_read;
    transporter_poll_write_fn f_poll_write;
    transporter_close_fn f_close;
    transporter_destroy_fn f_destroy;
    transporter_ctrl f_ctrl;
};
 
 
 
#ifdef __cplusplus
} // extern "C"
#endif
 
#endif