123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235 |
- #if !defined(MQTT_CLIENT_H)
- #define MQTT_CLIENT_H
- #if defined(__cplusplus)
- extern "C" {
- #endif
- #if defined(WIN32_DLL) || defined(WIN64_DLL)
- #define DLLImport __declspec(dllimport)
- #define DLLExport __declspec(dllexport)
- #elif defined(LINUX_SO)
- #define DLLImport extern
- #define DLLExport __attribute__ ((visibility ("default")))
- #else
- #define DLLImport
- #define DLLExport
- #endif
- #include <MQTTPacket.h>
- #include <MQTTInterface.h>
- #if defined(MQTTCLIENT_PLATFORM_HEADER)
- #define xstr(s) str(s)
- #define str(s) #s
- #include xstr(MQTTCLIENT_PLATFORM_HEADER)
- #endif
- #define MAX_PACKET_ID 65535
- #if !defined(MAX_MESSAGE_HANDLERS)
- #define MAX_MESSAGE_HANDLERS 5
- #endif
- enum QoS { QOS0, QOS1, QOS2, SUBFAIL=(int)0x80 };
- enum returnCode { BUFFER_OVERFLOW = -2, FAILURE = -1, MQTT_SUCCESS = 0 };
- extern void TimerInit(Timer*);
- extern char TimerIsExpired(Timer*);
- extern void TimerCountdownMS(Timer*, unsigned int);
- extern void TimerCountdown(Timer*, unsigned int);
- extern int TimerLeftMS(Timer*);
- typedef struct MQTTMessage
- {
- enum QoS qos;
- unsigned char retained;
- unsigned char dup;
- unsigned short id;
- void *payload;
- size_t payloadlen;
- } MQTTMessage;
- typedef struct MessageData
- {
- MQTTMessage* message;
- MQTTString* topicName;
- } MessageData;
- typedef struct MQTTConnackData
- {
- unsigned char rc;
- unsigned char sessionPresent;
- } MQTTConnackData;
- typedef struct MQTTSubackData
- {
- enum QoS grantedQoS;
- } MQTTSubackData;
- typedef void (*messageHandler)(MessageData*);
- typedef struct MQTTClient
- {
- unsigned int next_packetid,
- command_timeout_ms;
- size_t buf_size,
- readbuf_size;
- unsigned char *buf,
- *readbuf;
- unsigned int keepAliveInterval;
- char ping_outstanding;
- int isconnected;
- int cleansession;
- struct MessageHandlers
- {
- const char* topicFilter;
- void (*fp) (MessageData*);
- } messageHandlers[MAX_MESSAGE_HANDLERS];
- void (*defaultMessageHandler) (MessageData*);
- Network* ipstack;
- Timer last_sent, last_received;
- osMutexId_t mutex;
- #if defined(MQTT_TASK)
- Mutex mutex;
- Thread thread;
- #endif
- } MQTTClient;
- #define DefaultClient {0, 0, 0, 0, NULL, NULL, 0, 0, 0}
- DLLExport void MQTTClientInit(MQTTClient* client, Network* network, unsigned int command_timeout_ms,
- unsigned char* sendbuf, size_t sendbuf_size, unsigned char* readbuf, size_t readbuf_size);
- DLLExport int MQTTConnectWithResults(MQTTClient* client, MQTTPacket_connectData* options,
- MQTTConnackData* data);
- DLLExport int MQTTConnect(MQTTClient* client, MQTTPacket_connectData* options);
- DLLExport int MQTTPublish(MQTTClient* client, const char*, MQTTMessage*);
- DLLExport int MQTTSetMessageHandler(MQTTClient* c, const char* topicFilter, messageHandler messageHandler);
- DLLExport int MQTTSubscribe(MQTTClient* client, const char* topicFilter, enum QoS, messageHandler);
- DLLExport int MQTTSubscribeWithResults(MQTTClient* client, const char* topicFilter, enum QoS, messageHandler, MQTTSubackData* data);
- DLLExport int MQTTUnsubscribe(MQTTClient* client, const char* topicFilter);
- DLLExport int MQTTDisconnect(MQTTClient* client);
- DLLExport int MQTTYield(MQTTClient* client, int time);
- DLLExport int MQTTIsConnected(MQTTClient* client);
- #if defined(MQTT_TASK)
- DLLExport int MQTTStartTask(MQTTClient* client);
- #endif
- #if defined(__cplusplus)
- }
- #endif
- #endif
|