X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Ftest_filter_rewrite.cpp;h=110d6144037ec4d8d29d7e92f4fb2990c22fd67f;hb=586d78659d671683f33ec55f4a7d32b28e345ccd;hp=65cb4c08fd140425d27b20e258c2f62debea150e;hpb=8bcd4c3e063e932b2f80f9491ec0af66d3da5c2e;p=metaproxy-moved-to-github.git diff --git a/src/test_filter_rewrite.cpp b/src/test_filter_rewrite.cpp index 65cb4c0..110d614 100644 --- a/src/test_filter_rewrite.cpp +++ b/src/test_filter_rewrite.cpp @@ -1,5 +1,5 @@ /* This file is part of Metaproxy. - Copyright (C) 2005-2013 Index Data + Copyright (C) Index Data Metaproxy is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free @@ -38,29 +38,11 @@ Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA using namespace boost::unit_test; namespace mp = metaproxy_1; -/* - * The global testconfig is commented out, as it won't even compile - * on old Centos5 machines -struct TestConfig { - TestConfig() - { - std::cout << "global setup\n"; - yaz_log_init_level(YLOG_ALL); - } - ~TestConfig() - { - std::cout << "global teardown\n"; - } -}; - -BOOST_GLOBAL_FIXTURE( TestConfig ); -*/ BOOST_AUTO_TEST_CASE( test_filter_rewrite_1 ) { try { - std::cout << "Running non-xml config test case" << std::endl; mp::RouterChain router; mp::filter::HttpRewrite fhr; @@ -68,30 +50,45 @@ BOOST_AUTO_TEST_CASE( test_filter_rewrite_1 ) "\n" "\n" - " \n" - " \n" - " \n" + " \n" + " \n" + " \n" " \n" " \n" - " \n" - " \n" - " \n" + " \n" + " \n" + " \n" + " \n" + " \n" " \n" - " \n" - " \n" - " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" " \n" " \n" - " \n" - " \n" - " \n" - " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" " \n" "\n" ; @@ -112,15 +109,17 @@ BOOST_AUTO_TEST_CASE( test_filter_rewrite_1 ) mp::odr odr; Z_GDU *gdu_req = z_get_HTTP_Request_uri(odr, - "http://proxyhost/proxypath/targetsite/page1.html", 0, 1); - + "http://proxyhost/proxypath/targetsite/page1.html", 0, 1); + + Z_HTTP_Request *hreq = gdu_req->u.HTTP_Request; + z_HTTP_header_set(odr, &hreq->headers, + "X-Metaproxy-SkipLink", ".* skiplink.com" ); pack.request() = gdu_req; //create the http response const char *resp_buf = "HTTP/1.1 200 OK\r\n" - "Content-Length: 441\r\n" "Content-Type: text/html\r\n" "Link: ; rel=absolute\r\n" "Link: ; rel=relative\r\n" @@ -132,7 +131,10 @@ BOOST_AUTO_TEST_CASE( test_filter_rewrite_1 ) "}" "" "" - "" + "" "" "

Welcome to our website. It doesn't make it easy to get pro" "xified" @@ -141,11 +143,14 @@ BOOST_AUTO_TEST_CASE( test_filter_rewrite_1 ) "" " Another abs link" "" + "" + "\n" + "skip\n" ""; const char *resp_expected = "HTTP/1.1 200 OK\r\n" - "Content-Length: 522\r\n" + "Content-Length: 686\r\n" "Content-Type: text/html\r\n" "Link: ; rel=absolute\r\n" "Link: ; rel=relative\r\n" @@ -157,65 +162,213 @@ BOOST_AUTO_TEST_CASE( test_filter_rewrite_1 ) "}" "" "" - "" + "" "" "

Welcome to our website. It doesn't make it easy to get pro" "xified" "" " An absolute link" - "" + "" " Another abs link" "" + "" + "\n" + "skip\n" ""; - int r; Z_GDU *gdu_res; - ODR dec = odr_createmem(ODR_DECODE); + mp::odr dec(ODR_DECODE); + mp::odr enc(ODR_ENCODE); odr_setbuf(dec, (char *) resp_buf, strlen(resp_buf), 0); - r = z_GDU(dec, &gdu_res, 0, 0); + int r = z_GDU(dec, &gdu_res, 0, 0); BOOST_CHECK(r); if (r) { BOOST_CHECK_EQUAL(gdu_res->which, Z_GDU_HTTP_Response); + + pack.response() = gdu_res; + + //feed to the router + pack.router(router).move(); + + //analyze the response + Z_GDU *gdu_res_rew = pack.response().get(); + BOOST_CHECK(gdu_res_rew); + BOOST_CHECK_EQUAL(gdu_res_rew->which, Z_GDU_HTTP_Response); + + Z_HTTP_Response *hres = gdu_res_rew->u.HTTP_Response; + BOOST_CHECK(hres); + + z_GDU(enc, &gdu_res_rew, 0, 0); + char *resp_result; + int resp_result_len; + resp_result = odr_getbuf(enc, &resp_result_len, 0); + + int equal = ((size_t) resp_result_len == strlen(resp_expected)) + && !memcmp(resp_result, resp_expected, resp_result_len); + BOOST_CHECK(equal); + + if (!equal) + { + //compare buffers + std::cout << "Expected result:\n" << resp_expected << "\n"; + std::cout << "Got result:\n"; + fflush(stdout); + fwrite(resp_result, 1, resp_result_len, stdout); + fflush(stdout); + std::cout << "\nGot result buf len: " << resp_result_len + << "\n"; + } } + } + catch (std::exception & e) { + std::cout << e.what(); + std::cout << std::endl; + BOOST_CHECK (false); + } +} + +BOOST_AUTO_TEST_CASE( test_filter_rewrite_2 ) +{ + try + { + mp::RouterChain router; + mp::filter::HttpRewrite fhr; + + std::string xmlconf = + "\n" + "\n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + " \n" + "\n" + ; + + std::cout << xmlconf; + + // reading and parsing XML conf + xmlDocPtr doc = xmlParseMemory(xmlconf.c_str(), xmlconf.size()); + BOOST_CHECK(doc); + xmlNode *root_element = xmlDocGetRootElement(doc); + fhr.configure(root_element, true, ""); + xmlFreeDoc(doc); - pack.response() = gdu_res; + router.append(fhr); - //feed to the router - pack.router(router).move(); + // create an http request + mp::Package pack; - //analyze the response - Z_GDU *gdu_res_rew = pack.response().get(); - BOOST_CHECK(gdu_res_rew); - BOOST_CHECK_EQUAL(gdu_res_rew->which, Z_GDU_HTTP_Response); + mp::odr odr; + Z_GDU *gdu_req = z_get_HTTP_Request_uri(odr, + "http://proxyhost/proxypath/targetsite/page1.html", 0, 1); - Z_HTTP_Response *hres = gdu_res_rew->u.HTTP_Response; - BOOST_CHECK(hres); + pack.request() = gdu_req; - //compare buffers - std::cout << "Expected result:\n" << resp_expected << std::endl; + //create the http response - ODR enc = odr_createmem(ODR_ENCODE); - z_GDU(enc, &gdu_res_rew, 0, 0); - char *resp_result; - int resp_result_len; - resp_result = odr_getbuf(enc, &resp_result_len, 0); + const char *resp_buf = + "HTTP/1.1 200 OK\r\n" + "Content-Type: application/javascript\r\n" + "Link: ; rel=absolute\r\n" + "Link: ; rel=relative\r\n" + "\r\n" + "// \"\n" + "my.location = 'http://targetsite/images/bg.png';\n" + "my.other = \"http://targetsite/images/fg.png\";\n" + "my.thrd = \"other\";\n" + "// \"http://targetsite/images/bg.png\n"; - BOOST_CHECK(resp_result); - BOOST_CHECK_EQUAL((size_t) resp_result_len, strlen(resp_expected)); + const char *resp_expected = + "HTTP/1.1 200 OK\r\n" + "Content-Length: 195\r\n" + "Content-Type: application/javascript\r\n" + "Link: ; rel=absolute\r\n" + "Link: ; rel=relative\r\n" + "\r\n" + "// \"\n" + "my.location = 'http://proxyhost/proxypath/targetsite/images/bg.png';\n" + "my.other = \"http://proxyhost/proxypath/targetsite/images/fg.png\";\n" + "my.thrd = \"other\";\n" + "// \"http://targetsite/images/bg.png\n"; - std::cout << "Rewritten result:\n" << std::endl; - fflush(stdout); - fwrite(resp_result, 1, resp_result_len, stdout); - fflush(stdout); - std::cout << "\nRewritten result buf len: " << resp_result_len - << std::endl; + Z_GDU *gdu_res; + mp::odr dec(ODR_DECODE); + mp::odr enc(ODR_ENCODE); + odr_setbuf(dec, (char *) resp_buf, strlen(resp_buf), 0); + int r = z_GDU(dec, &gdu_res, 0, 0); - BOOST_CHECK(memcmp(resp_result, resp_expected, resp_result_len) == 0); + BOOST_CHECK(r); + if (r) + { + BOOST_CHECK_EQUAL(gdu_res->which, Z_GDU_HTTP_Response); - odr_destroy(dec); - odr_destroy(enc); + pack.response() = gdu_res; + + //feed to the router + pack.router(router).move(); + + //analyze the response + Z_GDU *gdu_res_rew = pack.response().get(); + BOOST_CHECK(gdu_res_rew); + BOOST_CHECK_EQUAL(gdu_res_rew->which, Z_GDU_HTTP_Response); + + Z_HTTP_Response *hres = gdu_res_rew->u.HTTP_Response; + BOOST_CHECK(hres); + + z_GDU(enc, &gdu_res_rew, 0, 0); + char *resp_result; + int resp_result_len; + resp_result = odr_getbuf(enc, &resp_result_len, 0); + + int equal = ((size_t) resp_result_len == strlen(resp_expected)) + && !memcmp(resp_result, resp_expected, resp_result_len); + BOOST_CHECK(equal); + + if (!equal) + { + //compare buffers + std::cout << "Expected result:\n" << resp_expected << "\n"; + std::cout << "Got result:\n"; + fflush(stdout); + fwrite(resp_result, 1, resp_result_len, stdout); + fflush(stdout); + std::cout << "\nGot result buf len: " << resp_result_len + << "\n"; + } + } } catch (std::exception & e) { std::cout << e.what(); @@ -224,7 +377,6 @@ BOOST_AUTO_TEST_CASE( test_filter_rewrite_1 ) } } - /* * Local variables: * c-basic-offset: 4