Compare commits
21 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
aa62bcaf02 | ||
|
|
90435b1260 | ||
|
|
ac391a49a4 | ||
|
|
30e75b82e0 | ||
|
|
65e22c85c6 | ||
|
|
bd566945cc | ||
|
|
66cb80ff3f | ||
|
|
ef4a0263a6 | ||
|
|
3135d9a28c | ||
|
|
6b9d764c23 | ||
|
|
42d89cdf06 | ||
|
|
67ce97e523 | ||
|
|
25602ec2f5 | ||
|
|
fd305d7b48 | ||
|
|
6339be8044 | ||
|
|
d3bf379d19 | ||
|
|
3c77f7cafd | ||
|
|
ff3ff6e80e | ||
|
|
c4cc36a88f | ||
|
|
14882fed22 | ||
|
|
ead3ae90e9 |
@@ -0,0 +1,111 @@
|
||||
#include <SPI.h>
|
||||
#include <Ethernet.h>
|
||||
|
||||
#include "TinyMqtt.h" // https://github.com/hsaturn/TinyMqtt
|
||||
|
||||
#define WIZRST D3 //Specify pin to use for reseting W5500
|
||||
#define WIZCS D1 //Specify the pin for SPI CS
|
||||
|
||||
#define PORT 1883
|
||||
MqttBroker broker(PORT);
|
||||
unsigned long Time;
|
||||
unsigned long freeRam;
|
||||
|
||||
/** Basic Mqtt Broker
|
||||
*
|
||||
* +-----------------------------+
|
||||
* | ESP |
|
||||
* | +--------+ |
|
||||
* | | broker | | 1883 <--- External client/s
|
||||
* | +--------+ |
|
||||
* | |
|
||||
* +-----------------------------+
|
||||
*
|
||||
* Your ESP will become a MqttBroker.
|
||||
* You can test it with any client such as mqtt-spy for example
|
||||
*
|
||||
*/
|
||||
|
||||
#if defined(USE_ETHERNET)
|
||||
|
||||
byte mac[] = { 0x00, 0xAA, 0xBB, 0xE0, 0x01, 0x25 }; //MAC Address
|
||||
//IPAddress ip = (192,168,0,88); //Fixed IP Address
|
||||
|
||||
#else
|
||||
|
||||
const char* ssid = "xxxxxxx";
|
||||
const char* password = "xxxxxxxx";
|
||||
|
||||
#endif
|
||||
|
||||
|
||||
void WizReset() {
|
||||
Serial.print("Resetting Wiz W5500 Ethernet Board... ");
|
||||
pinMode(WIZRST, OUTPUT);
|
||||
digitalWrite(WIZRST, HIGH);
|
||||
delay(250);
|
||||
digitalWrite(WIZRST, LOW);
|
||||
delay(50);
|
||||
digitalWrite(WIZRST, HIGH);
|
||||
delay(350);
|
||||
Serial.println("Done.");
|
||||
}
|
||||
|
||||
void setup()
|
||||
{
|
||||
Serial.begin(115200);
|
||||
|
||||
#if defined(USE_ETHERNET)
|
||||
|
||||
Ethernet.init(WIZCS); // SPI CS Pin
|
||||
SPI.begin();
|
||||
WizReset();
|
||||
Console << TinyConsole::green << "Starting Ethernet...." << endl;
|
||||
Ethernet.begin(mac); //Connect using DHCP
|
||||
//Ethernet.begin(mac,ip); //Connect using Fixed IP
|
||||
if (Ethernet.hardwareStatus() == EthernetNoHardware) {
|
||||
Console << TinyConsole::red << "Ethernet shield was not found. Sorry, can't run without hardware. :(" << endl;
|
||||
} else
|
||||
if (Ethernet.linkStatus() == LinkOFF) {
|
||||
Console << TinyConsole::red << "Ethernet cable is not connected." << endl;
|
||||
}
|
||||
Console << TinyConsole::green << "Local Ethernet IP address: " << Ethernet.localIP() << endl;
|
||||
broker.begin();
|
||||
Console << "Broker ready (eth) : " << Ethernet.localIP() << " on port " << PORT << endl;
|
||||
|
||||
#else
|
||||
|
||||
if (strlen(ssid)==0)
|
||||
Console << TinyConsole::red << "****** PLEASE MODIFY ssid/password *************" << endl;
|
||||
WiFi.disconnect(); //Remove previous SSID & Password
|
||||
WiFi.begin(ssid, password); // Connect to the network
|
||||
Console << TinyConsole::white << "WiFi Connecting to " << ssid << " ...";
|
||||
int i = 0;
|
||||
while (WiFi.status() != WL_CONNECTED) { // Wait for the Wi-Fi to connect
|
||||
delay(1000);
|
||||
Console << TinyConsole::white << ".";
|
||||
i++;
|
||||
if (i > 20) break;
|
||||
}
|
||||
Console << endl << endl;
|
||||
Console << TinyConsole::green << "Connected to " << ssid << " IP address: " << WiFi.localIP() << endl;
|
||||
broker.begin();
|
||||
Console << "Broker ready (wifi) : " << WiFi.localIP() << " on port " << PORT << endl;
|
||||
|
||||
#endif
|
||||
}
|
||||
|
||||
void loop()
|
||||
{
|
||||
broker.loop();
|
||||
if(millis()-Time>10000) {
|
||||
Time=millis();
|
||||
if(ESP.getFreeHeap()!=freeRam)
|
||||
{
|
||||
freeRam=ESP.getFreeHeap();
|
||||
Serial.print("RAM:");
|
||||
Serial.println(freeRam);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,117 @@
|
||||
#include <SPI.h>
|
||||
#include <Ethernet.h>
|
||||
|
||||
#include "TinyMqtt.h" // https://github.com/hsaturn/TinyMqtt
|
||||
|
||||
#define WIZRST 20 //Specify pin to use for reseting W5500 = GPIO20
|
||||
#define WIZCS 17 //Specify the pin for SPI CS = GPIO17 = D5
|
||||
|
||||
#define PORT 1883
|
||||
MqttBroker broker(PORT);
|
||||
unsigned long Time;
|
||||
unsigned long freeRam;
|
||||
|
||||
/** Basic Mqtt Broker
|
||||
*
|
||||
* +-----------------------------+
|
||||
* | ESP |
|
||||
* | +--------+ |
|
||||
* | | broker | | 1883 <--- External client/s
|
||||
* | +--------+ |
|
||||
* | |
|
||||
* +-----------------------------+
|
||||
*
|
||||
* Your ESP will become a MqttBroker.
|
||||
* You can test it with any client such as mqtt-spy for example
|
||||
*
|
||||
*/
|
||||
|
||||
#if defined(USE_ETHERNET)
|
||||
|
||||
byte mac[] = { 0x00, 0xAA, 0xBB, 0xE0, 0x01, 0x25 }; //MAC Address
|
||||
//IPAddress ip = (192,168,0,88); //Fixed IP Address
|
||||
|
||||
#else
|
||||
|
||||
const char* ssid = "xxxxxxx";
|
||||
const char* password = "xxxxxxxx";
|
||||
|
||||
#endif
|
||||
|
||||
|
||||
void WizReset() {
|
||||
Serial.print("Resetting Wiz W5500 Ethernet Board... ");
|
||||
pinMode(WIZRST, OUTPUT);
|
||||
digitalWrite(WIZRST, HIGH);
|
||||
delay(250);
|
||||
digitalWrite(WIZRST, LOW);
|
||||
delay(50);
|
||||
digitalWrite(WIZRST, HIGH);
|
||||
delay(350);
|
||||
Serial.println("Done.");
|
||||
}
|
||||
|
||||
void setup()
|
||||
{
|
||||
Serial.begin(115200);
|
||||
|
||||
#if defined(USE_ETHERNET)
|
||||
|
||||
Ethernet.init(WIZCS);
|
||||
SPI.begin();
|
||||
WizReset();
|
||||
Console << TinyConsole::green << "Starting Ethernet...." << endl;
|
||||
Ethernet.begin(mac); //Connect using DHCP
|
||||
//Ethernet.begin(mac,ip); //Connect using Fixed IP
|
||||
if (Ethernet.hardwareStatus() == EthernetNoHardware) {
|
||||
Console << TinyConsole::red << "Ethernet shield was not found. Sorry, can't run without hardware. :(" << endl;
|
||||
} else
|
||||
if (Ethernet.linkStatus() == LinkOFF) {
|
||||
Console << TinyConsole::red << "Ethernet cable is not connected." << endl;
|
||||
}
|
||||
Console << TinyConsole::green << "Local Ethernet IP address: " << Ethernet.localIP() << endl;
|
||||
broker.begin();
|
||||
Console << "Broker ready (eth) : " << Ethernet.localIP() << " on port " << PORT << endl;
|
||||
|
||||
#else
|
||||
|
||||
if (strlen(ssid)==0)
|
||||
Console << TinyConsole::red << "****** PLEASE MODIFY ssid/password *************" << endl;
|
||||
WiFi.disconnect(); //Remove previous SSID & Password
|
||||
WiFi.begin(ssid, password); // Connect to the network
|
||||
Console << TinyConsole::white << "WiFi Connecting to " << ssid << " ...";
|
||||
int i = 0;
|
||||
while (WiFi.status() != WL_CONNECTED) { // Wait for the Wi-Fi to connect
|
||||
delay(1000);
|
||||
Console << TinyConsole::white << ".";
|
||||
i++;
|
||||
if (i > 20) break;
|
||||
}
|
||||
Console << endl << endl;
|
||||
Console << TinyConsole::green << "Connected to " << ssid << " IP address: " << WiFi.localIP() << endl;
|
||||
broker.begin();
|
||||
Console << "Broker ready (wifi) : " << WiFi.localIP() << " on port " << PORT << endl;
|
||||
|
||||
#endif
|
||||
}
|
||||
|
||||
void loop()
|
||||
{
|
||||
broker.loop();
|
||||
if(millis()-Time>10000) {
|
||||
Time=millis();
|
||||
#ifdef ARDUINO_ARCH_RP2040
|
||||
if(rp2040.getFreeHeap()!=freeRam) {
|
||||
freeRam=rp2040.getFreeHeap();
|
||||
#else
|
||||
if(ESP.getFreeHeap()!=freeRam) {
|
||||
freeRam=ESP.getFreeHeap();
|
||||
#endif
|
||||
|
||||
|
||||
Serial.print("RAM:");
|
||||
Serial.println(freeRam);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
5
examples/W5500/client-with-W5500-RP2040/readme
Normal file
5
examples/W5500/client-with-W5500-RP2040/readme
Normal file
@@ -0,0 +1,5 @@
|
||||
In TinyString.h the operator
|
||||
|
||||
TinyString& operator +=(int);
|
||||
|
||||
may need to be added.
|
||||
@@ -431,14 +431,6 @@ void eval(string &cmd)
|
||||
convertToCommand(s);
|
||||
if (s.length() == 0)
|
||||
{
|
||||
}
|
||||
else if (compare(s, "debug"))
|
||||
{
|
||||
#if TINY_MQTT_DEBUG
|
||||
TinyMqtt::debug = getint(cmd);
|
||||
#else
|
||||
Console << red << "TinyMqtt not compiled in debug" << endl;
|
||||
#endif
|
||||
}
|
||||
else if (compare(s, "list"))
|
||||
{
|
||||
@@ -448,6 +440,10 @@ void eval(string &cmd)
|
||||
Console << " " << fb.first << " : " << fb.second.url << ":" << fb.second.port << endl;
|
||||
}
|
||||
}
|
||||
else if (compare(s, "free"))
|
||||
{
|
||||
Console << "Free memory: " << ESP.getFreeHeap() << endl;
|
||||
}
|
||||
else if (compare(s, "delete"))
|
||||
{
|
||||
if (client == nullptr && broker == nullptr)
|
||||
@@ -497,7 +493,22 @@ void eval(string &cmd)
|
||||
{
|
||||
if (compare(s, "connect"))
|
||||
{
|
||||
Console << "NYI" << endl;
|
||||
string remote = getword(cmd);
|
||||
int port = getint(cmd);
|
||||
if (port == 0) port=1883;
|
||||
broker->connect(remote, port);
|
||||
if (broker->connected())
|
||||
Console << "Broker connected";
|
||||
else
|
||||
Console << red << "Unable to connect";
|
||||
|
||||
Console << " to " << remote << ':' << port << white << endl;
|
||||
}
|
||||
else if (compare(s, "retain"))
|
||||
{
|
||||
if (cmd.size())
|
||||
broker->retain(getint(cmd));
|
||||
Console << "retain=" << broker->retain() << ", retained msg=" << broker->retainCount() << endl;
|
||||
}
|
||||
else if (compare(s, "view"))
|
||||
{
|
||||
@@ -515,6 +526,10 @@ void eval(string &cmd)
|
||||
{
|
||||
clientConnect(client, cmd);
|
||||
}
|
||||
else if (compare(s, "rpublish"))
|
||||
{
|
||||
retval = client->publish(getword(cmd), getword(cmd), true);
|
||||
}
|
||||
else if (compare(s, "publish"))
|
||||
{
|
||||
retval = client->publish(getword(cmd), getword(cmd));
|
||||
@@ -760,7 +775,8 @@ void eval(string &cmd)
|
||||
Console << save_cursor << magenta;
|
||||
Console.gotoxy(1, 1);
|
||||
}
|
||||
Console << "--< " << '/' << clients.size() << " client/s. >--" << erase_to_end << endl;
|
||||
Console << "--< " << '/' << clients.size() << " client/s. >--" << erase_to_end;
|
||||
Console << " (FreeMem: " << ESP.getFreeHeap() << ')' << endl;
|
||||
for (auto it : clients)
|
||||
{
|
||||
it.second->dump(" ");
|
||||
@@ -786,19 +802,22 @@ void eval(string &cmd)
|
||||
{
|
||||
Console << "syntax:" << endl;
|
||||
Console << " MqttBroker:" << endl;
|
||||
Console << " broker {broker_name} {port} : create a new broker" << endl;
|
||||
Console << " broker_name can be one of 'list'" << endl;
|
||||
Console << " broker_name.delete : delete a broker (buggy)" << endl;
|
||||
Console << " broker_name.view : dump a broker" << endl;
|
||||
Console << " broker {name} {port} : create a new broker" << endl;
|
||||
Console << " name can be one of 'list'" << endl;
|
||||
Console << " name.delete : delete a broker (buggy)" << endl;
|
||||
Console << " name.retain [#] : show/set retain value" << endl;
|
||||
Console << " name.view : dump a broker" << endl;
|
||||
Console << endl;
|
||||
Console << " MqttClient:" << endl;
|
||||
Console << " client {name} {broker} : create a client then" << endl;
|
||||
Console << " name.connect [ip] [port] [alive]" << endl;
|
||||
Console << " name.[un]subscribe topic" << endl;
|
||||
Console << " name.publish topic [payload]" << endl;
|
||||
Console << " name.rpublish topic [payload] : publish a retained message" << endl;
|
||||
Console << " name.view" << endl;
|
||||
Console << " name.delete" << endl;
|
||||
Console << endl;
|
||||
Console << " free : view free mem" << endl;
|
||||
Console << " list : list of free brokers (debug 1 advised)" << endl;
|
||||
Console << " debug #" << endl;
|
||||
Console << " list : get list of free brokers" << endl;
|
||||
|
||||
@@ -8,7 +8,7 @@
|
||||
},
|
||||
"dependencies":
|
||||
{ "hsaturn/TinyConsole" : "*" },
|
||||
"version": "0.9.19",
|
||||
"version": "1.0.0",
|
||||
"exclude": "",
|
||||
"examples": "examples/*/*.ino",
|
||||
"frameworks": "arduino",
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
name=TinyMqtt
|
||||
version=0.9.19
|
||||
version=1.0.0
|
||||
author=Francois BIOT, HSaturn, <hsaturn@gmail.com>
|
||||
maintainer=Francois BIOT <hsaturn@gmail.com>
|
||||
sentence=A tiny broker and client library for MQTT messaging.
|
||||
|
||||
@@ -9,10 +9,14 @@ static auto red = TinyConsole::red;
|
||||
static auto yellow = TinyConsole::yellow;
|
||||
|
||||
int TinyMqtt::debug=2;
|
||||
|
||||
#endif
|
||||
|
||||
#ifdef EPOXY_DUINO
|
||||
std::map<MqttMessage::Type, int> MqttClient::counters;
|
||||
int MqttBroker::instances = 0;
|
||||
int MqttClient::instances = 0;
|
||||
|
||||
#endif
|
||||
|
||||
MqttBroker::MqttBroker(uint16_t port, uint8_t max_retain_size)
|
||||
@@ -23,10 +27,17 @@ MqttBroker::MqttBroker(uint16_t port, uint8_t max_retain_size)
|
||||
#ifdef TINY_MQTT_ASYNC
|
||||
server->onClient(onClient, this);
|
||||
#endif
|
||||
#ifdef EPOXY_DUINO
|
||||
instances++;
|
||||
#endif
|
||||
}
|
||||
|
||||
MqttBroker::~MqttBroker()
|
||||
{
|
||||
#ifdef EPOXY_DUINO
|
||||
instances--;
|
||||
#endif
|
||||
closeRemoteBroker();
|
||||
while(clients.size())
|
||||
{
|
||||
auto client = clients[0];
|
||||
@@ -52,10 +63,11 @@ MqttClient::MqttClient(MqttBroker* local_broker, TcpClient* new_client)
|
||||
// client->onConnect() TODO
|
||||
// client->onDisconnect() TODO
|
||||
#else
|
||||
tcp_client = new WiFiClient(*new_client);
|
||||
tcp_client = new TcpClient(*new_client);
|
||||
#endif
|
||||
#ifdef EPOXY_DUINO
|
||||
alive = millis()+500000;
|
||||
instances++;
|
||||
#else
|
||||
alive = millis()+5000; // TODO MAGIC client expires after 5s if no CONNECT msg
|
||||
#endif
|
||||
@@ -68,10 +80,16 @@ MqttClient::MqttClient(MqttBroker* local_broker, const string& id)
|
||||
keep_alive = 0;
|
||||
|
||||
if (local_broker) local_broker->addClient(this);
|
||||
#ifdef EPOXY_DUINO
|
||||
instances++;
|
||||
#endif
|
||||
}
|
||||
|
||||
MqttClient::~MqttClient()
|
||||
{
|
||||
#ifdef EPOXY_DUINO
|
||||
instances--;
|
||||
#endif
|
||||
close();
|
||||
delete tcp_client;
|
||||
debug("*** MqttClient delete()");
|
||||
@@ -138,9 +156,19 @@ void MqttBroker::addClient(MqttClient* client)
|
||||
clients.push_back(client);
|
||||
}
|
||||
|
||||
void MqttBroker::closeRemoteBroker()
|
||||
{
|
||||
if (remote_broker)
|
||||
{
|
||||
delete remote_broker;
|
||||
remote_broker = nullptr;
|
||||
}
|
||||
}
|
||||
|
||||
void MqttBroker::connect(const string& host, uint16_t port)
|
||||
{
|
||||
debug("MqttBroker::connect");
|
||||
closeRemoteBroker();
|
||||
if (remote_broker == nullptr) remote_broker = new MqttClient;
|
||||
remote_broker->connect(host, port);
|
||||
remote_broker->local_broker = this; // Because connect removed the link
|
||||
@@ -183,7 +211,7 @@ void MqttBroker::onClient(void* broker_ptr, TcpClient* client)
|
||||
void MqttBroker::loop()
|
||||
{
|
||||
#ifndef TINY_MQTT_ASYNC
|
||||
WiFiClient client = server->accept();
|
||||
TcpClient client = server->accept();
|
||||
|
||||
if (client)
|
||||
{
|
||||
@@ -218,8 +246,10 @@ void MqttBroker::loop()
|
||||
MqttError MqttBroker::subscribe(MqttClient* client, const Topic& topic, uint8_t qos)
|
||||
{
|
||||
debug("MqttBroker::subscribe to " << topic.str() << ", retained=" << retained.size() );
|
||||
for(auto& [retained_topic, retain]: retained)
|
||||
for(auto& retainItem: retained)
|
||||
{
|
||||
auto &retained_topic = retainItem.first;
|
||||
auto &retain = retainItem.second;
|
||||
debug(" retained: " << retained_topic.str());
|
||||
if (topic.matches(retained_topic))
|
||||
{
|
||||
@@ -309,7 +339,7 @@ void MqttClient::clientAlive(uint32_t more_seconds)
|
||||
|
||||
void MqttClient::loop()
|
||||
{
|
||||
if (keep_alive && (millis() >= alive - 5000))
|
||||
if (keep_alive && (millis() >= alive))
|
||||
{
|
||||
if (tcp_client && tcp_client->connected())
|
||||
{
|
||||
@@ -616,6 +646,7 @@ void MqttClient::processMessage(MqttMessage* mesg)
|
||||
if (mqtt_connected() or tcp_client == nullptr)
|
||||
{
|
||||
uint8_t qos = mesg->flags();
|
||||
qos = (qos / 2) & 3;
|
||||
payload = header;
|
||||
mesg->getString(payload, len);
|
||||
Topic published(payload, len);
|
||||
@@ -623,9 +654,20 @@ void MqttClient::processMessage(MqttMessage* mesg)
|
||||
#if TINY_MQTT_DEBUG
|
||||
Console << "Received Publish (" << published.str().c_str() << ") size=" << (int)len << endl;
|
||||
#endif
|
||||
// << '(' << string(payload, len).c_str() << ')' << " msglen=" << mesg->length() << endl;
|
||||
if (qos) payload+=2; // ignore packet identifier if any
|
||||
|
||||
const char* ID; // remove PublishID() to avoid misuse
|
||||
if (qos) {
|
||||
ID = payload;
|
||||
payload+=2; // ignore packet identifier if any
|
||||
}
|
||||
len=mesg->end()-payload;
|
||||
if (qos == 1)
|
||||
{
|
||||
MqttMessage msg(MqttMessage::Type::PubAck);
|
||||
msg.add(ID[0]); // MessageID high
|
||||
msg.add(ID[1]); // MessageID low
|
||||
msg.sendTo(this);
|
||||
}
|
||||
// TODO reset DUP
|
||||
// TODO reset RETAIN
|
||||
|
||||
@@ -755,7 +797,7 @@ MqttError MqttClient::publish(const Topic& topic, const char* payload, size_t pa
|
||||
{
|
||||
return local_broker->publish(this, topic, msg);
|
||||
}
|
||||
else if (tcp_client)
|
||||
else if (tcp_client and connected())
|
||||
return msg.sendTo(this);
|
||||
else
|
||||
return MqttNowhereToSend;
|
||||
@@ -927,14 +969,19 @@ void MqttBroker::retainDrop()
|
||||
|
||||
void MqttBroker::retain(const Topic& topic, const MqttMessage& msg)
|
||||
{
|
||||
debug("MqttBroker::retain msg_type=" << _HEX(msg.type()));
|
||||
debug("MqttBroker::retain msg_type=" << _HEX(msg.type()) << ", retain_size=" << retain_size);
|
||||
if (retain_size==0 or msg.type() != MqttMessage::Publish) return;
|
||||
if (msg.flags() & 1) // flag RETAIN
|
||||
{
|
||||
debug(" retaining " << topic.str());
|
||||
if (retained.find(topic) == retained.end()) retainDrop();
|
||||
auto old = retained.find(topic);
|
||||
if (old == retained.end())
|
||||
retainDrop();
|
||||
else
|
||||
retained.erase(old);
|
||||
// FIXME if payload size == 0 remove message from retained
|
||||
Retain r(micros(), msg);
|
||||
r.msg.retained();
|
||||
retained.insert({ topic, std::move(r)});
|
||||
}
|
||||
}
|
||||
|
||||
@@ -8,7 +8,10 @@
|
||||
// TODO Should add a AUnit with both TINY_MQTT_ASYNC and not TINY_MQTT_ASYNC
|
||||
// #define TINY_MQTT_ASYNC // Uncomment this to use ESPAsyncTCP instead of normal cnx
|
||||
|
||||
#if defined(ESP8266) || defined(EPOXY_DUINO)
|
||||
|
||||
#if defined(TINY_MQTT_ETHERNET)
|
||||
#include <Ethernet.h>
|
||||
#elif defined(ESP8266) || defined(EPOXY_DUINO)
|
||||
#ifdef TINY_MQTT_ASYNC
|
||||
#include <ESPAsyncTCP.h>
|
||||
#else
|
||||
@@ -19,6 +22,8 @@
|
||||
#ifdef TINY_MQTT_ASYNC
|
||||
#include <AsyncTCP.h> // https://github.com/me-no-dev/AsyncTCP
|
||||
#endif
|
||||
#elif defined(ARDUINO_ARCH_RP2040)
|
||||
#include <WiFi.h> // works with Raspberry Pi Pico W, earlephilhower
|
||||
#endif
|
||||
#ifdef EPOXY_DUINO
|
||||
#define dbg_ptr uint64_t
|
||||
@@ -53,12 +58,17 @@
|
||||
#define debug(what) {}
|
||||
#endif
|
||||
|
||||
#ifdef TINY_MQTT_ASYNC
|
||||
#if defined(TINY_MQTT_ETHERNET)
|
||||
using TcpClient = EthernetClient;
|
||||
using TcpServer = EthernetServer;
|
||||
#else
|
||||
#ifdef TINY_MQTT_ASYNC
|
||||
using TcpClient = AsyncClient;
|
||||
using TcpServer = AsyncServer;
|
||||
#else
|
||||
#else
|
||||
using TcpClient = WiFiClient;
|
||||
using TcpServer = WiFiServer;
|
||||
#endif
|
||||
#endif
|
||||
|
||||
enum __attribute__((packed)) MqttError
|
||||
@@ -133,6 +143,7 @@ class MqttMessage
|
||||
const char* end() const { return &buffer[0]+buffer.size(); }
|
||||
const char* getVHeader() const { return &buffer[vheader]; }
|
||||
void complete() { encodeLength(); }
|
||||
void retained() { if ((buffer[0] & 0xF)==Publish) buffer[0] |= 1; }
|
||||
|
||||
void reset();
|
||||
|
||||
@@ -209,8 +220,8 @@ class MqttClient
|
||||
~MqttClient();
|
||||
|
||||
void connect(MqttBroker* local_broker);
|
||||
void connect(string broker, uint16_t port, uint16_t keep_alive = 10);
|
||||
void connect(const IPAddress& ip, uint16_t port, uint16_t keep_alive = 10)
|
||||
void connect(string broker, uint16_t port = 1883, uint16_t keep_alive = 10);
|
||||
void connect(const IPAddress& ip, uint16_t port = 1883, uint16_t keep_alive = 10)
|
||||
{ connect(ip.toString().c_str(), port, keep_alive); }
|
||||
|
||||
// TODO it seems that connected returns true in tcp mode even if
|
||||
@@ -289,6 +300,7 @@ class MqttClient
|
||||
|
||||
#ifdef EPOXY_DUINO
|
||||
static std::map<MqttMessage::Type, int> counters; // Number of processed messages
|
||||
static int instances;
|
||||
#endif
|
||||
uint32_t keepAlive() const { return keep_alive; }
|
||||
|
||||
@@ -345,7 +357,9 @@ class MqttBroker
|
||||
bool connected() const { return remote_broker ? remote_broker->connected() : false; }
|
||||
|
||||
size_t clientsCount() const { return clients.size(); }
|
||||
void retain(uint8_t size) { retain_size = size; }
|
||||
uint8_t retain() { return retain_size; }
|
||||
void retain(uint8_t size) { retain_size = size; if (size==0) retained.clear(); }
|
||||
uint8_t retainCount() const { return retained.size(); }
|
||||
|
||||
void dump(string indent="")
|
||||
{
|
||||
@@ -354,6 +368,9 @@ class MqttBroker
|
||||
}
|
||||
|
||||
const std::vector<MqttClient*> getClients() const { return clients; }
|
||||
#ifdef EPOXY_DUINO
|
||||
static int instances;
|
||||
#endif
|
||||
|
||||
private:
|
||||
friend class MqttClient;
|
||||
@@ -383,6 +400,8 @@ class MqttBroker
|
||||
const char* auth_password = "guest";
|
||||
MqttClient* remote_broker = nullptr;
|
||||
|
||||
void closeRemoteBroker();
|
||||
|
||||
void retain(const Topic& topic, const MqttMessage& msg);
|
||||
void retainDrop();
|
||||
|
||||
|
||||
@@ -1,11 +1,23 @@
|
||||
# See https://github.com/bxparks/EpoxyDuino for documentation about this
|
||||
# Makefile to compile and run Arduino programs natively on Linux or MacOS.
|
||||
# vim: noexpandtab
|
||||
|
||||
include ../Makefile.opts
|
||||
|
||||
APP_NAME := tinymqtt-test
|
||||
APP_NAME := compile-tests
|
||||
ARDUINO_LIBS := AUnit AceCommon AceTime TinyMqtt EspMock ESP8266WiFi ESPAsync ESP8266mDNS TinyConsole
|
||||
ARDUINO_LIB_DIRS := ../../../EspMock/libraries
|
||||
EPOXY_CORE := EPOXY_CORE_ESP8266
|
||||
DUMMY := 1
|
||||
include ../../../EpoxyDuino/EpoxyDuino.mk
|
||||
RUN = no
|
||||
APP_SRCS_COMP += $(shell find ../../examples -name "*.ino")
|
||||
APP_SRCS_CPP += $(APP_SRCS_COMP:%.ino=%.o)
|
||||
CXXFLAGS = -D_GNU_SOURCE -Werror=return-type -std=gnu++17 -Wall -g3 -O0 -DEPOXY_DUINO
|
||||
|
||||
include ../Makefile.opts
|
||||
|
||||
all:
|
||||
|
||||
compile-tests.out: $(OBJS)
|
||||
|
||||
run:
|
||||
@echo "No run for compile tests"
|
||||
exit 0
|
||||
|
||||
|
||||
@@ -1,848 +0,0 @@
|
||||
// vim: ts=2 sw=2 expandtab smartindent
|
||||
#include <TinyConsole.h>
|
||||
#include <TinyMqtt.h> // https://github.com/hsaturn/TinyMqtt
|
||||
#include <TinyStreaming.h>
|
||||
|
||||
#include <sstream>
|
||||
#include <string>
|
||||
#include <map>
|
||||
|
||||
using string = TinyConsole::string;
|
||||
|
||||
bool echo_on = true;
|
||||
auto green = TinyConsole::green;
|
||||
auto red = TinyConsole::red;
|
||||
auto white = TinyConsole::white;
|
||||
auto cyan = TinyConsole::cyan;
|
||||
auto yellow = TinyConsole::yellow;
|
||||
auto magenta = TinyConsole::magenta;
|
||||
auto save_cursor = TinyConsole::save_cursor;
|
||||
auto restore_cursor = TinyConsole::restore_cursor;
|
||||
auto erase_to_end = TinyConsole::erase_to_end;
|
||||
|
||||
const char* ssid = "";
|
||||
const char* password = "";
|
||||
|
||||
struct free_broker
|
||||
{
|
||||
public:
|
||||
free_broker(const char* s, uint16_t p, const char* /* comment */) : url(s), port(p) {}
|
||||
|
||||
string url;
|
||||
uint16_t port;
|
||||
};
|
||||
|
||||
const std::map<string, free_broker> list =
|
||||
{
|
||||
{ "mqtthq", { "public.mqtthq.com" , 8083, "publish/subscribe" }},
|
||||
{ "hivemq", { "broker.hivemq.com", 1883, "" }}
|
||||
};
|
||||
|
||||
/** Very complex example
|
||||
* Console allowing to make any kind of test,
|
||||
* even some stress tests.
|
||||
*
|
||||
* Upload the sketch, the use the terminal.
|
||||
* Press H for mini help.
|
||||
*
|
||||
* tested with mqtt-spy-0.5.4
|
||||
* TODO examples of scripts
|
||||
*/
|
||||
|
||||
void onPublish(const MqttClient* srce, const Topic& topic, const char* payload, size_t length)
|
||||
{
|
||||
Console << cyan << "--> " << srce->id().c_str() << ": received " << topic.c_str() << white;
|
||||
if (payload)
|
||||
{
|
||||
Console << ", payload[" << length << "]=[";
|
||||
while(length--)
|
||||
{
|
||||
const char c=*payload++;
|
||||
if (c<32)
|
||||
Console << '?';
|
||||
else
|
||||
Console << c;
|
||||
}
|
||||
Console << ']' << endl;
|
||||
}
|
||||
}
|
||||
|
||||
std::map<string, MqttClient*> clients;
|
||||
std::map<string, MqttBroker*> brokers;
|
||||
std::map<string, string> vars;
|
||||
|
||||
void eval(string& cmd);
|
||||
|
||||
void replace(const char* d, string& str, string srch, string to)
|
||||
{
|
||||
if (d[0] && d[1])
|
||||
{
|
||||
srch=d[0]+srch+d[1];
|
||||
to=d[0]+to+d[1];
|
||||
|
||||
size_t pos = 0;
|
||||
while((pos=str.find(srch, pos)) != string::npos)
|
||||
{
|
||||
str.erase(pos, srch.length());
|
||||
str.insert(pos, to);
|
||||
pos += to.length()-1;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
void replaceVars(string& cmd)
|
||||
{
|
||||
cmd = ' '+cmd+' ';
|
||||
|
||||
for(auto it: vars)
|
||||
{
|
||||
replace("..", cmd, it.first, it.second);
|
||||
replace(". ", cmd, it.first, it.second);
|
||||
replace(" .", cmd, it.first, it.second);
|
||||
replace(" ", cmd, it.first, it.second);
|
||||
}
|
||||
cmd.erase(0, cmd.find_first_not_of(' '));
|
||||
cmd.erase(cmd.find_last_not_of(' ')+1);
|
||||
|
||||
}
|
||||
|
||||
void onCommand(const string& command)
|
||||
{
|
||||
Console << endl;
|
||||
string cmd=command;
|
||||
if (cmd.substr(0,3)!="set") replaceVars(cmd);
|
||||
eval(cmd);
|
||||
Console << endl;
|
||||
Console.prompt();
|
||||
}
|
||||
|
||||
void setup()
|
||||
{
|
||||
Serial.begin(115200);
|
||||
Console.begin(Serial);
|
||||
Console.setPrompt("> ");
|
||||
Console.setCallback(onCommand);
|
||||
delay(500);
|
||||
|
||||
Console.cls();
|
||||
Console << endl << endl;
|
||||
Console << yellow
|
||||
<< "***************************************************************" << endl;
|
||||
Console << "* Welcome to the TinyMqtt console" << endl;
|
||||
Console << "* The console allows to test all features of the libraries." << endl;
|
||||
Console << "* Enter help to view the list of commands." << endl;
|
||||
Console << "***************************************************************" << endl;
|
||||
Console << endl;
|
||||
if (strlen(ssid)==0)
|
||||
Console << red << "* ERROR: You must modify ssid/password in order" << endl
|
||||
<< " to be able to connect to your Wifi network." << endl;
|
||||
Console << endl << white;
|
||||
|
||||
Console << "Connecting to '" << ssid << "' ";
|
||||
|
||||
WiFi.mode(WIFI_STA);
|
||||
WiFi.begin(ssid, password);
|
||||
WiFi.mode(WIFI_STA);
|
||||
WiFi.begin(ssid, password);
|
||||
|
||||
while (WiFi.status() != WL_CONNECTED)
|
||||
{ Console << '-'; delay(500); }
|
||||
|
||||
Console << endl << "Connected to " << ssid << "IP address: " << WiFi.localIP() << endl;
|
||||
|
||||
const char* name="tinytest";
|
||||
Console << "Starting MDNS, name= " << name;
|
||||
|
||||
MqttBroker* broker = new MqttBroker(1883);
|
||||
broker->begin();
|
||||
brokers["broker"] = broker;
|
||||
|
||||
if (Console.isTerm()) onCommand("every 333 view");
|
||||
}
|
||||
|
||||
string getword(string& str, const char* if_empty=nullptr, char sep=' ');
|
||||
|
||||
int getint(string& str, const int if_empty=0)
|
||||
{
|
||||
string str2=str;
|
||||
string sword = getword(str);
|
||||
if (sword[0] and isdigit(sword[0]))
|
||||
{
|
||||
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;
|
||||
}
|
||||
str=str2;
|
||||
return if_empty;
|
||||
}
|
||||
|
||||
string getword(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);
|
||||
string sword;
|
||||
while(str.length() and (str[0]!=sep or quote))
|
||||
{
|
||||
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]!=')') Console << "Missing ')'" << endl;
|
||||
}
|
||||
else
|
||||
{
|
||||
to=from;
|
||||
from=0;
|
||||
}
|
||||
return String(random(from,to)).c_str();
|
||||
}
|
||||
else
|
||||
{
|
||||
Console << "Missing '('" << endl;
|
||||
}
|
||||
}
|
||||
while(str[0]==' ') str.erase(0,1);
|
||||
return sword;
|
||||
}
|
||||
|
||||
bool isaddr(string s)
|
||||
{
|
||||
if (s.length()==0 or s.length()>3) return false;
|
||||
for(char c: s)
|
||||
if (c<'0' or c>'9') return false;
|
||||
return true;
|
||||
}
|
||||
|
||||
string getip(string& str, const char* if_empty=nullptr, char sep=' ')
|
||||
{
|
||||
string addr=getword(str, if_empty, sep);
|
||||
string ip=addr;
|
||||
std::vector<string> build;
|
||||
while(ip.length())
|
||||
{
|
||||
string b=getword(ip,nullptr,'.');
|
||||
if (isaddr(b) && build.size()<4)
|
||||
{
|
||||
build.push_back(b);
|
||||
}
|
||||
else
|
||||
return addr;
|
||||
}
|
||||
IPAddress local=WiFi.localIP();
|
||||
addr.clear();
|
||||
while(build.size()!=4)
|
||||
{
|
||||
std::stringstream b;
|
||||
b << (int)local[3-build.size()];
|
||||
build.insert(build.begin(), b.str().c_str());
|
||||
}
|
||||
for(string s: build)
|
||||
{
|
||||
if (addr.length()) addr += '.';
|
||||
addr += s;
|
||||
}
|
||||
Console << "connect address: " << addr << endl;
|
||||
return addr;
|
||||
}
|
||||
|
||||
std::set<string> commands = {
|
||||
"broker", "blink", "client", "connect",
|
||||
"create", "delete", "debug", "help", "interval",
|
||||
"list", "ls", "ip", "off", "on", "set",
|
||||
"publish", "reset", "subscribe", "unsubscribe", "view", "echo", "every"
|
||||
};
|
||||
|
||||
void convertToCommand(string& search)
|
||||
{
|
||||
while(search[0]==' ') search.erase(0,1);
|
||||
if (search.length()==0) return;
|
||||
string matches;
|
||||
int count=0;
|
||||
for(string cmd: commands)
|
||||
{
|
||||
if (cmd.substr(0, search.length()) == search)
|
||||
{
|
||||
if (count) matches +=", ";
|
||||
count++;
|
||||
matches += cmd;
|
||||
}
|
||||
}
|
||||
if (count==1)
|
||||
search = matches;
|
||||
else if (count>1)
|
||||
{
|
||||
Console << "Ambiguous command: " << matches << endl;
|
||||
search.clear();
|
||||
}
|
||||
}
|
||||
|
||||
bool compare(string s, const char* cmd)
|
||||
{
|
||||
uint8_t p=0;
|
||||
while(s[p++]==*cmd++)
|
||||
{
|
||||
if (*cmd==0 or s[p]==0) return true;
|
||||
if (s[p]==' ') return true;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
using ClientFunction = void(*)(string& cmd, MqttClient* publish);
|
||||
|
||||
struct Every
|
||||
{
|
||||
string cmd;
|
||||
uint32_t ms;
|
||||
uint32_t next;
|
||||
uint32_t underrun=0;
|
||||
bool active=true;
|
||||
|
||||
void dump()
|
||||
{
|
||||
if (active)
|
||||
Console << green << "enabled";
|
||||
else
|
||||
Console << red << "disabled";
|
||||
|
||||
auto mill=millis();
|
||||
Console << white << ms << "ms [" << cmd << "] next in ";
|
||||
if (mill > next)
|
||||
Console << "now";
|
||||
else
|
||||
Console << 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 clientConnect(MqttClient* client, string& cmd)
|
||||
{
|
||||
string remote = getword(cmd);
|
||||
uint16_t port;
|
||||
auto it=list.find(remote);
|
||||
if (it != list.end())
|
||||
{
|
||||
Console << "Connecting to free broker: " << remote << endl;
|
||||
remote = it->second.url;
|
||||
port=it->second.port;
|
||||
}
|
||||
else
|
||||
port=getint(cmd);
|
||||
|
||||
client->connect(remote.c_str(), port, getint(cmd, 60));
|
||||
Console << (client->connected() ? "connected." : "not connected") << endl;
|
||||
}
|
||||
|
||||
void eval(string& cmd)
|
||||
{
|
||||
while(cmd.length())
|
||||
{
|
||||
MqttError retval = MqttOk;
|
||||
|
||||
string s;
|
||||
MqttBroker* broker = nullptr;
|
||||
MqttClient* client = nullptr;
|
||||
|
||||
// client.function notation
|
||||
if (cmd.find('.') != 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
|
||||
{
|
||||
Console << red << "Unknown class (" << s.c_str() << ")" << white << endl;
|
||||
cmd.clear();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
s = getword(cmd);
|
||||
if (s.length()) convertToCommand(s);
|
||||
if (s.length()==0)
|
||||
{}
|
||||
else if (compare(s, "debug"))
|
||||
{
|
||||
#if TINY_MQTT_DEBUG
|
||||
TinyMqtt::debug = getint(cmd);
|
||||
#else
|
||||
Console << red << "TinyMqtt not compiled in debug" << endl;
|
||||
#endif
|
||||
}
|
||||
else if (compare(s, "list"))
|
||||
{
|
||||
Console << "List of free servers" << endl;
|
||||
for(const auto& fb: list)
|
||||
{
|
||||
Console << " " << fb.first << " : " << fb.second.url << ":" << fb.second.port << endl;
|
||||
}
|
||||
}
|
||||
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
|
||||
Console << red << "Unable to find (" << s.c_str() << ")" << white << endl;
|
||||
}
|
||||
if (client)
|
||||
{
|
||||
for (auto it: clients)
|
||||
{
|
||||
if (it.second != client) continue;
|
||||
Console << "deleted" << endl;
|
||||
delete (it.second);
|
||||
clients.erase(it.first);
|
||||
break;
|
||||
}
|
||||
cmd += " ls";
|
||||
}
|
||||
else if (broker)
|
||||
{
|
||||
for(auto it: brokers)
|
||||
{
|
||||
if (broker != it.second) continue;
|
||||
Console << "deleted" << endl;
|
||||
delete (it.second);
|
||||
brokers.erase(it.first);
|
||||
break;
|
||||
}
|
||||
cmd += " ls";
|
||||
}
|
||||
else
|
||||
Console << "Nothing to delete" << endl;
|
||||
}
|
||||
else if (broker)
|
||||
{
|
||||
if (compare(s,"connect"))
|
||||
{
|
||||
Console << "NYI" << endl;
|
||||
}
|
||||
else if (compare(s, "view"))
|
||||
{
|
||||
broker->dump();
|
||||
}
|
||||
else
|
||||
{
|
||||
Console << "Unknown broker command (" << s << ")" << endl;
|
||||
s.clear();
|
||||
}
|
||||
}
|
||||
else if (client)
|
||||
{
|
||||
if (compare(s,"connect"))
|
||||
{
|
||||
clientConnect(client, cmd);
|
||||
}
|
||||
else if (compare(s,"publish"))
|
||||
{
|
||||
retval = client->publish(getword(cmd), getword(cmd));
|
||||
}
|
||||
else if (compare(s,"subscribe"))
|
||||
{
|
||||
client->subscribe(getword(cmd));
|
||||
}
|
||||
else if (compare(s, "unsubscribe"))
|
||||
{
|
||||
client->unsubscribe(getword(cmd));
|
||||
}
|
||||
else if (compare(s, "view"))
|
||||
{
|
||||
client->dump();
|
||||
}
|
||||
else
|
||||
{
|
||||
Console << "Unknown client command (" << s << ")" << endl;
|
||||
s.clear();
|
||||
}
|
||||
}
|
||||
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, "echo"))
|
||||
{
|
||||
s=getword(cmd);
|
||||
if (s=="on")
|
||||
echo_on = true;
|
||||
else if (s=="off")
|
||||
echo_on = false;
|
||||
else
|
||||
{
|
||||
Console << s << ' ';
|
||||
while(cmd.length())
|
||||
{
|
||||
Console << getword(cmd) << ' ';
|
||||
}
|
||||
}
|
||||
}
|
||||
else if (compare(s, "every"))
|
||||
{
|
||||
uint32_t ms = getint(cmd, 0);
|
||||
if (ms)
|
||||
{
|
||||
if (cmd.length())
|
||||
{
|
||||
Every every;
|
||||
every.ms=ms;
|
||||
every.cmd=cmd;
|
||||
every.next=millis()+ms;
|
||||
everies.push_back(every);
|
||||
every.dump();
|
||||
Console << endl;
|
||||
cmd.clear();
|
||||
}
|
||||
}
|
||||
else if (compare(cmd, "off") or compare(cmd, "on"))
|
||||
{
|
||||
bool active=getword(cmd)=="on";
|
||||
uint8_t ever=getint(cmd, 100);
|
||||
uint8_t count=0;
|
||||
for(auto& every: everies)
|
||||
{
|
||||
if (count==ever or (ever==100))
|
||||
{
|
||||
if (every.active != active)
|
||||
{
|
||||
Console << "every #" << count << (active ? " on" :" off") << endl;
|
||||
every.active = active;
|
||||
every.underrun = 0;
|
||||
}
|
||||
}
|
||||
count++;
|
||||
}
|
||||
}
|
||||
else if (compare(cmd, "list") or cmd.length()==0)
|
||||
{
|
||||
getword(cmd);
|
||||
Console << "List of everies (ms=" << millis() << ")" << endl;
|
||||
uint8_t count=0;
|
||||
for(auto& every: everies)
|
||||
{
|
||||
Console << count << ": ";
|
||||
every.dump();
|
||||
Console << endl;
|
||||
count++;
|
||||
}
|
||||
}
|
||||
else if (compare(cmd, "remove"))
|
||||
{
|
||||
Console << "Removing..." << endl;
|
||||
getword(cmd);
|
||||
int8_t every=getint(cmd, -1);
|
||||
if (every==-1 and compare(cmd, "last") and everies.size())
|
||||
{
|
||||
getword(cmd);
|
||||
everies.erase(everies.begin()+everies.size()-1);
|
||||
}
|
||||
else if (every==-1 and compare(cmd, "all"))
|
||||
{
|
||||
getword(cmd);
|
||||
everies.clear();
|
||||
}
|
||||
else if (everies.size() > (uint8_t)every)
|
||||
{
|
||||
everies.erase(everies.begin()+every);
|
||||
}
|
||||
else
|
||||
Console << "Bad colmmand" << endl;
|
||||
}
|
||||
else
|
||||
Console << "Bad command" << endl;
|
||||
}
|
||||
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();
|
||||
Console << "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, "broker"))
|
||||
{
|
||||
string id=getword(cmd);
|
||||
if (clients.find(id) != clients.end())
|
||||
{
|
||||
Console << "A client already have that name" << endl;
|
||||
cmd.clear();
|
||||
}
|
||||
else 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;
|
||||
Console << "new broker (" << id.c_str() << ")" << endl;
|
||||
}
|
||||
else
|
||||
{
|
||||
Console << "Missing port" << endl;
|
||||
cmd.clear();
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
Console << "Missing or existing broker name (" << id.c_str() << ")" << endl;
|
||||
cmd.clear();
|
||||
}
|
||||
}
|
||||
else if (compare(s, "client"))
|
||||
{
|
||||
string id=getword(cmd);
|
||||
if (brokers.find(id) != brokers.end())
|
||||
{
|
||||
Console << "A broker have that name" << endl;
|
||||
cmd.clear();
|
||||
}
|
||||
else if (id.length() or clients.find(id)!=clients.end())
|
||||
{
|
||||
s=getword(cmd); // broker
|
||||
if (s=="" or brokers.find(s) != brokers.end() or list.find(s) != list.end())
|
||||
{
|
||||
MqttBroker* broker = nullptr;
|
||||
if (s.length()) broker = brokers[s];
|
||||
MqttClient* client = new MqttClient(broker, id);
|
||||
clients[id]=client;
|
||||
client->setCallback(onPublish);
|
||||
if (list.find(s) != list.end())
|
||||
{
|
||||
cmd=s+' '+cmd;
|
||||
clientConnect(client, cmd);
|
||||
}
|
||||
Console << "new client (" << id.c_str() << ", " << s.c_str() << ')' << endl;
|
||||
}
|
||||
else if (s.length())
|
||||
{
|
||||
Console << " not found." << endl;
|
||||
cmd.clear();
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
Console << "Missing or existing client name" << endl;
|
||||
cmd.clear();
|
||||
}
|
||||
}
|
||||
else if (compare(s, "set"))
|
||||
{
|
||||
string name(getword(cmd));
|
||||
if (name.length()==0)
|
||||
{
|
||||
for(auto it: vars)
|
||||
{
|
||||
Console << " " << it.first << " -> " << it.second << endl;
|
||||
}
|
||||
}
|
||||
else if (commands.find(name) != commands.end())
|
||||
{
|
||||
Console << "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"))
|
||||
{
|
||||
bool view = compare(s, "view");
|
||||
if (view)
|
||||
{
|
||||
Console << save_cursor << magenta;
|
||||
Console.gotoxy(1,1);
|
||||
}
|
||||
Console << "--< " << '/' << clients.size() << " client/s. >--" << erase_to_end << endl;
|
||||
for(auto it: clients)
|
||||
{
|
||||
it.second->dump(" ");
|
||||
}
|
||||
|
||||
Console << "--< " << brokers.size() << " brokers/s. >--" << erase_to_end << endl;
|
||||
for(auto it: brokers)
|
||||
{
|
||||
Console << " +-- '" << it.first.c_str() << "' " << it.second->clientsCount() << " client/s."<< erase_to_end << endl;
|
||||
it.second->dump(" ");
|
||||
}
|
||||
if (view)
|
||||
{
|
||||
Console.bg(white);
|
||||
Console << erase_to_end << restore_cursor;
|
||||
}
|
||||
}
|
||||
else if (compare(s, "reset"))
|
||||
ESP.restart();
|
||||
else if (compare(s, "ip"))
|
||||
Console << "IP: " << WiFi.localIP() << endl;
|
||||
else if (compare(s,"help"))
|
||||
{
|
||||
Console << "syntax:" << endl;
|
||||
Console << " MqttBroker:" << endl;
|
||||
Console << " broker {broker_name} {port} : create a new broker" << endl;
|
||||
Console << " broker_name can be one of 'list'" << endl;
|
||||
Console << " broker_name.delete : delete a broker (buggy)" << endl;
|
||||
Console << " broker_name.view : dump a broker" << endl;
|
||||
Console << endl;
|
||||
Console << " MqttClient:" << endl;
|
||||
Console << " client {name} {broker} : create a client then" << endl;
|
||||
Console << " name.connect [ip] [port] [alive]" << endl;
|
||||
Console << " name.[un]subscribe topic" << endl;
|
||||
Console << " name.publish topic [payload]" << endl;
|
||||
Console << " name.view" << endl;
|
||||
Console << " name.delete" << endl;
|
||||
Console << endl;
|
||||
Console << " list : list of free brokers (debug 1 advised)" << endl;
|
||||
Console << " debug #" << endl;
|
||||
Console << " list : get list of free brokers" << endl;
|
||||
Console << " blink [Dx on_ms off_ms] : make pin blink" << endl;
|
||||
Console << " ls / ip / reset" << endl;
|
||||
Console << " set [name][value]" << endl;
|
||||
Console << " ! repeat last command" << endl;
|
||||
Console << endl;
|
||||
Console << " echo [on|off] or strings" << endl;
|
||||
Console << " every ms [command]; every list; every remove [nr|all]; every (on|off) [#]" << endl;
|
||||
Console << " on {output}; off {output}" << endl;
|
||||
Console << " $id : name of the client." << endl;
|
||||
Console << " rnd[(min[,max])] random number." << endl;
|
||||
Console << endl;
|
||||
}
|
||||
else
|
||||
{
|
||||
while(s[0]==' ') s.erase(0,1);
|
||||
if (s.length())
|
||||
Console << "Unknown command (" << s.c_str() << ")" << endl;
|
||||
}
|
||||
|
||||
if (retval != MqttOk)
|
||||
{
|
||||
Console << "# MQTT ERROR " << retval << endl;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
void loop()
|
||||
{
|
||||
auto ms=millis();
|
||||
int8_t out=0;
|
||||
int16_t blink_bits = blink;
|
||||
uint8_t e=0;
|
||||
|
||||
for(auto& every: everies)
|
||||
{
|
||||
if (not every.active) continue;
|
||||
if (every.ms && every.cmd.length() && ms > every.next)
|
||||
{
|
||||
string cmd(every.cmd);
|
||||
eval(cmd);
|
||||
every.next += every.ms;
|
||||
if (ms > every.next and ms > every.underrun)
|
||||
{
|
||||
every.next += every.ms;
|
||||
Console << yellow << "Underrun every #" << e << ", " << (ms - every.next) << "ms late" << endl;
|
||||
every.underrun = ms+5000;
|
||||
}
|
||||
}
|
||||
e++;
|
||||
}
|
||||
|
||||
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++;
|
||||
}
|
||||
|
||||
#if defined(ESP9266)
|
||||
MDNS.update();
|
||||
#endif
|
||||
|
||||
for(auto it: brokers)
|
||||
it.second->loop();
|
||||
|
||||
for(auto it: clients)
|
||||
it.second->loop();
|
||||
|
||||
Console.loop();
|
||||
}
|
||||
@@ -144,6 +144,93 @@ test(suback)
|
||||
assertEqual(MqttClient::counters[MqttMessage::Type::SubAck], 1);
|
||||
}
|
||||
|
||||
test(remote_client_deletion)
|
||||
{
|
||||
assertEqual(MqttClient::instances, 0);
|
||||
{
|
||||
start_many_wifi_esp(3, true);
|
||||
assertEqual(WiFi.status(), WL_CONNECTED);
|
||||
|
||||
MqttBroker broker(1883);
|
||||
broker.begin();
|
||||
IPAddress broker_ip = WiFi.localIP();
|
||||
|
||||
// A first remote client
|
||||
ESP8266WiFiClass::selectInstance(2);
|
||||
MqttClient remote_client;
|
||||
assertEqual(MqttClient::instances, 1);
|
||||
|
||||
remote_client.connect(broker_ip.toString().c_str());
|
||||
broker.loop(); remote_client.loop();
|
||||
assertEqual(MqttClient::instances, 2); // broker creates a client to manage remote_client
|
||||
|
||||
// A second remote client
|
||||
ESP8266WiFiClass::selectInstance(3);
|
||||
MqttClient secund_client;
|
||||
assertEqual(MqttClient::instances, 3);
|
||||
|
||||
secund_client.connect(broker_ip.toString().c_str());
|
||||
broker.loop(); remote_client.loop();
|
||||
assertEqual(MqttClient::instances, 4);
|
||||
|
||||
// Now disconnect remote clients
|
||||
remote_client.close();
|
||||
broker.loop(); remote_client.loop();
|
||||
assertEqual(MqttClient::instances, 3);
|
||||
|
||||
secund_client.close();
|
||||
broker.loop(); remote_client.loop();
|
||||
assertEqual(MqttClient::instances, 2); // These instances are in this scope
|
||||
|
||||
// Now simulate that the external client is dead without disconnecting
|
||||
secund_client.connect(broker_ip.toString().c_str());
|
||||
broker.loop(); remote_client.loop();
|
||||
assertEqual(MqttClient::instances, 3);
|
||||
|
||||
WiFi.disconnect();
|
||||
broker.loop(); remote_client.loop();
|
||||
broker.loop(); remote_client.loop();
|
||||
assertEqual(MqttClient::instances, 2);
|
||||
|
||||
}
|
||||
|
||||
assertEqual(MqttClient::instances, 0);
|
||||
}
|
||||
|
||||
test(broker_connect_and_client_deletion)
|
||||
{
|
||||
assertEqual(MqttClient::instances, 0);
|
||||
{
|
||||
start_many_wifi_esp(2, true);
|
||||
assertEqual(WiFi.status(), WL_CONNECTED);
|
||||
|
||||
MqttBroker broker(1883);
|
||||
broker.begin();
|
||||
|
||||
ESP8266WiFiClass::selectInstance(2);
|
||||
MqttBroker remote_broker(1883);
|
||||
remote_broker.begin();
|
||||
IPAddress remote_broker_ip = WiFi.localIP();
|
||||
assertEqual(MqttClient::instances, 0);
|
||||
|
||||
ESP8266WiFiClass::selectInstance(1);
|
||||
broker.connect(remote_broker_ip.toString().c_str());
|
||||
remote_broker.loop();
|
||||
assertEqual(remote_broker.clientsCount(), (size_t)1);
|
||||
|
||||
// Here, we have two MqttClient
|
||||
// The client that connects broker to remote_broker
|
||||
// The client created by remote_broker
|
||||
assertEqual(MqttClient::instances, 2);
|
||||
|
||||
broker.connect("");
|
||||
remote_broker.loop(); broker.loop();
|
||||
remote_broker.loop(); broker.loop();
|
||||
assertEqual(remote_broker.clientsCount(), (size_t)0);
|
||||
}
|
||||
assertEqual(MqttClient::instances, 0);
|
||||
}
|
||||
|
||||
test(client_keep_alive_high)
|
||||
{
|
||||
const uint32_t keep_alive=1000;
|
||||
@@ -191,37 +278,41 @@ test(retained_message)
|
||||
broker.retain(10);
|
||||
IPAddress broker_ip = WiFi.localIP();
|
||||
|
||||
MqttClient local_client(&broker);
|
||||
MqttClient local_client(&broker, "sender");
|
||||
|
||||
// Send a retained message
|
||||
// No remote client connected
|
||||
local_client.publish("topic", "retained", true);
|
||||
local_client.publish("topic", "retained once", true);
|
||||
for(int i=0; i<2; i++) { broker.loop(); local_client.loop(); };
|
||||
|
||||
for(int i=0; i<2; i++)
|
||||
{
|
||||
broker.loop();
|
||||
local_client.loop();
|
||||
};
|
||||
// Send a second message on the same topic (issue 86)
|
||||
local_client.publish("topic", "retained once", true);
|
||||
for(int i=0; i<2; i++) { broker.loop(); local_client.loop(); };
|
||||
|
||||
// Send a second message on the same topic (issue 86)
|
||||
local_client.publish("topic", "retained last", true);
|
||||
for(int i=0; i<2; i++) { broker.loop(); local_client.loop(); };
|
||||
|
||||
// No connect a client from 2nd Esp
|
||||
ESP8266WiFiClass::selectInstance(2);
|
||||
MqttClient remote_client;
|
||||
MqttClient remote_client("receiver");
|
||||
remote_client.connect(broker_ip, 1883);
|
||||
remote_client.setCallback(onPublish);
|
||||
|
||||
assertTrue(remote_client.connected());
|
||||
for(int i=0; i<4; i++) { broker.loop(); local_client.loop(); remote_client.loop(); };
|
||||
for(int i=0; i<10; i++) { broker.loop(); local_client.loop(); remote_client.loop(); };
|
||||
assertEqual(broker.clientsCount(), (size_t) 2);
|
||||
|
||||
// Should not have received anything yet
|
||||
assertEqual(published.size(), (size_t)0);
|
||||
|
||||
// Now, remote client subscribes to topic
|
||||
remote_client.subscribe("topic");
|
||||
for(int i=0; i<4; i++) { broker.loop(); local_client.loop(); remote_client.loop(); };
|
||||
remote_client.subscribe("#");
|
||||
for(int i=0; i<10; i++) { broker.loop(); local_client.loop(); remote_client.loop(); };
|
||||
|
||||
// Check that the retained message is published
|
||||
// Check that the retained message is published once
|
||||
assertEqual(published.size(), (size_t)1);
|
||||
assertEqual(published["receiver"]["topic"], 1);
|
||||
|
||||
// FIXME we should check that
|
||||
// 1 - Retained message has the retain flag set
|
||||
@@ -258,6 +349,39 @@ test(retained_message)
|
||||
assertEqual(published.size(), (size_t)2);
|
||||
}
|
||||
|
||||
test(retained_payload) // # issue #84
|
||||
{
|
||||
published.clear();
|
||||
|
||||
start_many_wifi_esp(2, true);
|
||||
assertEqual(WiFi.status(), WL_CONNECTED);
|
||||
|
||||
MqttBroker broker(1883);
|
||||
broker.begin();
|
||||
broker.retain(10);
|
||||
IPAddress broker_ip = WiFi.localIP();
|
||||
|
||||
MqttClient local_client(&broker, "sender");
|
||||
|
||||
// Send a retained message
|
||||
// No remote client connected
|
||||
local_client.publish("topic", "retained", true);
|
||||
for(int i=0; i<2; i++) { broker.loop(); local_client.loop(); };
|
||||
|
||||
// No connect a client from 2nd Esp
|
||||
ESP8266WiFiClass::selectInstance(2);
|
||||
MqttClient remote_client("receiver");
|
||||
remote_client.connect(broker_ip, 1883);
|
||||
remote_client.setCallback(onPublish);
|
||||
remote_client.subscribe("#");
|
||||
|
||||
assertTrue(remote_client.connected());
|
||||
for(int i=0; i<10; i++) { broker.loop(); local_client.loop(); remote_client.loop(); };
|
||||
|
||||
// Check that the retained message is published
|
||||
assertEqual(lastPayload, "retained");
|
||||
}
|
||||
|
||||
test(remote_client_disconnect_reconnect)
|
||||
{
|
||||
published.clear();
|
||||
|
||||
Reference in New Issue
Block a user