1431 lines
56 KiB
C++
1431 lines
56 KiB
C++
#include "NukiOpenerWrapper.h"
|
|
#include <RTOS.h>
|
|
#include "PreferencesKeys.h"
|
|
#include "MqttTopics.h"
|
|
#include "Logger.h"
|
|
#include "RestartReason.h"
|
|
#include <NukiOpenerUtils.h>
|
|
|
|
NukiOpenerWrapper* nukiOpenerInst;
|
|
Preferences* nukiOpenerPreferences = nullptr;
|
|
|
|
NukiOpenerWrapper::NukiOpenerWrapper(const std::string& deviceName, NukiDeviceId* deviceId, BleScanner::Scanner* scanner, NetworkOpener* network, Gpio* gpio, Preferences* preferences)
|
|
: _deviceName(deviceName),
|
|
_deviceId(deviceId),
|
|
_nukiOpener(deviceName, _deviceId->get()),
|
|
_bleScanner(scanner),
|
|
_network(network),
|
|
_gpio(gpio),
|
|
_preferences(preferences)
|
|
{
|
|
Log->print("Device id opener: ");
|
|
Log->println(_deviceId->get());
|
|
|
|
nukiOpenerInst = this;
|
|
|
|
memset(&_lastKeyTurnerState, sizeof(NukiLock::KeyTurnerState), 0);
|
|
memset(&_lastBatteryReport, sizeof(NukiLock::BatteryReport), 0);
|
|
memset(&_batteryReport, sizeof(NukiLock::BatteryReport), 0);
|
|
memset(&_keyTurnerState, sizeof(NukiLock::KeyTurnerState), 0);
|
|
_keyTurnerState.lockState = NukiOpener::LockState::Undefined;
|
|
|
|
network->setLockActionReceivedCallback(nukiOpenerInst->onLockActionReceivedCallback);
|
|
network->setConfigUpdateReceivedCallback(nukiOpenerInst->onConfigUpdateReceivedCallback);
|
|
network->setKeypadCommandReceivedCallback(nukiOpenerInst->onKeypadCommandReceivedCallback);
|
|
|
|
_gpio->addCallback(NukiOpenerWrapper::gpioActionCallback);
|
|
}
|
|
|
|
|
|
NukiOpenerWrapper::~NukiOpenerWrapper()
|
|
{
|
|
_bleScanner = nullptr;
|
|
}
|
|
|
|
|
|
void NukiOpenerWrapper::initialize()
|
|
{
|
|
_nukiOpener.initialize();
|
|
_nukiOpener.registerBleScanner(_bleScanner);
|
|
|
|
_intervalLockstate = _preferences->getInt(preference_query_interval_lockstate);
|
|
_intervalConfig = _preferences->getInt(preference_query_interval_configuration);
|
|
_intervalBattery = _preferences->getInt(preference_query_interval_battery);
|
|
_intervalKeypad = _preferences->getInt(preference_query_interval_keypad);
|
|
_keypadEnabled = _preferences->getBool(preference_keypad_info_enabled);
|
|
_publishAuthData = _preferences->getBool(preference_publish_authdata);
|
|
_maxKeypadCodeCount = _preferences->getUInt(preference_opener_max_keypad_code_count);
|
|
_restartBeaconTimeout = _preferences->getInt(preference_restart_ble_beacon_lost);
|
|
_hassEnabled = _preferences->getString(preference_mqtt_hass_discovery) != "";
|
|
_nrOfRetries = _preferences->getInt(preference_command_nr_of_retries);
|
|
_retryDelay = _preferences->getInt(preference_command_retry_delay);
|
|
_rssiPublishInterval = _preferences->getInt(preference_rssi_publish_interval) * 1000;
|
|
|
|
if(_retryDelay <= 100)
|
|
{
|
|
_retryDelay = 100;
|
|
_preferences->putInt(preference_command_retry_delay, _retryDelay);
|
|
}
|
|
|
|
if(_intervalLockstate == 0)
|
|
{
|
|
_intervalLockstate = 60 * 30;
|
|
_preferences->putInt(preference_query_interval_lockstate, _intervalLockstate);
|
|
}
|
|
if(_intervalConfig == 0)
|
|
{
|
|
_intervalConfig = 60 * 60;
|
|
_preferences->putInt(preference_query_interval_configuration, _intervalConfig);
|
|
}
|
|
if(_intervalBattery == 0)
|
|
{
|
|
_intervalBattery = 60 * 30;
|
|
_preferences->putInt(preference_query_interval_battery, _intervalBattery);
|
|
}
|
|
if(_intervalKeypad == 0)
|
|
{
|
|
_intervalKeypad = 60 * 30;
|
|
_preferences->putInt(preference_query_interval_keypad, _intervalKeypad);
|
|
}
|
|
/*
|
|
if(_intervalKeypad == 0)
|
|
{
|
|
_intervalKeypad = 60 * 30;
|
|
_preferences->putInt(preference_query_interval_keypad, _intervalKeypad);
|
|
}
|
|
*/
|
|
if(_restartBeaconTimeout < 10)
|
|
{
|
|
_restartBeaconTimeout = -1;
|
|
_preferences->putInt(preference_restart_ble_beacon_lost, _restartBeaconTimeout);
|
|
}
|
|
|
|
_nukiOpener.setEventHandler(this);
|
|
|
|
Log->print(F("Lock state interval: "));
|
|
Log->print(_intervalLockstate);
|
|
Log->print(F(" | Battery interval: "));
|
|
Log->print(_intervalBattery);
|
|
Log->print(F(" | Publish auth data: "));
|
|
Log->println(_publishAuthData ? "yes" : "no");
|
|
|
|
if(!_publishAuthData)
|
|
{
|
|
_clearAuthData = true;
|
|
}
|
|
}
|
|
|
|
void NukiOpenerWrapper::update()
|
|
{
|
|
if(!_paired)
|
|
{
|
|
Log->println(F("Nuki opener start pairing"));
|
|
_network->publishBleAddress("");
|
|
|
|
Nuki::AuthorizationIdType idType = _preferences->getBool(preference_register_as_app) ?
|
|
Nuki::AuthorizationIdType::App :
|
|
Nuki::AuthorizationIdType::Bridge;
|
|
|
|
if(_nukiOpener.pairNuki(idType) == NukiOpener::PairingResult::Success)
|
|
{
|
|
Log->println(F("Nuki opener paired"));
|
|
_paired = true;
|
|
_network->publishBleAddress(_nukiOpener.getBleAddress().toString());
|
|
}
|
|
else
|
|
{
|
|
delay(200);
|
|
return;
|
|
}
|
|
}
|
|
|
|
unsigned long ts = millis();
|
|
unsigned long lastReceivedBeaconTs = _nukiOpener.getLastReceivedBeaconTs();
|
|
uint8_t queryCommands = _network->queryCommands();
|
|
|
|
if(_restartBeaconTimeout > 0 &&
|
|
ts > 60000 &&
|
|
lastReceivedBeaconTs > 0 &&
|
|
_disableBleWatchdogTs < ts &&
|
|
(ts - lastReceivedBeaconTs > _restartBeaconTimeout * 1000))
|
|
{
|
|
Log->print("No BLE beacon received from the opener for ");
|
|
Log->print((millis() - _nukiOpener.getLastReceivedBeaconTs()) / 1000);
|
|
Log->println(" seconds, restarting device.");
|
|
delay(200);
|
|
restartEsp(RestartReason::BLEBeaconWatchdog);
|
|
}
|
|
|
|
_nukiOpener.updateConnectionState();
|
|
|
|
if(_statusUpdated || _nextLockStateUpdateTs == 0 || ts >= _nextLockStateUpdateTs || (queryCommands & QUERY_COMMAND_LOCKSTATE) > 0)
|
|
{
|
|
_nextLockStateUpdateTs = ts + _intervalLockstate * 1000;
|
|
updateKeyTurnerState();
|
|
_statusUpdated = false;
|
|
}
|
|
if(_nextBatteryReportTs == 0 || ts > _nextBatteryReportTs || (queryCommands & QUERY_COMMAND_BATTERY) > 0)
|
|
{
|
|
_nextBatteryReportTs = ts + _intervalBattery * 1000;
|
|
updateBatteryState();
|
|
}
|
|
if(_nextConfigUpdateTs == 0 || ts > _nextConfigUpdateTs || (queryCommands & QUERY_COMMAND_CONFIG) > 0)
|
|
{
|
|
_nextConfigUpdateTs = ts + _intervalConfig * 1000;
|
|
updateConfig();
|
|
if(_hassEnabled && !_hassSetupCompleted)
|
|
{
|
|
setupHASS();
|
|
}
|
|
}
|
|
if(_hassEnabled && _configRead && _network->reconnected())
|
|
{
|
|
setupHASS();
|
|
}
|
|
if(_rssiPublishInterval > 0 && (_nextRssiTs == 0 || ts > _nextRssiTs))
|
|
{
|
|
_nextRssiTs = ts + _rssiPublishInterval;
|
|
|
|
int rssi = _nukiOpener.getRssi();
|
|
if(rssi != _lastRssi)
|
|
{
|
|
_network->publishRssi(rssi);
|
|
_lastRssi = rssi;
|
|
}
|
|
}
|
|
|
|
if(_hasKeypad && _keypadEnabled && (_nextKeypadUpdateTs == 0 || ts > _nextKeypadUpdateTs || (queryCommands & QUERY_COMMAND_KEYPAD) > 0))
|
|
{
|
|
_nextKeypadUpdateTs = ts + _intervalKeypad * 1000;
|
|
updateKeypad();
|
|
}
|
|
|
|
if(_nextLockAction != (NukiOpener::LockAction)0xff && ts > _nextRetryTs)
|
|
{
|
|
Nuki::CmdResult cmdResult = _nukiOpener.lockAction(_nextLockAction, 0, 0);
|
|
|
|
char resultStr[15] = {0};
|
|
NukiOpener::cmdResultToString(cmdResult, resultStr);
|
|
|
|
_network->publishCommandResult(resultStr);
|
|
|
|
Log->print(F("Lock action result: "));
|
|
Log->println(resultStr);
|
|
|
|
if(cmdResult == Nuki::CmdResult::Success)
|
|
{
|
|
_retryCount = 0;
|
|
_nextLockAction = (NukiOpener::LockAction) 0xff;
|
|
_network->publishRetry("--");
|
|
if(_intervalLockstate > 10)
|
|
{
|
|
_nextLockStateUpdateTs = ts + 10 * 1000;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if(_retryCount < _nrOfRetries)
|
|
{
|
|
Log->print(F("Opener: Last command failed, retrying after "));
|
|
Log->print(_retryDelay);
|
|
Log->print(F(" milliseconds. Retry "));
|
|
Log->print(_retryCount + 1);
|
|
Log->print(" of ");
|
|
Log->println(_nrOfRetries);
|
|
|
|
_network->publishRetry(std::to_string(_retryCount + 1));
|
|
|
|
_nextRetryTs = millis() + _retryDelay;
|
|
|
|
++_retryCount;
|
|
}
|
|
else
|
|
{
|
|
Log->println(F("Opener: Maximum number of retries exceeded, aborting."));
|
|
_network->publishRetry("failed");
|
|
_retryCount = 0;
|
|
_nextRetryTs = 0;
|
|
_nextLockAction = (NukiOpener::LockAction) 0xff;
|
|
}
|
|
}
|
|
postponeBleWatchdog();
|
|
}
|
|
|
|
if(_clearAuthData)
|
|
{
|
|
_network->clearAuthorizationInfo();
|
|
_clearAuthData = false;
|
|
}
|
|
|
|
memcpy(&_lastKeyTurnerState, &_keyTurnerState, sizeof(NukiOpener::OpenerState));
|
|
}
|
|
|
|
|
|
void NukiOpenerWrapper::electricStrikeActuation()
|
|
{
|
|
_nextLockAction = NukiOpener::LockAction::ElectricStrikeActuation;
|
|
}
|
|
|
|
void NukiOpenerWrapper::activateRTO()
|
|
{
|
|
_nextLockAction = NukiOpener::LockAction::ActivateRTO;
|
|
}
|
|
|
|
void NukiOpenerWrapper::activateCM()
|
|
{
|
|
_nextLockAction = NukiOpener::LockAction::ActivateCM;
|
|
}
|
|
|
|
void NukiOpenerWrapper::deactivateRtoCm()
|
|
{
|
|
if(_keyTurnerState.nukiState == NukiOpener::State::ContinuousMode)
|
|
{
|
|
_nextLockAction = NukiOpener::LockAction::DeactivateCM;
|
|
return;
|
|
}
|
|
|
|
if(_keyTurnerState.lockState == NukiOpener::LockState::RTOactive)
|
|
{
|
|
_nextLockAction = NukiOpener::LockAction::DeactivateRTO;
|
|
}
|
|
}
|
|
|
|
void NukiOpenerWrapper::deactivateRTO()
|
|
{
|
|
_nextLockAction = NukiOpener::LockAction::DeactivateRTO;
|
|
}
|
|
|
|
void NukiOpenerWrapper::deactivateCM()
|
|
{
|
|
_nextLockAction = NukiOpener::LockAction::DeactivateCM;
|
|
}
|
|
|
|
bool NukiOpenerWrapper::isPinSet()
|
|
{
|
|
return _nukiOpener.getSecurityPincode() != 0;
|
|
}
|
|
|
|
void NukiOpenerWrapper::setPin(const uint16_t pin)
|
|
{
|
|
_nukiOpener.saveSecurityPincode(pin);
|
|
}
|
|
|
|
void NukiOpenerWrapper::unpair()
|
|
{
|
|
_nukiOpener.unPairNuki();
|
|
_deviceId->assignNewId();
|
|
_preferences->remove(preference_nuki_id_opener);
|
|
_paired = false;
|
|
}
|
|
|
|
void NukiOpenerWrapper::updateKeyTurnerState()
|
|
{
|
|
Log->print(F("Querying opener state: "));
|
|
Nuki::CmdResult result =_nukiOpener.requestOpenerState(&_keyTurnerState);
|
|
|
|
char resultStr[15];
|
|
memset(&resultStr, 0, sizeof(resultStr));
|
|
NukiOpener::cmdResultToString(result, resultStr);
|
|
_network->publishLockstateCommandResult(resultStr);
|
|
|
|
if(result != Nuki::CmdResult::Success)
|
|
{
|
|
_retryLockstateCount++;
|
|
postponeBleWatchdog();
|
|
if(_retryLockstateCount < _nrOfRetries)
|
|
{
|
|
_nextLockStateUpdateTs = millis() + _retryDelay;
|
|
}
|
|
return;
|
|
}
|
|
_retryLockstateCount = 0;
|
|
|
|
if(_statusUpdated &&
|
|
_keyTurnerState.lockState == NukiOpener::LockState::Locked &&
|
|
_lastKeyTurnerState.lockState == NukiOpener::LockState::Locked &&
|
|
_lastKeyTurnerState.nukiState == _keyTurnerState.nukiState)
|
|
{
|
|
Log->println(F("Nuki opener: Ring detected (Locked)"));
|
|
_network->publishRing(true);
|
|
}
|
|
else
|
|
{
|
|
if(_keyTurnerState.lockState != _lastKeyTurnerState.lockState &&
|
|
_keyTurnerState.lockState == NukiOpener::LockState::Open &&
|
|
_keyTurnerState.trigger == NukiOpener::Trigger::Manual)
|
|
{
|
|
Log->println(F("Nuki opener: Ring detected (Open)"));
|
|
_network->publishRing(false);
|
|
}
|
|
|
|
_network->publishKeyTurnerState(_keyTurnerState, _lastKeyTurnerState);
|
|
updateGpioOutputs();
|
|
|
|
if(_keyTurnerState.nukiState == NukiOpener::State::ContinuousMode)
|
|
{
|
|
Log->println(F("Continuous Mode"));
|
|
}
|
|
|
|
char lockStateStr[20];
|
|
lockstateToString(_keyTurnerState.lockState, lockStateStr);
|
|
Log->println(lockStateStr);
|
|
}
|
|
|
|
if(_publishAuthData)
|
|
{
|
|
updateAuthData();
|
|
}
|
|
|
|
postponeBleWatchdog();
|
|
}
|
|
|
|
void NukiOpenerWrapper::updateBatteryState()
|
|
{
|
|
Log->print("Querying opener battery state: ");
|
|
Nuki::CmdResult result = _nukiOpener.requestBatteryReport(&_batteryReport);
|
|
printCommandResult(result);
|
|
if(result == Nuki::CmdResult::Success)
|
|
{
|
|
_network->publishBatteryReport(_batteryReport);
|
|
}
|
|
postponeBleWatchdog();
|
|
}
|
|
|
|
void NukiOpenerWrapper::updateConfig()
|
|
{
|
|
readConfig();
|
|
readAdvancedConfig();
|
|
_configRead = true;
|
|
bool expectedConfig = true;
|
|
|
|
if(_nukiConfigValid)
|
|
{
|
|
if(_preferences->getUInt(preference_nuki_id_opener, 0) == 0 || _retryConfigCount == 10)
|
|
{
|
|
_preferences->putUInt(preference_nuki_id_opener, _nukiConfig.nukiId);
|
|
}
|
|
|
|
if(_preferences->getUInt(preference_nuki_id_opener, 0) == _nukiConfig.nukiId)
|
|
{
|
|
_hasKeypad = _nukiConfig.hasKeypad > 0 || _nukiConfig.hasKeypadV2;
|
|
_firmwareVersion = std::to_string(_nukiConfig.firmwareVersion[0]) + "." + std::to_string(_nukiConfig.firmwareVersion[1]) + "." + std::to_string(_nukiConfig.firmwareVersion[2]);
|
|
_hardwareVersion = std::to_string(_nukiConfig.hardwareRevision[0]) + "." + std::to_string(_nukiConfig.hardwareRevision[1]);
|
|
_network->publishConfig(_nukiConfig);
|
|
_retryConfigCount = 0;
|
|
}
|
|
else
|
|
{
|
|
expectedConfig = false;
|
|
++_retryConfigCount;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
expectedConfig = false;
|
|
++_retryConfigCount;
|
|
}
|
|
if(_nukiAdvancedConfigValid && _preferences->getUInt(preference_nuki_id_opener, 0) == _nukiConfig.nukiId)
|
|
{
|
|
_network->publishAdvancedConfig(_nukiAdvancedConfig);
|
|
_retryConfigCount = 0;
|
|
}
|
|
else
|
|
{
|
|
expectedConfig = false;
|
|
++_retryConfigCount;
|
|
}
|
|
if(!expectedConfig && _retryConfigCount < 11)
|
|
{
|
|
unsigned long ts = millis();
|
|
_nextConfigUpdateTs = ts + 60000;
|
|
}
|
|
}
|
|
|
|
void NukiOpenerWrapper::updateAuthData()
|
|
{
|
|
if(_nukiOpener.getSecurityPincode() == 0) return;
|
|
|
|
Nuki::CmdResult result = _nukiOpener.retrieveLogEntries(0, 0, 0, true);
|
|
if(result != Nuki::CmdResult::Success)
|
|
{
|
|
return;
|
|
}
|
|
delay(100);
|
|
|
|
uint16_t count = _nukiOpener.getLogEntryCount();
|
|
|
|
result = _nukiOpener.retrieveLogEntries(0, count < 5 ? count : 5, 1, false);
|
|
if(result != Nuki::CmdResult::Success)
|
|
{
|
|
return;
|
|
}
|
|
delay(1000);
|
|
|
|
std::list<NukiOpener::LogEntry> log;
|
|
_nukiOpener.getLogEntries(&log);
|
|
|
|
if(log.size() > 0)
|
|
{
|
|
_network->publishAuthorizationInfo(log);
|
|
}
|
|
postponeBleWatchdog();
|
|
}
|
|
|
|
void NukiOpenerWrapper::updateKeypad()
|
|
{
|
|
if(_preferences->getBool(preference_keypad_info_enabled)) return;
|
|
|
|
Log->print(F("Querying opener keypad: "));
|
|
Nuki::CmdResult result = _nukiOpener.retrieveKeypadEntries(0, 0xffff);
|
|
printCommandResult(result);
|
|
if(result == Nuki::CmdResult::Success)
|
|
{
|
|
std::list<NukiLock::KeypadEntry> entries;
|
|
_nukiOpener.getKeypadEntries(&entries);
|
|
|
|
entries.sort([](const NukiLock::KeypadEntry& a, const NukiLock::KeypadEntry& b) { return a.codeId < b.codeId; });
|
|
|
|
uint keypadCount = entries.size();
|
|
if(keypadCount > _maxKeypadCodeCount)
|
|
{
|
|
_maxKeypadCodeCount = keypadCount;
|
|
_preferences->putUInt(preference_lock_max_keypad_code_count, _maxKeypadCodeCount);
|
|
}
|
|
|
|
_network->publishKeypad(entries, _maxKeypadCodeCount);
|
|
|
|
_keypadCodeIds.clear();
|
|
_keypadCodeIds.reserve(entries.size());
|
|
for(const auto& entry : entries)
|
|
{
|
|
_keypadCodeIds.push_back(entry.codeId);
|
|
}
|
|
}
|
|
|
|
postponeBleWatchdog();
|
|
}
|
|
|
|
void NukiOpenerWrapper::postponeBleWatchdog()
|
|
{
|
|
_disableBleWatchdogTs = millis() + 15000;
|
|
}
|
|
|
|
NukiOpener::LockAction NukiOpenerWrapper::lockActionToEnum(const char *str)
|
|
{
|
|
if(strcmp(str, "activateRTO") == 0) return NukiOpener::LockAction::ActivateRTO;
|
|
else if(strcmp(str, "deactivateRTO") == 0) return NukiOpener::LockAction::DeactivateRTO;
|
|
else if(strcmp(str, "electricStrikeActuation") == 0) return NukiOpener::LockAction::ElectricStrikeActuation;
|
|
else if(strcmp(str, "activateCM") == 0) return NukiOpener::LockAction::ActivateCM;
|
|
else if(strcmp(str, "deactivateCM") == 0) return NukiOpener::LockAction::DeactivateCM;
|
|
else if(strcmp(str, "fobAction2") == 0) return NukiOpener::LockAction::FobAction2;
|
|
else if(strcmp(str, "fobAction1") == 0) return NukiOpener::LockAction::FobAction1;
|
|
else if(strcmp(str, "fobAction3") == 0) return NukiOpener::LockAction::FobAction3;
|
|
return (NukiOpener::LockAction)0xff;
|
|
}
|
|
|
|
LockActionResult NukiOpenerWrapper::onLockActionReceivedCallback(const char *value)
|
|
{
|
|
NukiOpener::LockAction action = nukiOpenerInst->lockActionToEnum(value);
|
|
if((int)action == 0xff)
|
|
{
|
|
return LockActionResult::UnknownAction;
|
|
}
|
|
|
|
nukiOpenerPreferences = new Preferences();
|
|
nukiOpenerPreferences->begin("nukihub", true);
|
|
uint32_t aclPrefs[17];
|
|
nukiOpenerPreferences->getBytes(preference_acl, &aclPrefs, sizeof(aclPrefs));
|
|
|
|
if((action == NukiOpener::LockAction::ActivateRTO && (int)aclPrefs[9] == 1) || (action == NukiOpener::LockAction::DeactivateRTO && (int)aclPrefs[10] == 1) || (action == NukiOpener::LockAction::ElectricStrikeActuation && (int)aclPrefs[11] == 1) || (action == NukiOpener::LockAction::ActivateCM && (int)aclPrefs[12] == 1) || (action == NukiOpener::LockAction::DeactivateCM && (int)aclPrefs[13] == 1) || (action == NukiOpener::LockAction::FobAction1 && (int)aclPrefs[14] == 1) || (action == NukiOpener::LockAction::FobAction2 && (int)aclPrefs[15] == 1) || (action == NukiOpener::LockAction::FobAction3 && (int)aclPrefs[16] == 1))
|
|
{
|
|
nukiOpenerPreferences->end();
|
|
nukiOpenerInst->_nextLockAction = action;
|
|
return LockActionResult::Success;
|
|
}
|
|
|
|
nukiOpenerPreferences->end();
|
|
return LockActionResult::AccessDenied;
|
|
}
|
|
|
|
void NukiOpenerWrapper::onConfigUpdateReceivedCallback(const char *value)
|
|
{
|
|
nukiOpenerInst->onConfigUpdateReceived(value);
|
|
}
|
|
|
|
Nuki::AdvertisingMode NukiOpenerWrapper::advertisingModeToEnum(const char *str)
|
|
{
|
|
if(strcmp(str, "automatic") == 0) return Nuki::AdvertisingMode::Automatic;
|
|
else if(strcmp(str, "normal") == 0) return Nuki::AdvertisingMode::Normal;
|
|
else if(strcmp(str, "slow") == 0) return Nuki::AdvertisingMode::Slow;
|
|
else if(strcmp(str, "slowest") == 0) return Nuki::AdvertisingMode::Slowest;
|
|
return (Nuki::AdvertisingMode)0xff;
|
|
}
|
|
|
|
Nuki::TimeZoneId NukiOpenerWrapper::timeZoneToEnum(const char *str)
|
|
{
|
|
if(strcmp(str, "Africa/Cairo") == 0) return Nuki::TimeZoneId::Africa_Cairo;
|
|
else if(strcmp(str, "Africa/Lagos") == 0) return Nuki::TimeZoneId::Africa_Lagos;
|
|
else if(strcmp(str, "Africa/Maputo") == 0) return Nuki::TimeZoneId::Africa_Maputo;
|
|
else if(strcmp(str, "Africa/Nairobi") == 0) return Nuki::TimeZoneId::Africa_Nairobi;
|
|
else if(strcmp(str, "America/Anchorage") == 0) return Nuki::TimeZoneId::America_Anchorage;
|
|
else if(strcmp(str, "America/Argentina/Buenos_Aires") == 0) return Nuki::TimeZoneId::America_Argentina_Buenos_Aires;
|
|
else if(strcmp(str, "America/Chicago") == 0) return Nuki::TimeZoneId::America_Chicago;
|
|
else if(strcmp(str, "America/Denver") == 0) return Nuki::TimeZoneId::America_Denver;
|
|
else if(strcmp(str, "America/Halifax") == 0) return Nuki::TimeZoneId::America_Halifax;
|
|
else if(strcmp(str, "America/Los_Angeles") == 0) return Nuki::TimeZoneId::America_Los_Angeles;
|
|
else if(strcmp(str, "America/Manaus") == 0) return Nuki::TimeZoneId::America_Manaus;
|
|
else if(strcmp(str, "America/Mexico_City") == 0) return Nuki::TimeZoneId::America_Mexico_City;
|
|
else if(strcmp(str, "America/New_York") == 0) return Nuki::TimeZoneId::America_New_York;
|
|
else if(strcmp(str, "America/Phoenix") == 0) return Nuki::TimeZoneId::America_Phoenix;
|
|
else if(strcmp(str, "America/Regina") == 0) return Nuki::TimeZoneId::America_Regina;
|
|
else if(strcmp(str, "America/Santiago") == 0) return Nuki::TimeZoneId::America_Santiago;
|
|
else if(strcmp(str, "America/Sao_Paulo") == 0) return Nuki::TimeZoneId::America_Sao_Paulo;
|
|
else if(strcmp(str, "America/St_Johns") == 0) return Nuki::TimeZoneId::America_St_Johns;
|
|
else if(strcmp(str, "Asia/Bangkok") == 0) return Nuki::TimeZoneId::Asia_Bangkok;
|
|
else if(strcmp(str, "Asia/Dubai") == 0) return Nuki::TimeZoneId::Asia_Dubai;
|
|
else if(strcmp(str, "Asia/Hong_Kong") == 0) return Nuki::TimeZoneId::Asia_Hong_Kong;
|
|
else if(strcmp(str, "Asia/Jerusalem") == 0) return Nuki::TimeZoneId::Asia_Jerusalem;
|
|
else if(strcmp(str, "Asia/Karachi") == 0) return Nuki::TimeZoneId::Asia_Karachi;
|
|
else if(strcmp(str, "Asia/Kathmandu") == 0) return Nuki::TimeZoneId::Asia_Kathmandu;
|
|
else if(strcmp(str, "Asia/Kolkata") == 0) return Nuki::TimeZoneId::Asia_Kolkata;
|
|
else if(strcmp(str, "Asia/Riyadh") == 0) return Nuki::TimeZoneId::Asia_Riyadh;
|
|
else if(strcmp(str, "Asia/Seoul") == 0) return Nuki::TimeZoneId::Asia_Seoul;
|
|
else if(strcmp(str, "Asia/Shanghai") == 0) return Nuki::TimeZoneId::Asia_Shanghai;
|
|
else if(strcmp(str, "Asia/Tehran") == 0) return Nuki::TimeZoneId::Asia_Tehran;
|
|
else if(strcmp(str, "Asia/Tokyo") == 0) return Nuki::TimeZoneId::Asia_Tokyo;
|
|
else if(strcmp(str, "Asia/Yangon") == 0) return Nuki::TimeZoneId::Asia_Yangon;
|
|
else if(strcmp(str, "Australia/Adelaide") == 0) return Nuki::TimeZoneId::Australia_Adelaide;
|
|
else if(strcmp(str, "Australia/Brisbane") == 0) return Nuki::TimeZoneId::Australia_Brisbane;
|
|
else if(strcmp(str, "Australia/Darwin") == 0) return Nuki::TimeZoneId::Australia_Darwin;
|
|
else if(strcmp(str, "Australia/Hobart") == 0) return Nuki::TimeZoneId::Australia_Hobart;
|
|
else if(strcmp(str, "Australia/Perth") == 0) return Nuki::TimeZoneId::Australia_Perth;
|
|
else if(strcmp(str, "Australia/Sydney") == 0) return Nuki::TimeZoneId::Australia_Sydney;
|
|
else if(strcmp(str, "Europe/Berlin") == 0) return Nuki::TimeZoneId::Europe_Berlin;
|
|
else if(strcmp(str, "Europe/Helsinki") == 0) return Nuki::TimeZoneId::Europe_Helsinki;
|
|
else if(strcmp(str, "Europe/Istanbul") == 0) return Nuki::TimeZoneId::Europe_Istanbul;
|
|
else if(strcmp(str, "Europe/London") == 0) return Nuki::TimeZoneId::Europe_London;
|
|
else if(strcmp(str, "Europe/Moscow") == 0) return Nuki::TimeZoneId::Europe_Moscow;
|
|
else if(strcmp(str, "Pacific/Auckland") == 0) return Nuki::TimeZoneId::Pacific_Auckland;
|
|
else if(strcmp(str, "Pacific/Guam") == 0) return Nuki::TimeZoneId::Pacific_Guam;
|
|
else if(strcmp(str, "Pacific/Honolulu") == 0) return Nuki::TimeZoneId::Pacific_Honolulu;
|
|
else if(strcmp(str, "Pacific/Pago_Pago") == 0) return Nuki::TimeZoneId::Pacific_Pago_Pago;
|
|
else if(strcmp(str, "none") == 0) return Nuki::TimeZoneId::None;
|
|
return (Nuki::TimeZoneId)0xff;
|
|
}
|
|
|
|
uint8_t NukiOpenerWrapper::fobActionToInt(const char *str)
|
|
{
|
|
if(strcmp(str, "noaction") == 0) return 0;
|
|
else if(strcmp(str, "togglerto") == 0) return 1;
|
|
else if(strcmp(str, "activaterto") == 0) return 2;
|
|
else if(strcmp(str, "deactivaterto") == 0) return 3;
|
|
else if(strcmp(str, "open") == 0) return 7;
|
|
else if(strcmp(str, "ring") == 0) return 8;
|
|
return 99;
|
|
}
|
|
|
|
uint8_t NukiOpenerWrapper::operatingModeToInt(const char *str)
|
|
{
|
|
if(strcmp(str, "genericdooropener") == 0) return 0;
|
|
else if(strcmp(str, "analogueintercom") == 0) return 1;
|
|
else if(strcmp(str, "digitalintercom") == 0) return 2;
|
|
else if(strcmp(str, "siedle") == 0) return 3;
|
|
else if(strcmp(str, "tcs") == 0) return 4;
|
|
else if(strcmp(str, "bticino") == 0) return 5;
|
|
else if(strcmp(str, "siedlehts") == 0) return 6;
|
|
else if(strcmp(str, "str") == 0) return 7;
|
|
else if(strcmp(str, "ritto") == 0) return 8;
|
|
else if(strcmp(str, "fermax") == 0) return 9;
|
|
else if(strcmp(str, "comelit") == 0) return 10;
|
|
else if(strcmp(str, "urmetbibus") == 0) return 11;
|
|
else if(strcmp(str, "urmet2voice") == 0) return 12;
|
|
else if(strcmp(str, "golmar") == 0) return 13;
|
|
else if(strcmp(str, "sks") == 0) return 14;
|
|
else if(strcmp(str, "spare") == 0) return 15;
|
|
return 99;
|
|
}
|
|
|
|
NukiOpener::ButtonPressAction NukiOpenerWrapper::buttonPressActionToEnum(const char* str)
|
|
{
|
|
if(strcmp(str, "noaction") == 0) return NukiOpener::ButtonPressAction::NoAction;
|
|
else if(strcmp(str, "togglerto") == 0) return NukiOpener::ButtonPressAction::ToggleRTO;
|
|
else if(strcmp(str, "activaterto") == 0) return NukiOpener::ButtonPressAction::ActivateRTO;
|
|
else if(strcmp(str, "deactivaterto") == 0) return NukiOpener::ButtonPressAction::DeactivateRTO;
|
|
else if(strcmp(str, "togglecm") == 0) return NukiOpener::ButtonPressAction::ToggleCM;
|
|
else if(strcmp(str, "activatecm") == 0) return NukiOpener::ButtonPressAction::ActivateCM;
|
|
else if(strcmp(str, "deactivatecm") == 0) return NukiOpener::ButtonPressAction::DectivateCM;
|
|
else if(strcmp(str, "open") == 0) return NukiOpener::ButtonPressAction::Open;
|
|
return (NukiOpener::ButtonPressAction)0xff;
|
|
}
|
|
|
|
Nuki::BatteryType NukiOpenerWrapper::batteryTypeToEnum(const char* str)
|
|
{
|
|
if(strcmp(str, "alkali") == 0) return Nuki::BatteryType::Alkali;
|
|
else if(strcmp(str, "accumulators") == 0) return Nuki::BatteryType::Accumulators;
|
|
else if(strcmp(str, "lithium") == 0) return Nuki::BatteryType::Lithium;
|
|
return (Nuki::BatteryType)0xff;
|
|
}
|
|
|
|
void NukiOpenerWrapper::onConfigUpdateReceived(const char *value)
|
|
{
|
|
DynamicJsonDocument jsonResult(2048);
|
|
char _resbuf[2048];
|
|
|
|
DynamicJsonDocument json(2048);
|
|
DeserializationError jsonError = deserializeJson(json, value);
|
|
|
|
if(jsonError)
|
|
{
|
|
jsonResult["general"] = "invalidjson";
|
|
serializeJson(jsonResult, _resbuf, sizeof(_resbuf));
|
|
_network->publishConfigCommandResult(_resbuf);
|
|
return;
|
|
}
|
|
|
|
updateConfig();
|
|
|
|
if(!_nukiConfigValid || !_nukiAdvancedConfigValid)
|
|
{
|
|
jsonResult["general"] = "invalidconfig";
|
|
serializeJson(jsonResult, _resbuf, sizeof(_resbuf));
|
|
_network->publishConfigCommandResult(_resbuf);
|
|
return;
|
|
}
|
|
|
|
Nuki::CmdResult cmdResult;
|
|
const char *basicKeys[] = {"name", "latitude", "longitude", "pairingEnabled", "buttonEnabled", "ledFlashEnabled", "timeZoneOffset", "dstMode", "fobAction1", "fobAction2", "fobAction3", "operatingMode", "advertisingMode", "timeZone"};
|
|
const char *advancedKeys[] = {"intercomID", "busModeSwitch", "shortCircuitDaration", "electricStrikeDelay", "randomElectricStrikeDelay", "electricStrikeDuration", "disableRtoAfterRing", "rtoTimeout", "doorbellSuppression", "doorbellSuppressionDuration", "soundRing", "soundOpen", "soundRto", "soundCm", "soundConfirmation", "soundLevel", "singleButtonPressAction", "doubleButtonPressAction", "batteryType", "automaticBatteryTypeDetection"};
|
|
bool basicUpdated = false;
|
|
bool advancedUpdated = false;
|
|
uint32_t basicOpenerConfigAclPrefs[16];
|
|
uint32_t advancedOpenerConfigAclPrefs[20];
|
|
|
|
nukiOpenerPreferences = new Preferences();
|
|
nukiOpenerPreferences->begin("nukihub", true);
|
|
nukiOpenerPreferences->getBytes(preference_conf_opener_basic_acl, &basicOpenerConfigAclPrefs, sizeof(basicOpenerConfigAclPrefs));
|
|
nukiOpenerPreferences->getBytes(preference_conf_opener_advanced_acl, &advancedOpenerConfigAclPrefs, sizeof(advancedOpenerConfigAclPrefs));
|
|
|
|
for(int i=0; i < 16; i++)
|
|
{
|
|
if(json[basicKeys[i]])
|
|
{
|
|
if((int)basicOpenerConfigAclPrefs[i] == 1)
|
|
{
|
|
cmdResult = Nuki::CmdResult::Error;
|
|
|
|
if(strcmp(basicKeys[i], "name") == 0)
|
|
{
|
|
const char* keyvalue = json[basicKeys[i]];
|
|
|
|
if(strlen(keyvalue) <= 32)
|
|
{
|
|
if(strcmp((const char*)_nukiConfig.name, keyvalue) == 0) jsonResult[basicKeys[i]] = "unchanged";
|
|
else cmdResult = _nukiOpener.setName(std::string(keyvalue));
|
|
}
|
|
else jsonResult[basicKeys[i]] = "valuetoolong";
|
|
}
|
|
else if(strcmp(basicKeys[i], "latitude") == 0)
|
|
{
|
|
const float keyvalue = atof(json[basicKeys[i]]);
|
|
|
|
if(keyvalue > 0)
|
|
{
|
|
if(_nukiConfig.latitide == keyvalue) jsonResult[basicKeys[i]] = "unchanged";
|
|
else jsonResult[basicKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setLatitude(keyvalue);
|
|
}
|
|
else jsonResult[basicKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(basicKeys[i], "longitude") == 0)
|
|
{
|
|
const float keyvalue = atof(json[basicKeys[i]]);
|
|
|
|
if(keyvalue > 0)
|
|
{
|
|
if(_nukiConfig.longitude == keyvalue) jsonResult[basicKeys[i]] = "unchanged";
|
|
else jsonResult[basicKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setLongitude(keyvalue);
|
|
}
|
|
else jsonResult[basicKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(basicKeys[i], "pairingEnabled") == 0)
|
|
{
|
|
const uint8_t keyvalue = atoi(json[basicKeys[i]]);
|
|
|
|
if(keyvalue == 0 || keyvalue == 1)
|
|
{
|
|
if(_nukiConfig.pairingEnabled == keyvalue) jsonResult[basicKeys[i]] = "unchanged";
|
|
else cmdResult = _nukiOpener.enablePairing((keyvalue > 0));
|
|
}
|
|
else jsonResult[basicKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(basicKeys[i], "buttonEnabled") == 0)
|
|
{
|
|
const uint8_t keyvalue = atoi(json[basicKeys[i]]);
|
|
|
|
if(keyvalue == 0 || keyvalue == 1)
|
|
{
|
|
if(_nukiConfig.buttonEnabled == keyvalue) jsonResult[basicKeys[i]] = "unchanged";
|
|
else cmdResult = _nukiOpener.enableButton((keyvalue > 0));
|
|
}
|
|
else jsonResult[basicKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(basicKeys[i], "ledFlashEnabled") == 0)
|
|
{
|
|
const uint8_t keyvalue = atoi(json[basicKeys[i]]);
|
|
|
|
if(keyvalue == 0 || keyvalue == 1)
|
|
{
|
|
if(_nukiConfig.ledFlashEnabled == keyvalue) jsonResult[basicKeys[i]] = "unchanged";
|
|
else cmdResult = _nukiOpener.enableLedFlash((keyvalue > 0));
|
|
}
|
|
else jsonResult[basicKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(basicKeys[i], "timeZoneOffset") == 0)
|
|
{
|
|
const int16_t keyvalue = atoi(json[basicKeys[i]]);
|
|
|
|
if(keyvalue >= 0 && keyvalue <= 60)
|
|
{
|
|
if(_nukiConfig.timeZoneOffset == keyvalue) jsonResult[basicKeys[i]] = "unchanged";
|
|
else cmdResult = _nukiOpener.setTimeZoneOffset(keyvalue);
|
|
}
|
|
else jsonResult[basicKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(basicKeys[i], "dstMode") == 0)
|
|
{
|
|
const uint8_t keyvalue = atoi(json[basicKeys[i]]);
|
|
|
|
if(keyvalue == 0 || keyvalue == 1)
|
|
{
|
|
if(_nukiConfig.dstMode == keyvalue) jsonResult[basicKeys[i]] = "unchanged";
|
|
else cmdResult = _nukiOpener.enableDst((keyvalue > 0));
|
|
}
|
|
else jsonResult[basicKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(basicKeys[i], "fobAction1") == 0)
|
|
{
|
|
const uint8_t fobAct1 = nukiOpenerInst->fobActionToInt(json[basicKeys[i]]);
|
|
|
|
if(fobAct1 != 99)
|
|
{
|
|
if(_nukiConfig.fobAction1 == fobAct1) jsonResult[basicKeys[i]] = "unchanged";
|
|
else jsonResult[basicKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setFobAction(1, fobAct1);
|
|
}
|
|
else jsonResult[basicKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(basicKeys[i], "fobAction2") == 0)
|
|
{
|
|
const uint8_t fobAct2 = nukiOpenerInst->fobActionToInt(json[basicKeys[i]]);
|
|
|
|
if(fobAct2 != 99)
|
|
{
|
|
if(_nukiConfig.fobAction2 == fobAct2) jsonResult[basicKeys[i]] = "unchanged";
|
|
else jsonResult[basicKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setFobAction(2, fobAct2);
|
|
}
|
|
else jsonResult[basicKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(basicKeys[i], "fobAction3") == 0)
|
|
{
|
|
const uint8_t fobAct3 = nukiOpenerInst->fobActionToInt(json[basicKeys[i]]);
|
|
|
|
if(fobAct3 != 99)
|
|
{
|
|
if(_nukiConfig.fobAction3 == fobAct3) jsonResult[basicKeys[i]] = "unchanged";
|
|
else jsonResult[basicKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setFobAction(3, fobAct3);
|
|
}
|
|
else jsonResult[basicKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(basicKeys[i], "operatingMode") == 0)
|
|
{
|
|
const uint8_t opmode = nukiOpenerInst->operatingModeToInt(json[basicKeys[i]]);
|
|
|
|
if(opmode != 99)
|
|
{
|
|
if(_nukiConfig.operatingMode == opmode) jsonResult[basicKeys[i]] = "unchanged";
|
|
else jsonResult[basicKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setOperatingMode(opmode);
|
|
}
|
|
else jsonResult[basicKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(basicKeys[i], "advertisingMode") == 0)
|
|
{
|
|
Nuki::AdvertisingMode advmode = nukiOpenerInst->advertisingModeToEnum(json[basicKeys[i]]);
|
|
|
|
if(!(int)advmode == 0xff)
|
|
{
|
|
if(_nukiConfig.advertisingMode == advmode) jsonResult[basicKeys[i]] = "unchanged";
|
|
else cmdResult = _nukiOpener.setAdvertisingMode(advmode);
|
|
}
|
|
else jsonResult[basicKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(basicKeys[i], "timeZone") == 0)
|
|
{
|
|
Nuki::TimeZoneId tzid = nukiOpenerInst->timeZoneToEnum(json[basicKeys[i]]);
|
|
|
|
if(!(int)tzid == 0xff)
|
|
{
|
|
if(_nukiConfig.timeZoneId == tzid) jsonResult[basicKeys[i]] = "unchanged";
|
|
else cmdResult = _nukiOpener.setTimeZoneId(tzid);
|
|
}
|
|
else jsonResult[basicKeys[i]] = "invalidvalue";
|
|
}
|
|
|
|
if(cmdResult == Nuki::CmdResult::Success) basicUpdated = true;
|
|
|
|
if(!jsonResult[basicKeys[i]]) {
|
|
char resultStr[15] = {0};
|
|
NukiOpener::cmdResultToString(cmdResult, resultStr);
|
|
jsonResult[basicKeys[i]] = resultStr;
|
|
}
|
|
}
|
|
else jsonResult[basicKeys[i]] = "accessdenied";
|
|
}
|
|
}
|
|
|
|
for(int i=0; i < 20; i++)
|
|
{
|
|
if(json[advancedKeys[i]])
|
|
{
|
|
if((int)advancedOpenerConfigAclPrefs[i] == 1)
|
|
{
|
|
cmdResult = Nuki::CmdResult::Error;
|
|
|
|
if(strcmp(advancedKeys[i], "intercomID") == 0)
|
|
{
|
|
const uint16_t keyvalue = atoi(json[advancedKeys[i]]);
|
|
|
|
if(keyvalue >= 0)
|
|
{
|
|
if(_nukiAdvancedConfig.intercomID == keyvalue) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else jsonResult[advancedKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setIntercomID(keyvalue);
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "busModeSwitch") == 0)
|
|
{
|
|
const uint8_t keyvalue = atoi(json[advancedKeys[i]]);
|
|
|
|
if(keyvalue == 0 || keyvalue == 1)
|
|
{
|
|
if(_nukiAdvancedConfig.busModeSwitch == keyvalue) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else jsonResult[advancedKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setBusModeSwitch((keyvalue > 0));
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "shortCircuitDaration") == 0)
|
|
{
|
|
const uint16_t keyvalue = atoi(json[advancedKeys[i]]);
|
|
|
|
if(keyvalue >= 0)
|
|
{
|
|
if(_nukiAdvancedConfig.shortCircuitDaration == keyvalue) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else jsonResult[advancedKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setShortCircuitDaration(keyvalue);
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "electricStrikeDelay") == 0)
|
|
{
|
|
const uint16_t keyvalue = atoi(json[advancedKeys[i]]);
|
|
|
|
if(keyvalue >= 0 && keyvalue <= 30000)
|
|
{
|
|
if(_nukiAdvancedConfig.electricStrikeDelay == keyvalue) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else jsonResult[advancedKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setElectricStrikeDelay(keyvalue);
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "randomElectricStrikeDelay") == 0)
|
|
{
|
|
const uint8_t keyvalue = atoi(json[advancedKeys[i]]);
|
|
|
|
if(keyvalue == 0 || keyvalue == 1)
|
|
{
|
|
if(_nukiAdvancedConfig.randomElectricStrikeDelay == keyvalue) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else jsonResult[advancedKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.enableRandomElectricStrikeDelay((keyvalue > 0));
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "electricStrikeDuration") == 0)
|
|
{
|
|
const uint16_t keyvalue = atoi(json[advancedKeys[i]]);
|
|
|
|
if(keyvalue >= 1000 && keyvalue <= 30000)
|
|
{
|
|
if(_nukiAdvancedConfig.electricStrikeDuration == keyvalue) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else jsonResult[advancedKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setElectricStrikeDuration(keyvalue);
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "disableRtoAfterRing") == 0)
|
|
{
|
|
const uint8_t keyvalue = atoi(json[advancedKeys[i]]);
|
|
|
|
if(keyvalue == 0 || keyvalue == 1)
|
|
{
|
|
if(_nukiAdvancedConfig.disableRtoAfterRing == keyvalue) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else jsonResult[advancedKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.disableRtoAfterRing((keyvalue > 0));
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "rtoTimeout") == 0)
|
|
{
|
|
const uint8_t keyvalue = atoi(json[advancedKeys[i]]);
|
|
|
|
if(keyvalue >= 5 && keyvalue <= 60)
|
|
{
|
|
if(_nukiAdvancedConfig.rtoTimeout == keyvalue) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else jsonResult[advancedKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setRtoTimeout(keyvalue);
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "doorbellSuppression") == 0)
|
|
{
|
|
const uint8_t keyvalue = atoi(json[advancedKeys[i]]);
|
|
|
|
if(keyvalue >= 0)
|
|
{
|
|
if(_nukiAdvancedConfig.doorbellSuppression == keyvalue) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else jsonResult[advancedKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setDoorbellSuppression(keyvalue);
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "doorbellSuppressionDuration") == 0)
|
|
{
|
|
const uint16_t keyvalue = atoi(json[advancedKeys[i]]);
|
|
|
|
if(keyvalue >= 500 && keyvalue <= 10000)
|
|
{
|
|
if(_nukiAdvancedConfig.doorbellSuppressionDuration == keyvalue) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else jsonResult[advancedKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setDoorbellSuppressionDuration(keyvalue);
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "soundRing") == 0)
|
|
{
|
|
const uint8_t keyvalue = atoi(json[advancedKeys[i]]);
|
|
|
|
if(keyvalue >= 0 && keyvalue <= 3)
|
|
{
|
|
if(_nukiAdvancedConfig.soundRing == keyvalue) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else jsonResult[advancedKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setSoundRing(keyvalue);
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "soundOpen") == 0)
|
|
{
|
|
const uint8_t keyvalue = atoi(json[advancedKeys[i]]);
|
|
|
|
if(keyvalue >= 0 && keyvalue <= 3)
|
|
{
|
|
if(_nukiAdvancedConfig.soundOpen == keyvalue) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else jsonResult[advancedKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setSoundOpen(keyvalue);
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "soundRto") == 0)
|
|
{
|
|
const uint8_t keyvalue = atoi(json[advancedKeys[i]]);
|
|
|
|
if(keyvalue >= 0 && keyvalue <= 3)
|
|
{
|
|
if(_nukiAdvancedConfig.soundRto == keyvalue) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else jsonResult[advancedKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setSoundRto(keyvalue);
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "soundCm") == 0)
|
|
{
|
|
const uint8_t keyvalue = atoi(json[advancedKeys[i]]);
|
|
|
|
if(keyvalue >= 0 && keyvalue <= 3)
|
|
{
|
|
if(_nukiAdvancedConfig.soundCm == keyvalue) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else jsonResult[advancedKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.setSoundCm(keyvalue);
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "soundConfirmation") == 0)
|
|
{
|
|
const uint8_t keyvalue = atoi(json[advancedKeys[i]]);
|
|
|
|
if(keyvalue == 0 || keyvalue == 1)
|
|
{
|
|
if(_nukiAdvancedConfig.soundConfirmation == keyvalue) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else jsonResult[advancedKeys[i]] = "notimplemented"; //cmdResult = _nukiOpener.enableSoundConfirmation((keyvalue > 0));
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "soundLevel") == 0)
|
|
{
|
|
const uint8_t keyvalue = atoi(json[basicKeys[i]]);
|
|
|
|
if(keyvalue >= 0 && keyvalue <= 5)
|
|
{
|
|
if(_nukiAdvancedConfig.soundLevel == keyvalue) jsonResult[basicKeys[i]] = "unchanged";
|
|
else cmdResult = _nukiOpener.setSoundLevel(keyvalue);
|
|
}
|
|
else jsonResult[basicKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "singleButtonPressAction") == 0)
|
|
{
|
|
NukiOpener::ButtonPressAction sbpa = nukiOpenerInst->buttonPressActionToEnum(json[advancedKeys[i]]);
|
|
|
|
if(!(int)sbpa == 0xff)
|
|
{
|
|
if(_nukiAdvancedConfig.singleButtonPressAction == sbpa) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else cmdResult = _nukiOpener.setSingleButtonPressAction(sbpa);
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "doubleButtonPressAction") == 0)
|
|
{
|
|
NukiOpener::ButtonPressAction dbpa = nukiOpenerInst->buttonPressActionToEnum(json[advancedKeys[i]]);
|
|
|
|
if(!(int)dbpa == 0xff)
|
|
{
|
|
if(_nukiAdvancedConfig.doubleButtonPressAction == dbpa) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else cmdResult = _nukiOpener.setDoubleButtonPressAction(dbpa);
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "batteryType") == 0)
|
|
{
|
|
Nuki::BatteryType battype = nukiOpenerInst->batteryTypeToEnum(json[advancedKeys[i]]);
|
|
|
|
if(!(int)battype == 0xff)
|
|
{
|
|
if(_nukiAdvancedConfig.batteryType == battype) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else cmdResult = _nukiOpener.setBatteryType(battype);
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
else if(strcmp(advancedKeys[i], "automaticBatteryTypeDetection") == 0)
|
|
{
|
|
const uint8_t keyvalue = atoi(json[advancedKeys[i]]);
|
|
|
|
if(keyvalue == 0 || keyvalue == 1)
|
|
{
|
|
if(_nukiAdvancedConfig.automaticBatteryTypeDetection == keyvalue) jsonResult[advancedKeys[i]] = "unchanged";
|
|
else cmdResult = _nukiOpener.enableAutoBatteryTypeDetection((keyvalue > 0));
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "invalidvalue";
|
|
}
|
|
|
|
if(cmdResult == Nuki::CmdResult::Success) advancedUpdated = true;
|
|
|
|
if(!jsonResult[advancedKeys[i]]) {
|
|
char resultStr[15] = {0};
|
|
NukiOpener::cmdResultToString(cmdResult, resultStr);
|
|
jsonResult[advancedKeys[i]] = resultStr;
|
|
}
|
|
}
|
|
else jsonResult[advancedKeys[i]] = "accessdenied";
|
|
}
|
|
}
|
|
|
|
nukiOpenerPreferences->end();
|
|
|
|
if(basicUpdated || advancedUpdated)
|
|
{
|
|
_nextConfigUpdateTs = millis() + 300;
|
|
jsonResult["general"] = "success";
|
|
}
|
|
else jsonResult["general"] = "nochange";
|
|
|
|
serializeJson(jsonResult, _resbuf, sizeof(_resbuf));
|
|
_network->publishConfigCommandResult(_resbuf);
|
|
|
|
return;
|
|
}
|
|
|
|
void NukiOpenerWrapper::onKeypadCommandReceivedCallback(const char *command, const uint &id, const String &name, const String &code, const int& enabled)
|
|
{
|
|
nukiOpenerInst->onKeypadCommandReceived(command, id, name, code, enabled);
|
|
}
|
|
|
|
void NukiOpenerWrapper::gpioActionCallback(const GpioAction &action, const int& pin)
|
|
{
|
|
switch(action)
|
|
{
|
|
case GpioAction::ElectricStrikeActuation:
|
|
nukiOpenerInst->electricStrikeActuation();
|
|
break;
|
|
case GpioAction::ActivateRTO:
|
|
nukiOpenerInst->activateRTO();
|
|
break;
|
|
case GpioAction::ActivateCM:
|
|
nukiOpenerInst->activateCM();
|
|
break;
|
|
case GpioAction::DeactivateRtoCm:
|
|
nukiOpenerInst->deactivateRtoCm();
|
|
break;
|
|
case GpioAction::DeactivateRTO:
|
|
nukiOpenerInst->deactivateRTO();
|
|
break;
|
|
case GpioAction::DeactivateCM:
|
|
nukiOpenerInst->deactivateCM();
|
|
break;
|
|
}
|
|
}
|
|
|
|
void NukiOpenerWrapper::onKeypadCommandReceived(const char *command, const uint &id, const String &name, const String &code, const int& enabled)
|
|
{
|
|
if(!_preferences->getBool(preference_keypad_control_enabled))
|
|
{
|
|
_network->publishKeypadCommandResult("KeypadControlDisabled");
|
|
return;
|
|
}
|
|
|
|
if(!_hasKeypad)
|
|
{
|
|
if(_configRead)
|
|
{
|
|
_network->publishKeypadCommandResult("KeypadNotAvailable");
|
|
}
|
|
return;
|
|
}
|
|
if(!_keypadEnabled)
|
|
{
|
|
return;
|
|
}
|
|
|
|
bool idExists = std::find(_keypadCodeIds.begin(), _keypadCodeIds.end(), id) != _keypadCodeIds.end();
|
|
int codeInt = code.toInt();
|
|
bool codeValid = codeInt > 100000 && codeInt < 1000000 && (code.indexOf('0') == -1);
|
|
NukiLock::CmdResult result = (NukiLock::CmdResult)-1;
|
|
|
|
if(strcmp(command, "add") == 0)
|
|
{
|
|
if(name == "" || name == "--")
|
|
{
|
|
_network->publishKeypadCommandResult("MissingParameterName");
|
|
return;
|
|
}
|
|
if(codeInt == 0)
|
|
{
|
|
_network->publishKeypadCommandResult("MissingParameterCode");
|
|
return;
|
|
}
|
|
if(!codeValid)
|
|
{
|
|
_network->publishKeypadCommandResult("CodeInvalid");
|
|
return;
|
|
}
|
|
|
|
NukiLock::NewKeypadEntry entry;
|
|
memset(&entry, 0, sizeof(entry));
|
|
size_t nameLen = name.length();
|
|
memcpy(&entry.name, name.c_str(), nameLen > 20 ? 20 : nameLen);
|
|
entry.code = codeInt;
|
|
result = _nukiOpener.addKeypadEntry(entry);
|
|
Log->print("Add keypad code: "); Log->println((int)result);
|
|
updateKeypad();
|
|
}
|
|
else if(strcmp(command, "delete") == 0)
|
|
{
|
|
if(!idExists)
|
|
{
|
|
_network->publishKeypadCommandResult("UnknownId");
|
|
return;
|
|
}
|
|
result = _nukiOpener.deleteKeypadEntry(id);
|
|
Log->print("Delete keypad code: "); Log->println((int)result);
|
|
updateKeypad();
|
|
}
|
|
else if(strcmp(command, "update") == 0)
|
|
{
|
|
if(name == "" || name == "--")
|
|
{
|
|
_network->publishKeypadCommandResult("MissingParameterName");
|
|
return;
|
|
}
|
|
if(codeInt == 0)
|
|
{
|
|
_network->publishKeypadCommandResult("MissingParameterCode");
|
|
return;
|
|
}
|
|
if(!codeValid)
|
|
{
|
|
_network->publishKeypadCommandResult("CodeInvalid");
|
|
return;
|
|
}
|
|
if(!idExists)
|
|
{
|
|
_network->publishKeypadCommandResult("UnknownId");
|
|
return;
|
|
}
|
|
|
|
NukiLock::UpdatedKeypadEntry entry;
|
|
memset(&entry, 0, sizeof(entry));
|
|
entry.codeId = id;
|
|
size_t nameLen = name.length();
|
|
memcpy(&entry.name, name.c_str(), nameLen > 20 ? 20 : nameLen);
|
|
entry.code = codeInt;
|
|
entry.enabled = enabled == 0 ? 0 : 1;
|
|
result = _nukiOpener.updateKeypadEntry(entry);
|
|
Log->print("Update keypad code: "); Log->println((int)result);
|
|
updateKeypad();
|
|
}
|
|
else if(command == "--")
|
|
{
|
|
return;
|
|
}
|
|
else
|
|
{
|
|
_network->publishKeypadCommandResult("UnknownCommand");
|
|
return;
|
|
}
|
|
|
|
if((int)result != -1)
|
|
{
|
|
char resultStr[15];
|
|
memset(&resultStr, 0, sizeof(resultStr));
|
|
NukiOpener::cmdResultToString(result, resultStr);
|
|
_network->publishKeypadCommandResult(resultStr);
|
|
}
|
|
}
|
|
|
|
const NukiOpener::OpenerState &NukiOpenerWrapper::keyTurnerState()
|
|
{
|
|
return _keyTurnerState;
|
|
}
|
|
|
|
const bool NukiOpenerWrapper::isPaired() const
|
|
{
|
|
return _paired;
|
|
}
|
|
|
|
const bool NukiOpenerWrapper::hasKeypad() const
|
|
{
|
|
return _hasKeypad;
|
|
}
|
|
|
|
const BLEAddress NukiOpenerWrapper::getBleAddress() const
|
|
{
|
|
return _nukiOpener.getBleAddress();
|
|
}
|
|
|
|
BleScanner::Scanner *NukiOpenerWrapper::bleScanner()
|
|
{
|
|
return _bleScanner;
|
|
}
|
|
|
|
void NukiOpenerWrapper::notify(Nuki::EventType eventType)
|
|
{
|
|
if(eventType == Nuki::EventType::KeyTurnerStatusUpdated)
|
|
{
|
|
_statusUpdated = true;
|
|
}
|
|
}
|
|
|
|
void NukiOpenerWrapper::readConfig()
|
|
{
|
|
Log->print(F("Reading opener config. Result: "));
|
|
Nuki::CmdResult result = _nukiOpener.requestConfig(&_nukiConfig);
|
|
_nukiConfigValid = result == Nuki::CmdResult::Success;
|
|
char resultStr[20];
|
|
NukiOpener::cmdResultToString(result, resultStr);
|
|
Log->println(resultStr);
|
|
postponeBleWatchdog();
|
|
}
|
|
|
|
void NukiOpenerWrapper::readAdvancedConfig()
|
|
{
|
|
Log->print(F("Reading opener advanced config. Result: "));
|
|
Nuki::CmdResult result = _nukiOpener.requestAdvancedConfig(&_nukiAdvancedConfig);
|
|
_nukiAdvancedConfigValid = result == Nuki::CmdResult::Success;
|
|
char resultStr[20];
|
|
NukiOpener::cmdResultToString(result, resultStr);
|
|
Log->println(resultStr);
|
|
postponeBleWatchdog();
|
|
}
|
|
|
|
void NukiOpenerWrapper::setupHASS()
|
|
{
|
|
if(!_nukiConfigValid) return;
|
|
if(_preferences->getUInt(preference_nuki_id_opener, 0) != _nukiConfig.nukiId) return;
|
|
|
|
String baseTopic = _preferences->getString(preference_mqtt_opener_path);
|
|
char uidString[20];
|
|
itoa(_nukiConfig.nukiId, uidString, 16);
|
|
|
|
if(_preferences->getBool(preference_opener_continuous_mode))
|
|
{
|
|
_network->publishHASSConfig("Opener", baseTopic.c_str(), (char*)_nukiConfig.name, uidString, "deactivateCM", "activateCM", "electricStrikeActuation");
|
|
}
|
|
else
|
|
{
|
|
_network->publishHASSConfig("Opener", baseTopic.c_str(), (char*)_nukiConfig.name, uidString, "deactivateRTO", "activateRTO", "electricStrikeActuation");
|
|
}
|
|
|
|
_hassSetupCompleted = true;
|
|
|
|
Log->println("HASS setup for opener completed.");
|
|
}
|
|
|
|
void NukiOpenerWrapper::disableHASS()
|
|
{
|
|
if(!_nukiConfigValid) // only ask for config once to save battery life
|
|
{
|
|
Nuki::CmdResult result = _nukiOpener.requestConfig(&_nukiConfig);
|
|
_nukiConfigValid = result == Nuki::CmdResult::Success;
|
|
}
|
|
if(_nukiConfigValid)
|
|
{
|
|
char uidString[20];
|
|
itoa(_nukiConfig.nukiId, uidString, 16);
|
|
_network->removeHASSConfig(uidString);
|
|
}
|
|
else
|
|
{
|
|
Log->println(F("Unable to disable HASS. Invalid config received."));
|
|
}
|
|
}
|
|
|
|
void NukiOpenerWrapper::printCommandResult(Nuki::CmdResult result)
|
|
{
|
|
char resultStr[15];
|
|
NukiOpener::cmdResultToString(result, resultStr);
|
|
Log->println(resultStr);
|
|
}
|
|
|
|
std::string NukiOpenerWrapper::firmwareVersion() const
|
|
{
|
|
return _firmwareVersion;
|
|
}
|
|
|
|
std::string NukiOpenerWrapper::hardwareVersion() const
|
|
{
|
|
return _hardwareVersion;
|
|
}
|
|
|
|
void NukiOpenerWrapper::disableWatchdog()
|
|
{
|
|
_restartBeaconTimeout = -1;
|
|
}
|
|
|
|
void NukiOpenerWrapper::updateGpioOutputs()
|
|
{
|
|
using namespace NukiOpener;
|
|
|
|
const auto& pinConfiguration = _gpio->pinConfiguration();
|
|
|
|
const LockState& lockState = _keyTurnerState.lockState;
|
|
|
|
bool rtoActive = _keyTurnerState.lockState == LockState::RTOactive;
|
|
bool cmActive = _keyTurnerState.nukiState == State::ContinuousMode;
|
|
|
|
for(const auto& entry : pinConfiguration)
|
|
{
|
|
switch(entry.role)
|
|
{
|
|
case PinRole::OutputHighRtoActive:
|
|
_gpio->setPinOutput(entry.pin, rtoActive ? HIGH : LOW);
|
|
break;
|
|
case PinRole::OutputHighCmActive:
|
|
_gpio->setPinOutput(entry.pin, cmActive ? HIGH : LOW);
|
|
break;
|
|
case PinRole::OutputHighRtoOrCmActive:
|
|
_gpio->setPinOutput(entry.pin, rtoActive || cmActive ? HIGH : LOW);
|
|
break;
|
|
}
|
|
}
|
|
} |