Function lualib_http_request

src/Chain/libraries/glua/lhttplib.cpp:152–317

发起http请求, http.request(method, url, body, headers)

// 发起http请求, http.request(method, url, body, headers)
static int lualib_http_request(lua_State *L)
{
	auto method = luaL_checkstring(L, 1);
	auto url = luaL_checkstring(L, 2);
	std::string method_str(method);
	easy_toupper(method_str);
	size_t body_len = 0;
	auto body = luaL_tolstring(L, 3, &body_len);
	/*
	auto headers_table_value = lua_type_to_storage_value_type(L, 4);
	if(headers_table_value.type != GluaStorageValueType::LVALUE_TABLE)
	{
		global_glua_chain_api->throw_exception(L, THINKYOUNG_API_SIMPLE_ERROR, "headers must be table");
		return 0;
	}
	*/
	// auto headers_table = headers_table_value.value.table_value;
	std::string url_str(url);
	std::wstring url_wstr(url_str.begin(), url_str.end());
	auto uri = glua::net::Uri::parse(url_wstr);
	int result_count = lualib_net_connect_impl(L, uri.host_str(), uri.port_int());
	auto *socket = (TcpSocket*)lua_touserdata(L, -1);
	lua_pop(L, result_count);
	std::vector<char> buf;
	std::stringstream ss;
	ss << method_str << " " << uri.path_str();
	if (uri.query_string.length() > 0)
		ss << "?" << uri.query_string_str();
	ss << " HTTP/1.1\r\n";
	/*
	for(const auto &p : *headers_table)
	{
		if (p.second.type == GluaStorageValueType::LVALUE_STRING)
			ss << p.first << ":" << p.second.value.string_value << "\r\n";
		else if(p.second.type == GluaStorageValueType::LVALUE_INTEGER)
			ss << p.first << ":" << p.second.value.int_value << "\r\n";
		else if (p.second.type == GluaStorageValueType::LVALUE_NUMBER)
			ss << p.first << ":" << p.second.value.number_value << "\r\n";
		else if (p.second.type == GluaStorageValueType::LVALUE_BOOLEAN)
			ss << p.first << ":" << p.second.value.bool_value << "\r\n";
	}
	*/
	std::list<const void*> ignored_nested;
	ss << "Host:" << uri.host_str() << "\r\n";
	ss << "Connection:keep-alive" << "\r\n";
	luaL_traverse_table_with_nested(L, 4, response_headers_traverser, &ss, ignored_nested, 0);
	ss << "\r\n";
	std::string data_str = ss.str();
	for (size_t i = 0; i < data_str.length(); ++i)
		buf.push_back(data_str[i]);
	for (size_t i = 0; i < body_len; ++i)
		buf.push_back(body[i]);
	result_count = lualib_net_write_impl(L, socket, buf);
	if (result_count > 0)
		lua_pop(L, result_count);
	// read response
	auto *ctx = new HttpContext();
	ctx->socket = socket;