-
Notifications
You must be signed in to change notification settings - Fork 1
/
sound_sensor.ino
229 lines (188 loc) · 6.27 KB
/
sound_sensor.ino
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
#include <FS.h> //this needs to be first, or it all crashes and burns...
#include <ESP8266WiFi.h> //https://github.com/esp8266/Arduino
//needed for library
#include <DNSServer.h>
#include <ESP8266WebServer.h>
#include <WiFiManager.h> //https://github.com/tzapu/WiFiManager
#include <ArduinoJson.h> //https://github.com/bblanchon/ArduinoJson
#include <Ticker.h>
#include <ESP8266HTTPClient.h>
#include <PubSubClient.h>
#define SERIAL_DEBUG 1
//define your default values here, if there are different values in config.json, they are overwritten.
#define SoundSensorPin A0
//define the pin for the sound sensor
#define VREF 3.3
//should be 3.3 for esp8266 wemos d1 mini pro
#define DAQ_INTERVAL 5
char sensorID[34] = "";
//flag for saving data
bool shouldSaveConfig = false;
volatile bool measurementFlag = true;
WiFiClient net;
PubSubClient client(net);
const char* fingerprint = "C3 57 0A 47 01 AA 16 DA 6E DA 51 1C B7 AC ED 64 5E AB EB 00";
Ticker DAQTimer;
//connect to mqtt server
void reconnect() {
// Loop until we're reconnected
while (!client.connected()) {
Serial.print("Attempting MQTT connection...");
String clientId = "ESP8266Client-";
// Attempt to connect
if (client.connect(clientId.c_str())) {
Serial.println("connected");
// Once connected, publish an announcement...
// ... and resubscribe
} else {
Serial.print("failed, rc=");
Serial.print(client.state());
Serial.println(" try again in 5 seconds");
// Wait 5 seconds before retrying
delay(5000);
}
}
}
//callback notifying us of the need to save config
void saveConfigCallback () {
Serial.println("Should save config");
shouldSaveConfig = true;
}
int readSoundLevel() {
float voltageValue, dbValue;
voltageValue = analogRead(SoundSensorPin) / 1024.0 * VREF;
dbValue = voltageValue * 50.0;
#if SERIAL_DEBUG
Serial.print(dbValue, 1);
Serial.println(" dBA");
#endif
return dbValue;
}
void setup() {
// put your setup code here, to run once:
Serial.begin(115200);
Serial.println();
twi_setClockStretchLimit(20000);
//clean FS, for testing
//SPIFFS.format();
//read configuration from FS json
Serial.println("mounting FS...");
if (SPIFFS.begin()) {
Serial.println("mounted file system");
if (SPIFFS.exists("/config.json")) {
//file exists, reading and loading
Serial.println("reading config file");
File configFile = SPIFFS.open("/config.json", "r");
if (configFile) {
Serial.println("opened config file");
size_t size = configFile.size();
// Allocate a buffer to store contents of the file.
std::unique_ptr<char[]> buf(new char[size]);
configFile.readBytes(buf.get(), size);
DynamicJsonBuffer jsonBuffer;
JsonObject& json = jsonBuffer.parseObject(buf.get());
json.printTo(Serial);
if (json.success()) {
Serial.println("\nparsed json");
strcpy(sensorID, json["sensorID"]);
} else {
Serial.println("failed to load json config");
}
}
}
} else {
Serial.println("failed to mount FS");
}
//end read
// The extra parameters to be configured (can be either global or just in the setup)
// After connecting, parameter.getValue() will get you the configured value
// id/name placeholder/prompt default length
WiFiManagerParameter custom_sensorID("sensorID", "Location", sensorID, 32);
//WiFiManager
//Local intialization. Once its business is done, there is no need to keep it around
WiFiManager wifiManager;
//wifiManager.resetSettings();
//set config save notify callback
wifiManager.setSaveConfigCallback(saveConfigCallback);
//add all your parameters here
wifiManager.addParameter(&custom_sensorID);
//sets timeout until configuration portal gets turned off
//useful to make it all retry or go to sleep
//in seconds
wifiManager.setTimeout(120);
wifiManager.setConnectTimeout(30);
//fetches ssid and pass and tries to connect
//if it does not connect it starts an access point with the specified name
//here "AutoConnectAP"
//and goes into a blocking loop awaiting configuration
//wifiManager.autoConnect(String(ESP.getChipId()).c_str(), "dankmemes");
if (!wifiManager.autoConnect(String(ESP.getChipId()).c_str())) {
digitalWrite(D4, HIGH);
Serial.println("failed to connect and hit timeout");
delay(3000);
//reset and try again, or maybe put it to deep sleep
ESP.restart();
delay(5000);
}
//if you get here you have connected to the WiFi
Serial.println("connected...yeey :)");
//read updated parameters
//save the custom parameters to FS
if (shouldSaveConfig) {
strcpy(sensorID, custom_sensorID.getValue());
Serial.println("saving config");
DynamicJsonBuffer jsonBuffer;
JsonObject& json = jsonBuffer.createObject();
json["sensorID"] = sensorID;
File configFile = SPIFFS.open("/config.json", "w");
if (!configFile) {
Serial.println("failed to open config file for writing");
}
json.printTo(Serial);
json.printTo(configFile);
configFile.close();
//end save
}
Serial.println("local ip");
Serial.println(WiFi.localIP());
DAQTimer.attach(DAQ_INTERVAL, setMeasurementFlag);
//connecting to MQTT server
client.setServer("iot.research.hamk.fi", 8883);
}
void loop() {
// put your main code here, to run repeatedly:
if (!client.connected()) {
reconnect();
}
client.loop();
delay(10);
if (measurementFlag) {
pushMqtt();
}
}
void setMeasurementFlag() {
measurementFlag = true;
}
void pushMqtt() {
long rssi = WiFi.RSSI();
//Creating JSON object to send to the webserver
static char result_str[128] = "";
StaticJsonBuffer<200> jsonBuffer;
JsonObject& root = jsonBuffer.createObject();
root["id"] = sensorID;
root["value"] = readSoundLevel();
root["uptime"] = millis();
root["rssi"] = rssi;
root.printTo(result_str);
if (WiFi.status() != WL_CONNECTED) {
WiFiManager wifiManager;
wifiManager.setTimeout(1);
wifiManager.setConnectTimeout(30);
while (WiFi.status() != WL_CONNECTED) {
wifiManager.autoConnect();
}
}
String fingerprint = "C3:57:0A:47:01:AA:16:DA:6E:DA:51:1C:B7:AC:ED:64:5E:AB:EB:00";
client.publish("puukoulu_sound_level", result_str);
measurementFlag = false;
}