mirror of
https://github.com/alexhopeoconnor/arduino-home-assistant.git
synced 2026-10-13 23:01:21 +10:00
366 lines
9.0 KiB
Arduino
366 lines
9.0 KiB
Arduino
#include <AUnit.h>
|
|
#include <ArduinoHA.h>
|
|
|
|
#define prepareTest \
|
|
initMqttTest(testDeviceId) \
|
|
lastCommandCallbackCall.reset();
|
|
|
|
#define assertCommandCallbackCalled(expectedCommand, callerPtr) \
|
|
assertTrue(lastCommandCallbackCall.called); \
|
|
assertEqual(static_cast<bool>(expectedCommand), lastCommandCallbackCall.state); \
|
|
assertEqual(callerPtr, lastCommandCallbackCall.caller);
|
|
|
|
#define assertCommandCallbackNotCalled() \
|
|
assertFalse(lastCommandCallbackCall.called);
|
|
|
|
using aunit::TestRunner;
|
|
|
|
struct CommandCallback {
|
|
bool called = false;
|
|
bool state = false;
|
|
HASwitch* caller = nullptr;
|
|
|
|
void reset() {
|
|
called = false;
|
|
state = false;
|
|
caller = nullptr;
|
|
}
|
|
};
|
|
|
|
static const char* testDeviceId = "testDevice";
|
|
static const char* testUniqueId = "uniqueSwitch";
|
|
static CommandCallback lastCommandCallbackCall;
|
|
|
|
const char ConfigTopic[] PROGMEM = {"homeassistant/switch/testDevice/uniqueSwitch/config"};
|
|
const char StateTopic[] PROGMEM = {"testData/testDevice/uniqueSwitch/stat_t"};
|
|
const char CommandTopic[] PROGMEM = {"testData/testDevice/uniqueSwitch/cmd_t"};
|
|
|
|
void onCommandReceived(bool state, HASwitch* caller)
|
|
{
|
|
lastCommandCallbackCall.called = true;
|
|
lastCommandCallbackCall.state = state;
|
|
lastCommandCallbackCall.caller = caller;
|
|
}
|
|
|
|
class CallbacksProcessor {
|
|
public:
|
|
void onCommand(bool state, HASwitch* caller) {
|
|
lastCommandCallbackCall.called = true;
|
|
lastCommandCallbackCall.state = state;
|
|
lastCommandCallbackCall.caller = caller;
|
|
}
|
|
};
|
|
|
|
AHA_TEST(SwitchTest, invalid_unique_id) {
|
|
prepareTest
|
|
|
|
HASwitch testSwitch(nullptr);
|
|
testSwitch.buildSerializerTest();
|
|
HASerializer* serializer = testSwitch.getSerializer();
|
|
|
|
assertTrue(serializer == nullptr);
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, default_params) {
|
|
prepareTest
|
|
|
|
HASwitch testSwitch(testUniqueId);
|
|
assertEntityConfig(
|
|
mock,
|
|
testSwitch,
|
|
(
|
|
"{"
|
|
"\"uniq_id\":\"uniqueSwitch\","
|
|
"\"dev\":{\"ids\":\"testDevice\"},"
|
|
"\"stat_t\":\"testData/testDevice/uniqueSwitch/stat_t\","
|
|
"\"cmd_t\":\"testData/testDevice/uniqueSwitch/cmd_t\""
|
|
"}"
|
|
)
|
|
)
|
|
assertEqual(2, mock->getFlushedMessagesNb());
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, extended_unique_id) {
|
|
prepareTest
|
|
|
|
device.enableExtendedUniqueIds();
|
|
HASwitch testSwitch(testUniqueId);
|
|
assertEntityConfig(
|
|
mock,
|
|
testSwitch,
|
|
(
|
|
"{"
|
|
"\"uniq_id\":\"testDevice_uniqueSwitch\","
|
|
"\"dev\":{\"ids\":\"testDevice\"},"
|
|
"\"stat_t\":\"testData/testDevice/uniqueSwitch/stat_t\","
|
|
"\"cmd_t\":\"testData/testDevice/uniqueSwitch/cmd_t\""
|
|
"}"
|
|
)
|
|
)
|
|
assertEqual(2, mock->getFlushedMessagesNb());
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, command_subscription) {
|
|
prepareTest
|
|
|
|
HASwitch testSwitch(testUniqueId);
|
|
mqtt.loop();
|
|
|
|
assertEqual(1, mock->getSubscriptionsNb());
|
|
assertEqual(AHATOFSTR(CommandTopic), mock->getSubscriptions()[0]->topic);
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, availability) {
|
|
prepareTest
|
|
|
|
HASwitch testSwitch(testUniqueId);
|
|
testSwitch.setAvailability(true);
|
|
mqtt.loop();
|
|
|
|
// availability is published after config in HASwitch
|
|
assertMqttMessage(
|
|
1,
|
|
F("testData/testDevice/uniqueSwitch/avty_t"),
|
|
"online",
|
|
true
|
|
)
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, publish_last_known_state) {
|
|
prepareTest
|
|
|
|
HASwitch testSwitch(testUniqueId);
|
|
testSwitch.setCurrentState(true);
|
|
mqtt.loop();
|
|
|
|
assertEqual(2, mock->getFlushedMessagesNb());
|
|
assertMqttMessage(1, AHATOFSTR(StateTopic), "ON", true)
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, publish_nothing_if_retained) {
|
|
prepareTest
|
|
|
|
HASwitch testSwitch(testUniqueId);
|
|
testSwitch.setRetain(true);
|
|
testSwitch.setCurrentState(true);
|
|
mqtt.loop();
|
|
|
|
assertEqual(1, mock->getFlushedMessagesNb()); // only config should be pushed
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, name_setter) {
|
|
prepareTest
|
|
|
|
HASwitch testSwitch(testUniqueId);
|
|
testSwitch.setName("testName");
|
|
|
|
assertEntityConfig(
|
|
mock,
|
|
testSwitch,
|
|
(
|
|
"{"
|
|
"\"name\":\"testName\","
|
|
"\"uniq_id\":\"uniqueSwitch\","
|
|
"\"dev\":{\"ids\":\"testDevice\"},"
|
|
"\"stat_t\":\"testData/testDevice/uniqueSwitch/stat_t\","
|
|
"\"cmd_t\":\"testData/testDevice/uniqueSwitch/cmd_t\""
|
|
"}"
|
|
)
|
|
)
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, object_id_setter) {
|
|
prepareTest
|
|
|
|
HASwitch testSwitch(testUniqueId);
|
|
testSwitch.setObjectId("testId");
|
|
|
|
assertEntityConfig(
|
|
mock,
|
|
testSwitch,
|
|
(
|
|
"{"
|
|
"\"obj_id\":\"testId\","
|
|
"\"uniq_id\":\"uniqueSwitch\","
|
|
"\"dev\":{\"ids\":\"testDevice\"},"
|
|
"\"stat_t\":\"testData/testDevice/uniqueSwitch/stat_t\","
|
|
"\"cmd_t\":\"testData/testDevice/uniqueSwitch/cmd_t\""
|
|
"}"
|
|
)
|
|
)
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, device_class) {
|
|
prepareTest
|
|
|
|
HASwitch testSwitch(testUniqueId);
|
|
testSwitch.setDeviceClass("testClass");
|
|
|
|
assertEntityConfig(
|
|
mock,
|
|
testSwitch,
|
|
(
|
|
"{"
|
|
"\"uniq_id\":\"uniqueSwitch\","
|
|
"\"dev_cla\":\"testClass\","
|
|
"\"dev\":{\"ids\":\"testDevice\"},"
|
|
"\"stat_t\":\"testData/testDevice/uniqueSwitch/stat_t\","
|
|
"\"cmd_t\":\"testData/testDevice/uniqueSwitch/cmd_t\""
|
|
"}"
|
|
)
|
|
)
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, icon_setter) {
|
|
prepareTest
|
|
|
|
HASwitch testSwitch(testUniqueId);
|
|
testSwitch.setIcon("testIcon");
|
|
|
|
assertEntityConfig(
|
|
mock,
|
|
testSwitch,
|
|
(
|
|
"{"
|
|
"\"uniq_id\":\"uniqueSwitch\","
|
|
"\"ic\":\"testIcon\","
|
|
"\"dev\":{\"ids\":\"testDevice\"},"
|
|
"\"stat_t\":\"testData/testDevice/uniqueSwitch/stat_t\","
|
|
"\"cmd_t\":\"testData/testDevice/uniqueSwitch/cmd_t\""
|
|
"}"
|
|
)
|
|
)
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, retain_setter) {
|
|
prepareTest
|
|
|
|
HASwitch testSwitch(testUniqueId);
|
|
testSwitch.setRetain(true);
|
|
|
|
assertEntityConfig(
|
|
mock,
|
|
testSwitch,
|
|
(
|
|
"{"
|
|
"\"uniq_id\":\"uniqueSwitch\","
|
|
"\"ret\":true,"
|
|
"\"dev\":{\"ids\":\"testDevice\"},"
|
|
"\"stat_t\":\"testData/testDevice/uniqueSwitch/stat_t\","
|
|
"\"cmd_t\":\"testData/testDevice/uniqueSwitch/cmd_t\""
|
|
"}"
|
|
)
|
|
)
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, optimistic_setter) {
|
|
prepareTest
|
|
|
|
HASwitch testSwitch(testUniqueId);
|
|
testSwitch.setOptimistic(true);
|
|
|
|
assertEntityConfig(
|
|
mock,
|
|
testSwitch,
|
|
(
|
|
"{"
|
|
"\"uniq_id\":\"uniqueSwitch\","
|
|
"\"opt\":true,"
|
|
"\"dev\":{\"ids\":\"testDevice\"},"
|
|
"\"stat_t\":\"testData/testDevice/uniqueSwitch/stat_t\","
|
|
"\"cmd_t\":\"testData/testDevice/uniqueSwitch/cmd_t\""
|
|
"}"
|
|
)
|
|
)
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, current_state_setter) {
|
|
prepareTest
|
|
|
|
HASwitch testSwitch(testUniqueId);
|
|
testSwitch.setCurrentState(true);
|
|
|
|
assertEqual(0, mock->getFlushedMessagesNb());
|
|
assertTrue(testSwitch.getCurrentState());
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, publish_state_on) {
|
|
prepareTest
|
|
|
|
mock->connectDummy();
|
|
HASwitch testSwitch(testUniqueId);
|
|
|
|
assertTrue(testSwitch.setState(true));
|
|
assertSingleMqttMessage(AHATOFSTR(StateTopic), "ON", true)
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, publish_state_off) {
|
|
prepareTest
|
|
|
|
mock->connectDummy();
|
|
HASwitch testSwitch(testUniqueId);
|
|
testSwitch.setCurrentState(true);
|
|
|
|
assertTrue(testSwitch.setState(false));
|
|
assertSingleMqttMessage(AHATOFSTR(StateTopic), "OFF", true)
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, command_on) {
|
|
prepareTest
|
|
|
|
HASwitch testSwitch(testUniqueId);
|
|
testSwitch.onCommand(onCommandReceived);
|
|
mock->fakeMessage(AHATOFSTR(CommandTopic), F("ON"));
|
|
|
|
assertCommandCallbackCalled(true, &testSwitch)
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, command_off) {
|
|
prepareTest
|
|
|
|
HASwitch testSwitch(testUniqueId);
|
|
testSwitch.onCommand(onCommandReceived);
|
|
mock->fakeMessage(AHATOFSTR(CommandTopic), F("OFF"));
|
|
|
|
assertCommandCallbackCalled(false, &testSwitch)
|
|
}
|
|
|
|
AHA_TEST(SwitchTest, different_switch_command) {
|
|
prepareTest
|
|
|
|
HASwitch testSwitch(testUniqueId);
|
|
testSwitch.onCommand(onCommandReceived);
|
|
mock->fakeMessage(
|
|
F("testData/testDevice/uniqueSwitchDifferent/cmd_t"),
|
|
F("CLOSE")
|
|
);
|
|
|
|
assertCommandCallbackNotCalled()
|
|
}
|
|
|
|
#ifdef ARDUINOHA_USE_STD_FUNCTION
|
|
AHA_TEST(SwitchTest, command_callback_std_function) {
|
|
prepareTest
|
|
|
|
CallbacksProcessor processor;
|
|
HASwitch testSwitch(testUniqueId);
|
|
testSwitch.onCommand(std::bind(&CallbacksProcessor::onCommand, &processor, std::placeholders::_1, std::placeholders::_2));
|
|
mock->fakeMessage(AHATOFSTR(CommandTopic), F("ON"));
|
|
|
|
assertCommandCallbackCalled(true, &testSwitch)
|
|
}
|
|
#endif
|
|
|
|
void setup()
|
|
{
|
|
delay(1000);
|
|
Serial.begin(115200);
|
|
while (!Serial);
|
|
}
|
|
|
|
void loop()
|
|
{
|
|
TestRunner::run();
|
|
delay(1);
|
|
}
|