mqtt_wrapper.h

Go to the documentation of this file.

/******************************************************************************
 * # License
 * <b>Copyright 2021 Silicon Laboratories Inc. www.silabs.com</b>
 ******************************************************************************
 * The licensor of this software is Silicon Laboratories Inc. Your use of this
 * software is governed by the terms of Silicon Labs Master Software License
 * Agreement (MSLA) available at
 * www.silabs.com/about-us/legal/master-software-license-agreement. This
 * software is distributed to you in Source Code format and is governed by the
 * sections of the MSLA applicable to Source Code.
 *
 *****************************************************************************/
#ifndef MQTT_WRAPPER_H
#define MQTT_WRAPPER_H
 
// Standard library
#include <stdbool.h>
 
// Unify components
#include "sl_status.h"
 
#ifdef __cplusplus
extern "C" {
#endif
 
struct mqtt_message {
  int mid;            
  const char *topic;  
  void *payload;      
  int payloadlen;     
  int qos;            
  bool retain;        
};
 
sl_status_t mqtt_wrapper_lib_init();
 
void *mqtt_wrapper_new(const char *id, bool clean_session, void *obj);
 
sl_status_t mqtt_wrapper_lib_cleanup();
 
void mqtt_wrapper_destroy(void *instance);
 
int mqtt_wrapper_socket(void *instance);
sl_status_t mqtt_wrapper_tls_set(void *instance,
                                 const char *cafile,
                                 const char *certfile,
                                 const char *keyfile);
sl_status_t mqtt_wrapper_tls_psk_set(void *instance,
                                     const char *psk,
                                     const char *id,
                                     const char *ciphers);
sl_status_t mqtt_wrapper_connect(void *instance,
                                 const char *host,
                                 int port,
                                 int keepalive);
 
sl_status_t mqtt_wrapper_disconnect(void *instance);
 
sl_status_t mqtt_wrapper_loop(void *instance, int timeout);
 
sl_status_t mqtt_wrapper_loop_read(void *instance);
 
sl_status_t mqtt_wrapper_loop_write(void *instance);
 
sl_status_t mqtt_wrapper_loop_misc(void *instance);
 
sl_status_t mqtt_wrapper_set_will_message(void *instance,
                                          const char *mqtt_client_id,
                                          int qos);
 
sl_status_t mqtt_wrapper_publish(void *instance,
                                 int *mid,
                                 const char *topic,
                                 int payloadlen,
                                 const void *payload,
                                 int qos,
                                 bool retain);
 
sl_status_t
  mqtt_wrapper_subscribe(void *instance, int *mid, const char *sub, int qos);
 
sl_status_t mqtt_wrapper_unsubscribe(void *instance, int *mid, const char *sub);
 
sl_status_t mqtt_wrapper_topic_matches_sub(const char *sub,
                                           const char *topic,
                                           bool *result);
 
void mqtt_wrapper_connect_callback_set(
  void *instance, void (*on_connect)(void *inst, void *obj, int result_code));
 
void mqtt_wrapper_disconnect_callback_set(
  void *instance, void (*on_disconnect)(void *inst, void *obj, int rc));
 
void mqtt_wrapper_message_callback_set(
  void *instance,
  void (*on_message)(void *inst, void *obj, const struct mqtt_message *msg));
 
#ifdef __cplusplus
}
#endif
 
#endif