This repository has been archived by the owner on Feb 4, 2023. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 30
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
### Releases v1.13.0 1. Add support to ESP32 boards using `LwIP W6100 Ethernet` 2. Fix bug of `_parseURL()`. Check [Bug with _parseURL() #21](khoih-prog/AsyncHTTPSRequest_Generic#21) 3. Improve `README.md` so that links can be used in other sites, such as `PIO`
- Loading branch information
1 parent
08d950e
commit cad009d
Showing
2 changed files
with
578 additions
and
0 deletions.
There are no files selected for viewing
308 changes: 308 additions & 0 deletions
308
...les/ESP32_W6100/AsyncHTTPMultiRequests_ESP32_W6100/AsyncHTTPMultiRequests_ESP32_W6100.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,308 @@ | ||
/**************************************************************************************************************************** | ||
AsyncHTTPMultiRequests_ESP32_W6100.ino - Dead simple AsyncHTTPRequest for ESP8266, ESP32 and currently STM32 with built-in LAN8742A Ethernet | ||
For ESP8266, ESP32 and STM32 with built-in LAN8742A Ethernet (Nucleo-144, DISCOVERY, etc) | ||
AsyncHTTPRequest_Generic is a library for the ESP8266, ESP32 and currently STM32 run built-in Ethernet WebServer | ||
Based on and modified from asyncHTTPrequest Library (https://github.com/boblemaire/asyncHTTPrequest) | ||
Built by Khoi Hoang https://github.com/khoih-prog/AsyncHTTPRequest_Generic | ||
Licensed under MIT license | ||
Copyright (C) <2018> <Bob Lemaire, IoTaWatt, Inc.> | ||
This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License | ||
as published bythe Free Software Foundation, either version 3 of the License, or (at your option) any later version. | ||
This program 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 General Public License for more details. | ||
You should have received a copy of the GNU General Public License along with this program. If not, see <https://www.gnu.org/licenses/>. | ||
*****************************************************************************************************************************/ | ||
//************************************************************************************************************ | ||
// | ||
// There are scores of ways to use AsyncHTTPRequest. The important thing to keep in mind is that | ||
// it is asynchronous and just like in JavaScript, everything is event driven. You will have some | ||
// reason to initiate an asynchronous HTTP request in your program, but then sending the request | ||
// headers and payload, gathering the response headers and any payload, and processing | ||
// of that response, can (and probably should) all be done asynchronously. | ||
// | ||
// In this example, a Ticker function is setup to fire every 300 seconds to initiate a request. | ||
// Everything is handled in AsyncHTTPRequest without blocking. | ||
// The callback onReadyStateChange is made progressively and like most JS scripts, we look for | ||
// readyState == 4 (complete) here. At that time the response is retrieved and printed. | ||
// | ||
// Note that there is no code in loop(). A code entered into loop would run oblivious to | ||
// the ongoing HTTP requests. The Ticker could be removed and periodic calls to sendRequest() | ||
// could be made in loop(), resulting in the same asynchronous handling. | ||
// | ||
// For demo purposes, debug is turned on for handling of the first request. These are the | ||
// events that are being handled in AsyncHTTPRequest. They all begin with Debug(nnn) where | ||
// nnn is the elapsed time in milliseconds since the transaction was started. | ||
// | ||
//************************************************************************************************************* | ||
|
||
#if !( defined(ESP32) ) | ||
#error This code is intended to run on the ESP32 platform! Please check your Tools->Board setting. | ||
#endif | ||
|
||
// Level from 0-4 | ||
#define ASYNC_HTTP_DEBUG_PORT Serial | ||
#define _ASYNC_HTTP_LOGLEVEL_ 1 | ||
#define _ETHERNET_WEBSERVER_LOGLEVEL_ 1 | ||
|
||
// 300s = 5 minutes to not flooding | ||
#define HTTP_REQUEST_INTERVAL 60 //300 | ||
|
||
// 10s | ||
#define HEARTBEAT_INTERVAL 10 | ||
|
||
////////////////////////////////////////////////////////// | ||
|
||
// Optional values to override default settings | ||
// Don't change unless you know what you're doing | ||
//#define ETH_SPI_HOST SPI3_HOST | ||
//#define SPI_CLOCK_MHZ 25 | ||
|
||
// Must connect INT to GPIOxx or not working | ||
//#define INT_GPIO 4 | ||
|
||
//#define MISO_GPIO 19 | ||
//#define MOSI_GPIO 23 | ||
//#define SCK_GPIO 18 | ||
//#define CS_GPIO 5 | ||
|
||
////////////////////////////////////////////////////////// | ||
|
||
#include <WebServer_ESP32_W6100.h> // https://github.com/khoih-prog/WebServer_ESP32_W6100 | ||
|
||
#define ASYNC_HTTP_REQUEST_GENERIC_VERSION_MIN_TARGET "AsyncHTTPRequest_Generic v1.12.0" | ||
#define ASYNC_HTTP_REQUEST_GENERIC_VERSION_MIN 1012000 | ||
|
||
// Uncomment for certain HTTP site to optimize | ||
//#define NOT_SEND_HEADER_AFTER_CONNECTED true | ||
|
||
// To be included only in main(), .ino with setup() to avoid `Multiple Definitions` Linker Error | ||
#include <AsyncHTTPRequest_Generic.h> // https://github.com/khoih-prog/AsyncHTTPRequest_Generic | ||
|
||
#include <Ticker.h> | ||
|
||
AsyncHTTPRequest request; | ||
Ticker ticker; | ||
Ticker ticker1; | ||
|
||
///////////////////////////////////////////// | ||
|
||
// Enter a MAC address and IP address for your controller below. | ||
#define NUMBER_OF_MAC 20 | ||
|
||
byte mac[][NUMBER_OF_MAC] = | ||
{ | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0x01 }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xBE, 0x02 }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0x03 }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xBE, 0x04 }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0x05 }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xBE, 0x06 }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0x07 }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xBE, 0x08 }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0x09 }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xBE, 0x0A }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0x0B }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xBE, 0x0C }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0x0D }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xBE, 0x0E }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0x0F }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xBE, 0x10 }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0x11 }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xBE, 0x12 }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0x13 }, | ||
{ 0xDE, 0xAD, 0xBE, 0xEF, 0xBE, 0x14 }, | ||
}; | ||
|
||
// Select the IP address according to your local network | ||
IPAddress myIP(192, 168, 2, 232); | ||
IPAddress myGW(192, 168, 2, 1); | ||
IPAddress mySN(255, 255, 255, 0); | ||
|
||
// Google DNS Server IP | ||
IPAddress myDNS(8, 8, 8, 8); | ||
|
||
///////////////////////////////////////////// | ||
|
||
void heartBeatPrint(void) | ||
{ | ||
static int num = 1; | ||
|
||
if (ESP32_W6100_isConnected()) | ||
Serial.print(F("H")); // H means connected to WiFi | ||
else | ||
Serial.print(F("F")); // F means not connected to WiFi | ||
|
||
if (num == 80) | ||
{ | ||
Serial.println(); | ||
num = 1; | ||
} | ||
else if (num++ % 10 == 0) | ||
{ | ||
Serial.print(F(" ")); | ||
} | ||
} | ||
|
||
// To replace with your real APP_API | ||
#define APP_API "SECRECT_APP_API" | ||
|
||
String requestPart1 = "http://api.openweathermap.org/data/2.5/onecall?lat=-24.32&lon=-46.9983"; | ||
String requestAPPID = "&appid=" + String(APP_API); | ||
|
||
// exclude fields: current,minutely,hourly,daily,alerts | ||
String requestCurrent = requestPart1 + "&exclude=minutely,hourly,daily,alerts" + requestAPPID; | ||
String requestMinutely = requestPart1 + "&exclude=current,hourly,daily,alerts" + requestAPPID; | ||
String requestHourly = requestPart1 + "&exclude=current,minutely,daily,alerts" + requestAPPID; | ||
String requestDaily = requestPart1 + "&exclude=current,minutely,hourly,alerts" + requestAPPID; | ||
String requestAlert = requestPart1 + "&exclude=current,minutely,hourly,daily" + requestAPPID; | ||
|
||
#define NUM_REQUESTS 5 | ||
|
||
const char* requestName[ NUM_REQUESTS ] = { "Current", "Minutely", "Hourly", "Daily", "Alert" }; | ||
|
||
const char* requestAll[ NUM_REQUESTS ] = { requestCurrent.c_str(), requestMinutely.c_str(), requestHourly.c_str(), requestDaily.c_str(), requestAlert.c_str() }; | ||
|
||
uint8_t requestIndex = 0; | ||
|
||
void sendRequest() | ||
{ | ||
static bool requestOpenResult; | ||
|
||
if (request.readyState() == readyStateUnsent || request.readyState() == readyStateDone) | ||
{ | ||
requestOpenResult = request.open("GET", requestAll[requestIndex] ); | ||
|
||
if (requestOpenResult) | ||
{ | ||
// Only send() if open() returns true, or crash | ||
request.send(); | ||
} | ||
else | ||
{ | ||
Serial.println("Can't send bad request"); | ||
} | ||
} | ||
else | ||
{ | ||
Serial.println("Can't send request"); | ||
} | ||
} | ||
|
||
void requestCB(void* optParm, AsyncHTTPRequest* request, int readyState) | ||
{ | ||
(void) optParm; | ||
|
||
if (readyState == readyStateDone) | ||
{ | ||
AHTTP_LOGDEBUG(F("\n**************************************")); | ||
AHTTP_LOGDEBUG1(F("Response Code = "), request->responseHTTPString()); | ||
|
||
if (request->responseHTTPcode() == 200) | ||
{ | ||
Serial.print(F("\n***************")); | ||
Serial.print(requestName[ requestIndex ]); | ||
Serial.println(F("***************")); | ||
Serial.println(request->responseText()); | ||
Serial.println(F("**************************************")); | ||
} | ||
|
||
#if 1 | ||
|
||
// Bypass hourly | ||
if (requestIndex == 1) | ||
requestIndex = 3; | ||
else | ||
requestIndex = (requestIndex + 1) % NUM_REQUESTS; | ||
|
||
#else | ||
// hourly too long, not display anyway. Not enough heap. | ||
requestIndex = (requestIndex + 1) % NUM_REQUESTS; | ||
#endif | ||
|
||
request->setDebug(false); | ||
} | ||
} | ||
|
||
|
||
void setup() | ||
{ | ||
// put your setup code here, to run once: | ||
Serial.begin(115200); | ||
|
||
while (!Serial && millis() < 5000); | ||
|
||
delay(200); | ||
|
||
Serial.print("\nStart AsyncHTTPMultiRequests_ESP32_W6100 on "); | ||
Serial.print(ARDUINO_BOARD); | ||
Serial.print(" with "); | ||
Serial.println(SHIELD_TYPE); | ||
Serial.println(WEBSERVER_ESP32_W6100_VERSION); | ||
Serial.println(ASYNC_HTTP_REQUEST_GENERIC_VERSION); | ||
|
||
Serial.setDebugOutput(true); | ||
|
||
#if defined(ASYNC_HTTP_REQUEST_GENERIC_VERSION_MIN) | ||
|
||
if (ASYNC_HTTP_REQUEST_GENERIC_VERSION_INT < ASYNC_HTTP_REQUEST_GENERIC_VERSION_MIN) | ||
{ | ||
Serial.print("Warning. Must use this example on Version equal or later than : "); | ||
Serial.println(ASYNC_HTTP_REQUEST_GENERIC_VERSION_MIN_TARGET); | ||
} | ||
|
||
#endif | ||
|
||
AHTTP_LOGWARN(F("Default SPI pinout:")); | ||
AHTTP_LOGWARN1(F("SPI_HOST:"), ETH_SPI_HOST); | ||
AHTTP_LOGWARN1(F("MOSI:"), MOSI_GPIO); | ||
AHTTP_LOGWARN1(F("MISO:"), MISO_GPIO); | ||
AHTTP_LOGWARN1(F("SCK:"), SCK_GPIO); | ||
AHTTP_LOGWARN1(F("CS:"), CS_GPIO); | ||
AHTTP_LOGWARN1(F("INT:"), INT_GPIO); | ||
AHTTP_LOGWARN1(F("SPI Clock (MHz):"), SPI_CLOCK_MHZ); | ||
AHTTP_LOGWARN(F("=========================")); | ||
|
||
/////////////////////////////////// | ||
|
||
// To be called before ETH.begin() | ||
ESP32_W6100_onEvent(); | ||
|
||
// start the ethernet connection and the server: | ||
// Use DHCP dynamic IP and random mac | ||
uint16_t index = millis() % NUMBER_OF_MAC; | ||
|
||
//bool begin(int MISO_GPIO, int MOSI_GPIO, int SCLK_GPIO, int CS_GPIO, int INT_GPIO, int SPI_CLOCK_MHZ, | ||
// int SPI_HOST, uint8_t *W6100_Mac = W6100_Default_Mac); | ||
//ETH.begin( MISO_GPIO, MOSI_GPIO, SCK_GPIO, CS_GPIO, INT_GPIO, SPI_CLOCK_MHZ, ETH_SPI_HOST ); | ||
ETH.begin( MISO_GPIO, MOSI_GPIO, SCK_GPIO, CS_GPIO, INT_GPIO, SPI_CLOCK_MHZ, ETH_SPI_HOST, mac[index] ); | ||
|
||
// Static IP, leave without this line to get IP via DHCP | ||
//bool config(IPAddress local_ip, IPAddress gateway, IPAddress subnet, IPAddress dns1 = 0, IPAddress dns2 = 0); | ||
//ETH.config(myIP, myGW, mySN, myDNS); | ||
|
||
ESP32_W6100_waitForConnect(); | ||
|
||
/////////////////////////////////// | ||
|
||
Serial.print(F("AsyncHTTPRequest @ IP : ")); | ||
Serial.println(ETH.localIP()); | ||
|
||
request.setDebug(false); | ||
|
||
request.onReadyStateChange(requestCB); | ||
ticker.attach(HTTP_REQUEST_INTERVAL, sendRequest); | ||
|
||
ticker1.attach(HEARTBEAT_INTERVAL, heartBeatPrint); | ||
|
||
// Send first request now | ||
sendRequest(); | ||
} | ||
|
||
void loop() | ||
{ | ||
} |
Oops, something went wrong.