mirror of https://github.com/arendst/Tasmota.git
307 lines
9.8 KiB
C++
307 lines
9.8 KiB
C++
/*
|
|
xdrv_52_3_berry_webserver.ino - Berry scripting language, webserver module
|
|
|
|
Copyright (C) 2021 Stephan Hadinger, Berry language by Guan Wenliang https://github.com/Skiars/berry
|
|
|
|
This program is free software: you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the 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 <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
|
|
#ifdef USE_BERRY
|
|
|
|
#ifdef USE_WEBCLIENT
|
|
|
|
#include <berry.h>
|
|
#include "HttpClientLight.h"
|
|
|
|
String wc_UrlEncode(const String& text) {
|
|
const char hex[] = "0123456789ABCDEF";
|
|
|
|
String encoded = "";
|
|
int len = text.length();
|
|
int i = 0;
|
|
while (i < len) {
|
|
char decodedChar = text.charAt(i++);
|
|
|
|
if (('a' <= decodedChar && decodedChar <= 'z') ||
|
|
('A' <= decodedChar && decodedChar <= 'Z') ||
|
|
('0' <= decodedChar && decodedChar <= '9') ||
|
|
('=' == decodedChar)) {
|
|
encoded += decodedChar;
|
|
} else {
|
|
encoded += '%';
|
|
encoded += hex[decodedChar >> 4];
|
|
encoded += hex[decodedChar & 0xF];
|
|
}
|
|
|
|
}
|
|
return encoded;
|
|
}
|
|
|
|
/*********************************************************************************************\
|
|
* Int constants
|
|
*********************************************************************************************/
|
|
// const be_constint_t webserver_constants[] = {
|
|
// { "BUTTON_CONFIGURATION", BUTTON_CONFIGURATION },
|
|
// { "BUTTON_INFORMATION", BUTTON_INFORMATION },
|
|
// { "BUTTON_MAIN", BUTTON_MAIN },
|
|
// { "BUTTON_MANAGEMENT", BUTTON_MANAGEMENT },
|
|
// { "BUTTON_MODULE", BUTTON_MODULE },
|
|
// { "HTTP_ADMIN", HTTP_ADMIN },
|
|
// { "HTTP_ANY", HTTP_ANY },
|
|
// { "HTTP_GET", HTTP_GET },
|
|
// { "HTTP_MANAGER", HTTP_MANAGER },
|
|
// { "HTTP_MANAGER_RESET_ONLY", HTTP_MANAGER_RESET_ONLY },
|
|
// { "HTTP_OFF", HTTP_OFF },
|
|
// { "HTTP_OPTIONS", HTTP_OPTIONS },
|
|
// { "HTTP_POST", HTTP_POST },
|
|
// { "HTTP_USER", HTTP_USER },
|
|
// };
|
|
|
|
/*********************************************************************************************\
|
|
* Native functions mapped to Berry functions
|
|
*
|
|
* import webclient
|
|
*
|
|
\*********************************************************************************************/
|
|
extern "C" {
|
|
// Berry: ``
|
|
//
|
|
int32_t wc_init(struct bvm *vm);
|
|
int32_t wc_init(struct bvm *vm) {
|
|
// int32_t argc = be_top(vm); // Get the number of arguments
|
|
WiFiClient * wcl = new WiFiClient();
|
|
be_pushcomptr(vm, (void*) wcl);
|
|
be_setmember(vm, 1, ".w");
|
|
HTTPClientLight * cl = new HTTPClientLight();
|
|
cl->setUserAgent(USE_BERRY_WEBCLIENT_USERAGENT);
|
|
cl->setConnectTimeout(USE_BERRY_WEBCLIENT_TIMEOUT); // set default timeout
|
|
be_pushcomptr(vm, (void*) cl);
|
|
be_setmember(vm, 1, ".p");
|
|
be_return_nil(vm);
|
|
}
|
|
|
|
HTTPClientLight * wc_getclient(struct bvm *vm) {
|
|
be_getmember(vm, 1, ".p");
|
|
void *p = be_tocomptr(vm, -1);
|
|
be_pop(vm, 1);
|
|
return (HTTPClientLight*) p;
|
|
}
|
|
|
|
WiFiClient * wc_getwificlient(struct bvm *vm) {
|
|
be_getmember(vm, 1, ".w");
|
|
void *p = be_tocomptr(vm, -1);
|
|
be_pop(vm, 1);
|
|
return (WiFiClient*) p;
|
|
}
|
|
|
|
int32_t wc_deinit(struct bvm *vm);
|
|
int32_t wc_deinit(struct bvm *vm) {
|
|
// int32_t argc = be_top(vm); // Get the number of arguments
|
|
HTTPClientLight * cl = wc_getclient(vm);
|
|
if (cl != nullptr) { delete cl; }
|
|
be_pushnil(vm);
|
|
be_setmember(vm, 1, ".p");
|
|
WiFiClient * wcl = wc_getwificlient(vm);
|
|
if (wcl != nullptr) { delete wcl; }
|
|
be_setmember(vm, 1, ".w");
|
|
be_return_nil(vm);
|
|
}
|
|
|
|
// wc.url_encode(string) -> string
|
|
int32_t wc_urlencode(struct bvm *vm);
|
|
int32_t wc_urlencode(struct bvm *vm) {
|
|
int32_t argc = be_top(vm);
|
|
if (argc >= 2 && be_isstring(vm, 2)) {
|
|
const char * s = be_tostring(vm, 2);
|
|
String url = wc_UrlEncode(String(s));
|
|
be_pushstring(vm, url.c_str());
|
|
be_return(vm); /* return self */
|
|
}
|
|
be_raise(vm, kTypeError, nullptr);
|
|
}
|
|
|
|
// wc.begin(url:string) -> self
|
|
int32_t wc_begin(struct bvm *vm);
|
|
int32_t wc_begin(struct bvm *vm) {
|
|
int32_t argc = be_top(vm);
|
|
if (argc == 1 || !be_tostring(vm, 2)) { be_raise(vm, "attribute_error", "missing URL as string"); }
|
|
const char * url = be_tostring(vm, 2);
|
|
HTTPClientLight * cl = wc_getclient(vm);
|
|
// open connection
|
|
if (!cl->begin(url)) {
|
|
be_raise(vm, "value_error", "unsupported protocol");
|
|
}
|
|
be_pushvalue(vm, 1);
|
|
be_return(vm); /* return self */
|
|
}
|
|
|
|
// wc.close(void) -> nil
|
|
int32_t wc_close(struct bvm *vm);
|
|
int32_t wc_close(struct bvm *vm) {
|
|
HTTPClientLight * cl = wc_getclient(vm);
|
|
cl->end();
|
|
be_return_nil(vm);
|
|
}
|
|
|
|
// wc.wc_set_timeouts([http_timeout_ms:int, tcp_timeout_ms:int]) -> self
|
|
int32_t wc_set_timeouts(struct bvm *vm);
|
|
int32_t wc_set_timeouts(struct bvm *vm) {
|
|
int32_t argc = be_top(vm);
|
|
HTTPClientLight * cl = wc_getclient(vm);
|
|
if (argc >= 2) {
|
|
cl->setTimeout(be_toint(vm, 2));
|
|
}
|
|
if (argc >= 3) {
|
|
cl->setConnectTimeout(be_toint(vm, 3));
|
|
}
|
|
be_pushvalue(vm, 1);
|
|
be_return(vm); /* return self */
|
|
}
|
|
|
|
// wc.set_useragent(user_agent:string) -> self
|
|
int32_t wc_set_useragent(struct bvm *vm);
|
|
int32_t wc_set_useragent(struct bvm *vm) {
|
|
int32_t argc = be_top(vm);
|
|
if (argc >= 2 && be_isstring(vm, 2)) {
|
|
HTTPClientLight * cl = wc_getclient(vm);
|
|
const char * useragent = be_tostring(vm, 2);
|
|
cl->setUserAgent(String(useragent));
|
|
be_pushvalue(vm, 1);
|
|
be_return(vm); /* return self */
|
|
}
|
|
be_raise(vm, kTypeError, nullptr);
|
|
}
|
|
|
|
// wc.wc_set_auth(auth:string | (user:string, password:string)) -> self
|
|
int32_t wc_set_auth(struct bvm *vm);
|
|
int32_t wc_set_auth(struct bvm *vm) {
|
|
int32_t argc = be_top(vm);
|
|
if (argc >= 2 && be_isstring(vm, 2) && (argc < 3 || be_isstring(vm, 3))) {
|
|
HTTPClientLight * cl = wc_getclient(vm);
|
|
const char * user = be_tostring(vm, 2);
|
|
if (argc == 2) {
|
|
cl->setAuthorization(user);
|
|
} else {
|
|
const char * password = be_tostring(vm, 3);
|
|
cl->setAuthorization(user, password);
|
|
}
|
|
be_pushvalue(vm, 1);
|
|
be_return(vm); /* return self */
|
|
}
|
|
be_raise(vm, kTypeError, nullptr);
|
|
}
|
|
|
|
// wc.addheader(name:string, value:string [, first:bool=false [, replace:bool=true]]) -> nil
|
|
int32_t wc_addheader(struct bvm *vm);
|
|
int32_t wc_addheader(struct bvm *vm) {
|
|
int32_t argc = be_top(vm);
|
|
if (argc >= 3 && (be_isstring(vm, 2) || be_isstring(vm, 2))) {
|
|
HTTPClientLight * cl = wc_getclient(vm);
|
|
|
|
const char * name = be_tostring(vm, 2);
|
|
const char * value = be_tostring(vm, 3);
|
|
bool first = false;
|
|
bool replace = true;
|
|
if (argc >= 4) {
|
|
first = be_tobool(vm, 4);
|
|
}
|
|
if (argc >= 5) {
|
|
replace = be_tobool(vm, 5);
|
|
}
|
|
// do the call
|
|
cl->addHeader(String(name), String(value), first, replace);
|
|
be_return_nil(vm);
|
|
}
|
|
be_raise(vm, kTypeError, nullptr);
|
|
}
|
|
|
|
// cw.connected(void) -> bool
|
|
int32_t wc_connected(struct bvm *vm);
|
|
int32_t wc_connected(struct bvm *vm) {
|
|
HTTPClientLight * cl = wc_getclient(vm);
|
|
be_pushbool(vm, cl->connected());
|
|
be_return(vm); /* return code */
|
|
}
|
|
|
|
// cw.GET(void) -> httpCode:int
|
|
int32_t wc_GET(struct bvm *vm);
|
|
int32_t wc_GET(struct bvm *vm) {
|
|
HTTPClientLight * cl = wc_getclient(vm);
|
|
uint32_t http_connect_time = millis();
|
|
int32_t httpCode = cl->GET();
|
|
if (httpCode <= -1000) {
|
|
AddLog(LOG_LEVEL_INFO, D_LOG_HTTP "TLS connection error: %d", -httpCode - 1000);
|
|
} else {
|
|
AddLog(LOG_LEVEL_DEBUG, PSTR(D_LOG_HTTP "TLS connected in %d ms, stack low mark %d"),
|
|
millis() - http_connect_time, uxTaskGetStackHighWaterMark(nullptr));
|
|
}
|
|
be_pushint(vm, httpCode);
|
|
be_return(vm); /* return code */
|
|
}
|
|
|
|
// wc.POST(string | bytes) -> httpCode:int
|
|
int32_t wc_POST(struct bvm *vm);
|
|
int32_t wc_POST(struct bvm *vm) {
|
|
int32_t argc = be_top(vm);
|
|
if (argc >= 2 && (be_isstring(vm, 2) || be_isbytes(vm, 2))) {
|
|
HTTPClientLight * cl = wc_getclient(vm);
|
|
const char * buf = nullptr;
|
|
size_t buf_len = 0;
|
|
if (be_isstring(vm, 2)) { // string
|
|
buf = be_tostring(vm, 2);
|
|
buf_len = strlen(buf);
|
|
} else { // bytes
|
|
buf = (const char*) be_tobytes(vm, 2, &buf_len);
|
|
}
|
|
uint32_t http_connect_time = millis();
|
|
int32_t httpCode = cl->POST((uint8_t*)buf, buf_len);
|
|
if (httpCode <= -1000) {
|
|
AddLog(LOG_LEVEL_INFO, D_LOG_HTTP "TLS connection error: %d", -httpCode - 1000);
|
|
} else {
|
|
AddLog(LOG_LEVEL_DEBUG, PSTR(D_LOG_HTTP "TLS connected in %d ms, stack low mark %d"),
|
|
millis() - http_connect_time, uxTaskGetStackHighWaterMark(nullptr));
|
|
}
|
|
be_pushint(vm, httpCode);
|
|
be_return(vm); /* return code */
|
|
}
|
|
be_raise(vm, kTypeError, nullptr);
|
|
}
|
|
|
|
int32_t wc_getstring(struct bvm *vm);
|
|
int32_t wc_getstring(struct bvm *vm) {
|
|
HTTPClientLight * cl = wc_getclient(vm);
|
|
int32_t sz = cl->getSize();
|
|
// abort if we exceed 32KB size, things will not go well otherwise
|
|
if (sz >= 32767) {
|
|
be_raise(vm, "value_error", "response size too big (>32KB)");
|
|
}
|
|
String payload = cl->getString();
|
|
be_pushstring(vm, payload.c_str());
|
|
cl->end(); // free allocated memory ~16KB
|
|
be_return(vm); /* return code */
|
|
}
|
|
|
|
int32_t wc_getsize(struct bvm *vm);
|
|
int32_t wc_getsize(struct bvm *vm) {
|
|
HTTPClientLight * cl = wc_getclient(vm);
|
|
be_pushint(vm, cl->getSize());
|
|
be_return(vm); /* return code */
|
|
}
|
|
|
|
}
|
|
|
|
#endif // USE_WEBCLIENT
|
|
#endif // USE_BERRY
|