Implement power control over radio transmission

Other changes: * Decouple settings * Add test env * Static network config
vi7 · Jan 14, 2022 · 657963c · 657963c
1 parent 8a3bb0d
commit 657963c
Show file tree

Hide file tree

Showing 13 changed files with 229 additions and 49 deletions.
diff --git a/.circleci/config.yml b/.circleci/config.yml
@@ -5,14 +5,16 @@ jobs:
     docker:
       - image: alpine
     steps:
+      - run:
+          name: Install packages
+          command: apk add --no-cache curl docker-cli make openssh git
       - checkout
       - setup_remote_docker:
           version: 20.10.7
           docker_layer_caching: true
       - run:
           name: smoke-test
           command: |
-            apk add --no-cache curl docker-cli make git
             if [ "$(git log -1 --format=format:%H -- client/)" == "$CIRCLE_SHA1" ]
             then
              make client-test
@@ -25,12 +27,12 @@ jobs:
     docker:
       - image: alpine
     steps:
+      - run:
+          name: Install packages
+          command: apk add --no-cache docker-cli make openssh git
       - checkout
       - setup_remote_docker:
           version: 20.10.7
-      - run:
-          name: Install packages
-          command: apk add --no-cache docker-cli make
       - run:
           name: Docker image release
           command: |

diff --git a/include/Settings.h b/include/Settings.h
@@ -0,0 +1,87 @@
+/**
+ *
+ * Settings.h
+ *
+ **/
+
+/*
+ * !! WARNING !!
+ *
+ * !!! DO NOT USE pins 5(D1),4(D2)
+ * because they are reserved
+ * for I2C bus SCL,SDA !!!
+ *
+ * !! WARNING !!
+ */
+
+#ifndef SETTINGS_H
+#define SETTINGS_H
+
+#include <Arduino.h>
+
+#ifndef CUSTOM_NETWORK
+#define IP_ADDRESS  "192.168.1.30"
+#define SUBNET      "255.255.255.0"
+#define GATEWAY     "192.168.1.1"
+#define DNS1        "192.168.1.4"
+#define DNS2        "192.168.1.1"
+#define HOSTNAME    "arduino-grower"
+#else
+#define IP_ADDRESS  "192.168.1.31"
+#define SUBNET      "255.255.255.0"
+#define GATEWAY     "192.168.1.1"
+#define DNS1        "192.168.1.4"
+#define DNS2        "192.168.1.1"
+#define HOSTNAME    "test-arduino-grower"
+#endif
+
+#define WEB_SERVER_PORT 80
+#define RADIO_POWER  // Enable power control over radio transmission
+
+#ifdef RADIO_POWER
+  #define TX_PIN 2
+  #define RCSWITCH_PROTOCOL 13
+  /*
+   * ORNO OR-AE-13132(GS) power extender codes
+   */
+  #define MSG_LENGTH 24
+
+  #define OUTLET1_ON  0x15533
+  #define OUTLET1_OFF 0x1553C
+  #define OUTLET2_ON  0x155C3
+  #define OUTLET2_OFF 0x155CC
+  #define OUTLET3_ON  0x15703
+  #define OUTLET3_OFF 0x1570C
+  #define OUTLET4_ON  0x15D03
+  #define OUTLET4_OFF 0x15D0C
+  #define OUTLET5_ON  0x17503
+  #define OUTLET5_OFF 0x1750C
+
+  #define LAMP_ON_CODE  OUTLET1_ON
+  #define LAMP_OFF_CODE OUTLET1_OFF
+  #define HUM_ON_CODE   OUTLET2_ON
+  #define HUM_OFF_CODE  OUTLET2_OFF
+  #define FAN_ON_CODE   OUTLET3_ON
+  #define FAN_OFF_CODE  OUTLET3_OFF
+#else
+  #define LAMPRELAYPIN  0  // white/light-brown
+  #define HUMRELAYPIN   2   // violet
+  #define FANRELAYPIN   16   // white
+#endif
+
+#define PUMPPIN 14       // blue
+#define LDRPIN A0        // dark-brown/blue
+
+// TODO: replace const's with define's
+/* monitoring constants */
+const uint8_t MAX_TEMP = 40;
+const uint8_t TEMP_HYSTERESIS = 10;
+// Recommended RH values:
+// - vegetative - 60%
+// - flowering - 50%
+const uint8_t MAX_RH = 50;
+const uint8_t RH_HYSTERESIS = 15;
+// lamp check interval in seconds
+const uint8_t LIGHT_CHECK_INTERVAL = 10;
+
+#endif
diff --git a/include/version.h b/include/version.h
@@ -11,6 +11,6 @@
 #ifndef VERSION_H
 #define VERSION_H
 
-#define VERSION "0.10.0"
+#define VERSION "0.11.0"
 
 #endif
