summaryrefslogtreecommitdiff
path: root/core/io/http_client.cpp
diff options
context:
space:
mode:
authorJuan Linietsky <reduzio@gmail.com>2014-04-28 21:56:43 -0300
committerJuan Linietsky <reduzio@gmail.com>2014-04-28 21:56:43 -0300
commit87f37bc5a305e6a68ef232be580350588e300fcc (patch)
tree608af97f58c0dd7f2f6f86d973b072f7888bfca0 /core/io/http_client.cpp
parent7fadc2f93a18f2b5487fbcd6e90bcde781c53fec (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.cpp40
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);
}