mirror of
https://github.com/cesanta/mongoose.git
synced 2024-12-18 19:38:13 +08:00
107 lines
3.3 KiB
C
107 lines
3.3 KiB
C
/*
|
|
* Copyright (c) 2014 Cesanta Software Limited
|
|
* All rights reserved
|
|
* This software is dual-licensed: 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. For the terms of this
|
|
* license, see <http://www.gnu.org/licenses/>.
|
|
*
|
|
* You are free to use this software under the terms of the GNU General
|
|
* Public License, 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.
|
|
*
|
|
* Alternatively, you can license this software under a commercial
|
|
* license, as set out in <https://www.cesanta.com/license>.
|
|
*/
|
|
|
|
#include "mongoose.h"
|
|
|
|
static const char *s_address = "localhost:1883";
|
|
static const char *s_user_name = NULL;
|
|
static const char *s_password = NULL;
|
|
static const char *s_topic = "/stuff";
|
|
static struct mg_mqtt_topic_expression s_topic_expr = {NULL, 0};
|
|
|
|
static void ev_handler(struct mg_connection *nc, int ev, void *p) {
|
|
struct mg_mqtt_message *msg = (struct mg_mqtt_message *) p;
|
|
(void) nc;
|
|
|
|
if (ev != MG_EV_POLL) printf("USER HANDLER GOT EVENT %d\n", ev);
|
|
|
|
switch (ev) {
|
|
case MG_EV_CONNECT: {
|
|
struct mg_send_mqtt_handshake_opts opts;
|
|
memset(&opts, 0, sizeof(opts));
|
|
opts.user_name = s_user_name;
|
|
opts.password = s_password;
|
|
|
|
mg_set_protocol_mqtt(nc);
|
|
mg_send_mqtt_handshake_opt(nc, "dummy", opts);
|
|
break;
|
|
}
|
|
case MG_EV_MQTT_CONNACK:
|
|
if (msg->connack_ret_code != MG_EV_MQTT_CONNACK_ACCEPTED) {
|
|
printf("Got mqtt connection error: %d\n", msg->connack_ret_code);
|
|
exit(1);
|
|
}
|
|
s_topic_expr.topic = s_topic;
|
|
printf("Subscribing to '%s'\n", s_topic);
|
|
mg_mqtt_subscribe(nc, &s_topic_expr, 1, 42);
|
|
break;
|
|
case MG_EV_MQTT_PUBACK:
|
|
printf("Message publishing acknowledged (msg_id: %d)\n", msg->message_id);
|
|
break;
|
|
case MG_EV_MQTT_SUBACK:
|
|
printf("Subscription acknowledged, forwarding to '/test'\n");
|
|
break;
|
|
case MG_EV_MQTT_PUBLISH: {
|
|
#if 0
|
|
char hex[1024] = {0};
|
|
mg_hexdump(nc->recv_mbuf.buf, msg->payload.len, hex, sizeof(hex));
|
|
printf("Got incoming message %.*s:\n%s", (int)msg->topic.len, msg->topic.p, hex);
|
|
#else
|
|
printf("Got incoming message %.*s: %.*s\n", (int) msg->topic.len,
|
|
msg->topic.p, (int) msg->payload.len, msg->payload.p);
|
|
#endif
|
|
|
|
printf("Forwarding to /test\n");
|
|
mg_mqtt_publish(nc, "/test", 65, MG_MQTT_QOS(0), msg->payload.p,
|
|
msg->payload.len);
|
|
break;
|
|
}
|
|
case MG_EV_CLOSE:
|
|
printf("Connection closed\n");
|
|
exit(1);
|
|
}
|
|
}
|
|
|
|
int main(int argc, char **argv) {
|
|
struct mg_mgr mgr;
|
|
int i;
|
|
|
|
mg_mgr_init(&mgr, NULL);
|
|
|
|
/* Parse command line arguments */
|
|
for (i = 1; i < argc; i++) {
|
|
if (strcmp(argv[i], "-h") == 0) {
|
|
s_address = argv[++i];
|
|
} else if (strcmp(argv[i], "-u") == 0) {
|
|
s_user_name = argv[++i];
|
|
} else if (strcmp(argv[i], "-t") == 0) {
|
|
s_topic = argv[++i];
|
|
} else if (strcmp(argv[i], "-p") == 0) {
|
|
s_password = argv[++i];
|
|
}
|
|
}
|
|
|
|
if (mg_connect(&mgr, s_address, ev_handler) == NULL) {
|
|
fprintf(stderr, "mg_connect(%s) failed\n", s_address);
|
|
exit(EXIT_FAILURE);
|
|
}
|
|
|
|
for (;;) {
|
|
mg_mgr_poll(&mgr, 1000);
|
|
}
|
|
}
|