From 45e62dbd9e964c74b24f7fcadad9b418f117e008 Mon Sep 17 00:00:00 2001
From: guowenxue <guowenxue@gmail.com>
Date: Thu, 27 Jun 2019 15:11:42 +0800
Subject: [PATCH] update mqttd, add hardware configured in configure files
---
mqttd/etc/conf.c | 89 ++++++++++++++++++++++++++++++++++++++++----
1 files changed, 81 insertions(+), 8 deletions(-)
diff --git a/mqttd/etc/conf.c b/mqttd/etc/conf.c
index b66d22a..f998ce4 100644
--- a/mqttd/etc/conf.c
+++ b/mqttd/etc/conf.c
@@ -25,28 +25,43 @@
if( !conf_file )
{
- fprintf(stderr, "\nWARNNING: Use default MQTT configure\n");
+ strncpy(ctx->id, "\"rpi3b001\"", sizeof(ctx->id));
/* logger settings */
strncpy(ctx->logfile, DBG_LOG_FILE, sizeof(ctx->logfile));
ctx->loglevel = LOG_LEVEL_DEBUG;
ctx->logsize = 1024;
+ if( logger_init(ctx->logfile, ctx->loglevel, ctx->logsize) < 0 )
+ {
+ fprintf(stderr, "Logger system initialise failure\n");
+ return -2;
+ }
+ log_nrml("Logger system initialise ok\n");
+ log_warn("WARNNING: Use default MQTT configure\n");
+
/* Broker settings */
strncpy(ctx->host, DEF_BORKER_HOSTNAME, sizeof(ctx->host));
ctx->port = DEF_BROKER_PORT;
+ log_nrml("Use default broker server [%s:%d]\n", ctx->host, ctx->port);
+
strncpy(ctx->uid, DEF_BROKER_USERNAME, sizeof(ctx->uid));
strncpy(ctx->pwd, DEF_BROKER_PASSWD, sizeof(ctx->pwd));
+ log_nrml("Use default broker author by [%s:%s]\n", ctx->uid, ctx->pwd);
+
ctx->keepalive = DEF_BROKER_KEEPALIVE;
+ log_nrml("Use default broker keepalive timeout [%d] seconds\n", ctx->keepalive);
/* Publisher settings */
strncpy(ctx->pubTopic, DEF_PUBTOPIC, sizeof(ctx->pubTopic));
ctx->pubQos = DEF_PUBQOS;
ctx->interval = DEF_PUBINTERVAL;
+ log_nrml("Use default publisher topic \"%s\" with Qos[%d] interval[%d]\n", ctx->pubTopic, ctx->pubQos, ctx->interval);
/* Subscriber settings */
strncpy(ctx->subTopic, DEF_SUBTOPIC, sizeof(ctx->subTopic));
ctx->subQos = DEF_SUBQOS;
+ log_nrml("Use default subscriber topic \"%s\" with Qos[%d]\n", ctx->subTopic, ctx->subQos);
return 0;
}
@@ -85,6 +100,66 @@
log_nrml("Logger system initialise ok\n");
+ /*+------------------------------------------------------+
+ *| parser hardware module configuration ID |
+ *+------------------------------------------------------+*/
+
+ /* hardware module enable or not */
+ ctx->hwconf.enable=iniparser_getint(ini, "hardware:enable", 0);
+ log_nrml("Parser hardware modules [%s]\n", ctx->hwconf.enable ? "enable" : "disable");
+
+ /* relay control light */
+ ctx->hwconf.relay=iniparser_getint(ini, "hardware:relay_pin", 0);
+ if( !ctx->hwconf.relay )
+ log_nrml("Parser relay module disabled\n");
+ else
+ log_nrml("Parser relay connected wPI #pin nubmer [%d]\n", ctx->hwconf.relay);
+
+ /* buzzer */
+ ctx->hwconf.beep=iniparser_getint(ini, "hardware:beep_pin", 0);
+
+ /* RGB 3-colors LED */
+ ctx->hwconf.redled=iniparser_getint(ini, "hardware:red_pin", 0);
+ ctx->hwconf.greenled=iniparser_getint(ini, "hardware:green_pin", 0);
+ ctx->hwconf.blueled=iniparser_getint(ini, "hardware:blue_pin", 0);
+ if( !ctx->hwconf.redled && !ctx->hwconf.greenled && !ctx->hwconf.blueled )
+ {
+ ctx->hwconf.leds = 0;
+ log_nrml("Parser RGB leds module disabled\n");
+ }
+ else
+ {
+ ctx->hwconf.leds = 1;
+ log_nrml("Parser RGB led connected wPI #pin nubmer [%d,%d,%d]\n",
+ ctx->hwconf.redled, ctx->hwconf.greenled, ctx->hwconf.blueled);
+ }
+
+ /* temperature sensor ds18b20 */
+ ctx->hwconf.ds18b20=iniparser_getint(ini, "hardware:ds18b20", 0);
+ log_nrml("Parser temperature sensor DS18B20 modules [%s]\n", ctx->hwconf.ds18b20 ? "enable" : "disable");
+
+ /* temperature and hummidity sensor sht2x */
+ ctx->hwconf.sht2x=iniparser_getint(ini, "hardware:sht2x", 0);
+ log_nrml("Parser temperature and hummidity sensor sht2x modules [%s]\n", ctx->hwconf.sht2x ? "enable" : "disable");
+
+ /* light intensity sensor TSL2561 */
+ ctx->hwconf.lux=iniparser_getint(ini, "hardware:lux", 0);
+ log_nrml("Parser light intensity sensor TSL2561 modules [%s]\n", ctx->hwconf.ds18b20 ? "enable" : "disable");
+
+
+ /*+------------------------------------------------------+
+ *| parser production ID |
+ *+------------------------------------------------------+*/
+
+ if( !(str=iniparser_getstring(ini, "common:id", NULL)) )
+ {
+ log_err("ERROR: Parser production ID failure\n");
+ return -2;
+ }
+ /* cJSON parser ID will get "" */
+ snprintf(ctx->id, sizeof(ctx->id), "\"%s\"", str);
+ log_nrml("Parser production ID [%s]\n", ctx->id);
+
/*+------------------------------------------------------+
*| parser broker settings |
@@ -103,7 +178,7 @@
return -2;
}
ctx->port = val;
- log_nrml("Parser and get broker server [%s:%d]\n", ctx->host, ctx->port);
+ log_nrml("Parser broker server [%s:%d]\n", ctx->host, ctx->port);
str=iniparser_getstring(ini, "broker:username", DEF_BROKER_USERNAME);
strncpy(ctx->uid, str, sizeof(ctx->uid) );
@@ -111,10 +186,10 @@
str=iniparser_getstring(ini, "broker:password", DEF_BROKER_PASSWD);
strncpy(ctx->pwd, str, sizeof(ctx->pwd) );
- log_nrml("Parser and get broker author by [%s:%s]\n", ctx->uid, ctx->pwd);
+ log_nrml("Parser broker author by [%s:%s]\n", ctx->uid, ctx->pwd);
ctx->keepalive = iniparser_getint(ini, "broker:keepalive", DEF_BROKER_KEEPALIVE);
- log_nrml("Parser and get broker keepalive timeout [%d] seconds\n", ctx->keepalive);
+ log_nrml("Parser broker keepalive timeout [%d] seconds\n", ctx->keepalive);
/*+------------------------------------------------------+
*| parser publisher settings |
@@ -122,11 +197,10 @@
str=iniparser_getstring(ini, "publisher:pubTopic", DEF_PUBTOPIC);
strncpy(ctx->pubTopic, str, sizeof(ctx->pubTopic) );
- log_nrml("Parser and get publisher topic \"%s\"\n", ctx->pubTopic);
ctx->pubQos = iniparser_getint(ini, "publisher:pubQos", DEF_PUBQOS);
ctx->interval = iniparser_getint(ini, "publisher:interval", DEF_PUBINTERVAL);
- log_nrml("Parser and get publisher Qos[%d] and interval [%d] seconds\n", ctx->pubQos, ctx->interval);
+ log_nrml("Parser publisher topic \"%s\" with Qos[%d] interval[%d]\n", ctx->pubTopic, ctx->pubQos, ctx->interval);
/*+------------------------------------------------------+
*| parser subscriber settings |
@@ -134,10 +208,9 @@
str=iniparser_getstring(ini, "subsciber:subTopic", DEF_SUBTOPIC);
strncpy(ctx->subTopic, str, sizeof(ctx->subTopic) );
- log_nrml("Parser and get subscriber topic \"%s\"\n", ctx->subTopic);
ctx->subQos = iniparser_getint(ini, "subsciber:subQos", DEF_SUBQOS);
- log_nrml("Parser and get subscriber Qos[%d]\n", ctx->subQos);
+ log_nrml("Parser subscriber topic \"%s\" with Qos[%d]\n", ctx->subTopic, ctx->subQos);
return 0;
}
--
Gitblit v1.9.1