1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
/*
* Copyright (c) 2021 One Identity
*
* This program is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License version 2 as published
* by the Free Software Foundation, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*
* As an additional exemption you are allowed to compile & link against the
* OpenSSL libraries as published by the OpenSSL project. See the file
* COPYING for details.
*
*/
#ifndef MQTT_CLIENT_OPTIONS_INCLUDED
#define MQTT_CLIENT_OPTIONS_INCLUDED
#include "driver.h"
#include <MQTTClient.h>
#define MQTT_DISCONNECT_TIMEOUT 10000
typedef struct _MQTTClientOptions MQTTClientOptions;
struct _MQTTClientOptions
{
gint keepalive;
gchar *address;
gint qos;
gchar *client_id;
gboolean cleansession;
gchar *username;
gchar *password;
gchar *http_proxy;
gchar *ca_dir;
gchar *ca_file;
gchar *cert_file;
gchar *key_file;
gchar *ciphers;
gint ssl_version;
gboolean peer_verify;
gboolean use_system_cert_store;
gpointer context;
gint(*log_error) (const gchar *str, gsize len, gpointer u);
};
void mqtt_client_options_defaults(MQTTClientOptions *self);
void mqtt_client_options_destroy(MQTTClientOptions *self);
void mqtt_client_options_set_keepalive (MQTTClientOptions *self, const gint keepalive);
gboolean mqtt_client_options_set_address(MQTTClientOptions *self, const gchar *address);
void mqtt_client_options_set_qos (MQTTClientOptions *self, const gint qos);
gboolean mqtt_client_options_set_client_id(MQTTClientOptions *self, const gchar *client_id);
void mqtt_client_options_set_cleansession(MQTTClientOptions *self, gboolean cleansession);
void mqtt_client_options_set_username(MQTTClientOptions *self, const gchar *username);
void mqtt_client_options_set_password(MQTTClientOptions *self, const gchar *password);
void mqtt_client_options_set_http_proxy(MQTTClientOptions *self, const gchar *http_proxy);
void mqtt_client_options_set_ca_dir(MQTTClientOptions *self, const gchar *ca_dir);
void mqtt_client_options_set_ca_file(MQTTClientOptions *self, const gchar *ca_file);
void mqtt_client_options_set_cert_file(MQTTClientOptions *self, const gchar *cert_file);
void mqtt_client_options_set_key_file(MQTTClientOptions *self, const gchar *key_file);
void mqtt_client_options_set_cipher_suite(MQTTClientOptions *self, const gchar *ciphers);
gboolean mqtt_client_options_set_ssl_version(MQTTClientOptions *self, const gchar *value);
void mqtt_client_options_set_peer_verify(MQTTClientOptions *self, gboolean verify);
void mqtt_client_options_use_system_cert_store(MQTTClientOptions *self, gboolean use_system_cert_store);
void mqtt_client_options_set_log_ssl_error_fn(MQTTClientOptions *self, gpointer context,
gint(*log_error)(const gchar *str, gsize len, gpointer u));
gchar *mqtt_client_options_get_address(MQTTClientOptions *self);
gint mqtt_client_options_get_qos(MQTTClientOptions *self);
gchar *mqtt_client_options_get_client_id(MQTTClientOptions *self);
void mqtt_client_options_to_mqtt_client_connection_option(MQTTClientOptions *self, MQTTClient_connectOptions *conn_opts,
MQTTClient_SSLOptions *ssl_opts);
gboolean mqtt_client_options_checker(MQTTClientOptions *self);
#endif /* MQTT_CLIENT_OPTIONS_INCLUDED */
|
