mirror of
https://github.com/daniviga/bite.git
synced 2024-11-25 06:16:13 +01:00
Compare commits
No commits in common. "5cff8b9c2ca859d084f8173912599fa654a53f5c" and "91b9c09c2baac905fb4e43c1f2a184d6941df939" have entirely different histories.
5cff8b9c2c
...
91b9c09c2b
1
.gitignore
vendored
1
.gitignore
vendored
|
@ -132,4 +132,3 @@ dmypy.json
|
||||||
|
|
||||||
##
|
##
|
||||||
production.py
|
production.py
|
||||||
settings.h
|
|
||||||
|
|
|
@ -20,19 +20,23 @@
|
||||||
|
|
||||||
#include <EEPROM.h>
|
#include <EEPROM.h>
|
||||||
#include <Ethernet.h>
|
#include <Ethernet.h>
|
||||||
#include "settings.h"
|
|
||||||
|
|
||||||
#define ERASE_FIRST 0
|
#define ERASE_FIRST 0
|
||||||
|
|
||||||
const byte mac[] = {
|
const byte mac[] = {
|
||||||
0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0xED
|
0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0xED
|
||||||
};
|
};
|
||||||
const char serial[] = SERIAL;
|
const char serial[] = "abcd1234";
|
||||||
|
|
||||||
struct netConfig {
|
struct netConfig {
|
||||||
IPAddress address = REMOTE_IP;
|
IPAddress address;
|
||||||
unsigned int port = REMOTE_PORT;
|
unsigned int port;
|
||||||
} config;
|
};
|
||||||
|
|
||||||
|
netConfig config = {
|
||||||
|
{192, 168, 10, 123},
|
||||||
|
80
|
||||||
|
};
|
||||||
|
|
||||||
void setup() {
|
void setup() {
|
||||||
|
|
||||||
|
|
|
@ -1,23 +0,0 @@
|
||||||
/* -*- coding: utf-8 -*-
|
|
||||||
* vim: tabstop=2 shiftwidth=2 softtabstop=2 syntax=c
|
|
||||||
*
|
|
||||||
* BITE - A Basic/IoT/Example
|
|
||||||
* Copyright (C) 2020-2021 Daniele Viganò <daniele@vigano.me>
|
|
||||||
*
|
|
||||||
* BITE is free software: you can redistribute it and/or modify
|
|
||||||
* it under the terms of the GNU Affero General Public License as published by
|
|
||||||
* the Free Software Foundation, either version 3 of the License, or
|
|
||||||
* (at your option) any later version.
|
|
||||||
*
|
|
||||||
* BITE 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 Affero General Public License for more details.
|
|
||||||
*
|
|
||||||
* You should have received a copy of the GNU Affero General Public License
|
|
||||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
#define SERIAL "uno_1"
|
|
||||||
#define REMOTE_IP {192, 168, 0, 1}
|
|
||||||
#define REMOTE_PORT 80
|
|
|
@ -91,10 +91,7 @@ void setup(void) {
|
||||||
Serial.print("Connecting to: ");
|
Serial.print("Connecting to: ");
|
||||||
Serial.print(config.address);
|
Serial.print(config.address);
|
||||||
Serial.print(":");
|
Serial.print(":");
|
||||||
Serial.print(config.port);
|
Serial.println(config.port);
|
||||||
Serial.print(" every ");
|
|
||||||
Serial.print(TELEMETRY_DELAY);
|
|
||||||
Serial.println("s");
|
|
||||||
|
|
||||||
#if USE_INTERNAL_NTP
|
#if USE_INTERNAL_NTP
|
||||||
timeClient.setPoolServerIP(config.address);
|
timeClient.setPoolServerIP(config.address);
|
||||||
|
|
|
@ -1 +0,0 @@
|
||||||
../../arduino/libraries/ArduinoJson
|
|
|
@ -1 +0,0 @@
|
||||||
../../arduino/libraries/Ethernet
|
|
|
@ -1 +0,0 @@
|
||||||
../../arduino/libraries/NTPClient
|
|
|
@ -1 +0,0 @@
|
||||||
../../arduino/libraries/pubsubclient
|
|
File diff suppressed because one or more lines are too long
|
@ -1,4 +0,0 @@
|
||||||
requests
|
|
||||||
jupyter
|
|
||||||
pandas
|
|
||||||
ipywidgets
|
|
|
@ -1,75 +0,0 @@
|
||||||
/* -*- coding: utf-8 -*-
|
|
||||||
* vim: tabstop=2 shiftwidth=2 softtabstop=2
|
|
||||||
*
|
|
||||||
* BITE - A Basic/IoT/Example
|
|
||||||
* Copyright (C) 2020-2021 Daniele Viganò <daniele@vigano.me>
|
|
||||||
*
|
|
||||||
* BITE is free software: you can redistribute it and/or modify
|
|
||||||
* it under the terms of the GNU Affero General Public License as published by
|
|
||||||
* the Free Software Foundation, either version 3 of the License, or
|
|
||||||
* (at your option) any later version.
|
|
||||||
*
|
|
||||||
* BITE 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 Affero General Public License for more details.
|
|
||||||
*
|
|
||||||
* You should have received a copy of the GNU Affero General Public License
|
|
||||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
#include <Preferences.h>
|
|
||||||
#include <Ethernet.h>
|
|
||||||
#include "settings.h"
|
|
||||||
|
|
||||||
#define ERASE_FIRST 1
|
|
||||||
|
|
||||||
Preferences preferences;
|
|
||||||
const char* serial = SERIAL;
|
|
||||||
|
|
||||||
const char* ssid = SECRET_SSID;
|
|
||||||
const char* password = SECRET_PASSWORD;
|
|
||||||
|
|
||||||
struct netConfig {
|
|
||||||
IPAddress address = REMOTE_IP;
|
|
||||||
unsigned int port = REMOTE_PORT;
|
|
||||||
} config;
|
|
||||||
|
|
||||||
void setup() {
|
|
||||||
|
|
||||||
Serial.begin(115200);
|
|
||||||
while (!Serial) {
|
|
||||||
; // wait for serial port to connect. Needed for native USB port only
|
|
||||||
}
|
|
||||||
|
|
||||||
preferences.begin("iot", false);
|
|
||||||
#if ERASE_FIRST
|
|
||||||
Serial.println("Erasing IoT data");
|
|
||||||
preferences.clear();
|
|
||||||
#endif
|
|
||||||
Serial.print("Writing IoT data");
|
|
||||||
preferences.putString("serial", serial);
|
|
||||||
Serial.print(".");
|
|
||||||
Serial.println(".");
|
|
||||||
|
|
||||||
preferences.putBytes("config", &config, sizeof(config));
|
|
||||||
Serial.println("Committing...");
|
|
||||||
preferences.end();
|
|
||||||
Serial.println("IoT data written!");
|
|
||||||
|
|
||||||
preferences.begin("wifi", false);
|
|
||||||
#if ERASE_FIRST
|
|
||||||
Serial.println("Erasing WiFI data");
|
|
||||||
preferences.clear();
|
|
||||||
#endif
|
|
||||||
Serial.println("Writing WiFi data");
|
|
||||||
preferences.putString("ssid", ssid);
|
|
||||||
preferences.putString("password", password);
|
|
||||||
Serial.println("Committing...");
|
|
||||||
preferences.end();
|
|
||||||
Serial.println("WiFi data written!");
|
|
||||||
}
|
|
||||||
|
|
||||||
void loop() {
|
|
||||||
/* Empty loop */
|
|
||||||
}
|
|
|
@ -1,25 +0,0 @@
|
||||||
/* -*- coding: utf-8 -*-
|
|
||||||
* vim: tabstop=2 shiftwidth=2 softtabstop=2 syntax=c
|
|
||||||
*
|
|
||||||
* BITE - A Basic/IoT/Example
|
|
||||||
* Copyright (C) 2020-2021 Daniele Viganò <daniele@vigano.me>
|
|
||||||
*
|
|
||||||
* BITE is free software: you can redistribute it and/or modify
|
|
||||||
* it under the terms of the GNU Affero General Public License as published by
|
|
||||||
* the Free Software Foundation, either version 3 of the License, or
|
|
||||||
* (at your option) any later version.
|
|
||||||
*
|
|
||||||
* BITE 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 Affero General Public License for more details.
|
|
||||||
*
|
|
||||||
* You should have received a copy of the GNU Affero General Public License
|
|
||||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
#define SERIAL "<fillme>"
|
|
||||||
#define REMOTE_IP {192, 168, 0, 1}
|
|
||||||
#define REMOTE_PORT 80
|
|
||||||
#define SECRET_SSID "<fillme>"
|
|
||||||
#define SECRET_PASSWORD "<fillme>"
|
|
|
@ -1,197 +0,0 @@
|
||||||
/* -*- coding: utf-8 -*-
|
|
||||||
* vim: tabstop=2 shiftwidth=2 softtabstop=2
|
|
||||||
*
|
|
||||||
* BITE - A Basic/IoT/Example
|
|
||||||
* Copyright (C) 2020-2021 Daniele Viganò <daniele@vigano.me>
|
|
||||||
*
|
|
||||||
* BITE is free software: you can redistribute it and/or modify
|
|
||||||
* it under the terms of the GNU Affero General Public License as published by
|
|
||||||
* the Free Software Foundation, either version 3 of the License, or
|
|
||||||
* (at your option) any later version.
|
|
||||||
*
|
|
||||||
* BITE 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 Affero General Public License for more details.
|
|
||||||
*
|
|
||||||
* You should have received a copy of the GNU Affero General Public License
|
|
||||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
#include <Preferences.h>
|
|
||||||
#include <WiFi.h>
|
|
||||||
#include <WiFiUdp.h>
|
|
||||||
#include <PubSubClient.h>
|
|
||||||
#include <NTPClient.h>
|
|
||||||
#include <ArduinoJson.h>
|
|
||||||
|
|
||||||
#define DEBUG_TO_SERIAL 1 // debug on serial port
|
|
||||||
#define USE_MQTT 1 // use mqtt protocol instead of http post
|
|
||||||
#define USE_INTERNAL_NTP 1 // use default ntp server or the internal one
|
|
||||||
#define TELEMETRY_DELAY 10 // second between telemetry samples
|
|
||||||
|
|
||||||
// const String serverName = "sensor.server.domain";
|
|
||||||
const size_t capacity = 2 * JSON_OBJECT_SIZE(3) + JSON_OBJECT_SIZE(2) + 20;
|
|
||||||
|
|
||||||
Preferences preferences;
|
|
||||||
|
|
||||||
DynamicJsonDocument telemetry(capacity);
|
|
||||||
JsonObject payload = telemetry.createNestedObject("payload");
|
|
||||||
|
|
||||||
unsigned int counter = 0;
|
|
||||||
|
|
||||||
WiFiUDP ntpUDP;
|
|
||||||
NTPClient timeClient(ntpUDP);
|
|
||||||
bool NTPValid = false;
|
|
||||||
|
|
||||||
WiFiClient ethClient;
|
|
||||||
PubSubClient clientMQTT(ethClient);
|
|
||||||
|
|
||||||
struct netConfig {
|
|
||||||
IPAddress address;
|
|
||||||
unsigned int port;
|
|
||||||
} config;
|
|
||||||
|
|
||||||
char* serial;
|
|
||||||
const String apiURL = "/api/device/subscribe/";
|
|
||||||
const String telemetryURL = "/telemetry/";
|
|
||||||
|
|
||||||
void setup(void) {
|
|
||||||
Serial.begin(115200);
|
|
||||||
|
|
||||||
StaticJsonDocument<64> api;
|
|
||||||
|
|
||||||
preferences.begin("iot");
|
|
||||||
// Get the serial number from flash
|
|
||||||
serial = strdup(preferences.getString("serial").c_str());
|
|
||||||
|
|
||||||
// Get network configuration
|
|
||||||
size_t _len = preferences.getBytesLength("config");
|
|
||||||
char _buffer[_len];
|
|
||||||
preferences.getBytes("config", &_buffer, _len);
|
|
||||||
memcpy(&config, _buffer, _len);
|
|
||||||
preferences.end();
|
|
||||||
|
|
||||||
// Get WiFi parameters
|
|
||||||
preferences.begin("wifi");
|
|
||||||
const char* _ssid = strdup(preferences.getString("ssid").c_str());
|
|
||||||
const char* _password = strdup(preferences.getString("password").c_str());
|
|
||||||
preferences.end();
|
|
||||||
|
|
||||||
Serial.print("Starting connecting WiFi to ");
|
|
||||||
Serial.print(_ssid);
|
|
||||||
delay(10);
|
|
||||||
WiFi.begin(_ssid, _password);
|
|
||||||
while (WiFi.status() != WL_CONNECTED) {
|
|
||||||
delay(500);
|
|
||||||
Serial.print(".");
|
|
||||||
}
|
|
||||||
Serial.println("\nWiFi connected");
|
|
||||||
|
|
||||||
Serial.print("IoT #");
|
|
||||||
Serial.print(serial);
|
|
||||||
Serial.print(" at address: ");
|
|
||||||
Serial.println(WiFi.localIP());
|
|
||||||
Serial.println();
|
|
||||||
Serial.print("Connecting to: ");
|
|
||||||
Serial.print(config.address.toString());
|
|
||||||
Serial.print(":");
|
|
||||||
Serial.print(config.port);
|
|
||||||
Serial.print(" every ");
|
|
||||||
Serial.print(TELEMETRY_DELAY);
|
|
||||||
Serial.println("s");
|
|
||||||
|
|
||||||
#if USE_INTERNAL_NTP
|
|
||||||
timeClient.setPoolServerIP(config.address);
|
|
||||||
#endif
|
|
||||||
timeClient.begin();
|
|
||||||
if (timeClient.update()) {
|
|
||||||
NTPValid = true;
|
|
||||||
}
|
|
||||||
|
|
||||||
#if DEBUG_TO_SERIAL
|
|
||||||
Serial.println("DEBUG: clock updated via NTP.");
|
|
||||||
#endif
|
|
||||||
|
|
||||||
api["serial"] = serial;
|
|
||||||
postData(config, apiURL, api);
|
|
||||||
|
|
||||||
telemetry["device"] = serial;
|
|
||||||
// payload["id"] = serverName;
|
|
||||||
|
|
||||||
#if USE_MQTT
|
|
||||||
clientMQTT.setServer(config.address, 1883);
|
|
||||||
#endif
|
|
||||||
}
|
|
||||||
|
|
||||||
void loop(void) {
|
|
||||||
const int postDelay = TELEMETRY_DELAY * 1000;
|
|
||||||
|
|
||||||
if (NTPValid) {
|
|
||||||
telemetry["clock"] = timeClient.getEpochTime();
|
|
||||||
} else {
|
|
||||||
telemetry["clock"] = NULL; // converted into 0
|
|
||||||
}
|
|
||||||
|
|
||||||
payload["hall"] = hallRead();
|
|
||||||
payload["wifi-rssi"] = WiFi.RSSI();
|
|
||||||
|
|
||||||
#if USE_MQTT
|
|
||||||
publishData(config, telemetry);
|
|
||||||
#else
|
|
||||||
postData(config, telemetryURL, telemetry);
|
|
||||||
#endif
|
|
||||||
|
|
||||||
if (counter == 6 * 120) { // Update clock every 6 times * 10 sec * 120 minutes = 2 hrs
|
|
||||||
timeClient.update();
|
|
||||||
counter = 0;
|
|
||||||
#if DEBUG_TO_SERIAL
|
|
||||||
Serial.println("DEBUG: clock updated via NTP.");
|
|
||||||
#endif
|
|
||||||
} else {
|
|
||||||
counter++;
|
|
||||||
}
|
|
||||||
|
|
||||||
delay(postDelay);
|
|
||||||
}
|
|
||||||
|
|
||||||
#if USE_MQTT
|
|
||||||
void publishData(const netConfig &mqtt, const DynamicJsonDocument &json) {
|
|
||||||
if (clientMQTT.connect(serial)) {
|
|
||||||
char buffer[256];
|
|
||||||
serializeJson(json, buffer);
|
|
||||||
clientMQTT.publish(serial, buffer);
|
|
||||||
|
|
||||||
#if DEBUG_TO_SERIAL
|
|
||||||
Serial.println("DEBUG: MQTT PUBLISH>>>");
|
|
||||||
serializeJsonPretty(json, Serial);
|
|
||||||
Serial.println("\n<<<");
|
|
||||||
#endif
|
|
||||||
}
|
|
||||||
}
|
|
||||||
#endif
|
|
||||||
|
|
||||||
void postData(const netConfig &postAPI, const String &URL, const DynamicJsonDocument &json) {
|
|
||||||
if (ethClient.connect(postAPI.address, postAPI.port)) {
|
|
||||||
ethClient.print("POST ");
|
|
||||||
ethClient.print(URL);
|
|
||||||
ethClient.println(" HTTP/1.1");
|
|
||||||
ethClient.print("Host: ");
|
|
||||||
ethClient.print(postAPI.address.toString());
|
|
||||||
ethClient.print(":");
|
|
||||||
ethClient.println(postAPI.port);
|
|
||||||
ethClient.println("Content-Type: application/json");
|
|
||||||
ethClient.print("Content-Length: ");
|
|
||||||
ethClient.println(measureJson(json));
|
|
||||||
ethClient.println("Connection: close");
|
|
||||||
ethClient.println();
|
|
||||||
serializeJson(json, ethClient);
|
|
||||||
ethClient.stop();
|
|
||||||
|
|
||||||
#if DEBUG_TO_SERIAL
|
|
||||||
Serial.println("DEBUG: HTTP POST>>>");
|
|
||||||
serializeJsonPretty(json, Serial);
|
|
||||||
Serial.println("\n<<<");
|
|
||||||
#endif
|
|
||||||
}
|
|
||||||
}
|
|
Loading…
Reference in New Issue
Block a user