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
|
||||
settings.h
|
||||
|
|
|
@ -20,19 +20,23 @@
|
|||
|
||||
#include <EEPROM.h>
|
||||
#include <Ethernet.h>
|
||||
#include "settings.h"
|
||||
|
||||
#define ERASE_FIRST 0
|
||||
|
||||
const byte mac[] = {
|
||||
0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0xED
|
||||
};
|
||||
const char serial[] = SERIAL;
|
||||
const char serial[] = "abcd1234";
|
||||
|
||||
struct netConfig {
|
||||
IPAddress address = REMOTE_IP;
|
||||
unsigned int port = REMOTE_PORT;
|
||||
} config;
|
||||
IPAddress address;
|
||||
unsigned int port;
|
||||
};
|
||||
|
||||
netConfig config = {
|
||||
{192, 168, 10, 123},
|
||||
80
|
||||
};
|
||||
|
||||
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(config.address);
|
||||
Serial.print(":");
|
||||
Serial.print(config.port);
|
||||
Serial.print(" every ");
|
||||
Serial.print(TELEMETRY_DELAY);
|
||||
Serial.println("s");
|
||||
Serial.println(config.port);
|
||||
|
||||
#if USE_INTERNAL_NTP
|
||||
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