/** * @file llhttpclient_test.cpp * @brief Testing the HTTP client classes. * * $LicenseInfo:firstyear=2006&license=viewerlgpl$ * Second Life Viewer Source Code * Copyright (C) 2010, Linden Research, Inc. * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; * version 2.1 of the License only. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with this library; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA * * Linden Research, Inc., 945 Battery Street, San Francisco, CA 94111 USA * $/LicenseInfo$ */ /** * * These classes test the HTTP client framework. * */ #include #include "linden_common.h" #include "lltut.h" #include "llhttpclient.h" #include "llformat.h" #include "llpipeutil.h" #include "llproxy.h" #include "llpumpio.h" #include "llsdhttpserver.h" #include "lliohttpserver.h" #include "lliosocket.h" #include "stringize.h" namespace tut { LLSD storage; class LLSDStorageNode : public LLHTTPNode { public: LLSD simpleGet() const { return storage; } LLSD simplePut(const LLSD& value) const { storage = value; return LLSD(); } }; class ErrorNode : public LLHTTPNode { public: void get(ResponsePtr r, const LLSD& context) const { r->status(599, "Intentional error"); } void post(ResponsePtr r, const LLSD& context, const LLSD& input) const { r->status(input["status"], input["reason"]); } }; class TimeOutNode : public LLHTTPNode { public: void get(ResponsePtr r, const LLSD& context) const { /* do nothing, the request will eventually time out */ } }; LLHTTPRegistration gStorageNode("/test/storage"); LLHTTPRegistration gErrorNode("/test/error"); LLHTTPRegistration gTimeOutNode("/test/timeout"); struct HTTPClientTestData { public: HTTPClientTestData(): local_server(STRINGIZE("http://127.0.0.1:" << getenv("PORT") << "/")) { apr_pool_create(&mPool, NULL); LLCurl::initClass(false); mServerPump = new LLPumpIO(mPool); mClientPump = new LLPumpIO(mPool); LLHTTPClient::setPump(*mClientPump); } ~HTTPClientTestData() { delete mServerPump; delete mClientPump; LLProxy::cleanupClass(); apr_pool_destroy(mPool); } void setupTheServer() { LLHTTPNode& root = LLIOHTTPServer::create(mPool, *mServerPump, 8888); LLHTTPStandardServices::useServices(); LLHTTPRegistrar::buildAllServices(root); } void runThePump(float timeout = 100.0f) { LLTimer timer; timer.setTimerExpirySec(timeout); while(!mSawCompleted && !mSawCompletedHeader && !timer.hasExpired()) { if (mServerPump) { mServerPump->pump(); mServerPump->callback(); } if (mClientPump) { mClientPump->pump(); mClientPump->callback(); } } } void killServer() { delete mServerPump; mServerPump = NULL; } const std::string local_server; private: apr_pool_t* mPool; LLPumpIO* mServerPump; LLPumpIO* mClientPump; protected: void ensureStatusOK() { if (mSawError) { std::string msg = llformat("error() called when not expected, status %d", mStatus); fail(msg); } } void ensureStatusError() { if (!mSawError) { fail("error() wasn't called"); } } LLSD getResult() { return mResult; } LLSD getHeader() { return mHeader; } protected: bool mSawError; U32 mStatus; std::string mReason; bool mSawCompleted; bool mSawCompletedHeader; LLSD mResult; LLSD mHeader; bool mResultDeleted; class Result : public LLHTTPClient::Responder { protected: Result(HTTPClientTestData& client) : mClient(client) { } public: static boost::intrusive_ptr build(HTTPClientTestData& client) { return boost::intrusive_ptr(new Result(client)); } ~Result() { mClient.mResultDeleted = true; } virtual void error(U32 status, const std::string& reason) { mClient.mSawError = true; mClient.mStatus = status; mClient.mReason = reason; } virtual void result(const LLSD& content) { mClient.mResult = content; } virtual void completed( U32 status, const std::string& reason, const LLSD& content) { LLHTTPClient::Responder::completed(status, reason, content); mClient.mSawCompleted = true; } virtual void completedHeader( U32 status, const std::string& reason, const LLSD& content) { mClient.mHeader = content; mClient.mSawCompletedHeader = true; } private: HTTPClientTestData& mClient; }; friend class Result; protected: LLHTTPClient::ResponderPtr newResult() { mSawError = false; mStatus = 0; mSawCompleted = false; mSawCompletedHeader = false; mResult.clear(); mHeader.clear(); mResultDeleted = false; return Result::build(*this); } }; typedef test_group HTTPClientTestGroup; typedef HTTPClientTestGroup::object HTTPClientTestObject; HTTPClientTestGroup httpClientTestGroup("http_client"); template<> template<> void HTTPClientTestObject::test<1>() { LLHTTPClient::get(local_server, newResult()); runThePump(); ensureStatusOK(); ensure("result object wasn't destroyed", mResultDeleted); } template<> template<> void HTTPClientTestObject::test<2>() { // Please nobody listen on this particular port... LLHTTPClient::get("http://127.0.0.1:7950", newResult()); runThePump(); ensureStatusError(); } template<> template<> void HTTPClientTestObject::test<3>() { LLSD sd; sd["list"][0]["one"] = 1; sd["list"][0]["two"] = 2; sd["list"][1]["three"] = 3; sd["list"][1]["four"] = 4; setupTheServer(); LLHTTPClient::post("http://localhost:8888/web/echo", sd, newResult()); runThePump(); ensureStatusOK(); ensure_equals("echoed result matches", getResult(), sd); } template<> template<> void HTTPClientTestObject::test<4>() { LLSD sd; sd["message"] = "This is my test message."; setupTheServer(); LLHTTPClient::put("http://localhost:8888/test/storage", sd, newResult()); runThePump(); ensureStatusOK(); LLHTTPClient::get("http://localhost:8888/test/storage", newResult()); runThePump(); ensureStatusOK(); ensure_equals("echoed result matches", getResult(), sd); } template<> template<> void HTTPClientTestObject::test<5>() { LLSD sd; sd["status"] = 543; sd["reason"] = "error for testing"; setupTheServer(); LLHTTPClient::post("http://localhost:8888/test/error", sd, newResult()); runThePump(); ensureStatusError(); ensure_contains("reason", mReason, sd["reason"]); } template<> template<> void HTTPClientTestObject::test<6>() { setupTheServer(); LLHTTPClient::get("http://localhost:8888/test/timeout", newResult()); runThePump(1.0f); killServer(); runThePump(); ensureStatusError(); ensure_equals("reason", mReason, "STATUS_ERROR"); } template<> template<> void HTTPClientTestObject::test<7>() { // Can not use the little mini server. The blocking request // won't ever let it run. Instead get from a known LLSD // source and compare results with the non-blocking get which // is tested against the mini server earlier. LLHTTPClient::get(local_server, newResult()); runThePump(); ensureStatusOK(); LLSD expected = getResult(); LLSD result; result = LLHTTPClient::blockingGet(local_server); LLSD body = result["body"]; ensure_equals("echoed result matches", body.size(), expected.size()); } template<> template<> void HTTPClientTestObject::test<8>() { // This is testing for the presence of the Header in the returned results // from an HTTP::get call. LLHTTPClient::get(local_server, newResult()); runThePump(); ensureStatusOK(); LLSD header = getHeader(); ensure("got a header", ! header.emptyMap().asBoolean()); } template<> template<> void HTTPClientTestObject::test<9>() { LLHTTPClient::head(local_server, newResult()); runThePump(); ensureStatusOK(); ensure("result object wasn't destroyed", mResultDeleted); } }