diff --git a/platformio.ini b/platformio.ini
@@ -8,7 +8,10 @@
 ; Please visit documentation for the other options and examples
 ; https://docs.platformio.org/page/projectconf.html
 
-[env:d1_mini]
+[platformio]
+default_envs = prod
+
+[env]
 platform = espressif8266
 board = d1_mini
 framework = arduino
@@ -25,3 +28,10 @@ lib_deps =
      DHT sensor library for ESPx@1.17
      https://github.com/jfturcot/SimpleTimer.git#b30890b8f7046bf3b0258e5870e5dda78ac5c71a
      https://github.com/enjoyneering/HTU2xD_SHT2x_Si70xx.git#5a76484f6fd0504125851cc23791f0e2a73e6dae
+     https://github.com/vi7/rc-switch.git#149eba564821e586ef1c221ff8eef1582672bccd
+
+[env:prod]
+
+[env:test]
+build_flags =
+     -D CUSTOM_NETWORK
diff --git a/src/DHTDevice.cpp b/src/DHTDevice.cpp
@@ -21,7 +21,11 @@ void DHTDevice::tempDataHandler(Device* device, uint8_t MAX_TEMP, uint8_t TEMP_H
     Serial.printf((char*)F("DHT: Failed to read temperature! Device status: %s\n"), dht.getStatusString());
     return;
   }
+  #ifdef RADIO_POWER
+  PowerManager::autoPower(&device->isAutoPowerOn, &device->isPowerOn, &temp, MAX_TEMP, TEMP_HYSTERESIS, &device->_onCode, &device->_offCode);
+  #else
   PowerManager::autoPower(&device->isAutoPowerOn, &device->isPowerOn, &temp, MAX_TEMP, TEMP_HYSTERESIS, &device->_pin);
