Compare commits
57 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
20292b7b7b | ||
|
|
26de3befa8 | ||
|
|
1098466055 | ||
|
|
2d3663e78c | ||
|
|
5e16282ad0 | ||
|
|
e35a43c4a4 | ||
|
|
087a203ba0 | ||
|
|
5d313bbf5e | ||
|
|
ce896f02c4 | ||
|
|
d3210c3c93 | ||
|
|
23f1207718 | ||
|
|
122ab88960 | ||
|
|
28b0ac1611 | ||
|
|
1cfb5cfab1 | ||
|
|
b023cd67a9 | ||
|
|
24ee6b5201 | ||
|
|
2e92a98db2 | ||
|
|
c59bddfd39 | ||
|
|
7bdb9cc0cd | ||
|
|
be62699702 | ||
|
|
77da47e1da | ||
|
|
88797bfafd | ||
|
|
1e3b37623d | ||
|
|
ba6a96976a | ||
|
|
6afd3939b3 | ||
|
|
2ffe0c13fa | ||
|
|
fe3f8d7b32 | ||
|
|
d1c7ebe134 | ||
|
|
aa0ed9a7a7 | ||
|
|
48eb0daf9a | ||
|
|
34c05bc37a | ||
|
|
7c96c4a5cc | ||
|
|
b280196395 | ||
|
|
c75f4893e8 | ||
|
|
d666f6a53b | ||
|
|
7ef18de755 | ||
|
|
838df3a34a | ||
|
|
ad602194cf | ||
|
|
afc9370e3e | ||
|
|
d96143f185 | ||
|
|
9c939a5667 | ||
|
|
8a25155fd8 | ||
|
|
d64ffe772e | ||
|
|
db610e6f0f | ||
|
|
6711f30ad0 | ||
|
|
3e8d34e4e7 | ||
|
|
67a296eb28 | ||
|
|
e90076d010 | ||
|
|
f42464c173 | ||
|
|
36b452281f | ||
|
|
077c0c6adf | ||
|
|
6f1e5d7488 | ||
|
|
ca8ad88109 | ||
|
|
986a9c592d | ||
|
|
62868cba34 | ||
|
|
80dade00fe | ||
|
|
8254bd4831 |
18
.github/workflows/ci.yml
vendored
Normal file
18
.github/workflows/ci.yml
vendored
Normal file
@@ -0,0 +1,18 @@
|
|||||||
|
name: "CI"
|
||||||
|
on:
|
||||||
|
|
||||||
|
jobs:
|
||||||
|
ci:
|
||||||
|
runs-on: ubuntu-20.04
|
||||||
|
steps:
|
||||||
|
- name: Checkout this repository
|
||||||
|
uses: actions/checkout@v2.3.4
|
||||||
|
- name: Cache for arduino-ci
|
||||||
|
uses: actions/cache@v2.1.3
|
||||||
|
with:
|
||||||
|
path: |
|
||||||
|
~/.arduino15
|
||||||
|
key: ${{ runner.os }}-arduino
|
||||||
|
- name: Install nix
|
||||||
|
uses: cachix/install-nix-action@v12
|
||||||
|
- run: nix-shell -I nixpkgs=channel:nixpkgs-unstable -p arduino-ci --run "arduino-ci"
|
||||||
5
.gitignore
vendored
5
.gitignore
vendored
@@ -1,5 +0,0 @@
|
|||||||
*~
|
|
||||||
src/my_credentials.h
|
|
||||||
*.o
|
|
||||||
*.swp
|
|
||||||
*.out
|
|
||||||
42
README.md
42
README.md
@@ -1,17 +1,19 @@
|
|||||||
# TinyMqtt
|
# TinyMqtt
|
||||||
|
|
||||||

|

