rtl433
UNKNOWN
RTL-433 utility
|
MQTT output for rtl_433 events. More...
Data Structures | |
struct | mqtt_client |
struct | data_output_mqtt_t |
Typedefs | |
typedef struct mqtt_client | mqtt_client_t |
Functions | |
static void | mqtt_client_event (struct mg_connection *nc, int ev, void *ev_data) |
static struct mg_mgr * | mqtt_client_init (char const *host, char const *port, char const *user, char const *pass, char const *client_id, int retain) |
static int | mqtt_client_poll (struct mg_mgr *mgr) |
static void | mqtt_client_publish (struct mg_mgr *mgr, char const *topic, char const *str) |
static void | mqtt_client_free (struct mg_mgr *mgr) |
static char * | mqtt_sanitize_topic (char *topic) |
clean the topic inplace to [-.A-Za-z0-9], esp. not whitespace, +, #, /, $ More... | |
static void | print_mqtt_array (data_output_t *output, data_array_t *array, char *format) |
static char * | append_topic (char *topic, data_t *data) |
static char * | expand_topic (char *topic, char const *format, data_t *data, char const *hostname) |
static void | print_mqtt_data (data_output_t *output, data_t *data, char *format) |
static void | print_mqtt_string (data_output_t *output, char const *str, char *format) |
static void | print_mqtt_double (data_output_t *output, double data, char *format) |
static void | print_mqtt_int (data_output_t *output, int data, char *format) |
static void | data_output_mqtt_poll (data_output_t *output) |
static void | data_output_mqtt_free (data_output_t *output) |
static char * | mqtt_topic_default (char const *topic, char const *base, char const *suffix) |
struct data_output * | data_output_mqtt_create (char const *host, char const *port, char *opts, char const *dev_hint) |
MQTT output for rtl_433 events.
Copyright (C) 2019 Christian Zuckschwerdt
This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version.
typedef struct mqtt_client mqtt_client_t |
|
static |
References DATA_INT, DATA_STRING, mqtt_sanitize_topic(), strlen(), data::type, and data::value.
Referenced by expand_topic().
struct data_output* data_output_mqtt_create | ( | char const * | host, |
char const * | port, | ||
char * | opts, | ||
char const * | dev_hint | ||
) |
References atobv(), mqtt_client::client_id, crc16(), data_output_mqtt_free(), data_output_mqtt_poll(), data_output_mqtt_t::devices, data_output_mqtt_t::events, getkwargs(), data_output_mqtt_t::hostname, data_output_mqtt_t::mgr, mqtt_client_init(), mqtt_topic_default(), data_output_mqtt_t::output, data_output::output_free, data_output::output_poll, data_output::print_array, data_output::print_data, data_output::print_double, data_output::print_int, print_mqtt_array(), print_mqtt_data(), print_mqtt_double(), print_mqtt_int(), print_mqtt_string(), data_output::print_string, remove_ws(), data_output_mqtt_t::states, strlen(), and trim_ws().
Referenced by add_mqtt_output().
|
static |
References data_output_mqtt_t::devices, data_output_mqtt_t::events, data_output_mqtt_t::mgr, mqtt_client_free(), and data_output_mqtt_t::states.
Referenced by data_output_mqtt_create().
|
static |
References data_output_mqtt_t::mgr, and mqtt_client_poll().
Referenced by data_output_mqtt_create().
|
static |
References append_topic(), and data::next.
Referenced by print_mqtt_data().
|
static |
|
static |
References mg_mgr_free(), and mg_mgr::user_data.
Referenced by data_output_mqtt_free().
|
static |
|
static |
References mg_mgr_poll().
Referenced by data_output_mqtt_poll().
|
static |
References mqtt_client::message_id, mg_mqtt_publish(), mg_next(), mqtt_client::publish_flags, strlen(), and mg_mgr::user_data.
Referenced by print_mqtt_data(), and print_mqtt_string().
|
static |
clean the topic inplace to [-.A-Za-z0-9], esp. not whitespace, +, #, /, $
Referenced by append_topic().
|
static |
References strdup().
Referenced by data_output_mqtt_create().
|
static |
References data_array::num_values, print_array_value(), strlen(), and data_output_mqtt_t::topic.
Referenced by data_output_mqtt_create().
|
static |
References data_print_jsons(), data_output_mqtt_t::devices, data_output_mqtt_t::events, expand_topic(), data::format, data_output_mqtt_t::hostname, data::key, data_output_mqtt_t::mgr, mqtt_client_publish(), data::next, print_value(), data_output_mqtt_t::states, strlen(), data_output_mqtt_t::topic, data::type, and data::value.
Referenced by data_output_mqtt_create().
|
static |
References print_mqtt_string().
Referenced by data_output_mqtt_create().
|
static |
References print_mqtt_string().
Referenced by data_output_mqtt_create().
|
static |
References data_output_mqtt_t::mgr, mqtt_client_publish(), and data_output_mqtt_t::topic.
Referenced by data_output_mqtt_create(), print_mqtt_double(), and print_mqtt_int().