+  #endif
 }
 
 void DHTDevice::rhDataHandler(Device* device, uint8_t MAX_RH, uint8_t RH_HYSTERESIS) {
@@ -31,7 +35,11 @@ void DHTDevice::rhDataHandler(Device* device, uint8_t MAX_RH, uint8_t RH_HYSTERE
     Serial.printf((char*)F("DHT: Failed to read humidity! Device status: %s\n"), dht.getStatusString());
     return;
   }
+  #ifdef RADIO_POWER
+  PowerManager::autoPower(&device->isAutoPowerOn, &device->isPowerOn, &rH, MAX_RH, RH_HYSTERESIS, &device->_onCode, &device->_offCode);
+  #else
   PowerManager::autoPower(&device->isAutoPowerOn, &device->isPowerOn, &rH, MAX_RH, RH_HYSTERESIS, &device->_pin);
+  #endif
 }
 
 String DHTDevice::status() {

diff --git a/src/DHTDevice.h b/src/DHTDevice.h
@@ -7,6 +7,7 @@
 
 #include <Arduino.h>
 #include <DHTesp.h>
+#include "Settings.h"
 #include "Device.h"
 #include "MetricsCollectable.h"
 

diff --git a/src/Device.cpp b/src/Device.cpp
@@ -5,12 +5,20 @@
 #include "Device.h"
 
 void Device::powerOn() {
+    #ifdef RADIO_POWER
+    this->isPowerOn = PowerManager::manualPowerOn(&_onCode);
+    #else
     this->isPowerOn = PowerManager::manualPowerOn(_pin);
+    #endif
     this->isAutoPowerOn = true;
 }
 
 void Device::powerOff() {
+    #ifdef RADIO_POWER
+    this->isPowerOn = PowerManager::manualPowerOff(&_offCode);
+    #else
     this->isPowerOn = PowerManager::manualPowerOff(_pin);
+    #endif
     this->isAutoPowerOn = false;
 }
 

diff --git a/src/Device.h b/src/Device.h
@@ -6,24 +6,37 @@
 #define DEVICE_H
 
 #include <Arduino.h>
+#include "Settings.h"
 #include "PowerManager.h"
 #include "scheduler.h"
 
 class Device {
 
     public:
-        uint8_t _pin; 
         bool isPowerOn;
         bool isAutoPowerOn;
+        uint8_t _pin;
 
         Device(){};
 
+        #ifdef RADIO_POWER
+        uint32_t _onCode;
+        uint32_t _offCode;
+
+        Device(uint32_t onCode, uint32_t offCode):
+         _onCode(onCode),
+         _offCode(offCode),
+         isAutoPowerOn(true) {
+            this->isPowerOn = PowerManager::manualPowerOn(&onCode);
+        };
+        #else
         Device(uint8_t pin):
          _pin(pin),
          isAutoPowerOn(true) {
             pinMode(pin, OUTPUT);
             this->isPowerOn = PowerManager::manualPowerOn(pin);
         };
+        #endif
 
         void powerOn();
 

diff --git a/src/HTU2xDDevice.cpp b/src/HTU2xDDevice.cpp
@@ -18,8 +18,11 @@ void HTU2xDDevice::tempDataHandler(Device* device, uint8_t MAX_TEMP, uint8_t TEM
     htu2xD->setResolution(HUMD_12BIT_TEMP_14BIT);     //humidity 12-bit, temperature 14-bit
     return;
   }
+  #ifdef RADIO_POWER
+  PowerManager::autoPower(&device->isAutoPowerOn, &device->isPowerOn, &temp, MAX_TEMP, TEMP_HYSTERESIS, &device->_onCode, &device->_offCode);
+  #else
   PowerManager::autoPower(&device->isAutoPowerOn, &device->isPowerOn, &temp, MAX_TEMP, TEMP_HYSTERESIS, &device->_pin);
-  // TODO: add delay(500) as in the HTU2xD_SHT2x_Si70xx lib example?
+  #endif
 }
 
 void HTU2xDDevice::rhDataHandler(Device* device, uint8_t MAX_RH, uint8_t RH_HYSTERESIS) {
@@ -29,7 +32,11 @@ void HTU2xDDevice::rhDataHandler(Device* device, uint8_t MAX_RH, uint8_t RH_HYST
     Serial.printf((char*)F("%s: Failed to read humidity! CRC8 or communication error occurred\n"), HTU2XD_NAME);
     return;
   }
+  #ifdef RADIO_POWER
+  PowerManager::autoPower(&device->isAutoPowerOn, &device->isPowerOn, &rH, MAX_RH, RH_HYSTERESIS, &device->_onCode, &device->_offCode);
+  #else
   PowerManager::autoPower(&device->isAutoPowerOn, &device->isPowerOn, &rH, MAX_RH, RH_HYSTERESIS, &device->_pin);
+  #endif
 }
 
 String HTU2xDDevice::status() {

diff --git a/src/HTU2xDDevice.h b/src/HTU2xDDevice.h
@@ -7,6 +7,7 @@
 
 #include <Arduino.h>
 #include <HTU2xD_SHT2x_Si70xx.h>
+#include "Settings.h"
 #include "Device.h"
 #include "MetricsCollectable.h"
 

diff --git a/src/PowerManager.cpp b/src/PowerManager.cpp
@@ -4,7 +4,28 @@
 
 
 #include "PowerManager.h"
+#ifdef RADIO_POWER
+void PowerManager::autoPower(bool *autoControl, bool *currentState, float *currVal, float maxVal, float valHyst,
+                              uint32_t *onCode, uint32_t *offCode) {
+  if (!*autoControl) return;
+  if (*currVal >= maxVal && *currentState) {
+    *currentState = manualPowerOff(offCode);
+  }
+  else if (*currVal < maxVal - valHyst && !*currentState) {
+    *currentState = manualPowerOn(onCode);
+  }
+}
 
+bool PowerManager::manualPowerOn(uint32_t *onCode) {
+  PowerManager::transmitter.send(*onCode, MSG_LENGTH);
+  return true;
+}
+
+bool PowerManager::manualPowerOff(uint32_t *offCode) {
+  PowerManager::transmitter.send(*offCode, MSG_LENGTH);
+  return false;
+}
+#else
 void PowerManager::autoPower(bool *autoControl, bool *currentState, float *currVal, float maxVal, float valHyst, uint8_t *pin) {
   if (!*autoControl) return;
   if (*currVal >= maxVal && *currentState) {
@@ -23,4 +44,5 @@ bool PowerManager::manualPowerOn(uint8_t pin) {
 bool PowerManager::manualPowerOff(uint8_t pin) {
   digitalWrite(pin, RELAY_OFF);
   return false;
-}
+}
+#endif
diff --git a/src/PowerManager.h b/src/PowerManager.h
@@ -10,12 +10,23 @@
 #define RELAY_OFF HIGH
 
 #include <Arduino.h>
+#include <RCSwitch.h>
+
+#include "Settings.h"
 
 class PowerManager {
     public:
+        static RCSwitch transmitter;
+        #ifdef RADIO_POWER
+        static void autoPower(bool *autoControl, bool *isOn, float *currVal, float maxVal, float valHyst,
+                                uint32_t *onCode, uint32_t *offCode);
+        static bool manualPowerOn(uint32_t *onCode);
+        static bool manualPowerOff(uint32_t *offCode);
+        #else
         static void autoPower(bool *autoControl, bool *isOn, float *currVal, float maxVal, float valHyst, uint8_t *pin);
         static bool manualPowerOn(uint8_t pin);
         static bool manualPowerOff(uint8_t pin);
+        #endif
 
 };