Compare commits
21 Commits
0.7.5
...
issue_2_br
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d39c58d8f5 | ||
|
|
36dde2c063 | ||
|
|
64a05bb60b | ||
|
|
bb89fc5284 | ||
|
|
c1fd1bc907 | ||
|
|
d919188eb0 | ||
|
|
9c7f3b6b8e | ||
|
|
88c7d552cb | ||
|
|
fab242e212 | ||
|
|
56a2be621f | ||
|
|
c4cf39ab68 | ||
|
|
90dea36ab0 | ||
|
|
25a721e06a | ||
|
|
b228d35ab0 | ||
|
|
c70716a595 | ||
|
|
8d5cad5fec | ||
|
|
d5430228e5 | ||
|
|
91c1f96146 | ||
|
|
f04a2a07c0 | ||
|
|
38f306c170 | ||
|
|
024e80c9dc |
8
.github/workflows/aunit.yml
vendored
8
.github/workflows/aunit.yml
vendored
@@ -24,5 +24,11 @@ jobs:
|
||||
git clone https://github.com/hsaturn/EspMock
|
||||
- name: Verify tests
|
||||
run: |
|
||||
make -C tests
|
||||
# Run tests for ESP8266
|
||||
make -C tests ESP_LIBS="ESP8266WiFi ESPAsyncTCP" tests
|
||||
make -C tests runtests
|
||||
make -C tests clean
|
||||
# Run tests for ESP32
|
||||
#make -C tests ESP_LIBS="ESP8266WiFi ESPAsyncTCP" tests
|
||||
#make -C tests runtests
|
||||
#make -C tests clean
|
||||
|
||||
12
README.md
12
README.md
@@ -1,12 +1,12 @@
|
||||
# TinyMqtt
|
||||
|
||||

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

|
||||

|
||||

|
||||

|
||||

