731 lines
28 KiB
C++
731 lines
28 KiB
C++
#include "netserver.h"
|
|
#include <SPIFFS.h>
|
|
|
|
#include "config.h"
|
|
#include "player.h"
|
|
#include "telnet.h"
|
|
#include "display.h"
|
|
#include "options.h"
|
|
#include "network.h"
|
|
#include "mqtt.h"
|
|
#include "controls.h"
|
|
#include <Update.h>
|
|
|
|
#ifndef MIN_MALLOC
|
|
#define MIN_MALLOC 24112
|
|
#endif
|
|
|
|
//#define CORS_DEBUG
|
|
|
|
NetServer netserver;
|
|
|
|
AsyncWebServer webserver(80);
|
|
AsyncWebSocket websocket("/ws");
|
|
AsyncUDP udp;
|
|
|
|
String processor(const String& var);
|
|
void handleUpload(AsyncWebServerRequest *request, String filename, size_t index, uint8_t *data, size_t len, bool final);
|
|
void handleUpdate(AsyncWebServerRequest *request, String filename, size_t index, uint8_t *data, size_t len, bool final);
|
|
void handleHTTPArgs(AsyncWebServerRequest * request);
|
|
void onWsEvent(AsyncWebSocket *server, AsyncWebSocketClient *client, AwsEventType type, void *arg, uint8_t *data, size_t len);
|
|
|
|
bool shouldReboot = false;
|
|
#ifdef MQTT_HOST
|
|
Ticker mqttplaylistticker;
|
|
bool mqttplaylistblock = false;
|
|
void mqttplaylistSend() {
|
|
mqttplaylistblock = true;
|
|
mqttplaylistticker.detach();
|
|
mqttPublishPlaylist();
|
|
mqttplaylistblock = false;
|
|
}
|
|
#endif
|
|
|
|
char* updateError() {
|
|
static char ret[140] = {0};
|
|
sprintf(ret, "Update failed with error (%d)<br /> %s", (int)Update.getError(), Update.errorString());
|
|
return ret;
|
|
}
|
|
|
|
bool NetServer::begin() {
|
|
importRequest = IMDONE;
|
|
irRecordEnable = false;
|
|
webserver.on("/", HTTP_ANY, handleHTTPArgs);
|
|
webserver.on(PLAYLIST_PATH, HTTP_GET, handleHTTPArgs);
|
|
webserver.on(INDEX_PATH, HTTP_GET, handleHTTPArgs);
|
|
webserver.on(SSIDS_PATH, HTTP_GET, handleHTTPArgs);
|
|
webserver.on("/upload", HTTP_POST, beginUpload, handleUpload);
|
|
webserver.on("/update", HTTP_GET, handleHTTPArgs);
|
|
webserver.on("/update", HTTP_POST, beginUpdate, handleUpdate);
|
|
webserver.on("/settings", HTTP_GET, handleHTTPArgs);
|
|
if (IR_PIN != 255) webserver.on("/ir", HTTP_GET, handleHTTPArgs);
|
|
webserver.serveStatic("/", SPIFFS, "/www/").setCacheControl("max-age=31536000");
|
|
#ifdef CORS_DEBUG
|
|
DefaultHeaders::Instance().addHeader(F("Access-Control-Allow-Origin"), F("*"));
|
|
DefaultHeaders::Instance().addHeader(F("Access-Control-Allow-Headers"), F("content-type"));
|
|
#endif
|
|
webserver.begin();
|
|
websocket.onEvent(onWsEvent);
|
|
webserver.addHandler(&websocket);
|
|
|
|
//echo -n "helle?" | socat - udp-datagram:255.255.255.255:44490,broadcast
|
|
if (udp.listen(44490)) {
|
|
udp.onPacket([](AsyncUDPPacket packet) {
|
|
if (strcmp((char*)packet.data(), "helle?") == 0)
|
|
packet.println(WiFi.localIP());
|
|
});
|
|
}
|
|
return true;
|
|
}
|
|
|
|
void NetServer::beginUpdate(AsyncWebServerRequest *request) {
|
|
shouldReboot = !Update.hasError();
|
|
AsyncWebServerResponse *response = request->beginResponse(200, "text/plain", shouldReboot ? "OK" : updateError());
|
|
response->addHeader("Connection", "close");
|
|
request->send(response);
|
|
}
|
|
|
|
void handleUpdate(AsyncWebServerRequest *request, String filename, size_t index, uint8_t *data, size_t len, bool final) {
|
|
if (!index) {
|
|
int target = (request->getParam("updatetarget", true)->value() == "spiffs") ? U_SPIFFS : U_FLASH;
|
|
Serial.printf("Update Start: %s\n", filename.c_str());
|
|
player.mode = STOPPED;
|
|
display.putRequest({NEWMODE, UPDATING});
|
|
if (!Update.begin(UPDATE_SIZE_UNKNOWN, target)) {
|
|
Update.printError(Serial);
|
|
request->send(200, "text/html", updateError());
|
|
}
|
|
}
|
|
if (!Update.hasError()) {
|
|
if (Update.write(data, len) != len) {
|
|
Update.printError(Serial);
|
|
request->send(200, "text/html", updateError());
|
|
}
|
|
}
|
|
if (final) {
|
|
if (Update.end(true)) {
|
|
Serial.printf("Update Success: %uB\n", index + len);
|
|
} else {
|
|
Update.printError(Serial);
|
|
request->send(200, "text/html", updateError());
|
|
}
|
|
}
|
|
}
|
|
|
|
void NetServer::beginUpload(AsyncWebServerRequest *request) {
|
|
if (request->hasParam("plfile", true, true)) {
|
|
netserver.importRequest = IMPL;
|
|
request->send(200);
|
|
} else if (request->hasParam("wifile", true, true)) {
|
|
netserver.importRequest = IMWIFI;
|
|
request->send(200);
|
|
} else {
|
|
request->send(404);
|
|
}
|
|
}
|
|
|
|
size_t NetServer::chunkedHtmlPageCallback(uint8_t* buffer, size_t maxLen, size_t index){
|
|
File requiredfile = SPIFFS.open(netserver.chunkedPathBuffer, "r");
|
|
if (!requiredfile) return 0;
|
|
size_t filesize = requiredfile.size();
|
|
size_t needread = filesize - index;
|
|
if (!needread) return 0;
|
|
size_t canread = (needread > maxLen) ? maxLen : needread;
|
|
DBGVB("[%s] seek to %d in %s and read %d bytes with maxLen=%d", __func__, index, netserver.chunkedPathBuffer, canread, maxLen);
|
|
requiredfile.seek(index, SeekSet);
|
|
requiredfile.read(buffer, canread);
|
|
index += canread;
|
|
if (requiredfile) requiredfile.close();
|
|
return canread;
|
|
}
|
|
|
|
void NetServer::chunkedHtmlPage(const String& contentType, AsyncWebServerRequest *request, const char * path, bool gzip) {
|
|
memset(chunkedPathBuffer, 0, sizeof(chunkedPathBuffer));
|
|
strlcpy(chunkedPathBuffer, path, sizeof(chunkedPathBuffer)-1);
|
|
PLOW();
|
|
AsyncWebServerResponse *response = request->beginChunkedResponse(contentType, chunkedHtmlPageCallback, processor);
|
|
xSemaphoreTake(player.playmutex, portMAX_DELAY);
|
|
request->send(response);
|
|
xSemaphoreGive(player.playmutex); PHIG();
|
|
}
|
|
/*
|
|
void NetServer::chunkedHtmlPage(const String& contentType, AsyncWebServerRequest *request, const char * path, bool gzip) {
|
|
static char pathbuffer[40] = { 0 };
|
|
strlcpy(pathbuffer, path, 39);
|
|
PLOW();
|
|
AsyncWebServerResponse *response = request->beginChunkedResponse(contentType, [](uint8_t *buffer, size_t maxLen, size_t index) -> size_t {
|
|
File requiredfile = SPIFFS.open(pathbuffer, "r");
|
|
if (!requiredfile) return 0;
|
|
size_t filesize = requiredfile.size();
|
|
size_t needread = filesize - index;
|
|
if (!needread) return 0;
|
|
size_t canread = (needread > maxLen) ? maxLen : needread;
|
|
DBGVB("[%s] seek to %d in %s and read %d bytes with maxLen=%d", __func__, index, pathbuffer, canread, maxLen);
|
|
requiredfile.seek(index, SeekSet);
|
|
requiredfile.read(buffer, canread);
|
|
index += canread;
|
|
if (requiredfile) requiredfile.close();
|
|
return canread;
|
|
}, processor); // AsyncWebServerResponse
|
|
|
|
xSemaphoreTake(player.playmutex, portMAX_DELAY);
|
|
request->send(response);
|
|
xSemaphoreGive(player.playmutex);
|
|
PHIG();
|
|
}
|
|
*/
|
|
void NetServer::loop() {
|
|
if (shouldReboot) {
|
|
Serial.println("Rebooting...");
|
|
delay(100);
|
|
ESP.restart();
|
|
}
|
|
websocket.cleanupClients();
|
|
//if (playlistrequest > 0) { requestOnChange(PLAYLIST, playlistrequest); playlistrequest = 0; } /* Cleanup this */
|
|
switch (importRequest) {
|
|
case IMPL: importPlaylist(); importRequest = IMDONE; break;
|
|
case IMWIFI: config.saveWifi(); importRequest = IMDONE; break;
|
|
default: break;
|
|
}
|
|
if (rssi < 255) requestOnChange(NRSSI, 0);
|
|
}
|
|
|
|
#if IR_PIN!=255
|
|
void NetServer::irToWs(const char* protocol, uint64_t irvalue) {
|
|
char buf[BUFLEN] = { 0 };
|
|
sprintf (buf, "{\"ircode\": %llu, \"protocol\": \"%s\"}", irvalue, protocol);
|
|
websocket.textAll(buf);
|
|
}
|
|
void NetServer::irValsToWs() {
|
|
if (!irRecordEnable) return;
|
|
char buf[BUFLEN] = { 0 };
|
|
sprintf (buf, "{\"irvals\": [%llu, %llu, %llu]}", config.ircodes.irVals[config.irindex][0], config.ircodes.irVals[config.irindex][1], config.ircodes.irVals[config.irindex][2]);
|
|
websocket.textAll(buf);
|
|
}
|
|
#endif
|
|
|
|
void NetServer::onWsMessage(void *arg, uint8_t *data, size_t len, uint8_t clientId) {
|
|
AwsFrameInfo *info = (AwsFrameInfo*)arg;
|
|
if (info->final && info->index == 0 && info->len == len && info->opcode == WS_TEXT) {
|
|
data[len] = 0;
|
|
char cmd[65], val[65];
|
|
if (config.parseWsCommand((const char*)data, cmd, val, 65)) {
|
|
if (strcmp(cmd, "getmode") == 0 ) { requestOnChange(GETMODE, clientId); return; }
|
|
if (strcmp(cmd, "getindex") == 0 ) { requestOnChange(GETINDEX, clientId); return; }
|
|
if (strcmp(cmd, "getsystem") == 0 ) { requestOnChange(GETSYSTEM, clientId); return; }
|
|
if (strcmp(cmd, "getscreen") == 0 ) { requestOnChange(GETSCREEN, clientId); return; }
|
|
if (strcmp(cmd, "gettimezone") == 0 ) { requestOnChange(GETTIMEZONE, clientId); return; }
|
|
if (strcmp(cmd, "getcontrols") == 0 ) { requestOnChange(GETCONTROLS, clientId); return; }
|
|
if (strcmp(cmd, "getweather") == 0 ) { requestOnChange(GETWEATHER, clientId); return; }
|
|
if (strcmp(cmd, "getactive") == 0 ) { requestOnChange(GETACTIVE, clientId); return; }
|
|
if (strcmp(cmd, "smartstart") == 0) {
|
|
byte valb = atoi(val);
|
|
config.store.smartstart = valb == 1 ? 1 : 2;
|
|
if (!player.isRunning() && config.store.smartstart == 1) config.store.smartstart = 0;
|
|
config.save();
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "audioinfo") == 0) {
|
|
byte valb = atoi(val);
|
|
config.store.audioinfo = valb;
|
|
config.save();
|
|
display.putRequest({NEWMODE, CLEAR}); display.putRequest({NEWMODE, PLAYER});
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "vumeter") == 0) {
|
|
byte valb = atoi(val);
|
|
config.store.vumeter = valb;
|
|
config.save();
|
|
display.putRequest({NEWMODE, CLEAR}); display.putRequest({NEWMODE, PLAYER});
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "softap") == 0) {
|
|
byte valb = atoi(val);
|
|
config.store.softapdelay = valb;
|
|
config.save();
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "invertdisplay") == 0) {
|
|
byte valb = atoi(val);
|
|
config.store.invertdisplay = valb;
|
|
config.save();
|
|
display.invert();
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "numplaylist") == 0) {
|
|
byte valb = atoi(val);
|
|
config.store.numplaylist = valb;
|
|
config.save();
|
|
display.putRequest({NEWMODE, CLEAR}); display.putRequest({NEWMODE, PLAYER});
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "fliptouch") == 0) {
|
|
byte valb = atoi(val);
|
|
config.store.fliptouch = valb == 1;
|
|
config.save();
|
|
flipTS();
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "dbgtouch") == 0) {
|
|
byte valb = atoi(val);
|
|
config.store.dbgtouch = valb == 1;
|
|
config.save();
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "flipscreen") == 0) {
|
|
byte valb = atoi(val);
|
|
config.store.flipscreen = valb;
|
|
config.save();
|
|
display.flip();
|
|
display.putRequest({NEWMODE, CLEAR}); display.putRequest({NEWMODE, PLAYER});
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "brightness") == 0) {
|
|
byte valb = atoi(val);
|
|
if (!config.store.dspon) requestOnChange(DSPON, 0);
|
|
config.store.brightness = valb;
|
|
config.setBrightness(true);
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "screenon") == 0) {
|
|
byte valb = atoi(val);
|
|
config.setDspOn(valb == 1);
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "contrast") == 0) {
|
|
byte valb = atoi(val);
|
|
config.store.contrast = valb;
|
|
config.save();
|
|
display.setContrast();
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "tzh") == 0) {
|
|
int vali = atoi(val);
|
|
config.store.tzHour = vali;
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "tzm") == 0) {
|
|
int vali = atoi(val);
|
|
config.store.tzMin = vali;
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "sntp2") == 0) {
|
|
strlcpy(config.store.sntp2, val, 35);
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "sntp1") == 0) {
|
|
strlcpy(config.store.sntp1, val, 35);
|
|
bool tzdone = false;
|
|
if (strlen(config.store.sntp1) > 0 && strlen(config.store.sntp2) > 0) {
|
|
configTime(config.store.tzHour * 3600 + config.store.tzMin * 60, config.getTimezoneOffset(), config.store.sntp1, config.store.sntp2);
|
|
tzdone = true;
|
|
} else if (strlen(config.store.sntp1) > 0) {
|
|
configTime(config.store.tzHour * 3600 + config.store.tzMin * 60, config.getTimezoneOffset(), config.store.sntp1);
|
|
tzdone = true;
|
|
}
|
|
if (tzdone) {
|
|
network.requestTimeSync(true);
|
|
config.save();
|
|
}
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "volsteps") == 0) {
|
|
uint8_t valb = atoi(val);
|
|
config.store.volsteps = valb;
|
|
config.save();
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "encacceleration") == 0) {
|
|
uint16_t valb = atoi(val);
|
|
setEncAcceleration(valb);
|
|
config.store.encacc = valb;
|
|
config.save();
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "irtlp") == 0) {
|
|
uint8_t valb = atoi(val);
|
|
setIRTolerance(valb);
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "showweather") == 0) {
|
|
uint8_t valb = atoi(val);
|
|
config.store.showweather = valb == 1;
|
|
config.save();
|
|
display.showWeather();
|
|
#ifdef USE_NEXTION
|
|
nextion.startWeather();
|
|
#endif
|
|
display.putRequest({NEWMODE, CLEAR}); display.putRequest({NEWMODE, PLAYER});
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "lat") == 0) {
|
|
strlcpy(config.store.weatherlat, val, 10);
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "lon") == 0) {
|
|
strlcpy(config.store.weatherlon, val, 10);
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "key") == 0) {
|
|
strlcpy(config.store.weatherkey, val, 64);
|
|
config.save();
|
|
display.showWeather();
|
|
#ifdef USE_NEXTION
|
|
nextion.startWeather();
|
|
#endif
|
|
display.putRequest({NEWMODE, CLEAR}); display.putRequest({NEWMODE, PLAYER});
|
|
return;
|
|
}
|
|
/* RESETS */
|
|
if (strcmp(cmd, "reset") == 0) {
|
|
if (strcmp(val, "system") == 0) {
|
|
config.store.smartstart = 2;
|
|
config.store.audioinfo = false;
|
|
config.store.vumeter = false;
|
|
config.store.softapdelay = 0;
|
|
config.save();
|
|
display.putRequest({NEWMODE, CLEAR}); display.putRequest({NEWMODE, PLAYER});
|
|
requestOnChange(GETSYSTEM, clientId);
|
|
return;
|
|
}
|
|
if (strcmp(val, "screen") == 0) {
|
|
config.store.flipscreen = false;
|
|
display.flip();
|
|
config.store.invertdisplay = false;
|
|
display.invert();
|
|
config.store.dspon = true;
|
|
config.store.brightness = 100;
|
|
config.setBrightness(false);
|
|
config.store.contrast = 55;
|
|
display.setContrast();
|
|
config.store.numplaylist = false;
|
|
config.save();
|
|
display.putRequest({NEWMODE, CLEAR}); display.putRequest({NEWMODE, PLAYER});
|
|
requestOnChange(GETSCREEN, clientId);
|
|
return;
|
|
}
|
|
if (strcmp(val, "timezone") == 0) {
|
|
config.store.tzHour = 3;
|
|
config.store.tzMin = 0;
|
|
strlcpy(config.store.sntp1, "pool.ntp.org", 35);
|
|
strlcpy(config.store.sntp2, "0.ru.pool.ntp.org", 35);
|
|
config.save();
|
|
configTime(config.store.tzHour * 3600 + config.store.tzMin * 60, config.getTimezoneOffset(), config.store.sntp1, config.store.sntp2);
|
|
network.requestTimeSync(true);
|
|
requestOnChange(GETTIMEZONE, clientId);
|
|
return;
|
|
}
|
|
if (strcmp(val, "weather") == 0) {
|
|
config.store.showweather = 0;
|
|
strlcpy(config.store.weatherlat, "55.7512", 10);
|
|
strlcpy(config.store.weatherlon, "37.6184", 10);
|
|
strlcpy(config.store.weatherkey, "", 64);
|
|
config.save();
|
|
display.showWeather();
|
|
#ifdef USE_NEXTION
|
|
nextion.startWeather();
|
|
#endif
|
|
display.putRequest({NEWMODE, CLEAR}); display.putRequest({NEWMODE, PLAYER});
|
|
requestOnChange(GETWEATHER, clientId);
|
|
return;
|
|
}
|
|
if (strcmp(val, "controls") == 0) {
|
|
config.store.volsteps = 1;
|
|
config.store.fliptouch = false;
|
|
config.store.dbgtouch = false;
|
|
setEncAcceleration(200);
|
|
setIRTolerance(40);
|
|
requestOnChange(GETCONTROLS, clientId);
|
|
return;
|
|
}
|
|
} /* EOF RESETS */
|
|
if (strcmp(cmd, "volume") == 0) {
|
|
byte v = atoi(val);
|
|
player.setVol(v, false);
|
|
}
|
|
if (strcmp(cmd, "balance") == 0) {
|
|
int8_t valb = atoi(val);
|
|
player.setBalance(valb);
|
|
config.setBalance(valb);
|
|
netserver.requestOnChange(BALANCE, 0);
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "treble") == 0) {
|
|
int8_t valb = atoi(val);
|
|
player.setTone(config.store.bass, config.store.middle, valb);
|
|
config.setTone(config.store.bass, config.store.middle, valb);
|
|
netserver.requestOnChange(EQUALIZER, 0);
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "middle") == 0) {
|
|
int8_t valb = atoi(val);
|
|
player.setTone(config.store.bass, valb, config.store.trebble);
|
|
config.setTone(config.store.bass, valb, config.store.trebble);
|
|
netserver.requestOnChange(EQUALIZER, 0);
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "bass") == 0) {
|
|
int8_t valb = atoi(val);
|
|
player.setTone(valb, config.store.middle, config.store.trebble);
|
|
config.setTone(valb, config.store.middle, config.store.trebble);
|
|
netserver.requestOnChange(EQUALIZER, 0);
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "submitplaylist") == 0) {
|
|
// xSemaphoreTake(player.playmutex, portMAX_DELAY);
|
|
return;
|
|
}
|
|
if (strcmp(cmd, "submitplaylistdone") == 0) {
|
|
#ifdef MQTT_HOST
|
|
//mqttPublishPlaylist();
|
|
mqttplaylistticker.attach(5, mqttplaylistSend);
|
|
#endif
|
|
// xSemaphoreGive(player.playmutex);
|
|
if (player.isRunning()) {
|
|
player.request.station = config.store.lastStation;
|
|
player.request.doSave = false;
|
|
}
|
|
return;
|
|
}
|
|
#if IR_PIN!=255
|
|
if (strcmp(cmd, "irbtn") == 0) {
|
|
config.irindex = atoi(val);
|
|
irRecordEnable = (config.irindex >= 0);
|
|
config.irchck = 0;
|
|
irValsToWs();
|
|
if (config.irindex < 0) config.saveIR();
|
|
}
|
|
if (strcmp(cmd, "chkid") == 0) {
|
|
config.irchck = atoi(val);
|
|
}
|
|
if (strcmp(cmd, "irclr") == 0) {
|
|
byte cl = atoi(val);
|
|
config.ircodes.irVals[config.irindex][cl] = 0;
|
|
}
|
|
#endif
|
|
}
|
|
}
|
|
}
|
|
|
|
void NetServer::getPlaylist(uint8_t clientId) {
|
|
char buf[160] = {0};
|
|
sprintf(buf, "{\"file\": \"http://%s%s\"}", WiFi.localIP().toString().c_str(), PLAYLIST_PATH);
|
|
if (clientId == 0) { websocket.textAll(buf); } else { websocket.text(clientId, buf); }
|
|
}
|
|
|
|
bool NetServer::importPlaylist() {
|
|
File tempfile = SPIFFS.open(TMP_PATH, "r");
|
|
if (!tempfile) {
|
|
return false;
|
|
}
|
|
char sName[BUFLEN], sUrl[BUFLEN];
|
|
int sOvol;
|
|
String line = tempfile.readStringUntil('\n');
|
|
if (config.parseCSV(line.c_str(), sName, sUrl, sOvol)) {
|
|
File playlistfile = SPIFFS.open(PLAYLIST_PATH, "w");
|
|
playlistfile.println(line);
|
|
while (tempfile.available()) {
|
|
line = tempfile.readStringUntil('\n');
|
|
if (config.parseCSV(line.c_str(), sName, sUrl, sOvol)) {
|
|
playlistfile.println(line);
|
|
}
|
|
}
|
|
playlistfile.close();
|
|
tempfile.close();
|
|
SPIFFS.remove(TMP_PATH);
|
|
requestOnChange(PLAYLISTSAVED, 0);
|
|
return true;
|
|
}
|
|
if (config.parseJSON(line.c_str(), sName, sUrl, sOvol)) {
|
|
File playlistfile = SPIFFS.open(PLAYLIST_PATH, "w");
|
|
String wline = String(sName) + "\t" + String(sUrl) + "\t" + String(sOvol);
|
|
playlistfile.println(wline);
|
|
while (tempfile.available()) {
|
|
line = tempfile.readStringUntil('\n');
|
|
if (config.parseJSON(line.c_str(), sName, sUrl, sOvol)) {
|
|
wline = String(sName) + "\t" + String(sUrl) + "\t" + String(sOvol);
|
|
playlistfile.println(wline);
|
|
}
|
|
}
|
|
playlistfile.close();
|
|
tempfile.close();
|
|
SPIFFS.remove(TMP_PATH);
|
|
requestOnChange(PLAYLISTSAVED, 0);
|
|
return true;
|
|
}
|
|
tempfile.close();
|
|
SPIFFS.remove(TMP_PATH);
|
|
return false;
|
|
}
|
|
|
|
void NetServer::requestOnChange(requestType_e request, uint8_t clientId) {
|
|
char buf[BUFLEN * 2] = { 0 };
|
|
switch (request) {
|
|
case PLAYLIST: getPlaylist(clientId); break;
|
|
case PLAYLISTSAVED: config.indexPlaylist(); config.initPlaylist(); getPlaylist(clientId); break;
|
|
case GETACTIVE: {
|
|
bool dbgact = false;
|
|
String act = "\"group_wifi\",";
|
|
if (network.status == CONNECTED) {
|
|
act += "\"group_system\",";
|
|
if (BRIGHTNESS_PIN != 255 || DSP_FLIPPED == 1 || DSP_MODEL == DSP_NOKIA5110 || dbgact) act += "\"group_display\",";
|
|
#ifdef USE_NEXTION
|
|
act += "\"group_nextion\",";
|
|
if (WEATHER_READY == 0 || dbgact) act += "\"group_weather\",";
|
|
#endif
|
|
#if defined(LCD_I2C) || DSP_OLED
|
|
act += "\"group_oled\",";
|
|
#endif
|
|
if (VU_READY == 1 || dbgact) act += "\"group_vu\",";
|
|
if (BRIGHTNESS_PIN != 255 || dbgact) act += "\"group_brightness\",";
|
|
if (DSP_FLIPPED == 1 || dbgact) act += "\"group_tft\",";
|
|
if (TS_CS != 255 || dbgact) act += "\"group_touch\",";
|
|
if (DSP_MODEL == DSP_NOKIA5110) act += "\"group_nokia\",";
|
|
if (DSP_MODEL != DSP_DUMMY || dbgact) act += "\"group_timezone\",";
|
|
if (WEATHER_READY == 1 || dbgact) act += "\"group_weather\",";
|
|
act += "\"group_controls\",";
|
|
if (ENC_BTNL != 255 || ENC2_BTNL != 255 || dbgact) act += "\"group_encoder\",";
|
|
if (IR_PIN != 255 || dbgact) act += "\"group_ir\",";
|
|
}
|
|
act = act.substring(0, act.length() - 1);
|
|
sprintf (buf, "{\"act\":[%s]}", act.c_str());
|
|
break;
|
|
}
|
|
case GETMODE: sprintf (buf, "{\"pmode\":\"%s\"}", network.status == CONNECTED ? "player" : "ap"); break;
|
|
case GETINDEX: requestOnChange(STATION, clientId); requestOnChange(TITLE, clientId); requestOnChange(VOLUME, clientId); requestOnChange(EQUALIZER, clientId); requestOnChange(BALANCE, clientId); requestOnChange(BITRATE, clientId); requestOnChange(MODE, clientId); return; break;
|
|
case GETSYSTEM: sprintf (buf, "{\"sst\":%d,\"aif\":%d,\"vu\":%d,\"softr\":%d}", config.store.smartstart != 2, config.store.audioinfo, config.store.vumeter, config.store.softapdelay); break;
|
|
case GETSCREEN: sprintf (buf, "{\"flip\":%d,\"inv\":%d,\"nump\":%d,\"tsf\":%d,\"tsd\":%d,\"dspon\":%d,\"br\":%d,\"con\":%d}", config.store.flipscreen, config.store.invertdisplay, config.store.numplaylist, config.store.fliptouch, config.store.dbgtouch, config.store.dspon, config.store.brightness, config.store.contrast); break;
|
|
case GETTIMEZONE: sprintf (buf, "{\"tzh\":%d,\"tzm\":%d,\"sntp1\":\"%s\",\"sntp2\":\"%s\"}", config.store.tzHour, config.store.tzMin, config.store.sntp1, config.store.sntp2); break;
|
|
case GETWEATHER: sprintf (buf, "{\"wen\":%d,\"wlat\":\"%s\",\"wlon\":\"%s\",\"wkey\":\"%s\"}", config.store.showweather, config.store.weatherlat, config.store.weatherlon, config.store.weatherkey); break;
|
|
case GETCONTROLS: sprintf (buf, "{\"vols\":%d,\"enca\":%d,\"irtl\":%d}", config.store.volsteps, config.store.encacc, config.store.irtlp); break;
|
|
case DSPON: sprintf (buf, "{\"dspontrue\":%d}", 1); break;
|
|
case STATION: sprintf (buf, "{\"nameset\": \"%s\"}", config.station.name); requestOnChange(ITEM, clientId); break;
|
|
case ITEM: sprintf (buf, "{\"current\": %d}", config.store.lastStation); break;
|
|
case TITLE: sprintf (buf, "{\"meta\": \"%s\"}", config.station.title); if (player.requestToStart) { telnet.info(); player.requestToStart = false; } else { telnet.printf("##CLI.META#: %s\n> ", config.station.title); } break;
|
|
case VOLUME: sprintf (buf, "{\"vol\": %d}", config.store.volume); break;
|
|
case NRSSI: sprintf (buf, "{\"rssi\": %d}", rssi); rssi = 255; break;
|
|
case BITRATE: sprintf (buf, "{\"bitrate\": %d}", config.station.bitrate); break;
|
|
case MODE: sprintf (buf, "{\"mode\": \"%s\"}", player.mode == PLAYING ? "playing" : "stopped"); break;
|
|
case EQUALIZER: sprintf (buf, "{\"bass\": %d, \"middle\": %d, \"trebble\": %d}", config.store.bass, config.store.middle, config.store.trebble); DBGVB("[%s] %s", __func__, buf); break;
|
|
case BALANCE: sprintf (buf, "{\"balance\": %d}", config.store.balance); break;
|
|
}
|
|
if (strlen(buf) > 0) {
|
|
if (clientId == 0) { websocket.textAll(buf); }else{ websocket.text(clientId, buf); }
|
|
#ifdef MQTT_HOST
|
|
if (clientId == 0 && (request == STATION || request == ITEM || request == TITLE || request == MODE)) mqttPublishStatus();
|
|
if (clientId == 0 && request == VOLUME) mqttPublishVolume();
|
|
#endif
|
|
}
|
|
}
|
|
|
|
String processor(const String& var) { // %Templates%
|
|
if (var == "VERSION") return VERSION;
|
|
return String();
|
|
}
|
|
|
|
void handleUpload(AsyncWebServerRequest *request, String filename, size_t index, uint8_t *data, size_t len, bool final) {
|
|
if (!index) {
|
|
PLOW();
|
|
request->_tempFile = SPIFFS.open(TMP_PATH , "w");
|
|
}
|
|
if (len) {
|
|
request->_tempFile.write(data, len);
|
|
//TODO check index+len size
|
|
}
|
|
if (final) {
|
|
request->_tempFile.close();
|
|
PHIG();
|
|
}
|
|
}
|
|
|
|
void onWsEvent(AsyncWebSocket *server, AsyncWebSocketClient *client, AwsEventType type, void *arg, uint8_t *data, size_t len) {
|
|
switch (type) {
|
|
case WS_EVT_CONNECT: if (config.store.audioinfo) Serial.printf("[WEBSOCKET] client #%u connected from %s\n", client->id(), client->remoteIP().toString().c_str()); break;
|
|
case WS_EVT_DISCONNECT: if (config.store.audioinfo) Serial.printf("[WEBSOCKET] client #%u disconnected\n", client->id()); break;
|
|
case WS_EVT_DATA: netserver.onWsMessage(arg, data, len, client->id()); break;
|
|
case WS_EVT_PONG:
|
|
case WS_EVT_ERROR:
|
|
break;
|
|
}
|
|
}
|
|
|
|
void handleHTTPArgs(AsyncWebServerRequest * request) {
|
|
if (request->method() == HTTP_GET) {
|
|
DBGVB("[%s] client ip=%s request of %s", __func__, request->client()->remoteIP().toString().c_str(), request->url().c_str());
|
|
if (strcmp(request->url().c_str(), PLAYLIST_PATH) == 0 || strcmp(request->url().c_str(), SSIDS_PATH) == 0 || strcmp(request->url().c_str(), INDEX_PATH) == 0 || strcmp(request->url().c_str(), TMP_PATH) == 0) {
|
|
#ifdef MQTT_HOST
|
|
if (strcmp(request->url().c_str(), PLAYLIST_PATH) == 0) while (mqttplaylistblock) vTaskDelay(5);
|
|
#endif
|
|
netserver.chunkedHtmlPage("application/octet-stream", request, request->url().c_str());
|
|
return;
|
|
}
|
|
if (strcmp(request->url().c_str(), "/") == 0 && request->params() == 0) {
|
|
netserver.chunkedHtmlPage(String(), request, network.status == CONNECTED ? "/www/index.html" : "/www/settings.html");
|
|
return;
|
|
}
|
|
if (strcmp(request->url().c_str(), "/update") == 0 || strcmp(request->url().c_str(), "/settings") == 0 || strcmp(request->url().c_str(), "/ir") == 0) {
|
|
char buf[40] = { 0 };
|
|
sprintf(buf, "/www%s.html", request->url().c_str());
|
|
netserver.chunkedHtmlPage(String(), request, buf);
|
|
return;
|
|
}
|
|
}
|
|
if (network.status == CONNECTED) {
|
|
if (request->hasArg("start")) player.request.station = config.store.lastStation;
|
|
if (request->hasArg("stop")) {
|
|
player.mode = STOPPED;
|
|
config.setTitle("[stopped]");
|
|
}
|
|
if (request->hasArg("prev")) player.prev();
|
|
if (request->hasArg("next")) player.next();
|
|
if (request->hasArg("volm")) player.stepVol(false);
|
|
if (request->hasArg("volp")) player.stepVol(true);
|
|
|
|
if (request->hasArg("trebble") && request->hasArg("middle") && request->hasArg("bass")) {
|
|
AsyncWebParameter* pt = request->getParam("trebble", request->method() == HTTP_POST);
|
|
AsyncWebParameter* pm = request->getParam("middle", request->method() == HTTP_POST);
|
|
AsyncWebParameter* pb = request->getParam("bass", request->method() == HTTP_POST);
|
|
int t = atoi(pt->value().c_str());
|
|
int m = atoi(pm->value().c_str());
|
|
int b = atoi(pb->value().c_str());
|
|
player.setTone(b, m, t);
|
|
config.setTone(b, m, t);
|
|
netserver.requestOnChange(EQUALIZER, 0);
|
|
}
|
|
if (request->hasArg("ballance")) {
|
|
AsyncWebParameter* p = request->getParam("ballance", request->method() == HTTP_POST);
|
|
int b = atoi(p->value().c_str());
|
|
player.setBalance(b);
|
|
config.setBalance(b);
|
|
netserver.requestOnChange(BALANCE, 0);
|
|
}
|
|
if (request->hasArg("playstation") || request->hasArg("play")) {
|
|
AsyncWebParameter* p = request->getParam(request->hasArg("playstation") ? "playstation" : "play", request->method() == HTTP_POST);
|
|
int id = atoi(p->value().c_str());
|
|
if (id < 1) id = 1;
|
|
if (id > config.store.countStation) id = config.store.countStation;
|
|
player.request.station = id;
|
|
player.request.doSave = true;
|
|
DBGVB("[%s] play=%d", __func__, id);
|
|
}
|
|
if (request->hasArg("vol")) {
|
|
AsyncWebParameter* p = request->getParam("vol", request->method() == HTTP_POST);
|
|
int v = atoi(p->value().c_str());
|
|
if (v < 0) v = 0;
|
|
if (v > 254) v = 254;
|
|
config.store.volume = v;
|
|
player.setVol(v, false);
|
|
DBGVB("[%s] vol=%d", __func__, v);
|
|
}
|
|
if (request->params() > 0) {
|
|
request->send(200);
|
|
return;
|
|
}
|
|
} else {
|
|
if (request->params() > 0) {
|
|
request->send(404);
|
|
return;
|
|
}
|
|
}
|
|
}
|