Compare commits

...

20 Commits

Author SHA1 Message Date
b943a3f1c8 Update README 2023-06-23 11:59:32 +02:00
409c7f6561 Deallocate the configuration data structure 2023-04-30 14:17:58 +02:00
7bdf50a34f Replace DHT11 sensor with DHT22 2023-04-20 13:26:41 +02:00
8a61260bc0 Update gitignore 2023-04-11 10:05:39 +02:00
36c83f8dee Allocate necessary memory for struct members 2023-04-11 07:35:27 +02:00
92eeb0a638 Load credentials and settings from config file 2023-04-06 08:28:01 +02:00
37e249a503 Update README 2023-04-03 10:38:52 +02:00
672875b74d Move header to include directory 2023-04-03 10:25:11 +02:00
ba6d31c798 Send the data to one MQTT topic using JSON 2023-04-03 06:23:03 +02:00
1ad08b06ff Transfer the data via MQTT 2023-04-03 03:26:12 +02:00
cbd7580002 Enable debugging support 2023-04-03 02:43:56 +02:00
f626085e40 Set a maximum number of connection retries 2023-03-30 02:10:49 +02:00
8658148646 Implement WLAN connection and deep sleep 2023-03-30 01:28:31 +02:00
6450fadd9a Ignore spurrious clang arguments 2023-03-15 05:33:55 +01:00
ad84bb683f Change time delay and output format 2023-03-15 05:33:55 +01:00
c62f482d1d Implement soil humidity logging to serial console 2023-03-15 05:33:54 +01:00
77ccf06986 Implement temperature/humidity logging to serial 2023-03-15 05:33:06 +01:00
d5dcb0cec5 Install DHT11 dependencies 2023-03-15 01:53:25 +01:00
e86d80b91b Update README 2023-03-15 01:49:46 +01:00
7bd32c7785 Add clang to dependencies 2023-03-15 01:41:23 +01:00
12 changed files with 234 additions and 5 deletions

2
.clangd Normal file
View File

@@ -0,0 +1,2 @@
CompileFlags:
Remove: [-mlongcalls, -free, -mtext-section-literals, -fipa-pta]

1
.gitignore vendored
View File

@@ -1 +1,2 @@
.pio
data/config.json

View File

