-
Notifications
You must be signed in to change notification settings - Fork 294
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
add adafruit io ssl/tls example for esp8266
- Loading branch information
1 parent
ac46745
commit c19e155
Showing
1 changed file
with
164 additions
and
0 deletions.
There are no files selected for viewing
164 changes: 164 additions & 0 deletions
164
examples/adafruitio_secure_esp8266/adafruitio_secure_esp8266.ino
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,164 @@ | ||
/*************************************************** | ||
Adafruit MQTT Library ESP8266 Adafruit IO SSL/TLS example | ||
Must use the latest version of ESP8266 Arduino from: | ||
https://github.com/esp8266/Arduino | ||
Works great with Adafruit's Huzzah ESP board & Feather | ||
----> https://www.adafruit.com/product/2471 | ||
----> https://www.adafruit.com/products/2821 | ||
Adafruit invests time and resources providing this open source code, | ||
please support Adafruit and open-source hardware by purchasing | ||
products from Adafruit! | ||
Written by Tony DiCola for Adafruit Industries. | ||
SSL/TLS additions by Todd Treece for Adafruit Industries. | ||
MIT license, all text above must be included in any redistribution | ||
****************************************************/ | ||
#include <ESP8266WiFi.h> | ||
#include "Adafruit_MQTT.h" | ||
#include "Adafruit_MQTT_Client.h" | ||
|
||
/************************* WiFi Access Point *********************************/ | ||
|
||
#define WLAN_SSID "...your SSID..." | ||
#define WLAN_PASS "...your password..." | ||
|
||
/************************* Adafruit.io Setup *********************************/ | ||
|
||
#define AIO_SERVER "io.adafruit.com" | ||
#define AIO_SERVERPORT 8883 // 8883 for MQTTS | ||
#define AIO_USERNAME "...your AIO username (see https://accounts.adafruit.com)..." | ||
#define AIO_KEY "...your AIO key..." | ||
|
||
/************ Global State (you don't need to change this!) ******************/ | ||
|
||
// WiFiFlientSecure for SSL/TLS support | ||
WiFiClientSecure client; | ||
|
||
// Store the MQTT server, username, and password in flash memory. | ||
// This is required for using the Adafruit MQTT library. | ||
const char MQTT_SERVER[] PROGMEM = AIO_SERVER; | ||
const char MQTT_USERNAME[] PROGMEM = AIO_USERNAME; | ||
const char MQTT_PASSWORD[] PROGMEM = AIO_KEY; | ||
|
||
// Setup the MQTT client class by passing in the WiFi client and MQTT server and login details. | ||
Adafruit_MQTT_Client mqtt(&client, MQTT_SERVER, AIO_SERVERPORT, MQTT_USERNAME, MQTT_PASSWORD); | ||
|
||
// io.adafruit.com SHA1 fingerprint | ||
const char* fingerprint = "26 96 1C 2A 51 07 FD 15 80 96 93 AE F7 32 CE B9 0D 01 55 C4"; | ||
|
||
/****************************** Feeds ***************************************/ | ||
|
||
// Setup a feed called 'photocell' for publishing. | ||
// Notice MQTT paths for AIO follow the form: <username>/feeds/<feedname> | ||
const char TEST_FEED[] PROGMEM = AIO_USERNAME "/feeds/test"; | ||
Adafruit_MQTT_Publish test = Adafruit_MQTT_Publish(&mqtt, TEST_FEED); | ||
|
||
/*************************** Sketch Code ************************************/ | ||
|
||
// 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 verifyFingerprint(); | ||
|
||
void setup() { | ||
Serial.begin(115200); | ||
delay(10); | ||
|
||
Serial.println(F("Adafruit IO MQTTS (SSL/TLS) Example")); | ||
|
||
// Connect to WiFi access point. | ||
Serial.println(); Serial.println(); | ||
Serial.print("Connecting to "); | ||
Serial.println(WLAN_SSID); | ||
|
||
delay(1000); | ||
|
||
WiFi.begin(WLAN_SSID, WLAN_PASS); | ||
delay(2000); | ||
|
||
while (WiFi.status() != WL_CONNECTED) { | ||
delay(500); | ||
Serial.print("."); | ||
} | ||
Serial.println(); | ||
|
||
Serial.println("WiFi connected"); | ||
Serial.println("IP address: "); Serial.println(WiFi.localIP()); | ||
|
||
// check the fingerprint of io.adafruit.com's SSL cert | ||
verifyFingerprint(); | ||
|
||
} | ||
|
||
uint32_t x=0; | ||
|
||
void loop() { | ||
// Ensure the connection to the MQTT server is alive (this will make the first | ||
// connection and automatically reconnect when disconnected). See the MQTT_connect | ||
// function definition further below. | ||
MQTT_connect(); | ||
|
||
// Now we can publish stuff! | ||
Serial.print(F("\nSending val ")); | ||
Serial.print(x); | ||
Serial.print(F(" to test feed...")); | ||
if (! test.publish(x++)) { | ||
Serial.println(F("Failed")); | ||
} else { | ||
Serial.println(F("OK!")); | ||
} | ||
|
||
} | ||
|
||
|
||
void verifyFingerprint() { | ||
|
||
const char* host = AIO_SERVER; | ||
|
||
Serial.print("Connecting to "); | ||
Serial.println(host); | ||
|
||
if (! client.connect(host, AIO_SERVERPORT)) { | ||
Serial.println("Connection failed. Halting execution."); | ||
while(1); | ||
} | ||
|
||
if (client.verify(fingerprint, host)) { | ||
Serial.println("Connection secure."); | ||
} else { | ||
Serial.println("Connection insecure! Halting execution."); | ||
while(1); | ||
} | ||
|
||
} | ||
|
||
// Function to connect and reconnect as necessary to the MQTT server. | ||
// Should be called in the loop function and it will take care if connecting. | ||
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 | ||
while (1); | ||
} | ||
} | ||
|
||
Serial.println("MQTT Connected!"); | ||
} |