mirror of
https://github.com/SpartanJ/eepp.git
synced 2026-06-01 02:56:28 +03:00
clang-formated all project source files.
Improved documentation. --HG-- branch : dev
This commit is contained in:
Martín Lucas Golini
@@ -1,11 +1,13 @@
|
||||
#include <eepp/ee.hpp>
|
||||
#include <args/args.hxx>
|
||||
#include <eepp/ee.hpp>
|
||||
|
||||
// Prints the response headers
|
||||
void printResponseHeaders( Http::Response& response ) {
|
||||
Http::Response::FieldTable headers = response.getHeaders();
|
||||
|
||||
std::cout << "HTTP/" << response.getMajorHttpVersion() << "." << response.getMinorHttpVersion() << " " << response.getStatus() << " " << Http::Response::statusToString( response.getStatus() ) << std::endl;
|
||||
std::cout << "HTTP/" << response.getMajorHttpVersion() << "." << response.getMinorHttpVersion()
|
||||
<< " " << response.getStatus() << " "
|
||||
<< Http::Response::statusToString( response.getStatus() ) << std::endl;
|
||||
|
||||
for ( auto&& head : headers ) {
|
||||
std::cout << head.first << ": " << head.second << std::endl;
|
||||
@@ -14,35 +16,45 @@ void printResponseHeaders( Http::Response& response ) {
|
||||
std::cout << std::endl;
|
||||
}
|
||||
|
||||
EE_MAIN_FUNC int main (int argc, char * argv []) {
|
||||
args::ArgumentParser parser("HTTP request program example");
|
||||
args::HelpFlag help(parser, "help", "Display this help menu", {'h', "help"});
|
||||
args::Flag resume(parser, "continue", "Resume getting a partially-downloaded file", {'c',"continue"});
|
||||
args::Flag compressed(parser, "compressed", "Request compressed response", {"compressed"});
|
||||
args::ValueFlag<std::string> postData(parser, "data", "HTTP POST data", {'d', "data"});
|
||||
args::ValueFlagList<std::string> multipartData(parser, "multipart-data", "Specify multipart MIME data", {'F', "form"});
|
||||
args::ValueFlagList<std::string> headers(parser, "header", "Pass custom header(s) to server", {'H', "header"});
|
||||
args::Flag includeHead(parser, "include", "Include protocol response headers in the output", {'i',"include"});
|
||||
args::Flag insecure(parser, "insecure", "Allow insecure server connections when using SSL", {'k',"insecure"});
|
||||
args::Flag location(parser, "location", "Follow redirects", {'L',"location"});
|
||||
args::ValueFlag<unsigned int> maxRedirs(parser, "max-redirs", "Maximum number of redirects allowed", {"max-redirs"});
|
||||
args::ValueFlag<std::string> output(parser, "file", "Write to file instead of stdout", {'o', "output"});
|
||||
args::ValueFlag<std::string> proxy(parser, "proxy", "[protocol://]host[:port] Use this proxy", {'x', "proxy"});
|
||||
args::Flag progress(parser, "progress", "Show current progress of a download", {'p',"progress"});
|
||||
args::Flag verbose(parser, "verbose", "Make the operation more talkative", {'v',"verbose"});
|
||||
args::ValueFlag<std::string> requestMethod(parser, "request", "Specify request command to use", {'X', "request"});
|
||||
args::Positional<std::string> url(parser, "URL", "The URL to request");
|
||||
EE_MAIN_FUNC int main( int argc, char* argv[] ) {
|
||||
args::ArgumentParser parser( "HTTP request program example" );
|
||||
args::HelpFlag help( parser, "help", "Display this help menu", {'h', "help"} );
|
||||
args::Flag resume( parser, "continue", "Resume getting a partially-downloaded file",
|
||||
{'c', "continue"} );
|
||||
args::Flag compressed( parser, "compressed", "Request compressed response", {"compressed"} );
|
||||
args::ValueFlag<std::string> postData( parser, "data", "HTTP POST data", {'d', "data"} );
|
||||
args::ValueFlagList<std::string> multipartData( parser, "multipart-data",
|
||||
"Specify multipart MIME data", {'F', "form"} );
|
||||
args::ValueFlagList<std::string> headers( parser, "header", "Pass custom header(s) to server",
|
||||
{'H', "header"} );
|
||||
args::Flag includeHead( parser, "include", "Include protocol response headers in the output",
|
||||
{'i', "include"} );
|
||||
args::Flag insecure( parser, "insecure", "Allow insecure server connections when using SSL",
|
||||
{'k', "insecure"} );
|
||||
args::Flag location( parser, "location", "Follow redirects", {'L', "location"} );
|
||||
args::ValueFlag<unsigned int> maxRedirs(
|
||||
parser, "max-redirs", "Maximum number of redirects allowed", {"max-redirs"} );
|
||||
args::ValueFlag<std::string> output( parser, "file", "Write to file instead of stdout",
|
||||
{'o', "output"} );
|
||||
args::ValueFlag<std::string> proxy( parser, "proxy", "[protocol://]host[:port] Use this proxy",
|
||||
{'x', "proxy"} );
|
||||
args::Flag progress( parser, "progress", "Show current progress of a download",
|
||||
{'p', "progress"} );
|
||||
args::Flag verbose( parser, "verbose", "Make the operation more talkative", {'v', "verbose"} );
|
||||
args::ValueFlag<std::string> requestMethod( parser, "request", "Specify request command to use",
|
||||
{'X', "request"} );
|
||||
args::Positional<std::string> url( parser, "URL", "The URL to request" );
|
||||
|
||||
try {
|
||||
parser.ParseCLI(argc, argv);
|
||||
} catch (const args::Help&) {
|
||||
parser.ParseCLI( argc, argv );
|
||||
} catch ( const args::Help& ) {
|
||||
std::cout << parser;
|
||||
return EXIT_SUCCESS;
|
||||
} catch (const args::ParseError& e) {
|
||||
} catch ( const args::ParseError& e ) {
|
||||
std::cerr << e.what() << std::endl;
|
||||
std::cerr << parser;
|
||||
return EXIT_FAILURE;
|
||||
} catch (args::ValidationError& e) {
|
||||
} catch ( args::ValidationError& e ) {
|
||||
std::cerr << e.what() << std::endl;
|
||||
std::cerr << parser;
|
||||
return EXIT_FAILURE;
|
||||
@@ -67,8 +79,8 @@ EE_MAIN_FUNC int main (int argc, char * argv []) {
|
||||
|
||||
// Allow insecure connections if requested
|
||||
if ( insecure ) {
|
||||
request.setValidateCertificate(false);
|
||||
request.setValidateHostname(false);
|
||||
request.setValidateCertificate( false );
|
||||
request.setValidateHostname( false );
|
||||
}
|
||||
|
||||
// Set the host and port from the URI
|
||||
@@ -78,12 +90,12 @@ EE_MAIN_FUNC int main (int argc, char * argv []) {
|
||||
request.setUri( uri.getPathEtc() );
|
||||
|
||||
// Set the headers
|
||||
for ( const std::string& header : args::get(headers) ) {
|
||||
for ( const std::string& header : args::get( headers ) ) {
|
||||
std::string::size_type pos = header.find_first_of( ':' );
|
||||
if ( std::string::npos != pos ) {
|
||||
std::string key( header.substr( 0, pos ) );
|
||||
std::string val( String::trim( header.substr( pos + 1 ) ) );
|
||||
request.setField(key, val);
|
||||
request.setField( key, val );
|
||||
}
|
||||
}
|
||||
|
||||
@@ -96,7 +108,7 @@ EE_MAIN_FUNC int main (int argc, char * argv []) {
|
||||
// Set the multipart data
|
||||
if ( multipartData ) {
|
||||
Http::MultipartEntitiesBuilder builder;
|
||||
for ( const std::string& part : args::get(multipartData) ) {
|
||||
for ( const std::string& part : args::get( multipartData ) ) {
|
||||
std::string::size_type pos = part.find_first_of( "=" );
|
||||
if ( std::string::npos != pos ) {
|
||||
std::string name( part.substr( 0, pos ) );
|
||||
@@ -127,50 +139,55 @@ EE_MAIN_FUNC int main (int argc, char * argv []) {
|
||||
|
||||
// If progress requested print a progress on screen
|
||||
if ( progress ) {
|
||||
request.setProgressCallback( []( const Http&, const Http::Request&, const Http::Response&, const Http::Request::Status& status, size_t totalBytes, size_t currentBytes ) {
|
||||
request.setProgressCallback( []( const Http&, const Http::Request&,
|
||||
const Http::Response&,
|
||||
const Http::Request::Status& status,
|
||||
size_t totalBytes, size_t currentBytes ) {
|
||||
if ( status == Http::Request::ContentReceived ) {
|
||||
static Clock elapsed;
|
||||
static Clock tickElapsed;
|
||||
if ( tickElapsed.getElapsedTime().asMilliseconds() < 100.f && totalBytes != currentBytes )
|
||||
if ( tickElapsed.getElapsedTime().asMilliseconds() < 100.f &&
|
||||
totalBytes != currentBytes )
|
||||
return true;
|
||||
tickElapsed.restart();
|
||||
double progress = currentBytes / static_cast<double>( totalBytes );
|
||||
Time eta( elapsed.getElapsedTime() / progress - elapsed.getElapsedTime() );
|
||||
int percent = static_cast<int>( eefloor( progress * 100. ) );
|
||||
std::string bytesProgress(
|
||||
String::format(
|
||||
"%s of %s", FileSystem::sizeToString( currentBytes ).c_str(),
|
||||
FileSystem::sizeToString( totalBytes ).c_str() ) );
|
||||
std::string bytesProgress( String::format(
|
||||
"%s of %s", FileSystem::sizeToString( currentBytes ).c_str(),
|
||||
FileSystem::sizeToString( totalBytes ).c_str() ) );
|
||||
double downloadSpeed = currentBytes / elapsed.getElapsedTime().asSeconds();
|
||||
std::cout << "\rDownloaded " << percent << "% (" << bytesProgress << ").";
|
||||
std::cout << "\rDownloaded " << percent << "% (" << bytesProgress << ").";
|
||||
|
||||
if ( totalBytes != currentBytes ) {
|
||||
std::cout << " ETA: " << eta.toString() << ".";
|
||||
} else {
|
||||
std::cout << " Downloaded in: " << elapsed.getElapsedTime().toString() << ".";
|
||||
std::cout << " Downloaded in: " << elapsed.getElapsedTime().toString()
|
||||
<< ".";
|
||||
}
|
||||
|
||||
std::cout << " Download Speed: " << FileSystem::sizeToString( downloadSpeed ) << "/s.";
|
||||
std::cout << " Download Speed: "
|
||||
<< FileSystem::sizeToString( downloadSpeed ) << "/s.";
|
||||
std::cout << " ";
|
||||
std::cout << std::flush;
|
||||
if ( totalBytes == currentBytes )
|
||||
std::cout << std::endl;
|
||||
}
|
||||
return true;
|
||||
});
|
||||
} );
|
||||
}
|
||||
|
||||
// Set follow redirect
|
||||
request.setFollowRedirect(location.Get());
|
||||
request.setFollowRedirect( location.Get() );
|
||||
|
||||
// Set the maximun number of redirects
|
||||
if ( maxRedirs ) {
|
||||
request.setMaxRedirects(maxRedirs.Get());
|
||||
request.setMaxRedirects( maxRedirs.Get() );
|
||||
}
|
||||
|
||||
// Set the proxy for the request
|
||||
char * http_proxy = getenv( "http_proxy" );
|
||||
if ( !proxy && NULL != http_proxy ) {
|
||||
char* http_proxy = getenv( "http_proxy" );
|
||||
if ( !proxy && NULL != http_proxy ) {
|
||||
http.setProxy( URI( http_proxy ) );
|
||||
} else if ( proxy ) {
|
||||
http.setProxy( URI( proxy.Get() ) );
|
||||
@@ -188,18 +205,19 @@ EE_MAIN_FUNC int main (int argc, char * argv []) {
|
||||
|
||||
if ( !output ) {
|
||||
// Send the request
|
||||
Http::Response response = http.sendRequest(request);
|
||||
Http::Response response = http.sendRequest( request );
|
||||
|
||||
// Check the status code and display the result
|
||||
Http::Response::Status status = response.getStatus();
|
||||
|
||||
if ( includeHead )
|
||||
printResponseHeaders(response);
|
||||
printResponseHeaders( response );
|
||||
|
||||
if ( status == Http::Response::Ok ) {
|
||||
std::cout << response.getBody();
|
||||
} else {
|
||||
std::cout << "Error " << status << std::endl << response.getStatusDescription() << std::endl;
|
||||
std::cout << "Error " << status << std::endl
|
||||
<< response.getStatusDescription() << std::endl;
|
||||
std::cout << response.getBody();
|
||||
}
|
||||
} else {
|
||||
@@ -218,19 +236,21 @@ EE_MAIN_FUNC int main (int argc, char * argv []) {
|
||||
if ( !FileSystem::fileExists( path + lastPathSegment ) || resume ) {
|
||||
path += lastPathSegment;
|
||||
} else {
|
||||
path += FileSystem::fileGetNumberedFileNameFromPath( path, lastPathSegment );
|
||||
path += FileSystem::fileGetNumberedFileNameFromPath( path,
|
||||
lastPathSegment );
|
||||
}
|
||||
} else {
|
||||
// Create a file name if no name found
|
||||
path += FileSystem::fileGetNumberedFileNameFromPath( path, "eepp-network-file", "-" );
|
||||
path += FileSystem::fileGetNumberedFileNameFromPath(
|
||||
path, "eepp-network-file", "-" );
|
||||
}
|
||||
}
|
||||
|
||||
// Download the request response into a file
|
||||
Http::Response response = http.downloadRequest(request, path, Seconds(5));
|
||||
Http::Response response = http.downloadRequest( request, path, Seconds( 5 ) );
|
||||
|
||||
if ( includeHead )
|
||||
printResponseHeaders(response);
|
||||
printResponseHeaders( response );
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user