|
||||||
|
[](https://github.com/hsaturn/TinyMqtt/actions/workflows/aunit.yml)
|
||||||

|

|
||||||

|

|
||||||
|

|
||||||

|

|
||||||

|

|
||||||
|
|
||||||
ESP 8266 is a small, fast and capable Mqtt Broker and Client
|
TinyMqtt is a small, fast and capable Mqtt Broker and Client for Esp8266 / Esp32 / Esp WROOM
|
||||||
|
|
||||||
## Features
|
## Features
|
||||||
|
|
||||||
- Very (very !!) fast broker I saw it re-sent 1000 topics per second for two
|
- Very (very !!) fast broker I saw it re-sent 1000 topics per second for two
|
||||||
clients that had subscribed (payload ~15 bytes). No topic lost.
|
clients that had subscribed (payload ~15 bytes ESP8266). No topic lost.
|
||||||
The max I've seen was 2k msg/s (1 client 1 subscription)
|
The max I've seen was 2k msg/s (1 client 1 subscription)
|
||||||
- Act as as a mqtt broker and/or a mqtt client
|
- Act as as a mqtt broker and/or a mqtt client
|
||||||
- Mqtt 3.1.1 / Qos 0 supported
|
- Mqtt 3.1.1 / Qos 0 supported
|
||||||
@@ -21,32 +23,16 @@ ESP 8266 is a small, fast and capable Mqtt Broker and Client
|
|||||||
- zeroconf, this is a strange but very powerful mode where
|
- zeroconf, this is a strange but very powerful mode where
|
||||||
all brokers tries to connect together on the same local network.
|
all brokers tries to connect together on the same local network.
|
||||||
|
|
||||||
## TODO List
|
|
||||||
* Use [Async library](https://github.com/me-no-dev/ESPAsyncTCP)
|
|
||||||
* Implement zeroconf mode (needs async)
|
|
||||||
* Add a max_clients in MqttBroker. Used with zeroconf, there will be
|
|
||||||
no need for having tons of clients (also RAM is the problem with many clients)
|
|
||||||
* Why not a 'global' TinyMqtt::loop() instead of having to call loop for all broker/clients instances
|
|
||||||
* Test what is the real max number of clients for broker. As far as I saw, 1k is needed per client which would make more than 30 clients critical.
|
|
||||||
* ~~MqttMessage uses a buffer 256 bytes which is usually far than needed.~~
|
|
||||||
* ~~MqttClient does not support more than one subscription at time~~
|
|
||||||
* ~~MqttClient auto re-subscribe (::resubscribe works bad on broker.emqx.io)~~
|
|
||||||
* MqttClient auto reconnection
|
|
||||||
* ~~MqttClient unsubscribe~~
|
|
||||||
* MqttClient does not sent payload to callback...
|
|
||||||
* MqttClient user/password
|
|
||||||
* Wildcards (I may implement only # as I'm not interrested by a clever and cpu consuming matching)
|
|
||||||
|
|
||||||
## Quickstart
|
## Quickstart
|
||||||
|
|
||||||
* install [TinyMqtt library](https://github.com/hsaturn/TinyMqtt)
|
* install [TinyMqtt library](https://github.com/hsaturn/TinyMqtt)
|
||||||
|
(you can use the Arduino library manager and search for TinyMqtt)
|
||||||
* modify <libraries/TinyMqtt/src/my_credentials.h> (wifi setup)
|
* modify <libraries/TinyMqtt/src/my_credentials.h> (wifi setup)
|
||||||
|
|
||||||
## Examples
|
## Examples
|
||||||
|
|
||||||
|
|
||||||
| Example | Description |
|
| Example | Description |
|
||||||
| ---------------------------- | --------------------------------- |
|
| ------------------- | ------------------------------------------ |
|
||||||
| client-without-wifi | standalone example |
|
| client-without-wifi | standalone example |
|
||||||
| simple-client | Connect the ESP to an external Mqtt broker |
|
| simple-client | Connect the ESP to an external Mqtt broker |
|
||||||
| simple-broker | Simple Mqtt broker with your ESP |
|
| simple-broker | Simple Mqtt broker with your ESP |
|
||||||
@@ -57,11 +43,25 @@ no need for having tons of clients (also RAM is the problem with many clients)
|
|||||||
|
|
||||||
## Standalone mode (zeroconf)
|
## Standalone mode (zeroconf)
|
||||||
-> The zeroconf mode is not yet implemented
|
-> The zeroconf mode is not yet implemented
|
||||||
zerofonf clients to connect to broker on local network.
|
zeroconf clients to connect to broker on local network.
|
||||||
|
|
||||||
In Zeroconf mode, each ESP is a a broker and scans the local network.
|
In Zeroconf mode, each ESP is a a broker and scans the local network.
|
||||||
After a while one ESP naturally becomes a 'master' and all ESP are connected together.
|
After a while one ESP naturally becomes a 'master' and all ESP are connected together.
|
||||||
No problem if the master dies, a new master will be choosen soon.
|
No problem if the master dies, a new master will be choosen soon.
|
||||||
|
|
||||||
|
## TODO List
|
||||||
|
* ~~Use [Async library](https://github.com/me-no-dev/ESPAsyncTCP)~~
|
||||||
|
* Implement zeroconf mode (needs async)
|
||||||
|
* Add a max_clients in MqttBroker. Used with zeroconf, there will be
|
||||||
|
no need for having tons of clients (also RAM is the problem with many clients)
|
||||||
|
* Why not a 'global' TinyMqtt::loop() instead of having to call loop for all broker/clients instances
|
||||||
|
* Test what is the real max number of clients for broker. As far as I saw, 1k is needed per client which would make more than 30 clients critical.
|
||||||
|
* ~~MqttClient auto re-subscribe (::resubscribe works bad on broker.emqx.io)~~
|
||||||
|
* MqttClient auto reconnection
|
||||||
|
* MqttClient user/password
|
||||||
|
* Wildcards (I may implement only # as I'm not interrested by a clever and cpu consuming matching)
|
||||||
|
* I suspect that MqttClient::parent could be removed and replaced with a simple boolean
|
||||||
|
(this'll need to rewrite a few functions)
|
||||||
|
|
||||||
## License
|
## License
|
||||||
Gnu GPL 3.0, see [LICENSE](https://github.com/hsaturn/TinyMqtt/blob/main/LICENSE).
|
Gnu GPL 3.0, see [LICENSE](https://github.com/hsaturn/TinyMqtt/blob/main/LICENSE).
|
||||||
|
|||||||
@@ -3,20 +3,32 @@
|
|||||||
/**
|
/**
|
||||||
* Local broker that accept connections and two local clients
|
* Local broker that accept connections and two local clients
|
||||||
*
|
*
|
||||||
|
*
|
||||||
|
* +-----------------------------+
|
||||||
|
* | ESP |
|
||||||
|
* | +--------+ | 1883 <--- External client/s
|
||||||
|
* | +-------->| broker | | 1883 <--- External client/s
|
||||||
|
* | | +--------+ |
|
||||||
|
* | | ^ |
|
||||||
|
* | | | |
|
||||||
|
* | | | | -----
|
||||||
|
* | v v | ---
|
||||||
|
* | +----------+ +----------+ | -
|
||||||
|
* | | internal | | internal | +-------* Wifi
|
||||||
|
* | | client | | client | |
|
||||||
|
* | +----------+ +----------+ |
|
||||||
|
* | |
|
||||||
|
* +-----------------------------+
|
||||||
|
*
|
||||||
* pros - Reduces internal latency (when publish is received by the same ESP)
|
* pros - Reduces internal latency (when publish is received by the same ESP)
|
||||||
* - Reduces wifi traffic
|
* - Reduces wifi traffic
|
||||||
* - No need to have an external broker
|
* - No need to have an external broker
|
||||||
* - can still report to a 'main' broker (TODO see documentation that have to be written)
|
* - can still report to a 'main' broker (TODO see documentation that have to be written)
|
||||||
* - accepts external clients
|
* - accepts external clients
|
||||||
*
|
*
|
||||||
* cons - Takes more memory
|
* cons - Takes more memory
|
||||||
* - a bit hard to understand
|
* - a bit hard to understand
|
||||||
*
|
|
||||||
* This sounds crazy: a mqtt mqtt that do not need a broker !
|
|
||||||
* The use case arise when one ESP wants to publish topics and subscribe to them at the same time.
|
|
||||||
* Without broker, the ESP won't react to its own topics.
|
|
||||||
*
|
*
|
||||||
* TinyMqtt mqtt allows this use case to work.
|
|
||||||
*/
|
*/
|
||||||
|
|
||||||
#include <my_credentials.h>
|
#include <my_credentials.h>
|
||||||
@@ -37,8 +49,8 @@ void onPublishB(const MqttClient* source, const Topic& topic, const char* payloa
|
|||||||
void setup()
|
void setup()
|
||||||
{
|
{
|
||||||
Serial.begin(115200);
|
Serial.begin(115200);
|
||||||
delay(500);
|
delay(500);
|
||||||
Serial << "Clients with wifi " << endl;
|
Serial << "Clients with wifi " << endl;
|
||||||
|
|
||||||
WiFi.mode(WIFI_STA);
|
WiFi.mode(WIFI_STA);
|
||||||
WiFi.begin(ssid, password);
|
WiFi.begin(ssid, password);
|
||||||
@@ -47,7 +59,7 @@ void setup()
|
|||||||
|
|
||||||
Serial << "Connected to " << ssid << "IP address: " << WiFi.localIP() << endl;
|
Serial << "Connected to " << ssid << "IP address: " << WiFi.localIP() << endl;
|
||||||
|
|
||||||
broker.begin();
|
broker.begin();
|
||||||
|
|
||||||
mqtt_a.setCallback(onPublishA);
|
mqtt_a.setCallback(onPublishA);
|
||||||
mqtt_a.subscribe(topic);
|
mqtt_a.subscribe(topic);
|
||||||
@@ -58,30 +70,30 @@ void setup()
|
|||||||
|
|
||||||
void loop()
|
void loop()
|
||||||
{
|
{
|
||||||
broker.loop();
|
broker.loop(); // Don't forget to add loop for every broker and clients
|
||||||
|
|
||||||
mqtt_a.loop();
|
mqtt_a.loop();
|
||||||
mqtt_b.loop();
|
mqtt_b.loop();
|
||||||
|
|
||||||
// ============= client A publish ================
|
// ============= client A publish ================
|
||||||
static const int intervalA = 5000; // publishes every 5s
|
static const int intervalA = 5000; // publishes every 5s
|
||||||
static uint32_t timerA = millis() + intervalA;
|
static uint32_t timerA = millis() + intervalA;
|
||||||
|
|
||||||
if (millis() > timerA)
|
if (millis() > timerA)
|
||||||
{
|
{
|
||||||
Serial << "A is publishing " << topic.c_str() << endl;
|
Serial << "A is publishing " << topic.c_str() << endl;
|
||||||
timerA += intervalA;
|
timerA += intervalA;
|
||||||
mqtt_a.publish(topic);
|
mqtt_a.publish(topic);
|
||||||
}
|
}
|
||||||
|
|
||||||
// ============= client B publish ================
|
// ============= client B publish ================
|
||||||
static const int intervalB = 7000; // will send topic each 7s
|
static const int intervalB = 7000; // will send topic each 7s
|
||||||
static uint32_t timerB = millis() + intervalB;
|
static uint32_t timerB = millis() + intervalB;
|
||||||
|
|
||||||
if (millis() > timerB)
|
if (millis() > timerB)
|
||||||
{
|
{
|
||||||
Serial << "B is publishing " << topic.c_str() << endl;
|
Serial << "B is publishing " << topic.c_str() << endl;
|
||||||
timerB += intervalB;
|
timerB += intervalB;
|
||||||
mqtt_b.publish(topic, std::string(String(15+millis()%10).c_str()));
|
mqtt_b.publish(topic, std::string(String(15+millis()%10).c_str()));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,12 +1,30 @@
|
|||||||
#include <TinyMqtt.h> // https://github.com/hsaturn/TinyMqtt
|
#include <TinyMqtt.h> // https://github.com/hsaturn/TinyMqtt
|
||||||
|
|
||||||
/** TinyMQTT allows a disconnected mode:
|
/** TinyMQTT allows a disconnected mode:
|
||||||
*
|
*
|
||||||
* In this example, local clients A and B are talking together, no need to be connected.
|
* +-----------------------------+
|
||||||
* A single ESP can use this to be able to comunicate with itself with the power
|
* | ESP |
|
||||||
* of MQTT, and once connected still continue to work with others.
|
* | +--------+ |
|
||||||
*
|
* | +-------->| broker | |
|
||||||
*/
|
* | | +--------+ |
|
||||||
|
* | | ^ |
|
||||||
|
* | | | |
|
||||||
|
* | v v |
|
||||||
|
* | +----------+ +----------+ |
|
||||||
|
* | | internal | | internal | |
|
||||||
|
* | | client | | client | |
|
||||||
|
* | +----------+ +----------+ |
|
||||||
|
* | |
|
||||||
|
* +-----------------------------+
|
||||||
|
*
|
||||||
|
* In this example, local clients A and B are talking together, no need to be connected.
|
||||||
|
*
|
||||||
|
* A single ESP can use this to be able to comunicate with itself with the power
|
||||||
|
* of MQTT, and once connected still continue to work with others.
|
||||||
|
*
|
||||||
|
* The broker may still be conected if wifi is on.
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
|
||||||
std::string topic="sensor/temperature";
|
std::string topic="sensor/temperature";
|
||||||
|
|
||||||
|
|||||||
@@ -5,6 +5,16 @@
|
|||||||
#define PORT 1883
|
#define PORT 1883
|
||||||
MqttBroker broker(PORT);
|
MqttBroker broker(PORT);
|
||||||
|
|
||||||
|
/** Basic Mqtt Broker
|
||||||
|
*
|
||||||
|
* +-----------------------------+
|
||||||
|
* | ESP |
|
||||||
|
* | +--------+ |
|
||||||
|
* | | broker | | 1883 <--- External client/s
|
||||||
|
* | +--------+ |
|
||||||
|
* | |
|
||||||
|
* +-----------------------------+
|
||||||
|
*/
|
||||||
void setup()
|
void setup()
|
||||||
{
|
{
|
||||||
Serial.begin(115200);
|
Serial.begin(115200);
|
||||||
|
|||||||
@@ -1,9 +1,23 @@
|
|||||||
#include <ESP8266WiFi.h>
|
|
||||||
#include "TinyMqtt.h" // https://github.com/hsaturn/TinyMqtt
|
#include "TinyMqtt.h" // https://github.com/hsaturn/TinyMqtt
|
||||||
|
|
||||||
/** Simple Client
|
/** Simple Client (The simplest configuration)
|
||||||
*
|
*
|
||||||
* This is the simplest Mqtt client configuration
|
*
|
||||||
|
* +--------+
|
||||||
|
* +------>| broker |<--- < Other client
|
||||||
|
* | +--------+
|
||||||
|
* |
|
||||||
|
* +-----------------+
|
||||||
|
* | ESP | |
|
||||||
|
* | +----------+ |
|
||||||
|
* | | internal | |
|
||||||
|
* | | client | |
|
||||||
|
* | +----------+ |
|
||||||
|
* | |
|
||||||
|
* +-----------------+
|
||||||
|
*
|
||||||
|
* 1 - edit my_credentials.h to setup wifi essid/password
|
||||||
|
* 2 - change BROKER values (or keep emqx.io test broker)
|
||||||
*
|
*
|
||||||
* pro - small memory footprint (both ram and flash)
|
* pro - small memory footprint (both ram and flash)
|
||||||
* - very simple to setup and use
|
* - very simple to setup and use
|
||||||
@@ -13,6 +27,9 @@
|
|||||||
* - local publishes takes more time (because they go outside)
|
* - local publishes takes more time (because they go outside)
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
const char* BROKER = "broker.emqx.io";
|
||||||
|
const uint16_t BROKER_PORT = 1883;
|
||||||
|
|
||||||
#include <my_credentials.h>
|
#include <my_credentials.h>
|
||||||
|
|
||||||
static float temp=19;
|
static float temp=19;
|
||||||
@@ -32,8 +49,7 @@ void setup()
|
|||||||
|
|
||||||
Serial << "Connected to " << ssid << "IP address: " << WiFi.localIP() << endl;
|
Serial << "Connected to " << ssid << "IP address: " << WiFi.localIP() << endl;
|
||||||
|
|
||||||
client.connect("192.168.1.40", 1883); // Put here your broker ip / port
|
client.connect(BROKER, BROKER_PORT); // Put here your broker ip / port
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void loop()
|
void loop()
|
||||||
|
|||||||
@@ -1,21 +1,25 @@
|
|||||||
#define TINY_MQTT_DEBUG
|
|
||||||
#include <TinyMqtt.h> // https://github.com/hsaturn/TinyMqtt
|
#include <TinyMqtt.h> // https://github.com/hsaturn/TinyMqtt
|
||||||
#include <MqttStreaming.h>
|
#include <MqttStreaming.h>
|
||||||
|
#if defined(ESP8266)
|
||||||
|
#include <ESP8266mDNS.h>
|
||||||
|
#elif defined(ESP32)
|
||||||
|
#include <ESPmDNS.h>
|
||||||
|
#else
|
||||||
|
#error Unsupported platform
|
||||||
|
#endif
|
||||||
|
#include <ESPmDNS.h>
|
||||||
|
|
||||||
#include <sstream>
|
#include <sstream>
|
||||||
#include <map>
|
#include <map>
|
||||||
|
|
||||||
/**
|
/** Very complex example
|
||||||
* Console allowing to make any kind of test.
|
* Console allowing to make any kind of test.
|
||||||
*
|
*
|
||||||
* pros - Reduces internal latency (when publish is received by the same ESP)
|
* Upload the sketch, the use the terminal.
|
||||||
* - Reduces wifi traffic
|
* Press H for mini help.
|
||||||
* - No need to have an external broker
|
|
||||||
* - can still report to a 'main' broker (TODO see documentation that have to be written)
|
|
||||||
* - accepts external clients
|
|
||||||
*
|
|
||||||
* cons - Takes more memory
|
|
||||||
* - a bit hard to understand
|
|
||||||
*
|
*
|
||||||
|
* tested with mqtt-spy-0.5.4
|
||||||
|
* TODO examples of scripts
|
||||||
*/
|
*/
|
||||||
|
|
||||||
#include <my_credentials.h>
|
#include <my_credentials.h>
|
||||||
@@ -55,6 +59,14 @@ void setup()
|
|||||||
Serial << "Connected to " << ssid << "IP address: " << WiFi.localIP() << endl;
|
Serial << "Connected to " << ssid << "IP address: " << WiFi.localIP() << endl;
|
||||||
Serial << "Type help for more..." << endl;
|
Serial << "Type help for more..." << endl;
|
||||||
|
|
||||||
|
const char* name="tinytest";
|
||||||
|
Serial << "Starting MDNS, name= " << name;
|
||||||
|
if (!MDNS.begin(name))
|
||||||
|
Serial << " error, not available." << endl;
|
||||||
|
else
|
||||||
|
Serial << " ok." << endl;
|
||||||
|
|
||||||
|
|
||||||
MqttBroker* broker = new MqttBroker(1883);
|
MqttBroker* broker = new MqttBroker(1883);
|
||||||
broker->begin();
|
broker->begin();
|
||||||
brokers["broker"] = broker;
|
brokers["broker"] = broker;
|
||||||
@@ -126,10 +138,10 @@ std::string getip(std::string& str, const char* if_empty=nullptr, char sep=' ')
|
|||||||
std::map<std::string, std::string> vars;
|
std::map<std::string, std::string> vars;
|
||||||
|
|
||||||
std::set<std::string> commands = {
|
std::set<std::string> commands = {
|
||||||
"auto", "broker", "client", "connect",
|
"auto", "broker", "blink", "client", "connect",
|
||||||
"create", "delete", "help", "interval",
|
"create", "delete", "help", "interval",
|
||||||
"ls", "ip", "off", "on", "set",
|
"ls", "ip", "off", "on", "set",
|
||||||
"publish", "reset", "subscribe", "view"
|
"publish", "reset", "subscribe", "unsubscribe", "view", "every"
|
||||||
};
|
};
|
||||||
|
|
||||||
void getCommand(std::string& search)
|
void getCommand(std::string& search)
|
||||||
@@ -307,15 +319,414 @@ std::map<MqttClient*, automatic*> automatic::autos;
|
|||||||
|
|
||||||
bool compare(std::string s, const char* cmd)
|
bool compare(std::string s, const char* cmd)
|
||||||
{
|
{
|
||||||
if (s.length()==0 or s.length()>strlen(cmd)) return false;
|
uint8_t p=0;
|
||||||
return strncmp(cmd, s.c_str(), s.length())==0;
|
while(s[p++]==*cmd++)
|
||||||
|
{
|
||||||
|
if (*cmd==0 or s[p]==0) return true;
|
||||||
|
if (s[p]==' ') return true;
|
||||||
|
}
|
||||||
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
using ClientFunction = void(*)(std::string& cmd, MqttClient* publish);
|
using ClientFunction = void(*)(std::string& cmd, MqttClient* publish);
|
||||||
|
|
||||||
|
struct Every
|
||||||
|
{
|
||||||
|
std::string cmd;
|
||||||
|
uint32_t ms;
|
||||||
|
uint32_t next;
|
||||||
|
|
||||||
|
void dump()
|
||||||
|
{
|
||||||
|
auto mill=millis();
|
||||||
|
Serial << ms << "ms [" << cmd << "] next in ";
|
||||||
|
if (mill > next)
|
||||||
|
Serial << "now";
|
||||||
|
else
|
||||||
|
Serial << next-mill << "ms";
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
uint32_t blink_ms_on[16];
|
||||||
|
uint32_t blink_ms_off[16];
|
||||||
|
uint32_t blink_next[16];
|
||||||
|
bool blink_state[16];
|
||||||
|
int16_t blink;
|
||||||
|
|
||||||
|
std::vector<Every> everies;
|
||||||
|
|
||||||
|
void eval(std::string& cmd)
|
||||||
|
{
|
||||||
|
while(cmd.length())
|
||||||
|
{
|
||||||
|
MqttError retval = MqttOk;
|
||||||
|
|
||||||
|
std::string s;
|
||||||
|
MqttBroker* broker = nullptr;
|
||||||
|
MqttClient* client = nullptr;
|
||||||
|
|
||||||
|
// client.function notation
|
||||||
|
// ("a.fun " becomes "fun a ")
|
||||||
|
if (cmd.find('.') != std::string::npos &&
|
||||||
|
cmd.find('.') < cmd.find(' '))
|
||||||
|
{
|
||||||
|
s=getword(cmd, nullptr, '.');
|
||||||
|
|
||||||
|
if (s.length())
|
||||||
|
{
|
||||||
|
if (clients.find(s) != clients.end())
|
||||||
|
{
|
||||||
|
client = clients[s];
|
||||||
|
}
|
||||||
|
else if (brokers.find(s) != brokers.end())
|
||||||
|
{
|
||||||
|
broker = brokers[s];
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
Serial << "Unknown class (" << s.c_str() << ")" << endl;
|
||||||
|
cmd="";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
s = getword(cmd);
|
||||||
|
if (s.length()) getCommand(s);
|
||||||
|
if (s.length()==0)
|
||||||
|
{}
|
||||||
|
else if (compare(s, "delete"))
|
||||||
|
{
|
||||||
|
if (client==nullptr && broker==nullptr)
|
||||||
|
{
|
||||||
|
s = getword(cmd);
|
||||||
|
if (clients.find(s) != clients.end())
|
||||||
|
{
|
||||||
|
client = clients[s];
|
||||||
|
}
|
||||||
|
else if (brokers.find(s) != brokers.end())
|
||||||
|
{
|
||||||
|
broker = brokers[s];
|
||||||
|
}
|
||||||
|
else
|
||||||
|
Serial << "Unable to find (" << s.c_str() << ")" << endl;
|
||||||
|
}
|
||||||
|
if (client)
|
||||||
|
{
|
||||||
|
for (auto it: clients)
|
||||||
|
{
|
||||||
|
if (it.second != client) continue;
|
||||||
|
Serial << "deleted" << endl;
|
||||||
|
delete (it.second);
|
||||||
|
clients.erase(it.first);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
cmd += " ls";
|
||||||
|
}
|
||||||
|
else if (broker)
|
||||||
|
{
|
||||||
|
for(auto it: brokers)
|
||||||
|
{
|
||||||
|
if (broker != it.second) continue;
|
||||||
|
Serial << "deleted" << endl;
|
||||||
|
delete (it.second);
|
||||||
|
brokers.erase(it.first);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
cmd += " ls";
|
||||||
|
}
|
||||||
|
else
|
||||||
|
Serial << "Nothing to delete" << endl;
|
||||||
|
}
|
||||||
|
else if (broker)
|
||||||
|
{
|
||||||
|
if (compare(s,"connect"))
|
||||||
|
{
|
||||||
|
Serial << "NYI" << endl;
|
||||||
|
}
|
||||||
|
else if (compare(s, "view"))
|
||||||
|
{
|
||||||
|
broker->dump();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else if (client)
|
||||||
|
{
|
||||||
|
if (compare(s,"connect"))
|
||||||
|
{
|
||||||
|
client->connect(getip(cmd,"192.168.1.40").c_str(), getint(cmd, 1883), getint(cmd, 60));
|
||||||
|
Serial << (client->connected() ? "connected." : "not connected") << endl;
|
||||||
|
}
|
||||||
|
else if (compare(s,"publish"))
|
||||||
|
{
|
||||||
|
while (cmd[0]==' ') cmd.erase(0,1);
|
||||||
|
retval = client->publish(getword(cmd, topic.c_str()), cmd.c_str(), cmd.length());
|
||||||
|
cmd=""; // remove payload
|
||||||
|
}
|
||||||
|
else if (compare(s,"subscribe"))
|
||||||
|
{
|
||||||
|
client->subscribe(getword(cmd, topic.c_str()));
|
||||||
|
}
|
||||||
|
else if (compare(s, "unsubscribe"))
|
||||||
|
{
|
||||||
|
client->unsubscribe(getword(cmd, topic.c_str()));
|
||||||
|
}
|
||||||
|
else if (compare(s, "view"))
|
||||||
|
{
|
||||||
|
client->dump();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else if (compare(s, "on"))
|
||||||
|
{
|
||||||
|
uint8_t pin=getint(cmd, 2);
|
||||||
|
pinMode(pin, OUTPUT);
|
||||||
|
digitalWrite(pin, HIGH);
|
||||||
|
}
|
||||||
|
else if (compare(s, "off"))
|
||||||
|
{
|
||||||
|
uint8_t pin=getint(cmd, 2);
|
||||||
|
pinMode(pin, OUTPUT);
|
||||||
|
digitalWrite(pin, LOW);
|
||||||
|
}
|
||||||
|
else if (compare(s, "every"))
|
||||||
|
{
|
||||||
|
uint32_t ms = getint(cmd, 0);
|
||||||
|
if (ms and cmd.length())
|
||||||
|
{
|
||||||
|
Every every;
|
||||||
|
every.ms=ms;
|
||||||
|
every.cmd=cmd;
|
||||||
|
every.next=millis()+ms;
|
||||||
|
everies.push_back(every);
|
||||||
|
every.dump();
|
||||||
|
Serial << endl;
|
||||||
|
cmd="";
|
||||||
|
}
|
||||||
|
else if (ms==0 and compare(cmd, "list"))
|
||||||
|
{
|
||||||
|
getword(cmd);
|
||||||
|
Serial << "List of everies (ms=" << millis() << ")" << endl;
|
||||||
|
uint8_t count=0;
|
||||||
|
for(auto& every: everies)
|
||||||
|
{
|
||||||
|
Serial << count << ": ";
|
||||||
|
every.dump();
|
||||||
|
Serial << endl;
|
||||||
|
count++;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else if (ms==0 and compare(cmd, "remove"))
|
||||||
|
{
|
||||||
|
getword(cmd);
|
||||||
|
int8_t every=getint(cmd, -1);
|
||||||
|
if (every==-1 and compare(cmd, "all"))
|
||||||
|
{
|
||||||
|
getword(cmd);
|
||||||
|
everies.clear();
|
||||||
|
}
|
||||||
|
else if (everies.size() > (uint8_t)every)
|
||||||
|
{
|
||||||
|
everies.erase(everies.begin()+every);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else if (compare(s, "blink"))
|
||||||
|
{
|
||||||
|
int8_t blink_nr = getint(cmd, -1);
|
||||||
|
if (blink_nr >= 0)
|
||||||
|
{
|
||||||
|
blink_ms_on[blink_nr]=getint(cmd, blink_ms_on[blink_nr]);
|
||||||
|
blink_ms_off[blink_nr]=getint(cmd, blink_ms_on[blink_nr]);
|
||||||
|
pinMode(blink_nr, OUTPUT);
|
||||||
|
blink_next[blink_nr] = millis();
|
||||||
|
Serial << "Blink " << blink_nr << ' ' << (blink_ms_on[blink_nr] ? "on" : "off") << endl;
|
||||||
|
if (blink_ms_on[blink_nr])
|
||||||
|
blink |= 1<< blink_nr;
|
||||||
|
else
|
||||||
|
{
|
||||||
|
blink &= ~(1<< blink_nr);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else if (compare(s, "auto"))
|
||||||
|
{
|
||||||
|
automatic::command(client, cmd);
|
||||||
|
if (client == nullptr)
|
||||||
|
cmd.clear();
|
||||||
|
}
|
||||||
|
else if (compare(s, "broker"))
|
||||||
|
{
|
||||||
|
std::string id=getword(cmd);
|
||||||
|
if (id.length() or brokers.find(id)!=brokers.end())
|
||||||
|
{
|
||||||
|
int port=getint(cmd, 0);
|
||||||
|
if (port)
|
||||||
|
{
|
||||||
|
MqttBroker* broker = new MqttBroker(port);
|
||||||
|
broker->begin();
|
||||||
|
|
||||||
|
brokers[id] = broker;
|
||||||
|
Serial << "new broker (" << id.c_str() << ")" << endl;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
Serial << "Missing port" << endl;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
Serial << "Missing or existing broker name (" << id.c_str() << ")" << endl;
|
||||||
|
cmd+=" ls";
|
||||||
|
}
|
||||||
|
else if (compare(s, "client"))
|
||||||
|
{
|
||||||
|
std::string id=getword(cmd);
|
||||||
|
if (id.length() or clients.find(id)!=clients.end())
|
||||||
|
{
|
||||||
|
s=getword(cmd); // broker name
|
||||||
|
if (s=="" or brokers.find(s) != brokers.end())
|
||||||
|
{
|
||||||
|
MqttBroker* broker = nullptr;
|
||||||
|
if (s.length()) broker = brokers[s];
|
||||||
|
MqttClient* client = new MqttClient(broker);
|
||||||
|
client->id(id);
|
||||||
|
clients[id]=client;
|
||||||
|
client->setCallback(onPublish);
|
||||||
|
client->subscribe(topic);
|
||||||
|
Serial << "new client (" << id.c_str() << ", " << s.c_str() << ')' << endl;
|
||||||
|
}
|
||||||
|
else if (s.length())
|
||||||
|
{
|
||||||
|
Serial << " not found." << endl;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
Serial << "Missing or existing client name" << endl;
|
||||||
|
cmd+=" ls";
|
||||||
|
}
|
||||||
|
else if (compare(s, "set"))
|
||||||
|
{
|
||||||
|
std::string name(getword(cmd));
|
||||||
|
if (name.length()==0)
|
||||||
|
{
|
||||||
|
for(auto it: vars)
|
||||||
|
{
|
||||||
|
Serial << " " << it.first << " -> " << it.second << endl;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else if (commands.find(name) != commands.end())
|
||||||
|
{
|
||||||
|
Serial << "Reserved keyword (" << name << ")" << endl;
|
||||||
|
cmd.clear();
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
if (cmd.length())
|
||||||
|
{
|
||||||
|
vars[name] = cmd;
|
||||||
|
cmd.clear();
|
||||||
|
}
|
||||||
|
else if (vars.find(name) != vars.end())
|
||||||
|
vars.erase(vars.find(name));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else if (compare(s, "ls") or compare(s, "view"))
|
||||||
|
{
|
||||||
|
Serial << "--< " << clients.size() << " client/s. >--" << endl;
|
||||||
|
for(auto it: clients)
|
||||||
|
{
|
||||||
|
Serial << " "; it.second->dump();
|
||||||
|
}
|
||||||
|
|
||||||
|
Serial << "--< " << brokers.size() << " brokers/s. >--" << endl;
|
||||||
|
for(auto it: brokers)
|
||||||
|
{
|
||||||
|
Serial << " ==[ Broker: " << it.first.c_str() << " ]== ";
|
||||||
|
it.second->dump();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else if (compare(s, "reset"))
|
||||||
|
ESP.restart();
|
||||||
|
else if (compare(s, "ip"))
|
||||||
|
Serial << "IP: " << WiFi.localIP() << endl;
|
||||||
|
else if (compare(s,"help"))
|
||||||
|
{
|
||||||
|
Serial << "syntax:" << endl;
|
||||||
|
Serial << " MqttBroker:" << endl;
|
||||||
|
Serial << " broker {name} {port} : create a new broker" << endl;
|
||||||
|
Serial << endl;
|
||||||
|
Serial << " MqttClient:" << endl;
|
||||||
|
Serial << " client {name} {parent broker} : create a client then" << endl;
|
||||||
|
Serial << " name.connect [ip] [port] [alive]" << endl;
|
||||||
|
Serial << " name.[un]subscribe [topic]" << endl;
|
||||||
|
Serial << " name.publish [topic][payload]" << endl;
|
||||||
|
Serial << " name.view" << endl;
|
||||||
|
Serial << " name.delete" << endl;
|
||||||
|
|
||||||
|
automatic::help();
|
||||||
|
Serial << endl;
|
||||||
|
Serial << " help" << endl;
|
||||||
|
Serial << " blink [Dx on_ms off_ms]" << endl;
|
||||||
|
Serial << " ls / ip / reset" << endl;
|
||||||
|
Serial << " set [name][value]" << endl;
|
||||||
|
Serial << " ! repeat last command" << endl;
|
||||||
|
Serial << endl;
|
||||||
|
Serial << " every ms [command]; every list; every remove [nr|all]" << endl;
|
||||||
|
Serial << " on {output}; off {output}" << endl;
|
||||||
|
Serial << " $id : name of the client." << endl;
|
||||||
|
Serial << " default topic is '" << topic.c_str() << "'" << endl;
|
||||||
|
Serial << endl;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
while(s[0]==' ') s.erase(0,1);
|
||||||
|
if (s.length())
|
||||||
|
Serial << "Unknown command (" << s.c_str() << ")" << endl;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (retval != MqttOk)
|
||||||
|
{
|
||||||
|
Serial << "## ERROR " << retval << endl;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
void loop()
|
void loop()
|
||||||
{
|
{
|
||||||
|
auto ms=millis();
|
||||||
|
int8_t out=0;
|
||||||
|
int16_t blink_bits = blink;
|
||||||
|
|
||||||
|
for(auto& every: everies)
|
||||||
|
{
|
||||||
|
if (every.ms && every.cmd.length() && ms > every.next)
|
||||||
|
{
|
||||||
|
std::string cmd(every.cmd);
|
||||||
|
eval(cmd);
|
||||||
|
every.next += every.ms;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
while(blink_bits)
|
||||||
|
{
|
||||||
|
if (blink_ms_on[out] and ms > blink_next[out])
|
||||||
|
{
|
||||||
|
if (blink_state[out])
|
||||||
|
{
|
||||||
|
blink_next[out] += blink_ms_on[out];
|
||||||
|
digitalWrite(out, LOW);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
blink_next[out] += blink_ms_off[out];
|
||||||
|
digitalWrite(abs(out), HIGH);
|
||||||
|
}
|
||||||
|
blink_state[out] = not blink_state[out];
|
||||||
|
}
|
||||||
|
blink_bits >>=1;
|
||||||
|
out++;
|
||||||
|
}
|
||||||
|
|
||||||
static long count;
|
static long count;
|
||||||
|
#if defined(ESP9266)
|
||||||
|
MDNS.update();
|
||||||
|
#endif
|
||||||
|
|
||||||
if (MqttClient::counter != count)
|
if (MqttClient::counter != count)
|
||||||
{
|
{
|
||||||
Serial << "# " << MqttClient::counter << endl;
|
Serial << "# " << MqttClient::counter << endl;
|
||||||
@@ -336,7 +747,6 @@ void loop()
|
|||||||
|
|
||||||
if (c==10 or c==14)
|
if (c==10 or c==14)
|
||||||
{
|
{
|
||||||
|
|
||||||
Serial << "----------------[ " << cmd.c_str() << " ]--------------" << endl;
|
Serial << "----------------[ " << cmd.c_str() << " ]--------------" << endl;
|
||||||
static std::string last_cmd;
|
static std::string last_cmd;
|
||||||
if (cmd=="!")
|
if (cmd=="!")
|
||||||
@@ -345,254 +755,7 @@ void loop()
|
|||||||
last_cmd=cmd;
|
last_cmd=cmd;
|
||||||
|
|
||||||
if (cmd.substr(0,3)!="set") replaceVars(cmd);
|
if (cmd.substr(0,3)!="set") replaceVars(cmd);
|
||||||
while(cmd.length())
|
eval(cmd);
|
||||||
{
|
|
||||||
MqttError retval = MqttOk;
|
|
||||||
|
|
||||||
std::string s;
|
|
||||||
MqttBroker* broker = nullptr;
|
|
||||||
MqttClient* client = nullptr;
|
|
||||||
|
|
||||||
// client.function notation
|
|
||||||
// ("a.fun " becomes "fun a ")
|
|
||||||
if (cmd.find('.') != std::string::npos &&
|
|
||||||
cmd.find('.') < cmd.find(' '))
|
|
||||||
{
|
|
||||||
s=getword(cmd, nullptr, '.');
|
|
||||||
|
|
||||||
if (s.length())
|
|
||||||
{
|
|
||||||
if (clients.find(s) != clients.end())
|
|
||||||
{
|
|
||||||
client = clients[s];
|
|
||||||
}
|
|
||||||
else if (brokers.find(s) != brokers.end())
|
|
||||||
{
|
|
||||||
broker = brokers[s];
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Serial << "Unknown class (" << s.c_str() << ")" << endl;
|
|
||||||
cmd="";
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
s = getword(cmd);
|
|
||||||
if (s.length()) getCommand(s);
|
|
||||||
if (s.length()==0)
|
|
||||||
{}
|
|
||||||
else if (compare(s, "delete"))
|
|
||||||
{
|
|
||||||
if (client==nullptr && broker==nullptr)
|
|
||||||
{
|
|
||||||
s = getword(cmd);
|
|
||||||
if (clients.find(s) != clients.end())
|
|
||||||
{
|
|
||||||
client = clients[s];
|
|
||||||
}
|
|
||||||
else if (brokers.find(s) != brokers.end())
|
|
||||||
{
|
|
||||||
broker = brokers[s];
|
|
||||||
}
|
|
||||||
else
|
|
||||||
Serial << "Unable to find (" << s.c_str() << ")" << endl;
|
|
||||||
}
|
|
||||||
if (client)
|
|
||||||
{
|
|
||||||
for (auto it: clients)
|
|
||||||
{
|
|
||||||
if (it.second != client) continue;
|
|
||||||
Serial << "deleted" << endl;
|
|
||||||
delete (it.second);
|
|
||||||
clients.erase(it.first);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
cmd += " ls";
|
|
||||||
}
|
|
||||||
else if (broker)
|
|
||||||
{
|
|
||||||
for(auto it: brokers)
|
|
||||||
{
|
|
||||||
if (broker != it.second) continue;
|
|
||||||
Serial << "deleted" << endl;
|
|
||||||
delete (it.second);
|
|
||||||
brokers.erase(it.first);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
cmd += " ls";
|
|
||||||
}
|
|
||||||
else
|
|
||||||
Serial << "Nothing to delete" << endl;
|
|
||||||
}
|
|
||||||
else if (broker)
|
|
||||||
{
|
|
||||||
if (compare(s,"connect"))
|
|
||||||
{
|
|
||||||
Serial << "NYI" << endl;
|
|
||||||
}
|
|
||||||
else if (compare(s, "view"))
|
|
||||||
{
|
|
||||||
broker->dump();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else if (client)
|
|
||||||
{
|
|
||||||
if (compare(s,"connect"))
|
|
||||||
{
|
|
||||||
client->connect(getip(cmd,"192.168.1.40").c_str(), getint(cmd, 1883), getint(cmd, 60));
|
|
||||||
Serial << (client->connected() ? "connected." : "not connected") << endl;
|
|
||||||
}
|
|
||||||
else if (compare(s,"publish"))
|
|
||||||
{
|
|
||||||
while (cmd[0]==' ') cmd.erase(0,1);
|
|
||||||
retval = client->publish(getword(cmd, topic.c_str()), cmd.c_str(), cmd.length());
|
|
||||||
cmd=""; // remove payload
|
|
||||||
}
|
|
||||||
else if (compare(s,"subscribe"))
|
|
||||||
{
|
|
||||||
client->subscribe(getword(cmd, topic.c_str()));
|
|
||||||
}
|
|
||||||
else if (compare(s, "view"))
|
|
||||||
{
|
|
||||||
client->dump();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else if (compare(s, "auto"))
|
|
||||||
{
|
|
||||||
automatic::command(client, cmd);
|
|
||||||
if (client == nullptr)
|
|
||||||
cmd.clear();
|
|
||||||
}
|
|
||||||
else if (compare(s, "broker"))
|
|
||||||
{
|
|
||||||
std::string id=getword(cmd);
|
|
||||||
if (id.length() or brokers.find(id)!=brokers.end())
|
|
||||||
{
|
|
||||||
int port=getint(cmd, 0);
|
|
||||||
if (port)
|
|
||||||
{
|
|
||||||
MqttBroker* broker = new MqttBroker(port);
|
|
||||||
broker->begin();
|
|
||||||
|
|
||||||
brokers[id] = broker;
|
|
||||||
Serial << "new broker (" << id.c_str() << ")" << endl;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
Serial << "Missing port" << endl;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
Serial << "Missing or existing broker name (" << id.c_str() << ")" << endl;
|
|
||||||
cmd+=" ls";
|
|
||||||
}
|
|
||||||
else if (compare(s, "client"))
|
|
||||||
{
|
|
||||||
std::string id=getword(cmd);
|
|
||||||
if (id.length() or clients.find(id)!=clients.end())
|
|
||||||
{
|
|
||||||
s=getword(cmd); // broker name
|
|
||||||
if (s=="" or brokers.find(s) != brokers.end())
|
|
||||||
{
|
|
||||||
MqttBroker* broker = nullptr;
|
|
||||||
if (s.length()) broker = brokers[s];
|
|
||||||
MqttClient* client = new MqttClient(broker);
|
|
||||||
client->id(id);
|
|
||||||
clients[id]=client;
|
|
||||||
client->setCallback(onPublish);
|
|
||||||
client->subscribe(topic);
|
|
||||||
Serial << "new client (" << id.c_str() << ", " << s.c_str() << ')' << endl;
|
|
||||||
}
|
|
||||||
else if (s.length())
|
|
||||||
{
|
|
||||||
Serial << " not found." << endl;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else
|
|
||||||
Serial << "Missing or existing client name" << endl;
|
|
||||||
cmd+=" ls";
|
|
||||||
}
|
|
||||||
else if (compare(s, "set"))
|
|
||||||
{
|
|
||||||
std::string name(getword(cmd));
|
|
||||||
if (name.length()==0)
|
|
||||||
{
|
|
||||||
for(auto it: vars)
|
|
||||||
{
|
|
||||||
Serial << " " << it.first << " -> " << it.second << endl;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else if (commands.find(name) != commands.end())
|
|
||||||
{
|
|
||||||
Serial << "Reserved keyword (" << name << ")" << endl;
|
|
||||||
cmd.clear();
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
if (cmd.length())
|
|
||||||
{
|
|
||||||
vars[name] = cmd;
|
|
||||||
cmd.clear();
|
|
||||||
}
|
|
||||||
else if (vars.find(name) != vars.end())
|
|
||||||
vars.erase(vars.find(name));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else if (compare(s, "ls") or compare(s, "view"))
|
|
||||||
{
|
|
||||||
Serial << "--< " << clients.size() << " client/s. >--" << endl;
|
|
||||||
for(auto it: clients)
|
|
||||||
{
|
|
||||||
Serial << " "; it.second->dump();
|
|
||||||
}
|
|
||||||
|
|
||||||
Serial << "--< " << brokers.size() << " brokers/s. >--" << endl;
|
|
||||||
for(auto it: brokers)
|
|
||||||
{
|
|
||||||
Serial << " ==[ Broker: " << it.first.c_str() << " ]== ";
|
|
||||||
it.second->dump();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else if (compare(s, "reset"))
|
|
||||||
ESP.restart();
|
|
||||||
else if (compare(s, "ip"))
|
|
||||||
Serial << "IP: " << WiFi.localIP() << endl;
|
|
||||||
else if (compare(s,"help"))
|
|
||||||
{
|
|
||||||
Serial << "syntax:" << endl;
|
|
||||||
Serial << " MqttBroker:" << endl;
|
|
||||||
Serial << " broker {name} {port} : create a new broker" << endl;
|
|
||||||
Serial << endl;
|
|
||||||
Serial << " MqttClient:" << endl;
|
|
||||||
Serial << " client {name} {parent broker} : create a client then" << endl;
|
|
||||||
Serial << " name.connect [ip] [port] [alive]" << endl;
|
|
||||||
Serial << " name.subscribe [topic]" << endl;
|
|
||||||
Serial << " name.publish [topic][payload]" << endl;
|
|
||||||
Serial << " name.view" << endl;
|
|
||||||
Serial << " name.delete" << endl;
|
|
||||||
|
|
||||||
automatic::help();
|
|
||||||
Serial << endl;
|
|
||||||
Serial << " help" << endl;
|
|
||||||
Serial << " ls / ip / reset" << endl;
|
|
||||||
Serial << " set [name][value]" << endl;
|
|
||||||
Serial << " ! repeat last command" << endl;
|
|
||||||
Serial << endl;
|
|
||||||
Serial << " $id : name of the client." << endl;
|
|
||||||
Serial << " default topic is '" << topic.c_str() << "'" << endl;
|
|
||||||
Serial << endl;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
while(s[0]==' ') s.erase(0,1);
|
|
||||||
if (s.length())
|
|
||||||
Serial << "Unknown command (" << s.c_str() << ")" << endl;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (retval != MqttOk)
|
|
||||||
{
|
|
||||||
Serial << "## ERROR " << retval << endl;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -1,12 +1,12 @@
|
|||||||
{
|
{
|
||||||
"name": "TinyMqtt",
|
"name": "TinyMqtt",
|
||||||
"keywords": "ethernet, mqtt, m2m, iot",
|
"keywords": "ethernet, mqtt, m2m, iot",
|
||||||
"description": "MQTT is a lightweight messaging protocol ideal for small devices. This library allows to send and receive MQTT messages. It does support MQTT 3.1.1 without QOS=0.",
|
"description": "MQTT is a lightweight messaging protocol ideal for small devices. This library allows to send and receive and host a broker for MQTT. It does support MQTT 3.1.1 with QOS=0 on ESP8266 and ESP32 WROOM platfrms.",
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
"url": "https://github.com/hsaturn/TinyMqtt.git"
|
"url": "https://github.com/hsaturn/TinyMqtt.git"
|
||||||
},
|
},
|
||||||
"version": "0.7.3",
|
"version": "0.7.4",
|
||||||
"exclude": "",
|
"exclude": "",
|
||||||
"examples": "examples/*/*.ino",
|
"examples": "examples/*/*.ino",
|
||||||
"frameworks": "arduino",
|
"frameworks": "arduino",
|
||||||
|
|||||||
@@ -1,11 +1,11 @@
|
|||||||
name=TinyMqtt
|
name=TinyMqtt
|
||||||
version=0.7.3
|
version=0.7.4
|
||||||
author=Francois BIOT, HSaturn, <hsaturn@gmail.com>
|
author=Francois BIOT, HSaturn, <hsaturn@gmail.com>
|
||||||
maintainer=Francois BIOT, HSaturn, <hsaturn@gmail.com>
|
maintainer=Francois BIOT, HSaturn, <hsaturn@gmail.com>
|
||||||
sentence=A tiny broker and client library for MQTT messaging.
|
sentence=A tiny broker and client library for MQTT messaging.
|
||||||
paragraph=MQTT is a lightweight messaging protocol ideal for small devices. This library allows to send and receive MQTT messages and to host a broker in your ESP. It does support MQTT 3.1.1 without QoS=0.
|
paragraph=MQTT is a lightweight messaging protocol ideal for small devices. This library allows to send and receive MQTT messages and to host a broker in your ESP 8266 and 32 WROOM. It does support MQTT 3.1.1 with QoS=0.
|
||||||
category=Communication
|
category=Communication
|
||||||
url=https://github.com/hsaturn/TinyMqtt
|
url=https://github.com/hsaturn/TinyMqtt
|
||||||
architectures=*
|
architectures=*
|
||||||
includes=TinyMqtt.h
|
includes=TinyMqtt.h
|
||||||
depends=
|
depends=AsyncTCP
|
||||||
|
|||||||
@@ -2,7 +2,6 @@
|
|||||||
#include <map>
|
#include <map>
|
||||||
#include <string>
|
#include <string>
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include <ESP8266WiFi.h>
|
|
||||||
|
|
||||||
/***
|
/***
|
||||||
* Allows to store up to 255 different strings with one byte class
|
* Allows to store up to 255 different strings with one byte class
|
||||||
@@ -29,7 +28,7 @@ class StringIndexer
|
|||||||
public:
|
public:
|
||||||
using index_t=uint8_t;
|
using index_t=uint8_t;
|
||||||
|
|
||||||
static const index_t strToIndex(const char* str, uint8_t len)
|
static index_t strToIndex(const char* str, uint8_t len)
|
||||||
{
|
{
|
||||||
for(auto it=strings.begin(); it!=strings.end(); it++)
|
for(auto it=strings.begin(); it!=strings.end(); it++)
|
||||||
{
|
{
|
||||||
|
|||||||
143
src/TinyMqtt.cpp
143
src/TinyMqtt.cpp
@@ -9,8 +9,12 @@ void outstring(const char* prefix, const char*p, uint16_t len)
|
|||||||
Serial << '\'' << endl;
|
Serial << '\'' << endl;
|
||||||
}
|
}
|
||||||
|
|
||||||
MqttBroker::MqttBroker(uint16_t port) : server(port)
|
MqttBroker::MqttBroker(uint16_t port)
|
||||||
{
|
{
|
||||||
|
server = new TcpServer(port);
|
||||||
|
#ifdef TCP_ASYNC
|
||||||
|
server->onClient(onClient, this);
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
MqttBroker::~MqttBroker()
|
MqttBroker::~MqttBroker()
|
||||||
@@ -19,14 +23,21 @@ MqttBroker::~MqttBroker()
|
|||||||
{
|
{
|
||||||
delete clients[0];
|
delete clients[0];
|
||||||
}
|
}
|
||||||
server.close();
|
delete server;
|
||||||
}
|
}
|
||||||
|
|
||||||
// private constructor used by broker only
|
// private constructor used by broker only
|
||||||
MqttClient::MqttClient(MqttBroker* parent, WiFiClient& new_client)
|
MqttClient::MqttClient(MqttBroker* parent, TcpClient* new_client)
|
||||||
: parent(parent)
|
: parent(parent)
|
||||||
{
|
{
|
||||||
client = new WiFiClient(new_client);
|
#ifdef TCP_ASYNC
|
||||||
|
client = new_client;
|
||||||
|
client->onData(onData, this);
|
||||||
|
// client->onConnect() TODO
|
||||||
|
// client->onDisconnect() TODO
|
||||||
|
#else
|
||||||
|
client = new WiFiClient(*new_client);
|
||||||
|
#endif
|
||||||
alive = millis()+5000; // client expires after 5s if no CONNECT msg
|
alive = millis()+5000; // client expires after 5s if no CONNECT msg
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -68,29 +79,22 @@ void MqttClient::close(bool bSendDisconnect)
|
|||||||
void MqttClient::connect(std::string broker, uint16_t port, uint16_t ka)
|
void MqttClient::connect(std::string broker, uint16_t port, uint16_t ka)
|
||||||
{
|
{
|
||||||
debug("cnx: closing");
|
debug("cnx: closing");
|
||||||
|
keep_alive = ka;
|
||||||
close();
|
close();
|
||||||
if (client) delete client;
|
if (client) delete client;
|
||||||
client = new WiFiClient;
|
client = new TcpClient;
|
||||||
|
|
||||||
debug("Trying to connect to " << broker.c_str() << ':' << port);
|
debug("Trying to connect to " << broker.c_str() << ':' << port);
|
||||||
|
#ifdef TCP_ASYNC
|
||||||
|
client->onData(onData, this);
|
||||||
|
client->onConnect(onConnect, this);
|
||||||
|
client->connect(broker.c_str(), port);
|
||||||
|
#else
|
||||||
if (client->connect(broker.c_str(), port))
|
if (client->connect(broker.c_str(), port))
|
||||||
{
|
{
|
||||||
debug("cnx: connecting");
|
onConnect(this, client);
|
||||||
MqttMessage msg(MqttMessage::Type::Connect);
|
|
||||||
msg.add("MQTT",4);
|
|
||||||
msg.add(0x4); // Mqtt protocol version 3.1.1
|
|
||||||
msg.add(0x0); // Connect flags TODO user / name
|
|
||||||
|
|
||||||
keep_alive = ka;
|
|
||||||
msg.add(0x00); // keep_alive
|
|
||||||
msg.add((char)keep_alive);
|
|
||||||
msg.add(clientId);
|
|
||||||
debug("cnx: mqtt connecting");
|
|
||||||
msg.sendTo(this);
|
|
||||||
msg.reset();
|
|
||||||
debug("cnx: mqtt sent " << (int32_t)parent);
|
|
||||||
|
|
||||||
clientAlive(0);
|
|
||||||
}
|
}
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
void MqttBroker::addClient(MqttClient* client)
|
void MqttBroker::addClient(MqttClient* client)
|
||||||
@@ -126,10 +130,24 @@ void MqttBroker::removeClient(MqttClient* remove)
|
|||||||
debug("Error cannot remove client"); // TODO should not occur
|
debug("Error cannot remove client"); // TODO should not occur
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void MqttBroker::onClient(void* broker_ptr, TcpClient* client)
|
||||||
|
{
|
||||||
|
MqttBroker* broker = static_cast<MqttBroker*>(broker_ptr);
|
||||||
|
|
||||||
|
broker->addClient(new MqttClient(broker, client));
|
||||||
|
debug("New client");
|
||||||
|
}
|
||||||
|
|
||||||
void MqttBroker::loop()
|
void MqttBroker::loop()
|
||||||
{
|
{
|
||||||
WiFiClient client = server.available();
|
#ifndef TCP_ASYNC
|
||||||
|
WiFiClient client = server->available();
|
||||||
|
|
||||||
|
if (client)
|
||||||
|
{
|
||||||
|
onClient(this, &client);
|
||||||
|
}
|
||||||
|
#endif
|
||||||
if (broker)
|
if (broker)
|
||||||
{
|
{
|
||||||
// TODO should monitor broker's activity.
|
// TODO should monitor broker's activity.
|
||||||
@@ -137,11 +155,6 @@ void MqttBroker::loop()
|
|||||||
broker->loop();
|
broker->loop();
|
||||||
}
|
}
|
||||||
|
|
||||||
if (client)
|
|
||||||
{
|
|
||||||
addClient(new MqttClient(this, client));
|
|
||||||
debug("New client (" << clients.size() << ')');
|
|
||||||
}
|
|
||||||
|
|
||||||
// for(auto it=clients.begin(); it!=clients.end(); it++)
|
// for(auto it=clients.begin(); it!=clients.end(); it++)
|
||||||
// use index because size can change during the loop
|
// use index because size can change during the loop
|
||||||
@@ -154,7 +167,7 @@ void MqttBroker::loop()
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
debug("Client " << client->id().c_str() << " Disconnected, parent=" << (int32_t)client->parent);
|
debug("Client " << client->id().c_str() << " Disconnected, parent=" << (dbg_ptr)client->parent);
|
||||||
// Note: deleting a client not added by the broker itself will probably crash later.
|
// Note: deleting a client not added by the broker itself will probably crash later.
|
||||||
delete client;
|
delete client;
|
||||||
break;
|
break;
|
||||||
@@ -168,6 +181,7 @@ MqttError MqttBroker::subscribe(const Topic& topic, uint8_t qos)
|
|||||||
{
|
{
|
||||||
return broker->subscribe(topic, qos);
|
return broker->subscribe(topic, qos);
|
||||||
}
|
}
|
||||||
|
return MqttNowhereToSend;
|
||||||
}
|
}
|
||||||
|
|
||||||
MqttError MqttBroker::publish(const MqttClient* source, const Topic& topic, const MqttMessage& msg) const
|
MqttError MqttBroker::publish(const MqttClient* source, const Topic& topic, const MqttMessage& msg) const
|
||||||
@@ -179,7 +193,7 @@ MqttError MqttBroker::publish(const MqttClient* source, const Topic& topic, cons
|
|||||||
for(auto client: clients)
|
for(auto client: clients)
|
||||||
{
|
{
|
||||||
i++;
|
i++;
|
||||||
#if TINY_MQTT_DEBUG
|
#ifdef TINY_MQTT_DEBUG
|
||||||
Serial << "brk_" << (broker && broker->connected() ? "con" : "dis") <<
|
Serial << "brk_" << (broker && broker->connected() ? "con" : "dis") <<
|
||||||
" srce=" << (source->isLocal() ? "loc" : "rem") << " clt#" << i << ", local=" << client->isLocal() << ", con=" << client->connected() << endl;
|
" srce=" << (source->isLocal() ? "loc" : "rem") << " clt#" << i << ", local=" << client->isLocal() << ", con=" << client->connected() << endl;
|
||||||
#endif
|
#endif
|
||||||
@@ -200,7 +214,7 @@ MqttError MqttBroker::publish(const MqttClient* source, const Topic& topic, cons
|
|||||||
{
|
{
|
||||||
doit = true;
|
doit = true;
|
||||||
}
|
}
|
||||||
#if TINY_MQTT_DEBUG
|
#ifdef TINY_MQTT_DEBUG
|
||||||
Serial << ", doit=" << doit << ' ';
|
Serial << ", doit=" << doit << ' ';
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
@@ -250,14 +264,14 @@ void MqttClient::loop()
|
|||||||
{
|
{
|
||||||
debug("pingreq");
|
debug("pingreq");
|
||||||
uint16_t pingreq = MqttMessage::Type::PingReq;
|
uint16_t pingreq = MqttMessage::Type::PingReq;
|
||||||
client->write((uint8_t*)(&pingreq), 2);
|
client->write((const char*)(&pingreq), 2);
|
||||||
clientAlive(0);
|
clientAlive(0);
|
||||||
|
|
||||||
// TODO when many MqttClient passes through a local browser
|
// TODO when many MqttClient passes through a local broker
|
||||||
// there is no need to send one PingReq per instance.
|
// there is no need to send one PingReq per instance.
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
#ifndef TCP_ASYNC
|
||||||
while(client && client->available()>0)
|
while(client && client->available()>0)
|
||||||
{
|
{
|
||||||
message.incoming(client->read());
|
message.incoming(client->read());
|
||||||
@@ -267,8 +281,47 @@ void MqttClient::loop()
|
|||||||
message.reset();
|
message.reset();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void MqttClient::onConnect(void *mqttclient_ptr, TcpClient*)
|
||||||
|
{
|
||||||
|
MqttClient* mqtt = static_cast<MqttClient*>(mqttclient_ptr);
|
||||||
|
debug("cnx: connecting");
|
||||||
|
MqttMessage msg(MqttMessage::Type::Connect);
|
||||||
|
msg.add("MQTT",4);
|
||||||
|
msg.add(0x4); // Mqtt protocol version 3.1.1
|
||||||
|
msg.add(0x0); // Connect flags TODO user / name
|
||||||
|
|
||||||
|
msg.add(0x00); // keep_alive
|
||||||
|
msg.add((char)mqtt->keep_alive);
|
||||||
|
msg.add(mqtt->clientId);
|
||||||
|
debug("cnx: mqtt connecting");
|
||||||
|
msg.sendTo(mqtt);
|
||||||
|
msg.reset();
|
||||||
|
debug("cnx: mqtt sent " << (dbg_ptr)mqtt->parent);
|
||||||
|
|
||||||
|
mqtt->clientAlive(0);
|
||||||
|
}
|
||||||
|
|
||||||
|
#ifdef TCP_ASYNC
|
||||||
|
void MqttClient::onData(void* client_ptr, TcpClient*, void* data, size_t len)
|
||||||
|
{
|
||||||
|
char* char_ptr = static_cast<char*>(data);
|
||||||
|
MqttClient* client=static_cast<MqttClient*>(client_ptr);
|
||||||
|
while(len>0)
|
||||||
|
{
|
||||||
|
client->message.incoming(*char_ptr++);
|
||||||
|
if (client->message.type())
|
||||||
|
{
|
||||||
|
client->processMessage(&client->message);
|
||||||
|
client->message.reset();
|
||||||
|
}
|
||||||
|
len--;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
|
||||||
void MqttClient::resubscribe()
|
void MqttClient::resubscribe()
|
||||||
{
|
{
|
||||||
// TODO resubscription limited to 256 bytes
|
// TODO resubscription limited to 256 bytes
|
||||||
@@ -341,10 +394,10 @@ long MqttClient::counter=0;
|
|||||||
void MqttClient::processMessage(const MqttMessage* mesg)
|
void MqttClient::processMessage(const MqttMessage* mesg)
|
||||||
{
|
{
|
||||||
counter++;
|
counter++;
|
||||||
#if TINY_MQTT_DEBUG
|
#ifdef TINY_MQTT_DEBUG
|
||||||
if (mesg->type() != MqttMessage::Type::PingReq && mesg->type() != MqttMessage::Type::PingResp)
|
if (mesg->type() != MqttMessage::Type::PingReq && mesg->type() != MqttMessage::Type::PingResp)
|
||||||
{
|
{
|
||||||
Serial << "---> INCOMING " << _HEX(mesg->type()) << " client(" << (int)client << ':' << clientId << ") mem=" << ESP.getFreeHeap() << endl;
|
Serial << "---> INCOMING " << _HEX(mesg->type()) << " client(" << (dbg_ptr)client << ':' << clientId << ") mem=" << ESP.getFreeHeap() << endl;
|
||||||
// mesg->hexdump("Incoming");
|
// mesg->hexdump("Incoming");
|
||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
@@ -438,7 +491,7 @@ if (mesg->type() != MqttMessage::Type::PingReq && mesg->type() != MqttMessage::T
|
|||||||
if (client)
|
if (client)
|
||||||
{
|
{
|
||||||
uint16_t pingreq = MqttMessage::Type::PingResp;
|
uint16_t pingreq = MqttMessage::Type::PingResp;
|
||||||
client->write((uint8_t*)(&pingreq), 2);
|
client->write((const char*)(&pingreq), 2);
|
||||||
bclose = false;
|
bclose = false;
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
@@ -453,25 +506,27 @@ if (mesg->type() != MqttMessage::Type::PingReq && mesg->type() != MqttMessage::T
|
|||||||
if (!mqtt_connected) break;
|
if (!mqtt_connected) break;
|
||||||
payload = header+2;
|
payload = header+2;
|
||||||
|
|
||||||
debug("subscribe loop");
|
debug("un/subscribe loop");
|
||||||
while(payload < mesg->end())
|
while(payload < mesg->end())
|
||||||
{
|
{
|
||||||
mesg->getString(payload, len); // Topic
|
mesg->getString(payload, len); // Topic
|
||||||
debug( " topic (" << std::string(payload, len) << ')');
|
debug( " topic (" << std::string(payload, len) << ')');
|
||||||
outstring("Subscribes", payload, len);
|
outstring(" un/subscribes", payload, len);
|
||||||
// subscribe(Topic(payload, len));
|
// subscribe(Topic(payload, len));
|
||||||
Topic topic(payload, len);
|
Topic topic(payload, len);
|
||||||
|
payload += len;
|
||||||
if ((mesg->type() & 0XF0) == MqttMessage::Type::Subscribe)
|
if ((mesg->type() & 0XF0) == MqttMessage::Type::Subscribe)
|
||||||
|
{
|
||||||
|
uint8_t qos = *payload++;
|
||||||
|
if (qos != 0) debug("Unsupported QOS" << qos << endl);
|
||||||
subscriptions.insert(topic);
|
subscriptions.insert(topic);
|
||||||
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
auto it=subscriptions.find(topic);
|
auto it=subscriptions.find(topic);
|
||||||
if (it != subscriptions.end())
|
if (it != subscriptions.end())
|
||||||
subscriptions.erase(it);
|
subscriptions.erase(it);
|
||||||
}
|
}
|
||||||
payload += len;
|
|
||||||
uint8_t qos = *payload++;
|
|
||||||
debug(" qos=" << qos);
|
|
||||||
}
|
}
|
||||||
debug("end loop");
|
debug("end loop");
|
||||||
bclose = false;
|
bclose = false;
|
||||||
@@ -479,6 +534,11 @@ if (mesg->type() != MqttMessage::Type::PingReq && mesg->type() != MqttMessage::T
|
|||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
|
|
||||||
|
case MqttMessage::Type::UnSuback:
|
||||||
|
if (!mqtt_connected) break;
|
||||||
|
bclose = false;
|
||||||
|
break;
|
||||||
|
|
||||||
case MqttMessage::Type::Publish:
|
case MqttMessage::Type::Publish:
|
||||||
if (mqtt_connected or client == nullptr)
|
if (mqtt_connected or client == nullptr)
|
||||||
{
|
{
|
||||||
@@ -656,6 +716,7 @@ void MqttMessage::add(const char* p, size_t len, bool addLength)
|
|||||||
{
|
{
|
||||||
if (addLength)
|
if (addLength)
|
||||||
{
|
{
|
||||||
|
buffer.reserve(buffer.length()+addLength+2);
|
||||||
incoming(len>>8);
|
incoming(len>>8);
|
||||||
incoming(len & 0xFF);
|
incoming(len & 0xFF);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,18 +1,48 @@
|
|||||||
#include <ESP8266WiFi.h>
|
#pragma once
|
||||||
|
|
||||||
|
// TODO Should add a AUnit with both TCP_ASYNC and not TCP_ASYNC
|
||||||
|
// #define TCP_ASYNC // Uncomment this to use ESPAsyncTCP instead of normal cnx
|
||||||
|
|
||||||
|
#if defined(ESP8266) || defined(EPOXY_DUINO)
|
||||||
|
#ifdef TCP_ASYNC
|
||||||
|
#include <ESPAsyncTCP.h>
|
||||||
|
#else
|
||||||
|
#include <ESP8266WiFi.h>
|
||||||
|
#endif
|
||||||
|
#elif defined(ESP32)
|
||||||
|
#ifdef TCP_ASYNC
|
||||||
|
#include <AsyncTCP.h> // https://github.com/me-no-dev/AsyncTCP
|
||||||
|
#else
|
||||||
|
#include <WiFi.h>
|
||||||
|
#endif
|
||||||
|
#endif
|
||||||
|
#ifdef EPOXY_DUINO
|
||||||
|
#define dbg_ptr uint64_t
|
||||||
|
#else
|
||||||
|
#define dbg_ptr uint32_t
|
||||||
|
#endif
|
||||||
#include <vector>
|
#include <vector>
|
||||||
#include <set>
|
#include <set>
|
||||||
#include <string>
|
#include <string>
|
||||||
#include "StringIndexer.h"
|
#include "StringIndexer.h"
|
||||||
#include <MqttStreaming.h>
|
#include <MqttStreaming.h>
|
||||||
|
|
||||||
#if 0
|
// #define TINY_MQTT_DEBUG
|
||||||
|
|
||||||
|
#ifdef TINY_MQTT_DEBUG
|
||||||
#define debug(what) { Serial << __LINE__ << ' ' << what << endl; delay(100); }
|
#define debug(what) { Serial << __LINE__ << ' ' << what << endl; delay(100); }
|
||||||
#define TINY_MQTT_DEBUG 1
|
|
||||||
#else
|
#else
|
||||||
#define TINY_MQTT_DEBUG 0
|
|
||||||
#define debug(what) {}
|
#define debug(what) {}
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
|
#ifdef TCP_ASYNC
|
||||||
|
using TcpClient = AsyncClient;
|
||||||
|
using TcpServer = AsyncServer;
|
||||||
|
#else
|
||||||
|
using TcpClient = WiFiClient;
|
||||||
|
using TcpServer = WiFiServer;
|
||||||
|
#endif
|
||||||
|
|
||||||
enum MqttError
|
enum MqttError
|
||||||
{
|
{
|
||||||
MqttOk = 0,
|
MqttOk = 0,
|
||||||
@@ -47,6 +77,7 @@ class MqttMessage
|
|||||||
Subscribe = 0x80,
|
Subscribe = 0x80,
|
||||||
SubAck = 0x90,
|
SubAck = 0x90,
|
||||||
UnSubscribe = 0xA0,
|
UnSubscribe = 0xA0,
|
||||||
|
UnSuback = 0xB0,
|
||||||
PingReq = 0xC0,
|
PingReq = 0xC0,
|
||||||
PingResp = 0xD0,
|
PingResp = 0xD0,
|
||||||
Disconnect = 0xE0
|
Disconnect = 0xE0
|
||||||
@@ -80,23 +111,15 @@ class MqttMessage
|
|||||||
// output buff+=2, len=length(str)
|
// output buff+=2, len=length(str)
|
||||||
static void getString(const char* &buff, uint16_t& len);
|
static void getString(const char* &buff, uint16_t& len);
|
||||||
|
|
||||||
|
|
||||||
Type type() const
|
Type type() const
|
||||||
{
|
{
|
||||||
return state == Complete ? static_cast<Type>(buffer[0]) : Unknown;
|
return state == Complete ? static_cast<Type>(buffer[0]) : Unknown;
|
||||||
}
|
}
|
||||||
|
|
||||||
// shouldn't exist because it breaks constness :-(
|
|
||||||
// but this saves memory so ...
|
|
||||||
void changeType(Type type) const
|
|
||||||
{
|
|
||||||
buffer[0] = type;
|
|
||||||
}
|
|
||||||
|
|
||||||
void create(Type type)
|
void create(Type type)
|
||||||
{
|
{
|
||||||
buffer=(char)type;
|
buffer=(char)type;
|
||||||
buffer+='\0';
|
buffer+='\0'; // reserved for msg length
|
||||||
vheader=2;
|
vheader=2;
|
||||||
size=0;
|
size=0;
|
||||||
state=Create;
|
state=Create;
|
||||||
@@ -189,11 +212,15 @@ class MqttClient
|
|||||||
static long counter;
|
static long counter;
|
||||||
|
|
||||||
private:
|
private:
|
||||||
|
static void onConnect(void * client_ptr, TcpClient*);
|
||||||
|
#ifdef TCP_ASYNC
|
||||||
|
static void onData(void* client_ptr, TcpClient*, void* data, size_t len);
|
||||||
|
#endif
|
||||||
MqttError sendTopic(const Topic& topic, MqttMessage::Type type, uint8_t qos);
|
MqttError sendTopic(const Topic& topic, MqttMessage::Type type, uint8_t qos);
|
||||||
void resubscribe();
|
void resubscribe();
|
||||||
|
|
||||||
friend class MqttBroker;
|
friend class MqttBroker;
|
||||||
MqttClient(MqttBroker* parent, WiFiClient& client);
|
MqttClient(MqttBroker* parent, TcpClient* client);
|
||||||
// republish a received publish if topic matches any in subscriptions
|
// republish a received publish if topic matches any in subscriptions
|
||||||
MqttError publishIfSubscribed(const Topic& topic, const MqttMessage& msg);
|
MqttError publishIfSubscribed(const Topic& topic, const MqttMessage& msg);
|
||||||
|
|
||||||
@@ -202,7 +229,7 @@ class MqttClient
|
|||||||
|
|
||||||
bool mqtt_connected = false;
|
bool mqtt_connected = false;
|
||||||
char mqtt_flags;
|
char mqtt_flags;
|
||||||
uint32_t keep_alive;
|
uint32_t keep_alive = 60;
|
||||||
uint32_t alive;
|
uint32_t alive;
|
||||||
MqttMessage message;
|
MqttMessage message;
|
||||||
|
|
||||||
@@ -211,7 +238,7 @@ class MqttClient
|
|||||||
// (this is the case when MqttBroker isn't used except here)
|
// (this is the case when MqttBroker isn't used except here)
|
||||||
MqttBroker* parent=nullptr; // connection to local broker
|
MqttBroker* parent=nullptr; // connection to local broker
|
||||||
|
|
||||||
WiFiClient* client=nullptr; // connection to mqtt client or to remote broker
|
TcpClient* client=nullptr; // connection to mqtt client or to remote broker
|
||||||
std::set<Topic> subscriptions;
|
std::set<Topic> subscriptions;
|
||||||
std::string clientId;
|
std::string clientId;
|
||||||
CallBack callback = nullptr;
|
CallBack callback = nullptr;
|
||||||
@@ -230,11 +257,9 @@ class MqttBroker
|
|||||||
MqttBroker(uint16_t port);
|
MqttBroker(uint16_t port);
|
||||||
~MqttBroker();
|
~MqttBroker();
|
||||||
|
|
||||||
void begin() { server.begin(); }
|
void begin() { server->begin(); }
|
||||||
void loop();
|
void loop();
|
||||||
|
|
||||||
uint16_t port() const { return server.port(); }
|
|
||||||
|
|
||||||
void connect(const std::string& host, uint16_t port=1883);
|
void connect(const std::string& host, uint16_t port=1883);
|
||||||
bool connected() const { return state == Connected; }
|
bool connected() const { return state == Connected; }
|
||||||
|
|
||||||
@@ -253,6 +278,7 @@ class MqttBroker
|
|||||||
private:
|
private:
|
||||||
friend class MqttClient;
|
friend class MqttClient;
|
||||||
|
|
||||||
|
static void onClient(void*, TcpClient*);
|
||||||
bool checkUser(const char* user, uint8_t len) const
|
bool checkUser(const char* user, uint8_t len) const
|
||||||
{ return compareString(auth_user, user, len); }
|
{ return compareString(auth_user, user, len); }
|
||||||
|
|
||||||
@@ -270,7 +296,7 @@ class MqttBroker
|
|||||||
|
|
||||||
bool compareString(const char* good, const char* str, uint8_t str_len) const;
|
bool compareString(const char* good, const char* str, uint8_t str_len) const;
|
||||||
std::vector<MqttClient*> clients;
|
std::vector<MqttClient*> clients;
|
||||||
WiFiServer server;
|
TcpServer* server;
|
||||||
|
|
||||||
const char* auth_user = "guest";
|
const char* auth_user = "guest";
|
||||||
const char* auth_password = "guest";
|
const char* auth_password = "guest";
|
||||||
|
|||||||
@@ -5,7 +5,7 @@ tests:
|
|||||||
$(MAKE) -C $$(dirname $$i) -j; \
|
$(MAKE) -C $$(dirname $$i) -j; \
|
||||||
done
|
done
|
||||||
|
|
||||||
runtests:
|
runtests: tests
|
||||||
set -e; \
|
set -e; \
|
||||||
for i in *-tests/Makefile; do \
|
for i in *-tests/Makefile; do \
|
||||||
echo '==== Running:' $$(dirname $$i); \
|
echo '==== Running:' $$(dirname $$i); \
|
||||||
|
|||||||
@@ -3,4 +3,5 @@
|
|||||||
|
|
||||||
APP_NAME := local-tests
|
APP_NAME := local-tests
|
||||||
ARDUINO_LIBS := AUnit AceCommon AceTime TinyMqtt EspMock
|
ARDUINO_LIBS := AUnit AceCommon AceTime TinyMqtt EspMock
|
||||||
include ../../../EpoxyDuino/EpoxyDuino.mk
|
ESP_LIBS = ESP8266WiFi ESPAsyncTCP
|
||||||
|
include ../../../EspMock/EspMock.mk
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
* TinyMqtt local unit tests.
|
* TinyMqtt local unit tests.
|
||||||
*
|
*
|
||||||
* Clients are connected to pseudo remote broker
|
* Clients are connected to pseudo remote broker
|
||||||
* The remote will be 127.0.0.1:1883
|
* The remote should be 127.0.0.1:1883 <--- But this does not work due to Esp network limitations
|
||||||
* We are using 127.0.0.1 because this is simpler to test with a single ESP
|
* We are using 127.0.0.1 because this is simpler to test with a single ESP
|
||||||
* Also, this will allow to mock and thus run Action on github
|
* Also, this will allow to mock and thus run Action on github
|
||||||
**/
|
**/
|
||||||
|
|||||||
@@ -3,4 +3,5 @@
|
|||||||
|
|
||||||
APP_NAME := nowifi-tests
|
APP_NAME := nowifi-tests
|
||||||
ARDUINO_LIBS := AUnit AceCommon AceTime TinyMqtt EspMock
|
ARDUINO_LIBS := AUnit AceCommon AceTime TinyMqtt EspMock
|
||||||
include ../../../EpoxyDuino/EpoxyDuino.mk
|
ESP_LIBS = ESP8266WiFi ESPAsyncTCP
|
||||||
|
include ../../../EspMock/EspMock.mk
|
||||||
|
|||||||
@@ -15,14 +15,16 @@ MqttBroker broker(1883);
|
|||||||
|
|
||||||
std::map<std::string, std::map<Topic, int>> published; // map[client_id] => map[topic] = count
|
std::map<std::string, std::map<Topic, int>> published; // map[client_id] => map[topic] = count
|
||||||
|
|
||||||
const char* lastPayload;
|
char* lastPayload = nullptr;
|
||||||
size_t lastLength;
|
size_t lastLength;
|
||||||
|
|
||||||
void onPublish(const MqttClient* srce, const Topic& topic, const char* payload, size_t length)
|
void onPublish(const MqttClient* srce, const Topic& topic, const char* payload, size_t length)
|
||||||
{
|
{
|
||||||
if (srce)
|
if (srce)
|
||||||
published[srce->id()][topic]++;
|
published[srce->id()][topic]++;
|
||||||
lastPayload = payload;
|
|
||||||
|
if (lastPayload) free(lastPayload);
|
||||||
|
lastPayload = strdup(payload);
|
||||||
lastLength = length;
|
lastLength = length;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -131,7 +133,6 @@ test(nowifi_nocallback_when_destroyed)
|
|||||||
|
|
||||||
test(nowifi_payload_nullptr)
|
test(nowifi_payload_nullptr)
|
||||||
{
|
{
|
||||||
return; // FIXME
|
|
||||||
published.clear();
|
published.clear();
|
||||||
|
|
||||||
const char* payload="abcd";
|
const char* payload="abcd";
|
||||||
|
|||||||
@@ -3,4 +3,5 @@
|
|||||||
|
|
||||||
APP_NAME := string-indexer-tests
|
APP_NAME := string-indexer-tests
|
||||||
ARDUINO_LIBS := AUnit AceCommon AceTime TinyMqtt EspMock
|
ARDUINO_LIBS := AUnit AceCommon AceTime TinyMqtt EspMock
|
||||||
include ../../../EpoxyDuino/EpoxyDuino.mk
|
ESP_LIBS = ESP8266WiFi ESPAsyncTCP
|
||||||
|
include ../../../EspMock/EspMock.mk
|
||||||
|
|||||||
@@ -1,28 +1,14 @@
|
|||||||
#include <AUnit.h>
|
#include <AUnit.h>
|
||||||
#include <TinyMqtt.h>
|
#include <StringIndexer.h>
|
||||||
#include <map>
|
#include <map>
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* TinyMqtt local unit tests.
|
* TinyMqtt / StringIndexer unit tests.
|
||||||
*
|
*
|
||||||
* Clients are connected to pseudo remote broker
|
|
||||||
* The remote will be 127.0.0.1:1883
|
|
||||||
* We are using 127.0.0.1 because this is simpler to test with a single ESP
|
|
||||||
* Also, this will allow to mock and thus run Action on github
|
|
||||||
**/
|
**/
|
||||||
|
|
||||||
using namespace std;
|
using namespace std;
|
||||||
|
|
||||||
MqttBroker broker(1883);
|
|
||||||
|
|
||||||
std::map<std::string, std::map<Topic, int>> published; // map[client_id] => map[topic] = count
|
|
||||||
|
|
||||||
void onPublish(const MqttClient* srce, const Topic& topic, const char* payload, size_t length)
|
|
||||||
{
|
|
||||||
if (srce)
|
|
||||||
published[srce->id()][topic]++;
|
|
||||||
}
|
|
||||||
|
|
||||||
test(indexer_empty)
|
test(indexer_empty)
|
||||||
{
|
{
|
||||||
assertEqual(StringIndexer::count(), 0);
|
assertEqual(StringIndexer::count(), 0);
|
||||||
|
|||||||
Reference in New Issue
Block a user