TinyMqtt/tests/local-tests/local-tests.ino

#include <Arduino.h>
#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;


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(local_client_should_unregister_when_destroyed)
{
  MqttBroker broker(1883);
  assertEqual(broker.localClientsCount(), (size_t)0);
  {
    MqttClient client(&broker);
    assertEqual(broker.localClientsCount(), (size_t)1);  // Ensure client is now connected
  }
  assertEqual(broker.localClientsCount(), (size_t)0);
}

test(local_client_alive)
{
  set_millis(0);
  MqttBroker broker(1883);
  MqttClient client(&broker);

  broker.loop();
  assertEqual(broker.localClientsCount(), (size_t)1);  // Ensure client is now connected

  add_millis(TINY_MQTT_DEFAULT_ALIVE*1000/2);
  broker.loop();
  assertEqual(broker.localClientsCount(), (size_t)1);  // Ensure client is still connected

  add_seconds(TINY_MQTT_DEFAULT_ALIVE*5);
  broker.loop();
  assertEqual(broker.localClientsCount(), (size_t)1);  // Ensure client is still connected
}

#if 0
test(local_connect)
{
  assertEqual(broker.localClientsCount(), (size_t)0);

  MqttClient client;
  assertTrue(client.connected());
  assertEqual(broker.localClientsCount(), (size_t)1);
}

test(local_publish_should_be_dispatched)
{
  published.clear();
  assertEqual(broker.localClientsCount(), (size_t)0);

  MqttClient subscriber;
  subscriber.subscribe("a/b");
  subscriber.subscribe("a/c");
  subscriber.setCallback(onPublish);

  MqttClient publisher;
  publisher.publish("a/b");
  publisher.publish("a/c");
  publisher.publish("a/c");

  assertEqual(published.size(), (size_t)1);  // 1 client has received something
  assertEqual(published[""]["a/b"], 1);
  assertEqual(published[""]["a/c"], 2);
}

test(local_publish_should_be_dispatched_to_local_clients)
{
  published.clear();
  assertEqual(broker.localClientsCount(), (size_t)0);

  MqttClient subscriber_a("A");
  subscriber_a.setCallback(onPublish);
  subscriber_a.subscribe("a/b");
  subscriber_a.subscribe("a/c");

  MqttClient subscriber_b("B");
  subscriber_b.setCallback(onPublish);
  subscriber_b.subscribe("a/b");

  MqttClient publisher;
  publisher.publish("a/b");
  publisher.publish("a/c");

  assertEqual(published.size(), (size_t)2);  // 2 clients have received something
  assertEqual(published["A"]["a/b"], 1);
  assertEqual(published["A"]["a/c"], 1);
  assertEqual(published["B"]["a/b"], 1);
  assertEqual(published["B"]["a/c"], 0);
}

test(local_unsubscribe)
{
  published.clear();
  assertEqual(broker.localClientsCount(), (size_t)0);

  MqttClient subscriber;
  subscriber.setCallback(onPublish);
  subscriber.subscribe("a/b");

  MqttClient publisher;
  publisher.publish("a/b");

  subscriber.unsubscribe("a/b");

  publisher.publish("a/b");
  publisher.publish("a/b");

  assertEqual(published[""]["a/b"], 1);  // Only one publish has been received
}

test(local_nocallback_when_destroyed)
{
  published.clear();
  assertEqual(broker.localClientsCount(), (size_t)0);

  MqttClient publisher;
  {
    MqttClient subscriber;
    subscriber.setCallback(onPublish);
    subscriber.subscribe("a/b");
    publisher.publish("a/b");
  }

  publisher.publish("a/b");

  assertEqual(published.size(), (size_t)1);  // Only one publish has been received
}
#endif

//----------------------------------------------------------------------------
// setup() and loop()
void setup() {
  delay(1000);
  Serial.begin(115200);
  while(!Serial);

  Serial.println("=============[ LOCAL TinyMqtt TESTS              ]========================");
}

void loop() {
  aunit::TestRunner::run();

  if (Serial.available()) ESP.reset();
}