#include "NukiOpenerWrapper.h" #include #include "PreferencesKeys.h" #include "MqttTopics.h" #include "Logger.h" #include "RestartReason.h" #include 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 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 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, "No Action") == 0) return 0; else if(strcmp(str, "Toggle RTO") == 0) return 1; else if(strcmp(str, "Activate RTO") == 0) return 2; else if(strcmp(str, "Deactivate RTO") == 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, "Generic door opener") == 0) return 0; else if(strcmp(str, "Analogue intercom") == 0) return 1; else if(strcmp(str, "Digital intercom") == 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, "Siedle HTS") == 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, "Urmet BiBus") == 0) return 11; else if(strcmp(str, "Urmet 2Voice") == 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; } uint8_t NukiOpenerWrapper::doorbellSuppressionToInt(const char *str) { if(strcmp(str, "Off") == 0) return 0; else if(strcmp(str, "CM") == 0) return 1; else if(strcmp(str, "RTO") == 0) return 2; else if(strcmp(str, "CM & RTO") == 0) return 3; else if(strcmp(str, "Ring") == 0) return 4; else if(strcmp(str, "CM & Ring") == 0) return 5; else if(strcmp(str, "RTO & Ring") == 0) return 6; else if(strcmp(str, "CM & RTO & Ring") == 0) return 7; return 99; } NukiOpener::ButtonPressAction NukiOpenerWrapper::buttonPressActionToEnum(const char* str) { if(strcmp(str, "No Action") == 0) return NukiOpener::ButtonPressAction::NoAction; else if(strcmp(str, "Toggle RTO") == 0) return NukiOpener::ButtonPressAction::ToggleRTO; else if(strcmp(str, "Activate RTO") == 0) return NukiOpener::ButtonPressAction::ActivateRTO; else if(strcmp(str, "Deactivate RTO") == 0) return NukiOpener::ButtonPressAction::DeactivateRTO; else if(strcmp(str, "Toggle CM") == 0) return NukiOpener::ButtonPressAction::ToggleCM; else if(strcmp(str, "Activate CM") == 0) return NukiOpener::ButtonPressAction::ActivateCM; else if(strcmp(str, "Deactivate CM") == 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", "shortCircuitDuration", "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.latitude == keyvalue) jsonResult[basicKeys[i]] = "unchanged"; else 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 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 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 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 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 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 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 cmdResult = _nukiOpener.setBusModeSwitch((keyvalue > 0)); } else jsonResult[advancedKeys[i]] = "invalidvalue"; } else if(strcmp(advancedKeys[i], "shortCircuitDuration") == 0) { const uint16_t keyvalue = atoi(json[advancedKeys[i]]); if(keyvalue >= 0) { if(_nukiAdvancedConfig.shortCircuitDuration == keyvalue) jsonResult[advancedKeys[i]] = "unchanged"; else cmdResult = _nukiOpener.setShortCircuitDuration(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 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 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 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 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 cmdResult = _nukiOpener.setRtoTimeout(keyvalue); } else jsonResult[advancedKeys[i]] = "invalidvalue"; } else if(strcmp(advancedKeys[i], "doorbellSuppression") == 0) { const uint8_t dbsupr = nukiOpenerInst->doorbellSuppressionToInt(json[advancedKeys[i]]); if(dbsupr != 99) { if(_nukiAdvancedConfig.doorbellSuppression == dbsupr) jsonResult[advancedKeys[i]] = "unchanged"; else cmdResult = _nukiOpener.setDoorbellSuppression(dbsupr); } else jsonResult[basicKeys[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 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 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 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 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 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 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; } } }