Skip to content

Commit ad9e10e

Browse files
authored
Merge pull request #831 from LeeLeahy2/web-sockets
Web sockets: Split out into WebSockets.ino, support multiple connections
2 parents d01cc6f + dfc3e35 commit ad9e10e

File tree

7 files changed

+550
-385
lines changed

7 files changed

+550
-385
lines changed

Firmware/RTK_Everywhere/Developer.ino

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -304,6 +304,12 @@ void webServerVerifyTables() {}
304304
bool wifiAfterCommand(int cmdIndex){return false;}
305305
bool webServerIsRunning() {return false;}
306306

307+
//----------------------------------------
308+
// Web Sockets
309+
//----------------------------------------
310+
311+
bool webSocketsIsConnected() (return false;}
312+
307313
#endif // COMPILE_AP
308314

309315
//======================================================================

Firmware/RTK_Everywhere/RTK_Everywhere.ino

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -430,7 +430,7 @@ bool savePossibleSettings = true; // Save possible vs. available settings. See r
430430
//-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-
431431
#ifdef COMPILE_WIFI
432432
int packetRSSI;
433-
RTK_WIFI wifi(false); // wifi(false); is non-verbose. For verbose, change to wifi(true);
433+
RTK_WIFI wifi(false); // wifi(false); is non-verbose. For verbose, change to wifi(true);
434434
#endif // COMPILE_WIFI
435435

436436
// WiFi Globals - For other module direct access
@@ -708,7 +708,6 @@ char *incomingSettings;
708708
int incomingSettingsSpot;
709709
unsigned long timeSinceLastIncomingSetting;
710710
unsigned long lastDynamicDataUpdate;
711-
bool websocketConnected = false;
712711

713712
#ifdef COMPILE_WIFI
714713
#ifdef COMPILE_AP

Firmware/RTK_Everywhere/States.ino

Lines changed: 5 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -171,7 +171,7 @@ void stateUpdate()
171171
| Set fixedBase true
172172
| STATE_BASE_NOT_STARTED falls into
173173
| STATE_BASE_FIXED_NOT_STARTED
174-
|
174+
|
175175
V
176176
.-----------------------------------.
177177
startBase() | STATE_BASE_NOT_STARTED |
@@ -489,7 +489,7 @@ void stateUpdate()
489489
// Confirm receipt so the web interface stops sending the config blob
490490
if (settings.debugWebServer == true)
491491
systemPrintln("Sending receipt confirmation of settings");
492-
sendStringToWebsocket("confirmDataReceipt,1,");
492+
webSocketsSendString("confirmDataReceipt,1,");
493493

494494
// Disallow new data to flow from websocket while we are parsing the current data
495495
currentlyParsingData = true;
@@ -521,27 +521,19 @@ void stateUpdate()
521521
#ifdef COMPILE_WIFI
522522
#ifdef COMPILE_AP
523523
// Handle dynamic requests coming from web config page
524-
if (websocketConnected == true)
524+
if (webSocketsIsConnected() == true)
525525
{
526526
// Update the coordinates on the AP page
527527
if ((millis() - lastDynamicDataUpdate) > 1000)
528528
{
529529
lastDynamicDataUpdate = millis();
530-
createDynamicDataString(settingsCSV);
531-
532-
sendStringToWebsocket(settingsCSV);
530+
webSocketsSendSettings();
533531
}
534532

535533
// If a firmware version was requested, and obtained, report it back to the web page
536534
if (strlen(otaReportedVersion) > 0)
537535
{
538-
createFirmwareVersionString(settingsCSV);
539-
540-
if (settings.debugWebServer)
541-
systemPrintf("WebServer: Firmware version requested. Sending: %s\r\n", settingsCSV);
542-
543-
sendStringToWebsocket(settingsCSV);
544-
536+
webSocketsSendFirmwareVersion();
545537
otaReportedVersion[0] = '\0'; // Zero out the reported version
546538
}
547539
}

0 commit comments

Comments
 (0)