SuplaDevice.h

/*
 Copyright (C) AC SOFTWARE SP. Z O.O.
 
 This program is free software; you can redistribute it and/or
 modify it under the terms of the GNU General Public License
 as published by the Free Software Foundation; either version 2
 of the License, or (at your option) any later version.
 This program is distributed in the hope that it will be useful,
 but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 You should have received a copy of the GNU General Public License
 along with this program; if not, write to the Free Software
 Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
*/
 
#ifndef SRC_SUPLADEVICE_H_
#define SRC_SUPLADEVICE_H_
 
#include <supla-common/log.h>
#include <supla-common/proto.h>
#include <supla/action_handler.h>
#include <supla/device/device_mode.h>
#include <supla/local_action.h>
#include <supla/suplet/config.h>
#if SUPLA_SUPLET_ENABLED
#include <supla/suplet/definition_cache.h>
#include <supla/suplet/storage.h>
#endif
#include <supla/uptime.h>
 
#include "supla/device/security_logger.h"
 
#define STATUS_UNKNOWN                   -1
#define STATUS_ALREADY_INITIALIZED       1
#define STATUS_MISSING_NETWORK_INTERFACE 2
#define STATUS_UNKNOWN_SERVER_ADDRESS    3
#define STATUS_UNKNOWN_LOCATION_ID       4
#define STATUS_INITIALIZED               5
#define STATUS_SERVER_DISCONNECTED       6
#define STATUS_ITERATE_FAIL              7
#define STATUS_NETWORK_DISCONNECTED      8
#define STATUS_ALL_PROTOCOLS_DISABLED    9
 
#define STATUS_REGISTER_IN_PROGRESS 10  // Don't change
#define STATUS_REGISTERED_AND_READY 17  // Don't change
 
#define STATUS_TEMPORARILY_UNAVAILABLE 21
#define STATUS_INVALID_GUID            22
#define STATUS_CHANNEL_LIMIT_EXCEEDED  23
#define STATUS_PROTOCOL_VERSION_ERROR  24
#define STATUS_BAD_CREDENTIALS         25
#define STATUS_LOCATION_CONFLICT       26
#define STATUS_CHANNEL_CONFLICT        27
#define STATUS_DEVICE_IS_DISABLED      28
#define STATUS_LOCATION_IS_DISABLED    29
#define STATUS_DEVICE_LIMIT_EXCEEDED   30
#define STATUS_REGISTRATION_DISABLED   31
#define STATUS_MISSING_CREDENTIALS     32
#define STATUS_INVALID_AUTHKEY         33
#define STATUS_NO_LOCATION_AVAILABLE   34
#define STATUS_UNKNOWN_ERROR           35
#define STATUS_COUNTRY_REJECTED        36
 
#define STATUS_CONFIG_MODE              40
#define STATUS_SOFTWARE_RESET           41
#define STATUS_SW_DOWNLOAD              50
#define STATUS_SUPLA_PROTOCOL_DISABLED  60
#define STATUS_TEST_WAIT_FOR_CFG_BUTTON 70
#define STATUS_OFFLINE_MODE             80
#define STATUS_NOT_CONFIGURED_MODE      90
 
typedef void (*_impl_arduino_status)(int status, const char *msg);
 
#ifdef ARDUINO
class __FlashStringHelper;
#else
#define __FlashStringHelper char
#endif
 
namespace Supla {
class Clock;
class Mutex;
class Element;
 
// 10 days
constexpr uint32_t AutomaticOtaCheckInterval = (10ULL * 24 * 60 * 60 * 1000);
 
enum class SwUpdateMode : uint8_t {
  NotSet,
  PeriodicCheckAndUpdate,
  OnlyCheck,
  CheckAndUpdate,
  RetryCheckAndUpdate,
};

enum class InitialMode : uint8_t {
  StartInCfgMode = 0,
  StartOffline = 1,
  StartWithCfgModeThenOffline = 2,
  StartInNotConfiguredMode = 3
};
 
enum class CfgModeState : uint8_t {
  NotSet = 0,
  CfgModeStartedFor1hPending = 1,
  CfgModeStartedPending = 2,
  CfgModeOngoing = 3,
  Done = 4,
};
 
struct ConfigurationState {
  uint8_t wifiEnabled : 1;
  uint8_t wifiSsidFilled : 1;
  uint8_t wifiPassFilled : 1;
  uint8_t protocolFilled : 1;
  uint8_t protocolNotEmpty : 1;
  uint8_t configNotComplete : 1;
  uint8_t atLeastOneProtoIsEnabled : 1;
 
  bool isEmpty() const;
 