@@ -1,13 +1,44 @@
* Homeostasis
Temperature, air humidity and soil humidity sensor that communicates via MQTT. The project is implemented using a Wemos D1 mini board with the following addons:
Temperature, air humidity and soil humidity sensor that communicates via MQTT. The project is implemented using a Wemos D1 mini board with the following components:
- DHT11
- Soil hygrometer sensor
- DHT22 temperature and humidity sensor
- FC-28 soil hygrometer sensor
- Battery shield
- 3.7V 1000mAh Lithium battery
The sensor captures the data every 15 minutes and sends it to a MQTT broker and then enters deep sleep, it is important to save power as the device runs off a battery.
#+ATTR_HTML: :width 60%
[[./result.png]]
** Pinout of the board
#+ATTR_HTML: :width 50%
#+ATTR_HTML: :width 40%
[[./pinout.png]]
** Dependencies
- [[https://github.com/adafruit/DHT-sensor-library][Adafruit DHT sensor library]]
- [[https://github.com/adafruit/Adafruit_Sensor][Adafruit Unified Sensor Driver]]
- [[https://github.com/knolleary/pubsubclient][PubSubClient]]
- [[https://github.com/bblanchon/ArduinoJson][ArduinoJSON]]
** Deployment
The software uses the Arduino framework and the development environment of [[https://platformio.org/][PlatformIO]], which offers better tools than the Arduino IDE.
1. Upload the configuration file to the board:
#+begin_src shell
pio run -t uploadfs
#+end_src
2. Compile the project
#+begin_src shell
pio run -t compile
#+end_src
3. Upload firmware
#+begin_src shell
pio run -t upload
#+end_src

12
data/example.json Normal file
View File

@@ -0,0 +1,12 @@
{
"ssid": "",
"psk": "",
"mqtt_host": "",
"mqtt_user": "",
"mqtt_password": "",
"mqtt_port": 1883,
"mqtt_topic": "",
"device_id": "",
"sleep_time": 30,
"connection_attempts": 60
}

27
include/config.h Normal file
View File

@@ -0,0 +1,27 @@
#ifndef CONFIG_H_
#define CONFIG_H_
#include "FS.h"
#include "LittleFS.h"
#include <ArduinoJson.h>
typedef struct {
const char *ssid;
const char *psk;
const char *mqtt_host;
const char *mqtt_user;
const char *mqtt_password;
const char *topic;
const char *device_id;
int mqtt_port;
long sleep_time;
int connection_attempts;
} Config;
void initialize_config(Config *config, StaticJsonDocument<512> json);
bool load_config_file(const char *file_path, Config *config);
long minutes_to_microseconds(int minutes);
#endif // CONFIG_H_

16
include/wlan.h Normal file
View File

@@ -0,0 +1,16 @@
#ifndef WLAN_H
#define WLAN_H
#include "config.h"
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
void initial_connection(const char *ssid, const char *psk);
void connect_wlan(Config *config);
void connect_mqtt(PubSubClient &client, Config *config);
void disconnect_mqtt(PubSubClient &client, const char *topic);
size_t construct_json(float *data, char *buffer, int buffer_size);
void mqtt_transfer(PubSubClient &client, Config *config, float *data);
void enter_deep_sleep(bool wifi_timeout, int sleep_time);
#endif /* WLAN_H */

View File

@@ -11,4 +11,10 @@
[env:d1_mini]
platform = espressif8266
board = d1_mini
board_build.filesystem = littlefs
framework = arduino
lib_deps =
adafruit/DHT sensor library@^1.4.4
adafruit/Adafruit Unified Sensor@^1.1.9
knolleary/PubSubClient@^2.8
bblanchon/ArduinoJson@^6.21.1

BIN
result.png Normal file

Binary file not shown.

After

Width:  |  Height:  |  Size: 3.7 MiB

View File

@@ -2,4 +2,4 @@
with pkgs;
mkShell { buildInputs = [ platformio ]; }
mkShell { buildInputs = [ platformio clang ]; }

30
src/config.cpp Normal file
View File

@@ -0,0 +1,30 @@
#include "config.h"
void initialize_config(Config *config, StaticJsonDocument<512> json) {
config->ssid = strdup(json["ssid"]);
config->psk = strdup(json["psk"]);
config->mqtt_host = strdup(json["mqtt_host"]);
config->mqtt_user = strdup(json["mqtt_user"]);
config->mqtt_password = strdup(json["mqtt_password"]);
config->topic = strdup(json["mqtt_topic"]);
config->device_id = strdup(json["device_id"]);
config->mqtt_port = json["mqtt_port"];
config->sleep_time = minutes_to_microseconds(json["sleep_time"]);
config->connection_attempts = json["connection_attempts"];
}
bool load_config_file(const char *file_path, Config *config) {
if (!LittleFS.begin())
return false;
File config_file = LittleFS.open(file_path, "r");
if (!config_file)
return false;
StaticJsonDocument<512> json;
DeserializationError err = deserializeJson(json, config_file);
if (err)
return false;
initialize_config(config, json);
return true;
}
long minutes_to_microseconds(int minutes) { return (minutes * 6e7); }

41
src/main.cpp Normal file
View File

@@ -0,0 +1,41 @@
#include "config.h"
#include "wlan.h"
#include <Arduino.h>
#include <DHT.h>
#define DHTTYPE DHT22
#define DHTPIN 4
DHT dht(DHTPIN, DHTTYPE);
const int fc28_pin = A0;
const char *config_file_path = "/config.json";
Config *config;
WiFiClient wifi_client;
PubSubClient mqtt_client(wifi_client);
bool check_valid_value(float value) {
return (!isnan(value) && value >= 0 && value <= 100);
}
void setup() {
Serial.begin(9600);
dht.begin();
config = (Config *)malloc(sizeof(Config));
if (!load_config_file(config_file_path, config))
Serial.println("ERROR: The config file could not be loaded");
connect_wlan(config);
}
void loop() {
float temperature = dht.readTemperature();
float humidity = dht.readHumidity();
int analog_val = analogRead(fc28_pin);
int soil_percentage = map(analog_val, 0, 1023, 0, 100);
float data[3] = {temperature, humidity, static_cast<float>(soil_percentage)};
if (check_valid_value(temperature) && check_valid_value(humidity)) {
mqtt_transfer(mqtt_client, config, data);
}
disconnect_mqtt(mqtt_client, config->topic);
free(config);
enter_deep_sleep(false, config->sleep_time);
}

63
src/wlan.cpp Normal file
View File

@@ -0,0 +1,63 @@
#include "wlan.h"
#include <ArduinoJson.h>
void initial_connection(const char *ssid, const char *psk) {
WiFi.begin(ssid, psk);
WiFi.persistent(true);
WiFi.setAutoConnect(true);
WiFi.setAutoReconnect(true);
}
void connect_wlan(Config *config) {
if (WiFi.SSID() != config->ssid)
initial_connection(config->ssid, config->psk);
int retries = 0;
while (WiFi.status() != WL_CONNECTED) {
if (retries == config->connection_attempts)
enter_deep_sleep(true, config->sleep_time);
retries++;
delay(1000);
Serial.print(".");
}
Serial.println("WiFi connected");
}
void connect_mqtt(PubSubClient &client, Config *config) {
if (!client.connected())
client.setServer(config->mqtt_host, config->mqtt_port);
if (client.connect(config->device_id, config->mqtt_user,
config->mqtt_password)) {
Serial.println("MQTT connected");
client.subscribe(config->topic);
}
}
void disconnect_mqtt(PubSubClient &client, const char *topic) {
Serial.println("Disconnecting MQTT");
client.unsubscribe(topic);
client.disconnect();
}
size_t construct_json(float *data, char *buffer, int buffer_size) {
StaticJsonDocument<100> json;
json["temperature"] = data[0];
json["humidity"] = data[1];
json["soil_humidity"] = data[2];
size_t payload_size = serializeJson(json, buffer, buffer_size);
return payload_size;
}
void mqtt_transfer(PubSubClient &client, Config *config, float *data) {
char buffer[100];
connect_mqtt(client, config);
size_t payload_size = construct_json(data, buffer, 100);
client.publish(config->topic, buffer, payload_size);
Serial.println("Data transferred successfully");
}
void enter_deep_sleep(bool wifi_timeout, int sleep_time) {
Serial.println("Entering deep sleep");
if (wifi_timeout)
WiFi.disconnect();
ESP.deepSleep(sleep_time, WAKE_RF_DEFAULT);
}