123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285 |
- /******************************************************************************
- * HTTP module for NodeMCU
- * vowstar@gmail.com
- * 2015-12-29
- *******************************************************************************/
- #include <c_stdlib.h>
- #include "module.h"
- #include "lauxlib.h"
- #include "platform.h"
- #include "cpu_esp8266.h"
- #include "httpclient.h"
- static int http_callback_registry = LUA_NOREF;
- static void http_callback( char * response, int http_status, char ** full_response_p )
- {
- const char *full_response = full_response_p ? *full_response_p : NULL;
- #if defined(HTTPCLIENT_DEBUG_ON)
- dbg_printf( "http_status=%d\n", http_status );
- if ( http_status != HTTP_STATUS_GENERIC_ERROR )
- {
- if (full_response != NULL) {
- dbg_printf( "strlen(full_response)=%d\n", strlen( full_response ) );
- }
- dbg_printf( "response=%s<EOF>\n", response );
- }
- #endif
- if (http_callback_registry != LUA_NOREF)
- {
- lua_State *L = lua_getstate();
- lua_rawgeti(L, LUA_REGISTRYINDEX, http_callback_registry);
- lua_pushnumber(L, http_status);
- if ( http_status != HTTP_STATUS_GENERIC_ERROR && response)
- {
- lua_pushstring(L, response);
- lua_newtable(L);
- const char *p = full_response;
- // Need to skip the HTTP/1.1 header line
- while (*p && *p != '\n') {
- p++;
- }
- if (*p == '\n') {
- p++;
- }
- while (*p && *p != '\r' && *p != '\n') {
- const char *eol = p;
- while (*eol && *eol != '\r') {
- eol++;
- }
- const char *colon = p;
- while (*colon != ':' && colon < eol) {
- colon++;
- }
- if (*colon != ':') {
- break;
- }
- const char *value = colon + 1;
- while (*value == ' ') {
- value++;
- }
- luaL_Buffer b;
- luaL_buffinit(L, &b);
- while (p < colon) {
- luaL_addchar(&b, tolower((unsigned char) *p));
- p++;
- }
- luaL_pushresult(&b);
- lua_pushlstring(L, value, eol - value);
- lua_settable(L, -3);
- p = eol + 1;
- if (*p == '\n') {
- p++;
- }
- }
- }
- else
- {
- lua_pushnil(L);
- lua_pushnil(L);
- }
- if (full_response_p && *full_response_p) {
- c_free(*full_response_p);
- *full_response_p = NULL;
- }
- luaL_unref(L, LUA_REGISTRYINDEX, http_callback_registry);
- http_callback_registry = LUA_NOREF;
- lua_call(L, 3, 0); // With 3 arguments and 0 result
- }
- }
- // Lua: http.request( url, method, header, body, function(status, reponse) end )
- static int http_lapi_request( lua_State *L )
- {
- int length;
- const char * url = luaL_checklstring(L, 1, &length);
- const char * method = luaL_checklstring(L, 2, &length);
- const char * headers = NULL;
- const char * body = NULL;
- // Check parameter
- if ((url == NULL) || (method == NULL))
- {
- return luaL_error( L, "wrong arg type" );
- }
- if (lua_isstring(L, 3))
- {
- headers = luaL_checklstring(L, 3, &length);
- }
- if (lua_isstring(L, 4))
- {
- body = luaL_checklstring(L, 4, &length);
- }
- if (lua_type(L, 5) == LUA_TFUNCTION || lua_type(L, 5) == LUA_TLIGHTFUNCTION) {
- lua_pushvalue(L, 5); // copy argument (func) to the top of stack
- luaL_unref(L, LUA_REGISTRYINDEX, http_callback_registry);
- http_callback_registry = luaL_ref(L, LUA_REGISTRYINDEX);
- }
- http_request(url, method, headers, body, http_callback, 0);
- return 0;
- }
- // Lua: http.post( url, header, body, function(status, reponse) end )
- static int http_lapi_post( lua_State *L )
- {
- int length;
- const char * url = luaL_checklstring(L, 1, &length);
- const char * headers = NULL;
- const char * body = NULL;
- // Check parameter
- if ((url == NULL))
- {
- return luaL_error( L, "wrong arg type" );
- }
- if (lua_isstring(L, 2))
- {
- headers = luaL_checklstring(L, 2, &length);
- }
- if (lua_isstring(L, 3))
- {
- body = luaL_checklstring(L, 3, &length);
- }
- if (lua_type(L, 4) == LUA_TFUNCTION || lua_type(L, 4) == LUA_TLIGHTFUNCTION) {
- lua_pushvalue(L, 4); // copy argument (func) to the top of stack
- if (http_callback_registry != LUA_NOREF)
- luaL_unref(L, LUA_REGISTRYINDEX, http_callback_registry);
- http_callback_registry = luaL_ref(L, LUA_REGISTRYINDEX);
- }
- http_post(url, headers, body, http_callback);
- return 0;
- }
- // Lua: http.put( url, header, body, function(status, reponse) end )
- static int http_lapi_put( lua_State *L )
- {
- int length;
- const char * url = luaL_checklstring(L, 1, &length);
- const char * headers = NULL;
- const char * body = NULL;
- // Check parameter
- if ((url == NULL))
- {
- return luaL_error( L, "wrong arg type" );
- }
- if (lua_isstring(L, 2))
- {
- headers = luaL_checklstring(L, 2, &length);
- }
- if (lua_isstring(L, 3))
- {
- body = luaL_checklstring(L, 3, &length);
- }
- if (lua_type(L, 4) == LUA_TFUNCTION || lua_type(L, 4) == LUA_TLIGHTFUNCTION) {
- lua_pushvalue(L, 4); // copy argument (func) to the top of stack
- if (http_callback_registry != LUA_NOREF)
- luaL_unref(L, LUA_REGISTRYINDEX, http_callback_registry);
- http_callback_registry = luaL_ref(L, LUA_REGISTRYINDEX);
- }
- http_put(url, headers, body, http_callback);
- return 0;
- }
- // Lua: http.delete( url, header, body, function(status, reponse) end )
- static int http_lapi_delete( lua_State *L )
- {
- int length;
- const char * url = luaL_checklstring(L, 1, &length);
- const char * headers = NULL;
- const char * body = NULL;
- // Check parameter
- if ((url == NULL))
- {
- return luaL_error( L, "wrong arg type" );
- }
- if (lua_isstring(L, 2))
- {
- headers = luaL_checklstring(L, 2, &length);
- }
- if (lua_isstring(L, 3))
- {
- body = luaL_checklstring(L, 3, &length);
- }
- if (lua_type(L, 4) == LUA_TFUNCTION || lua_type(L, 4) == LUA_TLIGHTFUNCTION) {
- lua_pushvalue(L, 4); // copy argument (func) to the top of stack
- if (http_callback_registry != LUA_NOREF)
- luaL_unref(L, LUA_REGISTRYINDEX, http_callback_registry);
- http_callback_registry = luaL_ref(L, LUA_REGISTRYINDEX);
- }
- http_delete(url, headers, body, http_callback);
- return 0;
- }
- // Lua: http.get( url, header, function(status, reponse) end )
- static int http_lapi_get( lua_State *L )
- {
- int length;
- const char * url = luaL_checklstring(L, 1, &length);
- const char * headers = NULL;
- // Check parameter
- if ((url == NULL))
- {
- return luaL_error( L, "wrong arg type" );
- }
- if (lua_isstring(L, 2))
- {
- headers = luaL_checklstring(L, 2, &length);
- }
- if (lua_type(L, 3) == LUA_TFUNCTION || lua_type(L, 3) == LUA_TLIGHTFUNCTION) {
- lua_pushvalue(L, 3); // copy argument (func) to the top of stack
- if (http_callback_registry != LUA_NOREF)
- luaL_unref(L, LUA_REGISTRYINDEX, http_callback_registry);
- http_callback_registry = luaL_ref(L, LUA_REGISTRYINDEX);
- }
- http_get(url, headers, http_callback);
- return 0;
- }
- // Module function map
- static const LUA_REG_TYPE http_map[] = {
- { LSTRKEY( "request" ), LFUNCVAL( http_lapi_request ) },
- { LSTRKEY( "post" ), LFUNCVAL( http_lapi_post ) },
- { LSTRKEY( "put" ), LFUNCVAL( http_lapi_put ) },
- { LSTRKEY( "delete" ), LFUNCVAL( http_lapi_delete ) },
- { LSTRKEY( "get" ), LFUNCVAL( http_lapi_get ) },
- { LSTRKEY( "OK" ), LNUMVAL( 0 ) },
- { LSTRKEY( "ERROR" ), LNUMVAL( HTTP_STATUS_GENERIC_ERROR ) },
-
- { LNILKEY, LNILVAL }
- };
- NODEMCU_MODULE(HTTP, "http", http_map, NULL);
|