-
Notifications
You must be signed in to change notification settings - Fork 7.6k
WifiMulti resilience updates #2775
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Changes from 3 commits
f8eaa42
d5b229c
0fab2f8
fa7d1be
a406a3f
f2b2ff9
3c5ecab
15af6ef
592079e
d0d4d17
838b075
c587b44
19ad37e
File filter
Filter by extension
Conversations
Jump to
Diff view
Diff view
There are no files selected for viewing
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,47 @@ | ||
/* | ||
* This sketch tries to connect to the best AP available, and tests for captive portals on open networks | ||
* | ||
*/ | ||
|
||
#include <WiFi.h> | ||
#include <WiFiMulti.h> | ||
|
||
WiFiMulti wifiMulti; | ||
|
||
bool bConnected = false; | ||
|
||
void setup() | ||
{ | ||
Serial.begin(115200); | ||
delay(10); | ||
|
||
wifiMulti.addAP("ssid_from_AP_1", "your_password_for_AP_1"); | ||
wifiMulti.addAP("ssid_from_AP_2", "your_password_for_AP_2"); | ||
wifiMulti.addAP("ssid_from_AP_3", "your_password_for_AP_3"); | ||
|
||
// These options can help when you need ANY kind of wifi connection to get a config file, report errors, etc. | ||
wifiMulti.setStrictMode(false); // Default is true. Library will disconnect and forget currently connected AP if it's not in the AP list. | ||
wifiMulti.setAllowOpenAP(true); // Default is false. True adds open APs to the list. | ||
wifiMulti.setTestConnection(true); // Default is false. Attempts to connect to a webserver in case of captive portals. Most useful with AllowOpenAP = true. | ||
|
||
// Optional - defaults to brainjar, but you should set this to a simple test page on your own server to ensure you can reach it | ||
// wifiMulti.setTestURL("http://www.brainjar.com/java/host/test.html"); // Must include http:// | ||
// wifiMulti.setTestPhrase("This is a very simple HTML file."); // Unique but short is best | ||
|
||
|
||
Serial.println("Connecting Wifi..."); | ||
if(wifiMulti.run() == WL_CONNECTED) { | ||
Serial.println(""); | ||
Serial.println("WiFi connected"); | ||
Serial.println("IP address: "); | ||
Serial.println(WiFi.localIP()); | ||
} | ||
} | ||
|
||
void loop() | ||
{ | ||
if( wifiMulti.run() != WL_CONNECTED) { | ||
Serial.println("WiFi not connected!"); | ||
delay(1000); | ||
} | ||
} | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. Could you please merge the master branch and resolve the conflicts ? |
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -48,10 +48,19 @@ uint8_t WiFiMulti::run(uint32_t connectTimeout) | |
int8_t scanResult; | ||
uint8_t status = WiFi.status(); | ||
if(status == WL_CONNECTED) { | ||
for(uint32_t x = 0; x < APlist.size(); x++) { | ||
if(WiFi.SSID()==APlist[x].ssid){ | ||
if (_bTestConnection && !_bWFMInit){ | ||
if (testConnection()) { | ||
_bWFMInit = true; | ||
return status; | ||
} | ||
} else if (!_bStrict) { | ||
return status; | ||
} else { | ||
for(uint32_t x = 0; x < APlist.size(); x++) { | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. since you don't need the index value this can be written as:
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. Much more elegant. I need to play with vectors more... |
||
if(WiFi.SSID()==APlist[x].ssid){ | ||
return status; | ||
} | ||
} | ||
} | ||
WiFi.disconnect(false,false); | ||
delay(10); | ||
|
@@ -62,10 +71,12 @@ uint8_t WiFiMulti::run(uint32_t connectTimeout) | |
if(scanResult == WIFI_SCAN_RUNNING) { | ||
// scan is running | ||
return WL_NO_SSID_AVAIL; | ||
} else if(scanResult >= 0) { | ||
} else if (scanResult >= 0) { | ||
// scan done analyze | ||
WifiAPlist_t bestNetwork { NULL, NULL }; | ||
int32_t bestIndex = 0; | ||
WifiAPlist_t bestNetwork { NULL, NULL, NULL }; | ||
int bestNetworkDb = INT_MIN; | ||
int bestNetworkSec; | ||
uint8_t bestBSSID[6]; | ||
int32_t bestChannel = 0; | ||
|
||
|
@@ -75,6 +86,9 @@ uint8_t WiFiMulti::run(uint32_t connectTimeout) | |
log_e("[WIFI] no networks found"); | ||
} else { | ||
log_i("[WIFI] %d networks found", scanResult); | ||
|
||
int8_t failCount = 0; | ||
int8_t foundCount = 0; | ||
for(int8_t i = 0; i < scanResult; ++i) { | ||
|
||
String ssid_scan; | ||
|
@@ -85,21 +99,47 @@ uint8_t WiFiMulti::run(uint32_t connectTimeout) | |
|
||
WiFi.getNetworkInfo(i, ssid_scan, sec_scan, rssi_scan, BSSID_scan, chan_scan); | ||
|
||
if (_bAllowOpenAP && sec_scan == WIFI_AUTH_OPEN){ | ||
bool found = false; | ||
for(uint32_t o = 0; o < APlist.size(); o++) { | ||
WifiAPlist_t check = APlist[o]; | ||
if (ssid_scan == check.ssid){ | ||
found = true; | ||
} | ||
} | ||
if (!found){ | ||
log_i("[WIFI] added %s to APList", ssid_scan); | ||
APlistAdd(ssid_scan.c_str()); | ||
// failCount++; | ||
// foundCount++; | ||
} | ||
} | ||
|
||
bool known = false; | ||
for(uint32_t x = 0; x < APlist.size(); x++) { | ||
WifiAPlist_t entry = APlist[x]; | ||
|
||
if(ssid_scan == entry.ssid) { // SSID match | ||
known = true; | ||
if(rssi_scan > bestNetworkDb) { // best network | ||
if(sec_scan == WIFI_AUTH_OPEN || entry.passphrase) { // check for passphrase if not open wlan | ||
bestNetworkDb = rssi_scan; | ||
bestChannel = chan_scan; | ||
memcpy((void*) &bestNetwork, (void*) &entry, sizeof(bestNetwork)); | ||
memcpy((void*) &bestBSSID, (void*) BSSID_scan, sizeof(bestBSSID)); | ||
|
||
if(ssid_scan == entry.ssid) { // It's on the list | ||
log_i("known ssid: %s, failed: %i", entry.ssid, entry.fail); | ||
foundCount++; | ||
if (!entry.fail){ | ||
known = true; | ||
log_i("rssi_scan: %d, bestNetworkDb: %d", rssi_scan, bestNetworkDb); | ||
if(rssi_scan > bestNetworkDb) { // best network | ||
if(_bAllowOpenAP || (sec_scan == WIFI_AUTH_OPEN || entry.passphrase)) { // check for passphrase if not open wlan | ||
log_i("best network is now: %s", ssid_scan); | ||
bestIndex = x; | ||
bestNetworkSec = sec_scan; | ||
bestNetworkDb = rssi_scan; | ||
bestChannel = chan_scan; | ||
memcpy((void*) &bestNetwork, (void*) &entry, sizeof(bestNetwork)); | ||
memcpy((void*) &bestBSSID, (void*) BSSID_scan, sizeof(bestBSSID)); | ||
} | ||
} | ||
break; | ||
} else { | ||
failCount++; | ||
} | ||
break; | ||
} | ||
} | ||
|
||
|
@@ -109,40 +149,66 @@ uint8_t WiFiMulti::run(uint32_t connectTimeout) | |
log_d(" %d: [%d][%02X:%02X:%02X:%02X:%02X:%02X] %s (%d) %c", i, chan_scan, BSSID_scan[0], BSSID_scan[1], BSSID_scan[2], BSSID_scan[3], BSSID_scan[4], BSSID_scan[5], ssid_scan.c_str(), rssi_scan, (sec_scan == WIFI_AUTH_OPEN) ? ' ' : '*'); | ||
} | ||
} | ||
log_i("foundCount = %d, failCount = %d", foundCount, failCount); | ||
|
||
if (foundCount == failCount){ | ||
failCount = 0; | ||
resetFails(); | ||
} | ||
foundCount = 0; | ||
} | ||
|
||
// clean up ram | ||
WiFi.scanDelete(); | ||
|
||
if(bestNetwork.ssid) { | ||
log_i("[WIFI] Connecting BSSID: %02X:%02X:%02X:%02X:%02X:%02X SSID: %s Channal: %d (%d)", bestBSSID[0], bestBSSID[1], bestBSSID[2], bestBSSID[3], bestBSSID[4], bestBSSID[5], bestNetwork.ssid, bestChannel, bestNetworkDb); | ||
log_i("[WIFI] Connecting BSSID: %02X:%02X:%02X:%02X:%02X:%02X SSID: %s Channel: %d (%d)", bestBSSID[0], bestBSSID[1], bestBSSID[2], bestBSSID[3], bestBSSID[4], bestBSSID[5], bestNetwork.ssid, bestChannel, bestNetworkDb); | ||
|
||
WiFi.begin(bestNetwork.ssid, bestNetwork.passphrase, bestChannel, bestBSSID); | ||
WiFi.begin(bestNetwork.ssid, (_bAllowOpenAP && bestNetworkSec == WIFI_AUTH_OPEN) ? NULL:bestNetwork.passphrase, bestChannel, bestBSSID); | ||
status = WiFi.status(); | ||
_bWFMInit = true; | ||
|
||
auto startTime = millis(); | ||
// wait for connection, fail, or timeout | ||
while(status != WL_CONNECTED && status != WL_NO_SSID_AVAIL && status != WL_CONNECT_FAILED && (millis() - startTime) <= connectTimeout) { | ||
delay(10); | ||
delay(100); | ||
status = WiFi.status(); | ||
} | ||
|
||
switch(status) { | ||
case 3: | ||
log_i("[WIFI] Connecting done."); | ||
log_d("[WIFI] SSID: %s", WiFi.SSID().c_str()); | ||
log_d("[WIFI] IP: %s", WiFi.localIP().toString().c_str()); | ||
log_d("[WIFI] MAC: %s", WiFi.BSSIDstr().c_str()); | ||
log_d("[WIFI] Channel: %d", WiFi.channel()); | ||
|
||
if (_bTestConnection){ | ||
// We connected to an AP but if it's a captive portal we're not going anywhere. Test it. | ||
if (testConnection()){ | ||
resetFails(); | ||
} else { | ||
markAsFailed(bestIndex); | ||
WiFi.disconnect(false,false); | ||
delay(100); | ||
status = WiFi.status(); | ||
} | ||
} else { | ||
resetFails(); | ||
} | ||
|
||
break; | ||
case 1: | ||
log_e("[WIFI] Connecting Failed AP not found."); | ||
markAsFailed(bestIndex); | ||
break; | ||
case 4: | ||
log_e("[WIFI] Connecting Failed."); | ||
markAsFailed(bestIndex); | ||
break; | ||
default: | ||
log_e("[WIFI] Connecting Failed (%d).", status); | ||
markAsFailed(bestIndex); | ||
break; | ||
} | ||
} else { | ||
|
@@ -161,6 +227,82 @@ uint8_t WiFiMulti::run(uint32_t connectTimeout) | |
return status; | ||
} | ||
|
||
void WiFiMulti::markAsFailed(int32_t i) { | ||
APlist[i].fail = true; | ||
log_i("marked %s as failed",APlist[i].ssid); | ||
} | ||
|
||
|
||
void WiFiMulti::resetFails(){ | ||
log_i("resetting failure flags"); | ||
for(uint32_t i = 0; i < APlist.size(); i++) { | ||
APlist[i].fail = false; | ||
} | ||
} | ||
|
||
void WiFiMulti::setStrictMode(bool bStrict) { | ||
_bStrict = bStrict; | ||
} | ||
|
||
void WiFiMulti::setAllowOpenAP(bool bAllowOpenAP) { | ||
_bAllowOpenAP = bAllowOpenAP; | ||
} | ||
|
||
void WiFiMulti::setTestConnection(bool bTestConnection){ | ||
_bTestConnection = bTestConnection; | ||
} | ||
void WiFiMulti::setTestPhrase(const char* testPhrase){ | ||
_testPhrase = testPhrase; | ||
} | ||
void WiFiMulti::setTestURL(String testURL){ | ||
_testURL = testURL; | ||
} | ||
|
||
bool WiFiMulti::testConnection(){ | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. why not add the URL as an argument (defaulting to NULL) and then parse it to get the port and so on? There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. I figured most people would just want to turn it on and forget it so I defaulted the test URL and phrase to amazon which I thought would be universal. |
||
//parse url | ||
int8_t split = _testURL.indexOf('/',7); | ||
String host = _testURL.substring(7, split); | ||
String url = _testURL.substring(split,_testURL.length()); | ||
|
||
log_i("Testing connection to %s. Test phrase is \"%s\"",_testURL.c_str(), _testPhrase.c_str()); | ||
// Use WiFiClient class to create TCP connections | ||
WiFiClient client; | ||
const int httpPort = 80; | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. port needs to be dynamically determined from the test url, it is not guaranteed that all servers will expose port 80 (most are moving to https as a default) There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. Hmm. Can I make an https request directly from wifiClient? I'm trying to keep it simple by not including more libraries than necessary. I'm assuming anyone using this function would set the test page manually. Still, if you feel this is important I'll modify it. There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. true, but if a user sets a url with https it would likely fail here as well There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. Yeah. In my example I specify that it must be http://. Need to think it through a bit more. |
||
if (!client.connect(host.c_str(), httpPort)) { | ||
log_e("Connection failed"); | ||
return false; | ||
} else { | ||
log_i("Connected to test host"); | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. at this point it should be possible to close the connection without reading the actual data since the point of this is to check that the connection to the internet is successful. There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. See above. I would rather skip the text check to make it simpler. Just need to make sure we don't get trapped. If this device gets onto xfinitywifi here it doesn't want to get off. There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. yeah, ideally this would exit once it receives the initial http header details (all lines until a blank line IIRC). Once the header has been received the connection can be closed. I'd recommend read by line and check the line for known keywords (Location: XXX, HTTP XXX 200|302 etc...) That way you can abort earlier from the line by line checking. There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. I agree with @atanisoft here :) there are some codes that show all is good. There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. actually what is the target? which codes would mean that something went bad? There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. All I am trying to do is ensure that the device can actually reach the internet - captive portals are the problem. If you're connected to Wifi but behind a captive portal you're not going anywhere. This functionality is most useful when you have bAllowOpenAP, which automatically connects to any and all open APs in addition to the ones in your list just to get online. In my case, once it's online it connects to my server, grabs a config file with the correct SSID information then turns bAllowOpenAP off and bStrictMode on. It's good functionality to put 1000 brand new devices online just by plugging them in and setting your AP to open mode for 15 minutes. I'm looking for anything but a 304 by default, but if that isn't good enough, you can set your own URL and look for any test phrase that you want, including text in a webpage. By default I don't want to look for 200's either in case a captive portal happens to return that. Looking for a permanent redirect seems like the best solution because a captive portal wouldn't do that and a site like google or amazon should be available everywhere. |
||
} | ||
|
||
// This will send the request to the server | ||
client.print(String("GET ") + url + " HTTP/1.1\r\n" + | ||
"Host: " + host + "\r\n" + | ||
"Connection: close\r\n\r\n"); | ||
unsigned long timeout = millis(); | ||
while (client.available() == 0) { | ||
if (millis() - timeout > 5000) { | ||
log_e(">>>Client timeout!"); | ||
client.stop(); | ||
return false; | ||
} | ||
} | ||
bool bSuccess = false; | ||
// Read all the lines of the reply from server and print them to Serial | ||
while(client.available()) { | ||
// String line = client.readStringUntil('\r'); | ||
// Serial.print(line); | ||
bSuccess = client.find(_testPhrase.c_str()); | ||
if (bSuccess){ | ||
log_i("Success. Found test phrase"); | ||
} else { | ||
log_e("Failed. Can't find test phrase"); | ||
} | ||
return bSuccess; | ||
} | ||
|
||
} | ||
|
||
// ################################################################################## | ||
|
||
bool WiFiMulti::APlistAdd(const char* ssid, const char *passphrase) | ||
|
@@ -170,13 +312,13 @@ bool WiFiMulti::APlistAdd(const char* ssid, const char *passphrase) | |
|
||
if(!ssid || *ssid == 0x00 || strlen(ssid) > 31) { | ||
// fail SSID to long or missing! | ||
log_e("[WIFI][APlistAdd] no ssid or ssid to long"); | ||
log_e("[WIFI][APlistAdd] no ssid or ssid too long"); | ||
return false; | ||
} | ||
|
||
if(passphrase && strlen(passphrase) > 63) { | ||
// fail passphrase to long! | ||
log_e("[WIFI][APlistAdd] passphrase to long"); | ||
log_e("[WIFI][APlistAdd] passphrase too long"); | ||
return false; | ||
} | ||
|
||
|
@@ -197,9 +339,11 @@ bool WiFiMulti::APlistAdd(const char* ssid, const char *passphrase) | |
} else { | ||
newAP.passphrase = NULL; | ||
} | ||
|
||
newAP.fail = false; | ||
|
||
APlist.push_back(newAP); | ||
log_i("[WIFI][APlistAdd] add SSID: %s", newAP.ssid); | ||
log_i("[WIFI][APlistAdd] added SSID: %s", newAP.ssid); | ||
return true; | ||
} | ||
|
||
|
@@ -213,6 +357,8 @@ void WiFiMulti::APlistClean(void) | |
if(entry.passphrase) { | ||
free(entry.passphrase); | ||
} | ||
//why doesn't this work??? | ||
//free(entry.fail); | ||
} | ||
APlist.clear(); | ||
} | ||
|
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -32,6 +32,7 @@ | |
typedef struct { | ||
char * ssid; | ||
char * passphrase; | ||
bool fail; | ||
} WifiAPlist_t; | ||
|
||
class WiFiMulti | ||
|
@@ -42,12 +43,32 @@ class WiFiMulti | |
|
||
bool addAP(const char* ssid, const char *passphrase = NULL); | ||
|
||
void setStrictMode(bool bStrict); | ||
void setAllowOpenAP(bool bAllowOpenAP); | ||
void setTestConnection(bool bTestConnection); | ||
void setTestPhrase(const char* testPhrase); | ||
void setTestURL(String url); | ||
|
||
uint8_t run(uint32_t connectTimeout=5000); | ||
|
||
void APlistClean(void); | ||
|
||
private: | ||
std::vector<WifiAPlist_t> APlist; | ||
|
||
bool _bStrict = true; | ||
bool _bAllowOpenAP = false; | ||
bool _bTestConnection = false; | ||
String _testPhrase = "simple HTML file."; | ||
String _testURL = "http://www.brainjar.com/java/host/test.html"; | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. It may be better to default this to www.google.com or similar that returns a very small page. Checking the actual content is not super critical to test that the connection was successful to the remote endpoint, just that a connection to the remote was successful. There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. I was/am concerned that a captive portal would return 200 and fool me. This test is almost purely to skip captive portals. I test it with the xfinitywifi AP at the office, but it could be the Starbucks next door. Thoughts? I wonder if looking for a 302 header would be better... There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. perhaps checking for a 302 would work as well. The ultimate goal would be to avoid downloading the full response when it is not needed in most cases. Only the first few lines of the response will be needed to detect a redirect or if it is a general 200. Having client.find() will result in a lot of heap usage for the duration of the find and it may not even find the string. There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. will client.find() abort as soon as it finds the target string? 302 Found in this case There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. Make that 200 OK... I updated the h file. |
||
bool _bWFMInit = false; | ||
|
||
void markAsFailed(int32_t i); | ||
void resetFails(); | ||
|
||
bool testConnection(); | ||
bool APlistAdd(const char* ssid, const char *passphrase = NULL); | ||
void APlistClean(void); | ||
|
||
|
||
}; | ||
|
||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.