From e7fc14742486fbf4cadb9d44cf50fbc0e1fb9fb0 Mon Sep 17 00:00:00 2001 From: hsaturn Date: Sun, 30 Oct 2022 21:43:45 +0100 Subject: [PATCH] Changed tab to spaces --- tests/local-tests/local-tests.ino | 160 +++++++++++++++--------------- 1 file changed, 80 insertions(+), 80 deletions(-) diff --git a/tests/local-tests/local-tests.ino b/tests/local-tests/local-tests.ino index e260b09..9d59bb9 100644 --- a/tests/local-tests/local-tests.ino +++ b/tests/local-tests/local-tests.ino @@ -4,148 +4,148 @@ #include /** - * 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 - **/ + * 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> published; // map[client_id] => map[topic] = count +std::map> 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]++; + if (srce) + published[srce->id()][topic]++; lastPayload = payload; - lastLength = length; + lastLength = length; } test(local_client_should_unregister_when_destroyed) { - assertEqual(broker.clientsCount(), (size_t)0); - { - assertEqual(broker.clientsCount(), (size_t)0); // Ensure client is not yet connected - MqttClient client(&broker); - assertEqual(broker.clientsCount(), (size_t)1); // Ensure client is now connected - } - assertEqual(broker.clientsCount(), (size_t)0); + assertEqual(broker.clientsCount(), (size_t)0); + { + assertEqual(broker.clientsCount(), (size_t)0); // Ensure client is not yet connected + MqttClient client(&broker); + assertEqual(broker.clientsCount(), (size_t)1); // Ensure client is now connected + } + assertEqual(broker.clientsCount(), (size_t)0); } #if 0 test(local_connect) { - assertEqual(broker.clientsCount(), (size_t)0); + assertEqual(broker.clientsCount(), (size_t)0); - MqttClient client; - assertTrue(client.connected()); - assertEqual(broker.clientsCount(), (size_t)1); + MqttClient client; + assertTrue(client.connected()); + assertEqual(broker.clientsCount(), (size_t)1); } test(local_publish_should_be_dispatched) { - published.clear(); - assertEqual(broker.clientsCount(), (size_t)0); + published.clear(); + assertEqual(broker.clientsCount(), (size_t)0); - MqttClient subscriber; - subscriber.subscribe("a/b"); - subscriber.subscribe("a/c"); - subscriber.setCallback(onPublish); + 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"); + 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); + 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.clientsCount(), (size_t)0); + published.clear(); + assertEqual(broker.clientsCount(), (size_t)0); - MqttClient subscriber_a("A"); - subscriber_a.setCallback(onPublish); - subscriber_a.subscribe("a/b"); - subscriber_a.subscribe("a/c"); + 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 subscriber_b("B"); + subscriber_b.setCallback(onPublish); + subscriber_b.subscribe("a/b"); - MqttClient publisher; - publisher.publish("a/b"); - publisher.publish("a/c"); + 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); + 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.clientsCount(), (size_t)0); + published.clear(); + assertEqual(broker.clientsCount(), (size_t)0); - MqttClient subscriber; - subscriber.setCallback(onPublish); - subscriber.subscribe("a/b"); + MqttClient subscriber; + subscriber.setCallback(onPublish); + subscriber.subscribe("a/b"); - MqttClient publisher; - publisher.publish("a/b"); + MqttClient publisher; + publisher.publish("a/b"); - subscriber.unsubscribe("a/b"); + subscriber.unsubscribe("a/b"); - publisher.publish("a/b"); - publisher.publish("a/b"); + publisher.publish("a/b"); + publisher.publish("a/b"); - assertEqual(published[""]["a/b"], 1); // Only one publish has been received + assertEqual(published[""]["a/b"], 1); // Only one publish has been received } test(local_nocallback_when_destroyed) { - published.clear(); - assertEqual(broker.clientsCount(), (size_t)0); + published.clear(); + assertEqual(broker.clientsCount(), (size_t)0); - MqttClient publisher; - { - MqttClient subscriber; - subscriber.setCallback(onPublish); - subscriber.subscribe("a/b"); - publisher.publish("a/b"); - } + MqttClient publisher; + { + MqttClient subscriber; + subscriber.setCallback(onPublish); + subscriber.subscribe("a/b"); + publisher.publish("a/b"); + } - publisher.publish("a/b"); + publisher.publish("a/b"); - assertEqual(published.size(), (size_t)1); // Only one publish has been received + 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); + delay(1000); + Serial.begin(115200); + while(!Serial); - Serial.println("=============[ LOCAL TinyMqtt TESTS ]========================"); + Serial.println("=============[ LOCAL TinyMqtt TESTS ]========================"); } void loop() { - aunit::TestRunner::run(); + aunit::TestRunner::run(); - if (Serial.available()) ESP.reset(); + if (Serial.available()) ESP.reset(); }