  ConfigurationState() {
    wifiEnabled = 0;
    wifiSsidFilled = 0;
    wifiPassFilled = 0;
    protocolFilled = 0;
    protocolNotEmpty = 0;
    configNotComplete = 0;
    atLeastOneProtoIsEnabled = 0;
  }
};
 
const char *getInitialModeName(const InitialMode mode);
 
namespace Device {
class SwUpdate;
class ChannelConflictResolver;
class ChannelConflictResolverList;
class SubdevicePairingHandler;
class StatusLed;
class LastStateLogger;
class SecurityLogger;
}  // namespace Device
 
namespace Protocol {
class SuplaSrpc;
}  // namespace Protocol
 
namespace Suplet {
class CapabilityRegistry;
class Manager;
class Registry;
class ServerConfigHandler;
enum class ServerConfigResult : uint8_t;
}  // namespace Suplet
 
}  // namespace Supla
 
class SuplaDeviceClass : public Supla::ActionHandler,
                         public Supla::LocalAction {
 public:
  SuplaDeviceClass();
  ~SuplaDeviceClass();
 
  void fillStateData(TDSC_ChannelState *channelState) const;
  void addClock(Supla::Clock *clock);  // DEPRECATED
  Supla::Clock *getClock() const;
 
  bool begin(const char GUID[SUPLA_GUID_SIZE],
             const char *Server,
             const char *email,
             const char authkey[SUPLA_AUTHKEY_SIZE],
             unsigned char protoVersion = 23);
 
  bool begin(unsigned char protoVersion = 23);
 
  // Use ASCII only in name
  void setName(const char *Name);
 
  void setGUID(const char GUID[SUPLA_GUID_SIZE]);
  void setAuthKey(const char authkey[SUPLA_AUTHKEY_SIZE]);
  void setEmail(const char *email);
  void setServer(const char *server);
  void setSwVersion(const char *);
 
  // Do not set the manufacturer ID to anything other than 0. Values other than
  // 0 are reserved for official Supla products only
  void setManufacturerId(int16_t);
 
  // Do not set the product ID to anything other than 0. Values other than
  // 0 are reserved for official Supla products only
  void setProductId(int16_t);
 
  void addFlags(int32_t);
  void removeFlags(int32_t);
  bool isSleepingDeviceEnabled() const;
 
  int generateHostname(char *, int macSize = 6);
 
  // Timer with 100 Hz frequency (10 ms)
  void onTimer(void);
  // Timer with 2000 Hz frequency (0.5 ms or 1 ms)
  void onFastTimer(void);
  void iterate(void);
 
  void status(int status,
              const __FlashStringHelper *msg,
              bool alwaysLog = false);
  void setStatusFuncImpl(_impl_arduino_status impl_arduino_status);
  void setServerPort(int value);
 
  int handleCalcfgFromServer(TSD_DeviceCalCfgRequest *request,
                             TDS_DeviceCalCfgResult *result = nullptr);
 
  void enterConfigMode();
  void leaveConfigModeWithoutRestart();
  void enterNormalMode();
  // Schedules timeout to restart device. When provided timeout is 0
  // then restart will be done asap.
  void scheduleSoftRestart(int timeout = 0);
  void scheduleProtocolsRestart(int timeout = 0);
  void softRestart();
  void saveStateToStorage();
  void restartCfgModeTimeout(bool requireRestart);
  void resetToFactorySettings();
  void disableLocalActionsIfNeeded();
  void requestCfgMode();
 
  int8_t getCurrentStatus() const;
  bool loadDeviceConfig();
  bool prepareLastStateLog();
  char *getLastStateLog();
  void addLastStateLog(const char *);
  void enableLastStateLog();
  void disableLastStateLog();
  void setRsaPublicKeyPtr(const uint8_t *ptr);
  const uint8_t *getRsaPublicKey() const;
  enum Supla::DeviceMode getDeviceMode() const;
 
  void setActivityTimeout(_supla_int_t newActivityTimeout);
  uint32_t getActivityTimeout();
 
  void handleAction(int event, int action) override;

  void setAutomaticResetOnConnectionProblem(unsigned int timeSec);
 
  void setLastStateLogger(Supla::Device::LastStateLogger *logger);
 
  void setSuplaCACert(const char *);
  void setSupla3rdPartyCACert(const char *);
  const char *getSuplaCACert() const;
 
  Supla::Uptime uptime;
 
  Supla::Protocol::SuplaSrpc *getSrpcLayer();
 
  void enableNetwork();
  void disableNetwork();
  bool getStorageInitResult();
  bool isSleepingAllowed();

  void allowWorkInOfflineMode(int mode = 1);

  void setInitialMode(Supla::InitialMode mode);

  Supla::InitialMode getInitialMode() const {
    return initialMode;
  }

  bool isRemoteDeviceConfigEnabled() const;

  void setShowUptimeInChannelState(bool value);

  void setLogLevel(int level);

  int getLogLevel();

  void setProtoVerboseLog(bool value);
 
  Supla::Mutex *getTimerAccessMutex();
 
  void setChannelConflictResolver(
      Supla::Device::ChannelConflictResolver *resolver);
  bool addChannelConflictResolver(
      Supla::Device::ChannelConflictResolver *resolver);
  bool removeChannelConflictResolver(
      Supla::Device::ChannelConflictResolver *resolver);
  void setSupletRuntime(Supla::Suplet::Manager *manager,
                        Supla::Suplet::Registry *registry);
  void setSupletCapabilityRegistry(Supla::Suplet::CapabilityRegistry *registry);
  void setSupletServerConfigHandler(
      Supla::Suplet::ServerConfigHandler *handler);
  Supla::Suplet::ServerConfigResult applySupletCommandJson(
      const char *commandJson);
  Supla::Suplet::ServerConfigResult validateSupletCommandJson(
      const char *commandJson) const;
  void setSubdevicePairingHandler(
      Supla::Device::SubdevicePairingHandler *handler);

  void setMacLengthInHostname(int value);

  void setCustomHostnamePrefix(const char *prefix);
 
  void setStatusLed(Supla::Device::StatusLed *led);

  void setLeaveCfgModeAfterInactivityMin(int valueMin);

  bool isLeaveCfgModeAfterInactivityEnabled() const;

  bool isAutomaticFirmwareUpdateEnabled() const;

  void setAutomaticFirmwareUpdateSupported(bool value);

  void identifyStatusLed();

  void testStepStatusLed(int times);

  void addSecurityLog(uint32_t source, const char *log) const;

  void addSecurityLog(Supla::SecurityLogSource source, const char *log) const;

  void setSecurityLogger(Supla::Device::SecurityLogger *logger);

  bool isSecurityLogEnabled() const;
 
 protected:
  void iterateSwUpdate();

  bool initSwUpdateInstance(Supla::SwUpdateMode mode, int securityOnly = -1);
 
  void iterateAlwaysElements(uint32_t _millis);
  bool iterateNetworkSetup();
  bool iterateSuplaProtocol(uint32_t _millis);
  void handleLocalActionTriggers();
  void checkIfLeaveCfgModeOrRestartIsNeeded();
  void createSrpcLayerIfNeeded();
  bool loadSupletRuntime();
  bool handleSupletRuntimeRefresh();
  void rewriteStateStorageIfInvalidAfterTopologyChange();
  void setupDeviceMode();
 
  uint32_t networkIsNotReadyCounter = 0;
  uint32_t deviceRestartTimeoutTimestamp = 0;
  uint32_t protocolRestartTimeoutTimestamp = 0;
  uint32_t waitForIterate = 0;
  uint32_t lastIterateTime = 0;
  uint32_t enterConfigModeTimestamp = 0;
  uint32_t forceRestartTimeMs = 0;
  uint32_t protocolRestartTimeMs = 0;
  uint32_t resetOnConnectionFailTimeoutSec = 0;
  uint32_t lastSwUpdateCheckTimestamp = 0;
 
  enum Supla::DeviceMode deviceMode = Supla::DEVICE_MODE_NOT_SET;
  bool triggerResetToFactorySettings = false;
  bool triggerStartLocalWebServer = false;
  bool triggerStopLocalWebServer = false;
  bool triggerCheckSwUpdate = false;
  bool requestNetworkLayerRestart = false;
  bool isNetworkSetupOk = false;
  bool skipNetwork = false;
  bool storageInitResult = false;
  bool showUptimeInChannelState = true;
  bool lastStateLogEnabled = true;
  // used to indicate if begin() method was called - it will be set to
  // true even if initialization procedure failed for some reason
  bool initializationDone = false;
  bool goToConfigModeAsap = false;
 
  uint8_t leaveCfgModeAfterInactivityMin = 5;
  uint8_t macLengthInHostname = 6;
  int8_t currentStatus = STATUS_UNKNOWN;
  uint8_t swUpdateAttempts = 0;
 
  Supla::InitialMode initialMode = Supla::InitialMode::StartInNotConfiguredMode;
  Supla::CfgModeState cfgModeState = Supla::CfgModeState::NotSet;
  Supla::ConfigurationState configurationState = {};
 
  Supla::Protocol::SuplaSrpc *srpcLayer = nullptr;
  Supla::Device::SwUpdate *swUpdate = nullptr;
  Supla::Device::ChannelConflictResolverList *channelConflictResolvers =
      nullptr;
#if SUPLA_SUPLET_ENABLED
  Supla::Suplet::Manager *supletManager = nullptr;
#endif
  Supla::Element *iterateConnectedPtr = nullptr;
  Supla::Device::LastStateLogger *lastStateLogger = nullptr;
  Supla::Mutex *timerAccessMutex = nullptr;
  Supla::Device::SubdevicePairingHandler *subdevicePairingHandler = nullptr;
  Supla::Device::StatusLed *statusLed = nullptr;
  Supla::Device::SecurityLogger *securityLogger = nullptr;
  const uint8_t *rsaPublicKey = nullptr;
  char *customHostnamePrefix = nullptr;
  _impl_arduino_status impl_arduino_status = nullptr;
};
 
extern SuplaDeviceClass SuplaDevice;
#endif  // SRC_SUPLADEVICE_H_