kopia lustrzana https://github.com/martin-ger/esp_mqtt
commit
1b84f1d84d
|
@ -0,0 +1,5 @@
|
||||||
|
.cproject
|
||||||
|
.project
|
||||||
|
build/
|
||||||
|
firmware/
|
||||||
|
|
|
@ -86,7 +86,7 @@ void user_init(void)
|
||||||
|
|
||||||
CFG_Load();
|
CFG_Load();
|
||||||
|
|
||||||
MQTT_InitConnection(&mqttClient, sysCfg.mqtt_host, sysCfg.mqtt_port, SEC_NONSSL);
|
MQTT_InitConnection(&mqttClient, sysCfg.mqtt_host, sysCfg.mqtt_port, sysCfg.security);
|
||||||
MQTT_InitClient(&mqttClient, sysCfg.device_id, sysCfg.mqtt_user, sysCfg.mqtt_pass, sysCfg.mqtt_keepalive);
|
MQTT_InitClient(&mqttClient, sysCfg.device_id, sysCfg.mqtt_user, sysCfg.mqtt_pass, sysCfg.mqtt_keepalive);
|
||||||
MQTT_OnConnected(&mqttClient, mqttConnectedCb);
|
MQTT_OnConnected(&mqttClient, mqttConnectedCb);
|
||||||
MQTT_OnPublished(&mqttClient, mqttPublishedCb);
|
MQTT_OnPublished(&mqttClient, mqttPublishedCb);
|
||||||
|
|
|
@ -1,6 +1,5 @@
|
||||||
#ifndef _USER_CONFIG_H_
|
#ifndef _USER_CONFIG_H_
|
||||||
#define _USER_CONFIG_H_
|
#define _USER_CONFIG_H_
|
||||||
#include "user_interface.h"
|
|
||||||
|
|
||||||
#define CFG_HOLDER 0x00FF55A4
|
#define CFG_HOLDER 0x00FF55A4
|
||||||
#define CFG_LOCATION 0x3C /* Please don't change or if you know what you doing */
|
#define CFG_LOCATION 0x3C /* Please don't change or if you know what you doing */
|
||||||
|
@ -21,7 +20,8 @@
|
||||||
#define STA_TYPE AUTH_WPA2_PSK
|
#define STA_TYPE AUTH_WPA2_PSK
|
||||||
|
|
||||||
#define MQTT_RECONNECT_TIMEOUT 5 /*second*/
|
#define MQTT_RECONNECT_TIMEOUT 5 /*second*/
|
||||||
#define MQTT_CONNTECT_TIMER 5 /**/
|
|
||||||
|
|
||||||
#define CLIENT_SSL_ENABLE
|
#define MQTT_CLIENT_SSL_ENABLE
|
||||||
|
//#undef MQTT_CLIENT_SSL_ENABLE
|
||||||
|
|
||||||
#endif
|
#endif
|
||||||
|
|
|
@ -34,6 +34,7 @@
|
||||||
#include "osapi.h"
|
#include "osapi.h"
|
||||||
#include "user_interface.h"
|
#include "user_interface.h"
|
||||||
|
|
||||||
|
#include "mqtt.h"
|
||||||
#include "config.h"
|
#include "config.h"
|
||||||
#include "user_config.h"
|
#include "user_config.h"
|
||||||
#include "debug.h"
|
#include "debug.h"
|
||||||
|
@ -93,7 +94,11 @@ void CFG_Load()
|
||||||
sysCfg.mqtt_port = MQTT_PORT;
|
sysCfg.mqtt_port = MQTT_PORT;
|
||||||
os_sprintf(sysCfg.mqtt_user, "%s", MQTT_USER);
|
os_sprintf(sysCfg.mqtt_user, "%s", MQTT_USER);
|
||||||
os_sprintf(sysCfg.mqtt_pass, "%s", MQTT_PASS);
|
os_sprintf(sysCfg.mqtt_pass, "%s", MQTT_PASS);
|
||||||
|
#ifdef MQTT_CLIENT_SSL_ENABLE
|
||||||
|
sysCfg.security = SEC_SSL;
|
||||||
|
#else
|
||||||
|
sysCfg.security = SEC_NONSSL;
|
||||||
|
#endif
|
||||||
sysCfg.mqtt_keepalive = MQTT_KEEPALIVE;
|
sysCfg.mqtt_keepalive = MQTT_KEEPALIVE;
|
||||||
|
|
||||||
INFO(" default configurations\r\n");
|
INFO(" default configurations\r\n");
|
||||||
|
|
|
@ -45,6 +45,7 @@ typedef struct{
|
||||||
uint8_t mqtt_user[32];
|
uint8_t mqtt_user[32];
|
||||||
uint8_t mqtt_pass[32];
|
uint8_t mqtt_pass[32];
|
||||||
uint32_t mqtt_keepalive;
|
uint32_t mqtt_keepalive;
|
||||||
|
uint8_t security;
|
||||||
} SYSCFG;
|
} SYSCFG;
|
||||||
|
|
||||||
typedef struct {
|
typedef struct {
|
||||||
|
|
|
@ -30,6 +30,7 @@
|
||||||
#ifndef USER_AT_MQTT_H_
|
#ifndef USER_AT_MQTT_H_
|
||||||
#define USER_AT_MQTT_H_
|
#define USER_AT_MQTT_H_
|
||||||
#include "mqtt_msg.h"
|
#include "mqtt_msg.h"
|
||||||
|
#include "user_interface.h"
|
||||||
#include "str_queue.h"
|
#include "str_queue.h"
|
||||||
typedef struct mqtt_event_data_t
|
typedef struct mqtt_event_data_t
|
||||||
{
|
{
|
||||||
|
|
|
@ -91,7 +91,7 @@ void user_init(void)
|
||||||
|
|
||||||
CFG_Load();
|
CFG_Load();
|
||||||
|
|
||||||
MQTT_InitConnection(&mqttClient, sysCfg.mqtt_host, sysCfg.mqtt_port, SEC_NONSSL);
|
MQTT_InitConnection(&mqttClient, sysCfg.mqtt_host, sysCfg.mqtt_port, sysCfg.security);
|
||||||
MQTT_InitClient(&mqttClient, sysCfg.device_id, sysCfg.mqtt_user, sysCfg.mqtt_pass, sysCfg.mqtt_keepalive);
|
MQTT_InitClient(&mqttClient, sysCfg.device_id, sysCfg.mqtt_user, sysCfg.mqtt_pass, sysCfg.mqtt_keepalive);
|
||||||
MQTT_OnConnected(&mqttClient, mqttConnectedCb);
|
MQTT_OnConnected(&mqttClient, mqttConnectedCb);
|
||||||
MQTT_OnDisconnected(&mqttClient, mqttDisconnectedCb);
|
MQTT_OnDisconnected(&mqttClient, mqttDisconnectedCb);
|
||||||
|
|
Ładowanie…
Reference in New Issue