summaryrefslogtreecommitdiff
path: root/util/httpclient.cpp
diff options
context:
space:
mode:
authorAntonin Kral <a.kral@bobek.cz>2011-09-14 17:08:06 +0200
committerAntonin Kral <a.kral@bobek.cz>2011-09-14 17:08:06 +0200
commit5d342a758c6095b4d30aba0750b54f13b8916f51 (patch)
tree762e9aa84781f5e3b96db2c02d356c29cf0217c0 /util/httpclient.cpp
parentcbe2d992e9cd1ea66af9fa91df006106775d3073 (diff)
downloadmongodb-5d342a758c6095b4d30aba0750b54f13b8916f51.tar.gz
Imported Upstream version 2.0.0
Diffstat (limited to 'util/httpclient.cpp')
-rw-r--r--util/httpclient.cpp150
1 files changed, 0 insertions, 150 deletions
diff --git a/util/httpclient.cpp b/util/httpclient.cpp
deleted file mode 100644
index 61d5671..0000000
--- a/util/httpclient.cpp
+++ /dev/null
@@ -1,150 +0,0 @@
-// httpclient.cpp
-
-/* Copyright 2009 10gen Inc.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-#include "pch.h"
-#include "httpclient.h"
-#include "sock.h"
-#include "message.h"
-#include "../bson/util/builder.h"
-
-namespace mongo {
-
- //#define HD(x) cout << x << endl;
-#define HD(x)
-
-
- int HttpClient::get( string url , Result * result ) {
- return _go( "GET" , url , 0 , result );
- }
-
- int HttpClient::post( string url , string data , Result * result ) {
- return _go( "POST" , url , data.c_str() , result );
- }
-
- int HttpClient::_go( const char * command , string url , const char * body , Result * result ) {
- uassert( 10271 , "invalid url" , url.find( "http://" ) == 0 );
- url = url.substr( 7 );
-
- string host , path;
- if ( url.find( "/" ) == string::npos ) {
- host = url;
- path = "/";
- }
- else {
- host = url.substr( 0 , url.find( "/" ) );
- path = url.substr( url.find( "/" ) );
- }
-
-
- HD( "host [" << host << "]" );
- HD( "path [" << path << "]" );
-
- string server = host;
- int port = 80;
-
- string::size_type idx = host.find( ":" );
- if ( idx != string::npos ) {
- server = host.substr( 0 , idx );
- string t = host.substr( idx + 1 );
- port = atoi( t.c_str() );
- }
-
- HD( "server [" << server << "]" );
- HD( "port [" << port << "]" );
-
- string req;
- {
- stringstream ss;
- ss << command << " " << path << " HTTP/1.1\r\n";
- ss << "Host: " << host << "\r\n";
- ss << "Connection: Close\r\n";
- ss << "User-Agent: mongodb http client\r\n";
- if ( body ) {
- ss << "Content-Length: " << strlen( body ) << "\r\n";
- }
- ss << "\r\n";
- if ( body ) {
- ss << body;
- }
-
- req = ss.str();
- }
-
- SockAddr addr( server.c_str() , port );
- HD( "addr: " << addr.toString() );
-
- MessagingPort p;
- if ( ! p.connect( addr ) )
- return -1;
-
- {
- const char * out = req.c_str();
- int toSend = req.size();
- p.send( out , toSend, "_go" );
- }
-
- char buf[4096];
- int got = p.unsafe_recv( buf , 4096 );
- buf[got] = 0;
-
- int rc;
- char version[32];
- assert( sscanf( buf , "%s %d" , version , &rc ) == 2 );
- HD( "rc: " << rc );
-
- StringBuilder sb;
- if ( result )
- sb << buf;
-
- while ( ( got = p.unsafe_recv( buf , 4096 ) ) > 0) {
- if ( result )
- sb << buf;
- }
-
- if ( result ) {
- result->_init( rc , sb.str() );
- }
-
- return rc;
- }
-
- void HttpClient::Result::_init( int code , string entire ) {
- _code = code;
- _entireResponse = entire;
-
- while ( true ) {
- size_t i = entire.find( '\n' );
- if ( i == string::npos ) {
- // invalid
- break;
- }
-
- string h = entire.substr( 0 , i );
- entire = entire.substr( i + 1 );
-
- if ( h.size() && h[h.size()-1] == '\r' )
- h = h.substr( 0 , h.size() - 1 );
-
- if ( h.size() == 0 )
- break;
- }
-
- _body = entire;
- }
-
-
-}