|
||||
[](https://github.com/hsaturn/TinyMqtt/issues)
|
||||
[](https://www.espressif.com/en/products/socs/esp8266)
|
||||
[](https://www.espressif.com/en/products/socs/esp32)
|
||||
[](https://www.gnu.org/licenses/gpl-3.0.fr.html)
|
||||
[](https://docs.oasis-open.org/mqtt/mqtt/v3.1.1/errata01/os/mqtt-v3.1.1-errata01-os-complete.html#_Toc442180822)
|
||||
|
||||
TinyMqtt is a small, fast and capable Mqtt Broker and Client for Esp8266 / Esp32 / Esp WROOM
|
||||
|
||||
|
||||
@@ -31,7 +31,8 @@
|
||||
*
|
||||
*/
|
||||
|
||||
#include <my_credentials.h>
|
||||
const char *ssid = "";
|
||||
const char *password = "";
|
||||
|
||||
std::string topic="sensor/temperature";
|
||||
|
||||
@@ -40,11 +41,11 @@ MqttBroker broker(1883);
|
||||
MqttClient mqtt_a(&broker);
|
||||
MqttClient mqtt_b(&broker);
|
||||
|
||||
void onPublishA(const MqttClient* source, const Topic& topic, const char* payload, size_t length)
|
||||
{ Serial << endl << "---------> A Received " << topic.c_str() << endl; }
|
||||
void onPublishA(const MqttClient* /* source */, const Topic& topic, const char* payload, size_t /* length */)
|
||||
{ Serial << "--> client A received " << topic.c_str() << ", " << payload << endl; }
|
||||
|
||||
void onPublishB(const MqttClient* source, const Topic& topic, const char* payload, size_t length)
|
||||
{ Serial << endl << "---------> B Received " << topic.c_str() << endl; }
|
||||
void onPublishB(const MqttClient* /* source */, const Topic& topic, const char* payload, size_t /* length */)
|
||||
{ Serial << "--> client B Received " << topic.c_str() << ", " << payload << endl; }
|
||||
|
||||
void setup()
|
||||
{
|
||||
@@ -52,6 +53,9 @@ void setup()
|
||||
delay(500);
|
||||
Serial << "Clients with wifi " << endl;
|
||||
|
||||
if (strlen(ssid)==0)
|
||||
Serial << "****** PLEASE EDIT THE EXAMPLE AND MODIFY ssid/password *************" << endl;
|
||||
|
||||
WiFi.mode(WIFI_STA);
|
||||
WiFi.begin(ssid, password);
|
||||
|
||||
@@ -76,14 +80,14 @@ void loop()
|
||||
mqtt_b.loop();
|
||||
|
||||
// ============= client A publish ================
|
||||
static const int intervalA = 5000; // publishes every 5s
|
||||
static const int intervalA = 5000; // publishes every 5s (please avoid usage of delay())
|
||||
static uint32_t timerA = millis() + intervalA;
|
||||
|
||||
if (millis() > timerA)
|
||||
{
|
||||
Serial << "A is publishing " << topic.c_str() << endl;
|
||||
timerA += intervalA;
|
||||
mqtt_a.publish(topic);
|
||||
mqtt_a.publish(topic, " sent by A");
|
||||
}
|
||||
|
||||
// ============= client B publish ================
|
||||
@@ -92,8 +96,9 @@ void loop()
|
||||
|
||||
if (millis() > timerB)
|
||||
{
|
||||
static int temperature;
|
||||
Serial << "B is publishing " << topic.c_str() << endl;
|
||||
timerB += intervalB;
|
||||
mqtt_b.publish(topic, std::string(String(15+millis()%10).c_str()));
|
||||
mqtt_b.publish(topic, " sent by B: "+std::string(String(16+temperature++%6).c_str()));
|
||||
}
|
||||
}
|
||||
|
||||
@@ -32,11 +32,11 @@ MqttBroker broker(1883);
|
||||
MqttClient mqtt_a(&broker);
|
||||
MqttClient mqtt_b(&broker);
|
||||
|
||||
void onPublishA(const MqttClient* srce, const Topic& topic, const char* payload, size_t length)
|
||||
{ Serial << "--> A Received " << topic.c_str() << endl; }
|
||||
void onPublishA(const MqttClient* /* srce */, const Topic& topic, const char* payload, size_t /* length */)
|
||||
{ Serial << "--> Client A received msg on topic " << topic.c_str() << ", " << payload << endl; }
|
||||
|
||||
void onPublishB(const MqttClient* srce, const Topic& topic, const char* payload, size_t length)
|
||||
{ Serial << "--> B Received " << topic.c_str() << endl; }
|
||||
void onPublishB(const MqttClient* /* srce */, const Topic& topic, const char* payload, size_t /* length */)
|
||||
{ Serial << "--> Client B received msg on topic " << topic.c_str() << ", " << payload << endl; }
|
||||
|
||||
void setup()
|
||||
{
|
||||
@@ -53,7 +53,7 @@ void setup()
|
||||
|
||||
void loop()
|
||||
{
|
||||
broker.loop();
|
||||
broker.loop(); // Don't forget to call loop() for all brokers and clients
|
||||
mqtt_a.loop();
|
||||
mqtt_b.loop();
|
||||
|
||||
@@ -65,7 +65,7 @@ void loop()
|
||||
{
|
||||
Serial << "A is publishing " << topic.c_str() << endl;
|
||||
timerA += intervalA;
|
||||
mqtt_a.publish(topic);
|
||||
mqtt_a.publish(topic, "sent by A");
|
||||
}
|
||||
|
||||
// ============= client B publish ================
|
||||
@@ -76,6 +76,6 @@ void loop()
|
||||
{
|
||||
Serial << "B is publishing " << topic.c_str() << endl;
|
||||
timerB += intervalB;
|
||||
mqtt_b.publish(topic);
|
||||
mqtt_b.publish(topic, "sent by B");
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,7 +1,5 @@
|
||||
#include "TinyMqtt.h" // https://github.com/hsaturn/TinyMqtt
|
||||
|
||||
#include <my_credentials.h>
|
||||
|
||||
#define PORT 1883
|
||||
MqttBroker broker(PORT);
|
||||
|
||||
@@ -14,11 +12,22 @@ MqttBroker broker(PORT);
|
||||
* | +--------+ |
|
||||
* | |
|
||||
* +-----------------------------+
|
||||
*
|
||||
* Your ESP will become a MqttBroker.
|
||||
* You can test it with any client such as mqtt-spy for example
|
||||
*
|
||||
*/
|
||||
|
||||
const char* ssid = "";
|
||||
const char* password = "";
|
||||
|
||||
void setup()
|
||||
{
|
||||
Serial.begin(115200);
|
||||
|
||||
if (strlen(ssid)==0)
|
||||
Serial << "****** PLEASE MODIFY ssid/password *************" << endl;
|
||||
|
||||
WiFi.mode(WIFI_STA);
|
||||
WiFi.begin(ssid, password);
|
||||
|
||||
|
||||
@@ -16,8 +16,10 @@
|
||||
* | |
|
||||
* +-----------------+
|
||||
*
|
||||
* 1 - edit my_credentials.h to setup wifi essid/password
|
||||
* 1 - change the ssid/password
|
||||
* 2 - change BROKER values (or keep emqx.io test broker)
|
||||
* 3 - you can use mqtt-spy to connect to the same broker and
|
||||
* see the sensor/temperature updated by the client.
|
||||
*
|
||||
* pro - small memory footprint (both ram and flash)
|
||||
* - very simple to setup and use
|
||||
@@ -30,7 +32,8 @@
|
||||
const char* BROKER = "broker.emqx.io";
|
||||
const uint16_t BROKER_PORT = 1883;
|
||||
|
||||
#include <my_credentials.h>
|
||||
const char* ssid = "";
|
||||
const char* password = "";
|
||||
|
||||
static float temp=19;
|
||||
static MqttClient client;
|
||||
@@ -39,7 +42,10 @@ void setup()
|
||||
{
|
||||
Serial.begin(115200);
|
||||
delay(500);
|
||||
|
||||
Serial << "Simple clients with wifi " << endl;
|
||||
if (strlen(ssid)==0)
|
||||
Serial << "****** PLEASE MODIFY ssid/password *************" << endl;
|
||||
|
||||
WiFi.mode(WIFI_STA);
|
||||
WiFi.begin(ssid, password);
|
||||
@@ -54,15 +60,28 @@ void setup()
|
||||
|
||||
void loop()
|
||||
{
|
||||
client.loop();
|
||||
client.loop(); // Don't forget to call loop() for each broker and client
|
||||
|
||||
delay(1000);
|
||||
// delay(1000); please avoid usage of delay (see below how this done using next_send and millis())
|
||||
static auto next_send = millis();
|
||||
|
||||
if (millis() > next_send)
|
||||
{
|
||||
next_send += 1000;
|
||||
|
||||
if (not client.connected())
|
||||
{
|
||||
Serial << millis() << ": Not connected to broker" << endl;
|
||||
return;
|
||||
}
|
||||
|
||||
auto rnd=random(100);
|
||||
|
||||
if (rnd > 66) temp += 0.1;
|
||||
else if (rnd < 33) temp -= 0.1;
|
||||
|
||||
client.publish("sensor/temperature", String(temp));
|
||||
Serial << "--> Publishing a new sensor/temperature value: " << temp << endl;
|
||||
|
||||
client.publish("sensor/temperature", String(temp));
|
||||
}
|
||||
}
|
||||
|
||||
@@ -3,6 +3,7 @@
|
||||
#if defined(ESP8266)
|
||||
#include <ESP8266mDNS.h>
|
||||
#elif defined(ESP32)
|
||||
#include <WiFi.h>
|
||||
#include <ESPmDNS.h>
|
||||
#else
|
||||
#error Unsupported platform
|
||||
@@ -11,8 +12,11 @@
|
||||
#include <sstream>
|
||||
#include <map>
|
||||
|
||||
bool echo_on = true;
|
||||
|
||||
/** Very complex example
|
||||
* Console allowing to make any kind of test.
|
||||
* Console allowing to make any kind of test,
|
||||
* even some stress tests.
|
||||
*
|
||||
* Upload the sketch, the use the terminal.
|
||||
* Press H for mini help.
|
||||
@@ -21,7 +25,8 @@
|
||||
* TODO examples of scripts
|
||||
*/
|
||||
|
||||
#include <my_credentials.h>
|
||||
const char* ssid = "";
|
||||
const char* password = "";
|
||||
|
||||
std::string topic="sensor/temperature";
|
||||
|
||||
@@ -46,17 +51,32 @@ void setup()
|
||||
WiFi.persistent(false); // https://github.com/esp8266/Arduino/issues/1054
|
||||
Serial.begin(115200);
|
||||
delay(500);
|
||||
Serial << endl << endl << endl
|
||||
<< "Connecting to '" << ssid << "' ";
|
||||
|
||||
Serial << endl << endl;
|
||||
Serial << "***************************************************************" << endl;
|
||||
Serial << "* Welcome to the TinyMqtt console" << endl;
|
||||
Serial << endl;
|
||||
Serial << "* The console allows to test all features of the libraries." << endl;
|
||||
Serial << endl;
|
||||
if (strlen(ssid)==0)
|
||||
Serial << "* WARNING: You may want to modify ssid/password in order" << endl
|
||||
<< " to reflect your Wifi configuration." << endl;
|
||||
Serial << endl;
|
||||
Serial << "* Enter help to view the list of commands." << endl;
|
||||
Serial << "***************************************************************" << endl;
|
||||
Serial << endl;
|
||||
|
||||
Serial << "Connecting to '" << ssid << "' ";
|
||||
|
||||
WiFi.mode(WIFI_STA);
|
||||
WiFi.begin(ssid, password);
|
||||
WiFi.mode(WIFI_STA);
|
||||
WiFi.begin(ssid, password);
|
||||
|
||||
while (WiFi.status() != WL_CONNECTED)
|
||||
{ Serial << '-'; delay(500); }
|
||||
|
||||
Serial << "Connected to " << ssid << "IP address: " << WiFi.localIP() << endl;
|
||||
Serial << "Type help for more..." << endl;
|
||||
Serial << endl << "Connected to " << ssid << "IP address: " << WiFi.localIP() << endl;
|
||||
|
||||
const char* name="tinytest";
|
||||
Serial << "Starting MDNS, name= " << name;
|
||||
@@ -71,27 +91,67 @@ void setup()
|
||||
brokers["broker"] = broker;
|
||||
}
|
||||
|
||||
std::string getword(std::string& str, const char* if_empty=nullptr, char sep=' ');
|
||||
|
||||
int getint(std::string& str, const int if_empty=0)
|
||||
{
|
||||
std::string sword;
|
||||
while(str.length() && str[0]>='0' && str[0]<='9')
|
||||
std::string str2=str;
|
||||
std::string sword = getword(str);
|
||||
if (sword[0] and isdigit(sword[0]))
|
||||
{
|
||||
sword += str[0]; str.erase(0,1);
|
||||
int ret=atoi(sword.c_str());
|
||||
while(isdigit(sword[0]) or sword[0]==' ') sword.erase(0,1);
|
||||
if (sword.length()) str = sword+' '+str;
|
||||
return ret;
|
||||
}
|
||||
while(str[0]==' ') str.erase(0,1);
|
||||
if (if_empty and sword.length()==0) return if_empty;
|
||||
return atoi(sword.c_str());
|
||||
str=str2;
|
||||
return if_empty;
|
||||
}
|
||||
|
||||
std::string getword(std::string& str, const char* if_empty=nullptr, char sep=' ')
|
||||
std::string getword(std::string& str, const char* if_empty/*=nullptr*/, char sep/*=' '*/)
|
||||
{
|
||||
char quote=(str[0]=='"' or str[0]=='\'' ? str[0] : 0);
|
||||
if (quote) str.erase(0,1);
|
||||
std::string sword;
|
||||
while(str.length() && str[0]!=sep)
|
||||
while(str.length() and (str[0]!=sep or quote))
|
||||
{
|
||||
sword += str[0]; str.erase(0,1);
|
||||
if (str[0]==quote)
|
||||
{
|
||||
str.erase(0,1);
|
||||
break;
|
||||
}
|
||||
sword += str[0];
|
||||
str.erase(0,1);
|
||||
}
|
||||
while(str[0]==sep) str.erase(0,1);
|
||||
if (if_empty and sword.length()==0) return if_empty;
|
||||
if (quote==false and sword.length()>=4 and sword.substr(0,3)=="rnd")
|
||||
{
|
||||
sword.erase(0,3);
|
||||
if (sword[0]=='(')
|
||||
{
|
||||
int to = 100;
|
||||
sword.erase(0,1);
|
||||
int from=getint(sword);
|
||||
if (sword[0]==',')
|
||||
{
|
||||
sword.erase(0,1);
|
||||
to = getint(sword);
|
||||
if (sword[0]!=')') Serial << "Missing ')'" << endl;
|
||||
}
|
||||
else
|
||||
{
|
||||
to=from;
|
||||
from=0;
|
||||
}
|
||||
return String(random(from,to)).c_str();
|
||||
}
|
||||
else
|
||||
{
|
||||
Serial << "Missing '('" << endl;
|
||||
}
|
||||
}
|
||||
while(str[0]==' ') str.erase(0,1);
|
||||
return sword;
|
||||
}
|
||||
|
||||
@@ -140,7 +200,7 @@ std::set<std::string> commands = {
|
||||
"auto", "broker", "blink", "client", "connect",
|
||||
"create", "delete", "help", "interval",
|
||||
"ls", "ip", "off", "on", "set",
|
||||
"publish", "reset", "subscribe", "unsubscribe", "view", "every"
|
||||
"publish", "reset", "subscribe", "unsubscribe", "view", "echo", "every"
|
||||
};
|
||||
|
||||
void convertToCommand(std::string& search)
|
||||
@@ -179,7 +239,7 @@ void replace(const char* d, std::string& str, std::string srch, std::string to)
|
||||
{
|
||||
str.erase(pos, srch.length());
|
||||
str.insert(pos, to);
|
||||
pos += to.length();
|
||||
pos += to.length()-1;
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -197,6 +257,7 @@ void replaceVars(std::string& cmd)
|
||||
}
|
||||
cmd.erase(0, cmd.find_first_not_of(" "));
|
||||
cmd.erase(cmd.find_last_not_of(" ")+1);
|
||||
|
||||
}
|
||||
|
||||
// publish at regular interval
|
||||
@@ -463,9 +524,7 @@ void eval(std::string& cmd)
|
||||
}
|
||||
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.clear(); // remove payload
|
||||
retval = client->publish(getword(cmd, topic.c_str()), getword(cmd));
|
||||
}
|
||||
else if (compare(s,"subscribe"))
|
||||
{
|
||||
@@ -497,6 +556,22 @@ void eval(std::string& cmd)
|
||||
pinMode(pin, OUTPUT);
|
||||
digitalWrite(pin, LOW);
|
||||
}
|
||||
else if (compare(s, "echo"))
|
||||
{
|
||||
s=getword(cmd);
|
||||
if (s=="on")
|
||||
echo_on = true;
|
||||
else if (s=="off")
|
||||
echo_on = false;
|
||||
else
|
||||
{
|
||||
Serial << s << ' ';
|
||||
while(cmd.length())
|
||||
{
|
||||
Serial << getword(cmd) << ' ';
|
||||
}
|
||||
}
|
||||
}
|
||||
else if (compare(s, "every"))
|
||||
{
|
||||
uint32_t ms = getint(cmd, 0);
|
||||
@@ -517,37 +592,21 @@ void eval(std::string& cmd)
|
||||
else if (compare(cmd, "off") or compare(cmd, "on"))
|
||||
{
|
||||
bool active=getword(cmd)=="on";
|
||||
uint8_t ever;
|
||||
if (compare(cmd, "all"))
|
||||
ever=100;
|
||||
else
|
||||
ever=getint(cmd, 99);
|
||||
uint8_t ever=getint(cmd, 100);
|
||||
uint8_t count=0;
|
||||
if (ever == 99)
|
||||
{
|
||||
Serial << "Missing every number" << endl;
|
||||
}
|
||||
else
|
||||
{
|
||||
for(auto& every: everies)
|
||||
{
|
||||
if (count==ever or (ever==100))
|
||||
{
|
||||
if (every.active != active)
|
||||
{
|
||||
Serial << "every #" << count << (active ? " on" :" off") << endl;
|
||||
every.active = active;
|
||||
every.underrun = 0;
|
||||
}
|
||||
ever = 99;
|
||||
break;
|
||||
}
|
||||
count++;
|
||||
}
|
||||
if (ever != 99)
|
||||
{
|
||||
Serial << "Every not found" << endl;
|
||||
}
|
||||
}
|
||||
}
|
||||
else if (compare(cmd, "list") or cmd.length()==0)
|
||||
{
|
||||
@@ -725,9 +784,11 @@ void eval(std::string& cmd)
|
||||
Serial << " set [name][value]" << endl;
|
||||
Serial << " ! repeat last command" << endl;
|
||||
Serial << endl;
|
||||
Serial << " every ms [command]; every list; every remove [nr|all], every [on|off] #" << endl;
|
||||
Serial << " echo [on|off] or strings" << endl;
|
||||
Serial << " every ms [command]; every list; every remove [nr|all], every (on|off) [#]" << endl;
|
||||
Serial << " on {output}; off {output}" << endl;
|
||||
Serial << " $id : name of the client." << endl;
|
||||
Serial << " rnd[(min[,max])] random number." << endl;
|
||||
Serial << " default topic is '" << topic.c_str() << "'" << endl;
|
||||
Serial << endl;
|
||||
}
|
||||
@@ -811,8 +872,10 @@ void loop()
|
||||
{
|
||||
static std::string cmd;
|
||||
char c=Serial.read();
|
||||
if (echo_on)
|
||||
Serial << c;
|
||||
|
||||
if (c==10 or c==14)
|
||||
if (c==10 or c==13)
|
||||
{
|
||||
Serial << "----------------[ " << cmd.c_str() << " ]--------------" << endl;
|
||||
static std::string last_cmd;
|
||||
|
||||
@@ -6,7 +6,7 @@
|
||||
"type": "git",
|
||||
"url": "https://github.com/hsaturn/TinyMqtt.git"
|
||||
},
|
||||
"version": "0.7.5",
|
||||
"version": "0.7.9",
|
||||
"exclude": "",
|
||||
"examples": "examples/*/*.ino",
|
||||
"frameworks": "arduino",
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
name=TinyMqtt
|
||||
version=0.7.5
|
||||
version=0.7.9
|
||||
author=Francois BIOT, HSaturn, <hsaturn@gmail.com>
|
||||
maintainer=Francois BIOT, HSaturn, <hsaturn@gmail.com>
|
||||
sentence=A tiny broker and client library for MQTT messaging.
|
||||
|
||||
@@ -42,7 +42,7 @@
|
||||
#ifndef ARDUINO_STREAMING
|
||||
#define ARDUINO_STREAMING
|
||||
|
||||
#if defined(ARDUINO) && ARDUINO >= 100
|
||||
#if (defined(ARDUINO) && ARDUINO >= 100) || defined(EPOXY_DUINO)
|
||||
#include "Arduino.h"
|
||||
#else
|
||||
#ifndef STREAMING_CONSOLE
|
||||
@@ -154,7 +154,7 @@ template<typename T>
|
||||
inline Print &operator <<(Print &obj, const _BASED<T> &arg)
|
||||
{ obj.print(arg.val, arg.base); return obj; }
|
||||
|
||||
#if ARDUINO >= 18
|
||||
#if ARDUINO >= 18 || defined(EPOXY_DUINO)
|
||||
// Specialization for class _FLOAT
|
||||
// Thanks to Michael Margolis for suggesting a way
|
||||
// to accommodate Arduino 0018's floating point precision
|
||||
|
||||
@@ -59,7 +59,7 @@ void MqttClient::close(bool bSendDisconnect)
|
||||
{
|
||||
debug("close " << id().c_str());
|
||||
mqtt_connected = false;
|
||||
if (client)
|
||||
if (client) // connected to a remote broker
|
||||
{
|
||||
if (bSendDisconnect and client->connected())
|
||||
{
|
||||
@@ -72,10 +72,16 @@ void MqttClient::close(bool bSendDisconnect)
|
||||
if (parent)
|
||||
{
|
||||
parent->removeClient(this);
|
||||
parent=nullptr;
|
||||
parent = nullptr;
|
||||
}
|
||||
}
|
||||
|
||||
void MqttClient::connect(MqttBroker* parentBroker)
|
||||
{
|
||||
close();
|
||||
parent = parentBroker;
|
||||
}
|
||||
|
||||
void MqttClient::connect(std::string broker, uint16_t port, uint16_t ka)
|
||||
{
|
||||
debug("cnx: closing");
|
||||
@@ -397,8 +403,13 @@ void MqttClient::processMessage(const MqttMessage* mesg)
|
||||
#ifdef TINY_MQTT_DEBUG
|
||||
if (mesg->type() != MqttMessage::Type::PingReq && mesg->type() != MqttMessage::Type::PingResp)
|
||||
{
|
||||
#ifdef NOT_ESP_CORE
|
||||
Serial << "---> INCOMING " << _HEX(mesg->type()) << " client(" << (dbg_ptr)client << ':' << clientId << ") mem=" << " ESP.getFreeHeap() "<< endl;
|
||||
#else
|
||||
Serial << "---> INCOMING " << _HEX(mesg->type()) << " client(" << (dbg_ptr)client << ':' << clientId << ") mem=" << ESP.getFreeHeap() << endl;
|
||||
#endif
|
||||
// mesg->hexdump("Incoming");
|
||||
mesg->hexdump("Incoming");
|
||||
}
|
||||
#endif
|
||||
auto header = mesg->getVHeader();
|
||||
@@ -540,6 +551,9 @@ if (mesg->type() != MqttMessage::Type::PingReq && mesg->type() != MqttMessage::T
|
||||
break;
|
||||
|
||||
case MqttMessage::Type::Publish:
|
||||
#ifdef TINY_MQTT_DEBUG
|
||||
Serial << "publish " << mqtt_connected << '/' << (long) client << endl;
|
||||
#endif
|
||||
if (mqtt_connected or client == nullptr)
|
||||
{
|
||||
uint8_t qos = mesg->type() & 0x6;
|
||||
@@ -554,8 +568,12 @@ if (mesg->type() != MqttMessage::Type::PingReq && mesg->type() != MqttMessage::T
|
||||
// TODO reset DUP
|
||||
// TODO reset RETAIN
|
||||
|
||||
if (client==nullptr) // internal MqttClient receives publish
|
||||
if (parent==nullptr or client==nullptr) // internal MqttClient receives publish
|
||||
{
|
||||
#ifdef TINY_MQTT_DEBUG
|
||||
Serial << (isSubscribedTo(published) ? "not" : "") << " subscribed.\n";
|
||||
Serial << "has " << (callback ? "" : "no ") << " callback.\n";
|
||||
#endif
|
||||
if (callback and isSubscribedTo(published))
|
||||
{
|
||||
callback(this, published, payload, len); // TODO send the real payload
|
||||
@@ -609,7 +627,6 @@ MqttError MqttClient::publish(const Topic& topic, const char* payload, size_t pa
|
||||
MqttMessage msg(MqttMessage::Publish);
|
||||
msg.add(topic);
|
||||
msg.add(payload, pay_length, false);
|
||||
msg.complete();
|
||||
if (parent)
|
||||
{
|
||||
return parent->publish(this, topic, msg);
|
||||
@@ -633,6 +650,10 @@ MqttError MqttClient::publishIfSubscribed(const Topic& topic, const MqttMessage&
|
||||
else
|
||||
{
|
||||
processMessage(&msg);
|
||||
|
||||
#ifdef TINY_MQTT_DEBUG
|
||||
Serial << "Should call the callback ?\n";
|
||||
#endif
|
||||
// callback(this, topic, nullptr, 0); // TODO Payload
|
||||
}
|
||||
}
|
||||
@@ -665,7 +686,12 @@ void MqttMessage::incoming(char in_byte)
|
||||
state = Length;
|
||||
break;
|
||||
case Length:
|
||||
size = (size<<7) + (in_byte & 0x3F);
|
||||
if (size==0)
|
||||
size = in_byte & 0x7F;
|
||||
else if (size<128)
|
||||
size += static_cast<uint16_t>(in_byte & 0x7F)<<7;
|
||||
else
|
||||
state = Error; // Really don't want to handle msg with length > 16k
|
||||
if (size > MaxBufferLength)
|
||||
{
|
||||
state = Error;
|
||||
@@ -705,7 +731,7 @@ void MqttMessage::incoming(char in_byte)
|
||||
reset();
|
||||
break;
|
||||
}
|
||||
if (buffer.length() > MaxBufferLength) // TODO magic 256 ?
|
||||
if (buffer.length() > MaxBufferLength)
|
||||
{
|
||||
debug("Too long " << state);
|
||||
reset();
|
||||
@@ -716,36 +742,47 @@ void MqttMessage::add(const char* p, size_t len, bool addLength)
|
||||
{
|
||||
if (addLength)
|
||||
{
|
||||
buffer.reserve(buffer.length()+addLength+2);
|
||||
buffer.reserve(buffer.length()+2);
|
||||
incoming(len>>8);
|
||||
incoming(len & 0xFF);
|
||||
}
|
||||
while(len--) incoming(*p++);
|
||||
}
|
||||
|
||||
void MqttMessage::encodeLength(char* msb, int length) const
|
||||
void MqttMessage::encodeLength() const
|
||||
{
|
||||
if (state != Complete)
|
||||
{
|
||||
int length = buffer.size()-2; // 1 byte for header, 1 byte for pre-reserved length field.
|
||||
std::string::size_type ins=1;
|
||||
do
|
||||
{
|
||||
uint8_t encoded(length & 0x7F);
|
||||
length >>=7;
|
||||
if (length) encoded |= 0x80;
|
||||
*msb++ = encoded;
|
||||
} while (length);
|
||||
};
|
||||
|
||||
void MqttMessage::complete()
|
||||
{
|
||||
encodeLength(&buffer[1], buffer.size()-2);
|
||||
if (ins==1)
|
||||
buffer[ins]=encoded;
|
||||
else
|
||||
buffer.insert(ins, 1, encoded);
|
||||
// On pourrait optimiser, cet insert est couteux, il faudrait en fait non pas
|
||||
// insérer, mais réserver 4 octets pour les remplir
|
||||
// plus tard avec ke fixed header et la taille.
|
||||
// Cela changerait en revanche le début du message qui ne serait plus
|
||||
// buffer[0], mais buffer[0..3] selon la taille du message.
|
||||
|
||||
++ins;
|
||||
} while (length);
|
||||
state = Complete;
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
MqttError MqttMessage::sendTo(MqttClient* client) const
|
||||
{
|
||||
if (buffer.size())
|
||||
{
|
||||
debug("sending " << buffer.size() << " bytes");
|
||||
encodeLength(&buffer[1], buffer.size()-2);
|
||||
encodeLength();
|
||||
// hexdump("snd");
|
||||
client->write(&buffer[0], buffer.size());
|
||||
}
|
||||
|
||||
@@ -10,10 +10,9 @@
|
||||
#include <ESP8266WiFi.h>
|
||||
#endif
|
||||
#elif defined(ESP32)
|
||||
#include <WiFi.h>
|
||||
#ifdef TCP_ASYNC
|
||||
#include <AsyncTCP.h> // https://github.com/me-no-dev/AsyncTCP
|
||||
#else
|
||||
#include <WiFi.h>
|
||||
#endif
|
||||
#endif
|
||||
#ifdef EPOXY_DUINO
|
||||
@@ -65,7 +64,7 @@ class Topic : public IndexedString
|
||||
class MqttClient;
|
||||
class MqttMessage
|
||||
{
|
||||
const uint16_t MaxBufferLength = 255;
|
||||
const uint16_t MaxBufferLength = 4096; //hard limit: 16k
|
||||
public:
|
||||
enum Type
|
||||
{
|
||||
@@ -102,8 +101,6 @@ class MqttMessage
|
||||
void add(const Topic& t) { add(t.str()); }
|
||||
const char* end() const { return &buffer[0]+buffer.size(); }
|
||||
const char* getVHeader() const { return &buffer[vheader]; }
|
||||
uint16_t length() const { return buffer.size(); }
|
||||
void complete();
|
||||
|
||||
void reset();
|
||||
|
||||
@@ -128,12 +125,12 @@ class MqttMessage
|
||||
void hexdump(const char* prefix=nullptr) const;
|
||||
|
||||
private:
|
||||
void encodeLength(char* msb, int length) const;
|
||||
void encodeLength() const;
|
||||
|
||||
mutable std::string buffer; // mutable -> sendTo()
|
||||
uint8_t vheader;
|
||||
uint16_t size; // bytes left to receive
|
||||
State state;
|
||||
mutable State state; // mutable -> encodeLength()
|
||||
};
|
||||
|
||||
class MqttBroker;
|
||||
@@ -173,10 +170,18 @@ class MqttClient
|
||||
/** Should be called in main loop() */
|
||||
void loop();
|
||||
void close(bool bSendDisconnect=true);
|
||||
void setCallback(CallBack fun) {callback=fun; };
|
||||
void setCallback(CallBack fun)
|
||||
{
|
||||
callback=fun;
|
||||
#ifdef TINY_MQTT_DEBUG
|
||||
Serial << "Callback set to " << (long)fun << endl;
|
||||
if (callback) callback(this, "test/topic", "value", 5);
|
||||
#endif
|
||||
};
|
||||
|
||||
// Publish from client to the world
|
||||
MqttError publish(const Topic&, const char* payload, size_t pay_length);
|
||||
MqttError publish(const Topic& t, const char* payload) { return publish(t, payload, strlen(payload)); }
|
||||
MqttError publish(const Topic& t, const String& s) { return publish(t, s.c_str(), s.length()); }
|
||||
MqttError publish(const Topic& t, const std::string& s) { return publish(t,s.c_str(),s.length());}
|
||||
MqttError publish(const Topic& t) { return publish(t, nullptr, 0);};
|
||||
@@ -214,6 +219,8 @@ class MqttClient
|
||||
static long counter;
|
||||
|
||||
private:
|
||||
|
||||
// event when tcp/ip link established (real or fake)
|
||||
static void onConnect(void * client_ptr, TcpClient*);
|
||||
#ifdef TCP_ASYNC
|
||||
static void onData(void* client_ptr, TcpClient*, void* data, size_t len);
|
||||
@@ -240,7 +247,7 @@ class MqttClient
|
||||
// (this is the case when MqttBroker isn't used except here)
|
||||
MqttBroker* parent=nullptr; // connection to local broker
|
||||
|
||||
TcpClient* client=nullptr; // connection to mqtt client or to remote broker
|
||||
TcpClient* client=nullptr; // connection to remote broker
|
||||
std::set<Topic> subscriptions;
|
||||
std::string clientId;
|
||||
CallBack callback = nullptr;
|
||||
|
||||
8
tests/length-tests.todo/Makefile
Normal file
8
tests/length-tests.todo/Makefile
Normal file
@@ -0,0 +1,8 @@
|
||||
# See https://github.com/bxparks/EpoxyDuino for documentation about this
|
||||
# Makefile to compile and run Arduino programs natively on Linux or MacOS.
|
||||
|
||||
APP_NAME := length-tests
|
||||
ARDUINO_LIBS := AUnit AceCommon AceTime TinyMqtt EspMock ESP8266WiFi ESPAsyncTCP
|
||||
ARDUINO_LIB_DIRS := ../../../EspMock/libraries
|
||||
EPOXY_CORE := EPOXY_CORE_ESP8266
|
||||
include ../../../EpoxyDuino/EpoxyDuino.mk
|
||||
53
tests/length-tests.todo/length-tests.ino
Normal file
53
tests/length-tests.todo/length-tests.ino
Normal file
@@ -0,0 +1,53 @@
|
||||
#include <AUnit.h>
|
||||
#include <TinyMqtt.h>
|
||||
#include <map>
|
||||
|
||||
/**
|
||||
* TinyMqtt local unit tests.
|
||||
*
|
||||
* Clients are connected to pseudo remote broker
|
||||
* 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
|
||||
* Also, this will allow to mock and thus run Action on github
|
||||
**/
|
||||
|
||||
using namespace std;
|
||||
|
||||
MqttBroker broker(1883);
|
||||
|
||||
std::map<std::string, std::map<Topic, int>> published; // map[client_id] => map[topic] = count
|
||||
|
||||
const char* lastPayload;
|
||||
size_t lastLength;
|
||||
|
||||
void onPublish(const MqttClient* srce, const Topic& topic, const char* payload, size_t length)
|
||||
{
|
||||
if (srce)
|
||||
published[srce->id()][topic]++;
|
||||
lastPayload = payload;
|
||||
lastLength = length;
|
||||
}
|
||||
|
||||
test(length_decode_greater_than_127)
|
||||
{
|
||||
// TODO WRITE THIS TEST
|
||||
// The test should verify than a mqtt message with more than 127 bytes is correctly decoded
|
||||
assertEqual(1,2);
|
||||
}
|
||||
|
||||
|
||||
//----------------------------------------------------------------------------
|
||||
// setup() and loop()
|
||||
void setup() {
|
||||
delay(1000);
|
||||
Serial.begin(115200);
|
||||
while(!Serial);
|
||||
|
||||
Serial.println("=============[ NO WIFI CONNECTION TinyMqtt TESTS ]========================");
|
||||
}
|
||||
|
||||
void loop() {
|
||||
aunit::TestRunner::run();
|
||||
|
||||
if (Serial.available()) ESP.reset();
|
||||
}
|
||||
@@ -2,6 +2,7 @@
|
||||
# Makefile to compile and run Arduino programs natively on Linux or MacOS.
|
||||
|
||||
APP_NAME := local-tests
|
||||
ARDUINO_LIBS := AUnit AceCommon AceTime TinyMqtt EspMock
|
||||
ESP_LIBS = ESP8266WiFi ESPAsyncTCP
|
||||
include ../../../EspMock/EspMock.mk
|
||||
ARDUINO_LIBS := AUnit AceCommon AceTime TinyMqtt EspMock ESP8266WiFi ESPAsyncTCP
|
||||
ARDUINO_LIB_DIRS := ../../../EspMock/libraries
|
||||
EPOXY_CORE := EPOXY_CORE_ESP8266
|
||||
include ../../../EpoxyDuino/EpoxyDuino.mk
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
#include <Arduino.h>
|
||||
#include <AUnit.h>
|
||||
#include <TinyMqtt.h>
|
||||
#include <map>
|
||||
|
||||
@@ -2,6 +2,7 @@
|
||||
# Makefile to compile and run Arduino programs natively on Linux or MacOS.
|
||||
|
||||
APP_NAME := nowifi-tests
|
||||
ARDUINO_LIBS := AUnit AceCommon AceTime TinyMqtt EspMock
|
||||
ESP_LIBS = ESP8266WiFi ESPAsyncTCP
|
||||
include ../../../EspMock/EspMock.mk
|
||||
ARDUINO_LIBS := AUnit AceCommon AceTime TinyMqtt EspMock ESP8266WiFi ESPAsyncTCP
|
||||
ARDUINO_LIB_DIRS := ../../../EspMock/libraries
|
||||
EPOXY_CORE := EPOXY_CORE_ESP8266
|
||||
include ../../../EpoxyDuino/EpoxyDuino.mk
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
#include <Arduino.h>
|
||||
#include <AUnit.h>
|
||||
#include <TinyMqtt.h>
|
||||
#include <map>
|
||||
|
||||
@@ -2,6 +2,7 @@
|
||||
# Makefile to compile and run Arduino programs natively on Linux or MacOS.
|
||||
|
||||
APP_NAME := string-indexer-tests
|
||||
ARDUINO_LIBS := AUnit AceCommon AceTime TinyMqtt EspMock
|
||||
ESP_LIBS = ESP8266WiFi ESPAsyncTCP
|
||||
include ../../../EspMock/EspMock.mk
|
||||
ARDUINO_LIBS := AUnit AceCommon AceTime TinyMqtt EspMock ESP8266WiFi ESPAsync
|
||||
ARDUINO_LIB_DIRS := ../../../EspMock/libraries
|
||||
EPOXY_CORE := EPOXY_CORE_ESP8266
|
||||
include ../../../EpoxyDuino/EpoxyDuino.mk
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
#include <Arduino.h>
|
||||
#include <AUnit.h>
|
||||
#include <StringIndexer.h>
|
||||
#include <map>
|
||||
@@ -105,5 +106,5 @@ void setup() {
|
||||
void loop() {
|
||||
aunit::TestRunner::run();
|
||||
|
||||
if (Serial.available()) ESP.reset();
|
||||
// if (Serial.available()) ESP.reset();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user