PubSub.h

Go to the documentation of this file.

 
#ifndef PUBSUB_H
 
#define PUBSUB_H
 
#include <stdint.h>
 
#include "commons/Includes.h"
 
#define MAXTOPICLENGTH 24
#define MAXCONTENTSIZE 30
 
typedef enum __attribute__((packed)) {
    MSGTYPE_SUBSCRIBE = (uint8_t)0x00,
    MSGTYPE_UNSUBSCRIBE,
    MSGTYPE_PUBLISH                                         
} MessageType;
 
typedef struct {
    MessageType type;
} MessageBase;
 
typedef struct : public MessageBase {
    char topic[MAXTOPICLENGTH]; 
} SubscribeAnnouncement;
 
typedef struct : public MessageBase{
    char topic[MAXTOPICLENGTH]; 
} UnsubscribeAnnouncement;
 
typedef struct : public MessageBase {
    char topic[MAXTOPICLENGTH]; 
    size_t contentSize; 
    void* content[MAXCONTENTSIZE]; 
} PublishContent;
 
LMQErrType publish(uint8_t *mac, char *topic, void *payload, size_t payloadSize, Elog *_logger = disableLogger());
 
LMQErrType subscribe(uint8_t *mac, char *topic, Elog *_logger = disableLogger());
 
LMQErrType unsubscribe(uint8_t *mac, char *topic, Elog *_logger = disableLogger());
 
bool isLMQMessage(const uint8_t *incomingData);
 
typedef struct {
    size_t contentSize; 
    void* content[MAXCONTENTSIZE]; 
} PayloadContent;
 
PayloadContent getLMQPayload(const uint8_t *incomingData);
 
#endif