jeanjack/PiedThon
1
0
Fork 1
Code Issues Pull Requests 1 Releases Wiki Activity

Implement ArduinoOTA, format arduino.cpp #1

Merged
jeanjack merged 3 commits from Lomanic/PiedThon:arduinoota into master 2019-11-23 11:26:53 +00:00
Conversation 0 Commits 3 Files Changed 2 +78 -79
1 changed files with 78 additions and 79 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit e99219cc16 - Show all commits

157
arduino.cpp
View File

@ -1,10 +1,10 @@
/***
* Fuz Piedthon
* Pedestrian traffic lights, green and red, controlled over MQTT
* Board: ESP8266
*
*/
Fuz Piedthon
Pedestrian traffic lights, green and red, controlled over MQTT
Board: ESP8266
*/
#include <Arduino.h>
@ -22,10 +22,10 @@
#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
#define WLAN_SSID ""
#define WLAN_PASS ""
#define MQTT_USERNAME "" //omg no user
#define MQTT_KEY "" //omg no key
*/
/// End of user config
@ -38,20 +38,20 @@ WiFiClient client;
void setupWifi() {
// Connect to WiFi access point.
Serial.print("Connecting to ");
Serial.println(WLAN_SSID);
// Connect to WiFi access point.
Serial.print("Connecting to ");
Serial.println(WLAN_SSID);
WiFi.begin(WLAN_SSID, WLAN_PASS);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
}
Serial.println();
WiFi.begin(WLAN_SSID, WLAN_PASS);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
}
Serial.println();
Serial.print("WiFi connected");
Serial.print(" IP address: ");
Serial.println(WiFi.localIP());
Serial.print("WiFi connected");
Serial.print(" IP address: ");
Serial.println(WiFi.localIP());
}
/// MQTT
@ -78,55 +78,55 @@ char *mqtt_message;
// Function to connect and reconnect as necessary to the MQTT server.
void MQTT_connect() {
int8_t ret;
int8_t ret;
// Stop if already connected.
if (mqtt.connected()) {
return;
// 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
}
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
}
}
Serial.println("MQTT Connected!");
}
Serial.println("MQTT Connected!");
}
/// 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;
case '3'​ : // Rien
digitalWrite(GPIO_ROUGE, HIGH);
digitalWrite(GPIO_VERT, HIGH);
break;
}
// 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;
case '3' : // Rien
digitalWrite(GPIO_ROUGE, HIGH);
digitalWrite(GPIO_VERT, HIGH);
break;
}
}
//// Bug workaround for Arduino 1.6.6, it seems to need a function declaration
@ -136,31 +136,30 @@ void messageToPiedthon(char *msg) {
void setup() {
Serial.begin(115200);
delay(10);
Serial.println(F("Adafruit MQTT PiedThon remix"));
Serial.begin(115200);
delay(10);
Serial.println(F("Adafruit MQTT PiedThon remix"));
pinMode(GPIO_VERT, OUTPUT);
pinMode(GPIO_ROUGE, OUTPUT);
pinMode(GPIO_VERT, OUTPUT);
pinMode(GPIO_ROUGE, OUTPUT);
setupWifi();
setupWifi();
// Setup MQTT subscription for onoff feed.
mqtt.subscribe(&sub_piedthon);
// Setup MQTT subscription for onoff feed.
mqtt.subscribe(&sub_piedthon);
}
void loop() {
MQTT_connect();
MQTT_connect();
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);
}
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);
}
}
}