diff options
author | Juan Linietsky <reduzio@gmail.com> | 2014-04-28 21:56:43 -0300 |
---|---|---|
committer | Juan Linietsky <reduzio@gmail.com> | 2014-04-28 21:56:43 -0300 |
commit | 87f37bc5a305e6a68ef232be580350588e300fcc (patch) | |
tree | 608af97f58c0dd7f2f6f86d973b072f7888bfca0 /core/io/http_client.cpp | |
parent | 7fadc2f93a18f2b5487fbcd6e90bcde781c53fec (diff) |
-Added OpenSSL and HTTPS support
-Built-in version of the library for Windows, Android and iOS (other OSs use system one)
-Small fixes all around
Diffstat (limited to 'core/io/http_client.cpp')
-rw-r--r-- | core/io/http_client.cpp | 40 |
1 files changed, 36 insertions, 4 deletions
diff --git a/core/io/http_client.cpp b/core/io/http_client.cpp index f9da846844..59bc5802ea 100644 --- a/core/io/http_client.cpp +++ b/core/io/http_client.cpp @@ -27,14 +27,14 @@ /* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */ /*************************************************************************/ #include "http_client.h" - +#include "io/stream_peer_ssl.h" Error HTTPClient::connect_url(const String& p_url) { return OK; } -Error HTTPClient::connect(const String &p_host,int p_port){ +Error HTTPClient::connect(const String &p_host, int p_port, bool p_ssl){ close(); conn_port=p_port; @@ -49,7 +49,11 @@ Error HTTPClient::connect(const String &p_host,int p_port){ } + ssl=p_ssl; connection=tcp_connection; + + + if (conn_host.is_valid_ip_address()) { //is ip Error err = tcp_connection->connect(IP_Address(conn_host),p_port); @@ -233,6 +237,17 @@ Error HTTPClient::poll(){ return OK; //do none } break; case StreamPeerTCP::STATUS_CONNECTED: { + if (ssl) { + Ref<StreamPeerSSL> ssl = StreamPeerSSL::create(); + Error err = ssl->connect(tcp_connection,true,conn_host); + if (err!=OK) { + close(); + status=STATUS_SSL_HANDSHAKE_ERROR; + return ERR_CANT_CONNECT; + } + print_line("SSL! TURNED ON!"); + connection=ssl; + } status=STATUS_CONNECTED; return OK; } break; @@ -525,9 +540,20 @@ HTTPClient::Status HTTPClient::get_status() const { return status; } +void HTTPClient::set_blocking_mode(bool p_enable) { + + blocking=p_enable; +} + +bool HTTPClient::is_blocking_mode_enabled() const{ + + return blocking; +} + + void HTTPClient::_bind_methods() { - ObjectTypeDB::bind_method(_MD("connect:Error","host","port"),&HTTPClient::connect); + ObjectTypeDB::bind_method(_MD("connect:Error","host","port","use_ssl"),&HTTPClient::connect,DEFVAL(false)); ObjectTypeDB::bind_method(_MD("set_connection","connection:StreamPeer"),&HTTPClient::set_connection); ObjectTypeDB::bind_method(_MD("request","method","url","headers","body"),&HTTPClient::request,DEFVAL(String())); ObjectTypeDB::bind_method(_MD("send_body_text","body"),&HTTPClient::send_body_text); @@ -542,9 +568,13 @@ void HTTPClient::_bind_methods() { ObjectTypeDB::bind_method(_MD("get_response_body_length"),&HTTPClient::get_response_body_length); ObjectTypeDB::bind_method(_MD("read_response_body_chunk"),&HTTPClient::read_response_body_chunk); + ObjectTypeDB::bind_method(_MD("set_blocking_mode","enabled"),&HTTPClient::set_blocking_mode); + ObjectTypeDB::bind_method(_MD("is_blocking_mode_enabled"),&HTTPClient::is_blocking_mode_enabled); + ObjectTypeDB::bind_method(_MD("get_status"),&HTTPClient::get_status); ObjectTypeDB::bind_method(_MD("poll:Error"),&HTTPClient::poll); + BIND_CONSTANT( METHOD_GET ); BIND_CONSTANT( METHOD_HEAD ); BIND_CONSTANT( METHOD_POST ); @@ -564,6 +594,7 @@ void HTTPClient::_bind_methods() { BIND_CONSTANT( STATUS_REQUESTING ); // request in progress BIND_CONSTANT( STATUS_BODY ); // request resulted in body ); which must be read BIND_CONSTANT( STATUS_CONNECTION_ERROR ); + BIND_CONSTANT( STATUS_SSL_HANDSHAKE_ERROR ); BIND_CONSTANT( RESPONSE_CONTINUE ); @@ -637,7 +668,8 @@ HTTPClient::HTTPClient(){ body_left=0; chunk_left=0; response_num=0; - + ssl=false; + blocking=false; tmp_read.resize(4096); } |