forked from premiere/premiere-libtorrent
108 lines
3.0 KiB
C++
108 lines
3.0 KiB
C++
#include "test.hpp"
|
|
#include "libtorrent/socket.hpp"
|
|
#include "libtorrent/connection_queue.hpp"
|
|
#include "libtorrent/http_connection.hpp"
|
|
#include "setup_transfer.hpp"
|
|
|
|
#include <fstream>
|
|
#include <boost/optional.hpp>
|
|
|
|
using namespace libtorrent;
|
|
|
|
io_service ios;
|
|
connection_queue cq(ios);
|
|
|
|
int connect_handler_called = 0;
|
|
int handler_called = 0;
|
|
int data_size = 0;
|
|
int http_status = 0;
|
|
asio::error_code error_code;
|
|
char data_buffer[4000];
|
|
|
|
void print_http_header(http_parser const& p)
|
|
{
|
|
std::cerr << " < " << p.status_code() << " " << p.message() << std::endl;
|
|
|
|
for (std::map<std::string, std::string>::const_iterator i
|
|
= p.headers().begin(), end(p.headers().end()); i != end; ++i)
|
|
{
|
|
std::cerr << " < " << i->first << ": " << i->second << std::endl;
|
|
}
|
|
}
|
|
|
|
void http_connect_handler(http_connection& c)
|
|
{
|
|
++connect_handler_called;
|
|
TEST_CHECK(c.socket().is_open());
|
|
std::cerr << "connected to: " << c.socket().remote_endpoint() << std::endl;
|
|
TEST_CHECK(c.socket().remote_endpoint().address() == address::from_string("127.0.0.1"));
|
|
}
|
|
|
|
void http_handler(asio::error_code const& ec, http_parser const& parser, char const* data, int size)
|
|
{
|
|
++handler_called;
|
|
data_size = size;
|
|
error_code = ec;
|
|
|
|
if (parser.header_finished())
|
|
{
|
|
http_status = parser.status_code();
|
|
if (http_status == 200)
|
|
{
|
|
TEST_CHECK(memcmp(data, data_buffer, size) == 0);
|
|
}
|
|
}
|
|
print_http_header(parser);
|
|
|
|
cq.close();
|
|
}
|
|
|
|
void reset_globals()
|
|
{
|
|
connect_handler_called = 0;
|
|
handler_called = 0;
|
|
data_size = 0;
|
|
http_status = 0;
|
|
error_code = asio::error_code();
|
|
}
|
|
|
|
void run_test(char const* url, int size, int status, int connected, boost::optional<asio::error_code> ec)
|
|
{
|
|
reset_globals();
|
|
|
|
std::cerr << " ===== TESTING: " << url << " =====" << std::endl;
|
|
|
|
boost::shared_ptr<http_connection> h(new http_connection(ios, cq
|
|
, &::http_handler, true, &::http_connect_handler));
|
|
h->get(url);
|
|
ios.reset();
|
|
ios.run();
|
|
|
|
std::cerr << "connect_handler_called: " << connect_handler_called << std::endl;
|
|
std::cerr << "handler_called: " << handler_called << std::endl;
|
|
std::cerr << "status: " << http_status << std::endl;
|
|
std::cerr << "size: " << data_size << std::endl;
|
|
std::cerr << "error_code: " << error_code.message() << std::endl;
|
|
TEST_CHECK(connect_handler_called == connected);
|
|
TEST_CHECK(handler_called == 1);
|
|
TEST_CHECK(data_size == size || size == -1);
|
|
TEST_CHECK(!ec || error_code == ec);
|
|
TEST_CHECK(http_status == status || status == -1);
|
|
}
|
|
|
|
int test_main()
|
|
{
|
|
typedef boost::optional<asio::error_code> err;
|
|
start_web_server(8001);
|
|
std::srand(std::time(0));
|
|
std::generate(data_buffer, data_buffer + sizeof(data_buffer), &std::rand);
|
|
std::ofstream("test_file").write(data_buffer, 3216);
|
|
run_test("http://127.0.0.1:8001/test_file", 3216, 200, 1, asio::error_code());
|
|
run_test("http://127.0.0.1:8001/non-existing-file", -1, 404, 1, err());
|
|
run_test("http://non-existent-domain.se/non-existing-file", -1, -1, 0, err(asio::error::host_not_found));
|
|
stop_web_server(8001);
|
|
std::remove("test_file");
|
|
return 0;
|
|
}
|
|
|