emcute.h

Go to the documentation of this file.

/*
 * Copyright (C) 2017 Freie Universität Berlin
 *
 * This file is subject to the terms and conditions of the GNU Lesser
 * General Public License v2.1. See the file LICENSE in the top level
 * directory for more details.
 */
 
#pragma once
 
#include <stdint.h>
#include <stddef.h>
#include <stdbool.h>
 
#include "net/sock/udp.h"
 
#ifdef __cplusplus
extern "C" {
#endif
 
#ifndef CONFIG_EMCUTE_DEFAULT_PORT
#define CONFIG_EMCUTE_DEFAULT_PORT          (1883U)
#endif
 
#ifndef CONFIG_EMCUTE_BUFSIZE
#define CONFIG_EMCUTE_BUFSIZE               (512U)
#endif
 
#ifndef CONFIG_EMCUTE_TOPIC_MAXLEN
#define CONFIG_EMCUTE_TOPIC_MAXLEN          (196U)
#endif
 
#ifndef CONFIG_EMCUTE_KEEPALIVE
#define CONFIG_EMCUTE_KEEPALIVE             (360)       /* -> 6 min*/
#endif
 
#ifndef CONFIG_EMCUTE_T_RETRY
#define CONFIG_EMCUTE_T_RETRY               (15U)       /* -> 15 sec */
#endif
 
#ifndef CONFIG_EMCUTE_N_RETRY
#define CONFIG_EMCUTE_N_RETRY               (3U)
#endif
enum {
    EMCUTE_DUP        = 0x80,   
    EMCUTE_QOS_MASK   = 0x60,   
    EMCUTE_QOS_2      = 0x40,   
    EMCUTE_QOS_1      = 0x20,   
    EMCUTE_QOS_0      = 0x00,   
    EMCUTE_RETAIN     = 0x10,   
    EMCUTE_WILL       = 0x08,   
    EMCUTE_CS         = 0x04,   
    EMCUTE_TIT_MASK   = 0x03,   
    EMCUTE_TIT_SHORT  = 0x02,   
    EMCUTE_TIT_PREDEF = 0x01,   
    EMCUTE_TIT_NORMAL = 0x00    
};
 
enum {
    EMCUTE_OK       =  0,       
    EMCUTE_NOGW     = -1,       
    EMCUTE_REJECT   = -2,       
    EMCUTE_OVERFLOW = -3,       
    EMCUTE_TIMEOUT  = -4,       
    EMCUTE_NOTSUP   = -5        
};
 
typedef struct {
    const char *name;           
    uint16_t id;                
} emcute_topic_t;
 
typedef void(*emcute_cb_t)(const emcute_topic_t *topic, void *data, size_t len);
 
typedef struct emcute_sub {
    struct emcute_sub *next;    
    emcute_topic_t topic;       
    emcute_cb_t cb;             
    void *arg;                  
} emcute_sub_t;
 
int emcute_con(sock_udp_ep_t *remote, bool clean, const char *will_topic,
               const void *will_msg, size_t will_msg_len, unsigned flags);
 
int emcute_discon(void);
 
int emcute_reg(emcute_topic_t *topic);
 
int emcute_pub(emcute_topic_t *topic, const void *buf, size_t len,
               unsigned flags);
 
int emcute_sub(emcute_sub_t *sub, unsigned flags);
 
int emcute_unsub(emcute_sub_t *sub);
 
int emcute_willupd_topic(const char *topic, unsigned flags);
 
int emcute_willupd_msg(const void *data, size_t len);
 
void emcute_run(uint16_t port, const char *id);
 
const char *emcute_type_str(uint8_t type);
 
#ifdef __cplusplus
}
#endif