PiedThon/arduino.cpp

203 lines
4.8 KiB
C++
Raw Normal View History

2019-11-20 20:13:47 +00:00
/***
Fuz Piedthon
Pedestrian traffic lights, green and red, controlled over MQTT
Board: ESP8266
*/
2019-11-20 20:13:47 +00:00
#include <Arduino.h>
2019-11-22 20:21:54 +00:00
#include <ESP8266mDNS.h>
#include <WiFiUdp.h>
#include <ArduinoOTA.h>
2019-11-20 20:13:47 +00:00
/// Pins configuration
#define GPIO_VERT 14
#define GPIO_ROUGE 16
/// MQTT Config
#define MQTT_SERVER "sonic.fuz.re"
#define MQTT_SERVERPORT 1883
2019-11-22 20:21:54 +00:00
#define ESP_HOSTNAME "piedthon"
2019-11-20 20:13:47 +00:00
#include "WifiCredFuz.cpp" // Wifi and MQTT Credentials
/* with
#define WLAN_SSID ""
#define WLAN_PASS ""
#define MQTT_USERNAME "" //omg no user
#define MQTT_KEY "" //omg no key
2019-11-20 20:13:47 +00:00
*/
/// End of user config
/// Wifi
#include <ESP8266WiFi.h>
WiFiClient client;
void setupWifi() {
// Connect to WiFi access point.
Serial.print("Connecting to ");
Serial.println(WLAN_SSID);
2019-11-20 20:13:47 +00:00
WiFi.begin(WLAN_SSID, WLAN_PASS);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
}
Serial.println();
2019-11-20 20:13:47 +00:00
Serial.print("WiFi connected");
Serial.print(" IP address: ");
Serial.println(WiFi.localIP());
2019-11-20 20:13:47 +00:00
}
/// MQTT
#include "Adafruit_MQTT.h"
#include "Adafruit_MQTT_Client.h"
/************ Global State (you don't need to change this!) ******************/
// Setup the MQTT client class by passing in the WiFi client and MQTT server and login details.
Adafruit_MQTT_Client mqtt(&client, MQTT_SERVER, MQTT_SERVERPORT, MQTT_USERNAME, MQTT_KEY);
/****************************** Feeds ***************************************/
2019-11-22 20:21:54 +00:00
// Setup a feed called 'pub_piedthon' for publishing.
Adafruit_MQTT_Publish pub_piedthon = Adafruit_MQTT_Publish(&mqtt, "piedthon/debug");
2019-11-20 20:13:47 +00:00
// Setup a feed called 'sub_piedthon' for subscribing to changes.
Adafruit_MQTT_Subscribe sub_piedthon = Adafruit_MQTT_Subscribe(&mqtt, "piedthon/input");
char *mqtt_message;
// Function to connect and reconnect as necessary to the MQTT server.
void MQTT_connect() {
int8_t ret;
// Stop if already connected.
if (mqtt.connected()) {
return;
}
Serial.print("Connecting to MQTT... ");
uint8_t retries = 3;
while ((ret = mqtt.connect()) != 0) { // connect will return 0 for connected
Serial.println(mqtt.connectErrorString(ret));
Serial.println("Retrying MQTT connection in 5 seconds...");
mqtt.disconnect();
delay(5000); // wait 5 seconds
retries--;
if (retries == 0) {
// basically die and wait for WDT to reset me
Serial.println("Fail to connect to MQTT after 3 tries ... ");
return; // will recall the function
2019-11-20 20:13:47 +00:00
}
}
Serial.println("MQTT Connected!");
2019-11-20 20:13:47 +00:00
}
/// PiedThon
void messageToPiedthon(char *msg) {
// Clignotement ? deux en même temps ?
switch (msg[0]) {
// LOW active le relay
case '0' : // Rouge et Vert
digitalWrite(GPIO_ROUGE, LOW);
digitalWrite(GPIO_VERT, LOW);
break;
case '1' : // ROUGE
digitalWrite(GPIO_VERT, HIGH);
digitalWrite(GPIO_ROUGE, LOW);
break;
case '2' : // VERT
digitalWrite(GPIO_VERT, LOW);
digitalWrite(GPIO_ROUGE, HIGH);
break;
2019-11-22 20:21:54 +00:00
case '3' : // Rien
digitalWrite(GPIO_ROUGE, HIGH);
digitalWrite(GPIO_VERT, HIGH);
break;
}
2019-11-20 20:13:47 +00:00
}
//// Bug workaround for Arduino 1.6.6, it seems to need a function declaration
//// for some reason (only affects ESP8266, likely an arduino-builder bug).
//void MQTT_connect();
void setup() {
Serial.begin(115200);
delay(10);
Serial.println(F("Adafruit MQTT PiedThon remix"));
2019-11-20 20:13:47 +00:00
pinMode(GPIO_VERT, OUTPUT);
pinMode(GPIO_ROUGE, OUTPUT);
2019-11-20 20:13:47 +00:00
2019-11-22 20:21:54 +00:00
randomSeed(analogRead(0));
setupWifi();
2019-11-20 20:13:47 +00:00
// Setup MQTT subscription for onoff feed.
mqtt.subscribe(&sub_piedthon);
2019-11-22 20:21:54 +00:00
ArduinoOTA.setHostname(ESP_HOSTNAME);
ArduinoOTA.onStart([]() { // switch off all the GPIOs during upgrade
digitalWrite(GPIO_ROUGE, HIGH);
digitalWrite(GPIO_VERT, HIGH);
});
ArduinoOTA.onProgress([](unsigned int progress, unsigned int total) {
/*if (progress % (total / 4) == 0) {
digitalWrite(GPIO_ROUGE, random(2) ? LOW : HIGH);
digitalWrite(GPIO_VERT, random(2) ? LOW : HIGH);
}*/
});
ArduinoOTA.onEnd([]() { // do a fancy thing with our board led at end
for (int i = 0; i < 10; i++) {
int RANDOM_GPIO = GPIO_ROUGE;
if (random(2)) { // random(2) returns 0 or 1 randomly
RANDOM_GPIO = GPIO_VERT;
}
digitalWrite(RANDOM_GPIO, !digitalRead(RANDOM_GPIO));
delay(400);
}
digitalWrite(GPIO_ROUGE, LOW);
digitalWrite(GPIO_VERT, LOW);
});
ArduinoOTA.onError([](ota_error_t error) {
(void)error;
ESP.restart();
});
ArduinoOTA.begin();
2019-11-20 20:13:47 +00:00
}
void loop() {
MQTT_connect();
2019-11-22 20:21:54 +00:00
ArduinoOTA.handle();
2019-11-20 20:13:47 +00:00
Adafruit_MQTT_Subscribe *subscription;
while ((subscription = mqtt.readSubscription(5000))) {
if (subscription == &sub_piedthon) {
mqtt_message = (char *) sub_piedthon.lastread;
Serial.println("Got: " + String(mqtt_message));
messageToPiedthon(mqtt_message);
2019-11-20 20:13:47 +00:00
}
}
2019-11-20 20:13:47 +00:00
}