/**
 * @file llappcorehttp.cpp
 * @brief 
 *
 * $LicenseInfo:firstyear=2012&license=viewerlgpl$
 * Second Life Viewer Source Code
 * Copyright (C) 2012-2013, 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$
 */

#include "llviewerprecompiledheaders.h"

#include "llappcorehttp.h"

#include "llviewercontrol.h"


const F64 LLAppCoreHttp::MAX_THREAD_WAIT_TIME(10.0);

LLAppCoreHttp::LLAppCoreHttp()
	: mRequest(NULL),
	  mStopHandle(LLCORE_HTTP_HANDLE_INVALID),
	  mStopRequested(0.0),
	  mStopped(false),
	  mPolicyDefault(-1),
	  mPolicyTexture(-1),
	  mPolicyMesh(-1)
{}


LLAppCoreHttp::~LLAppCoreHttp()
{
	delete mRequest;
	mRequest = NULL;
}


void LLAppCoreHttp::init()
{
	LLCore::HttpStatus status = LLCore::HttpRequest::createService();
	if (! status)
	{
		LL_ERRS("Init") << "Failed to initialize HTTP services.  Reason:  "
						<< status.toString()
						<< LL_ENDL;
	}

	// Point to our certs or SSH/https: will fail on connect
	status = LLCore::HttpRequest::setPolicyGlobalOption(LLCore::HttpRequest::GP_CA_FILE,
														gDirUtilp->getCAFile());
	if (! status)
	{
		LL_ERRS("Init") << "Failed to set CA File for HTTP services.  Reason:  "
						<< status.toString()
						<< LL_ENDL;
	}

	// Establish HTTP Proxy.  "LLProxy" is a special string which directs
	// the code to use LLProxy::applyProxySettings() to establish any
	// HTTP or SOCKS proxy for http operations.
	status = LLCore::HttpRequest::setPolicyGlobalOption(LLCore::HttpRequest::GP_LLPROXY, 1);
	if (! status)
	{
		LL_ERRS("Init") << "Failed to set HTTP proxy for HTTP services.  Reason:  "
						<< status.toString()
						<< LL_ENDL;
	}

	// Tracing levels for library & libcurl (note that 2 & 3 are beyond spammy):
	// 0 - None
	// 1 - Basic start, stop simple transitions
	// 2 - libcurl CURLOPT_VERBOSE mode with brief lines
	// 3 - with partial data content
	static const std::string http_trace("QAModeHttpTrace");
	if (gSavedSettings.controlExists(http_trace))
	{
		long trace_level(0L);
		trace_level = long(gSavedSettings.getU32(http_trace));
		status = LLCore::HttpRequest::setPolicyGlobalOption(LLCore::HttpRequest::GP_TRACE, trace_level);
	}
	
	// Setup default policy and constrain if directed to
	mPolicyDefault = LLCore::HttpRequest::DEFAULT_POLICY_ID;

	// Texture policy will use default for now.
	mPolicyTexture = mPolicyDefault;
	static const std::string texture_concur("TextureFetchConcurrency");
	if (gSavedSettings.controlExists(texture_concur))
	{
		U32 concur(llmin(gSavedSettings.getU32(texture_concur), U32(12)));

		if (concur > 0)
		{
			LLCore::HttpStatus status;
			status = LLCore::HttpRequest::setPolicyClassOption(mPolicyTexture,
															   LLCore::HttpRequest::CP_CONNECTION_LIMIT,
															   concur);
			if (! status)
			{
				LL_WARNS("Init") << "Unable to set texture fetch concurrency.  Reason:  "
								 << status.toString()
								 << LL_ENDL;
			}
			else
			{
				LL_INFOS("Init") << "Application settings overriding default texture fetch concurrency.  New value:  "
								 << concur
								 << LL_ENDL;
			}
		}
	}

	// Create the mesh class
	mPolicyMesh = LLCore::HttpRequest::createPolicyClass();
	if (! mPolicyMesh)
	{
		LL_WARNS("Init") << "Failed to create HTTP policy class for Mesh.  Using default policy."
						 << LL_ENDL;
		mPolicyMesh = mPolicyDefault;
	}
	else
	{
		static const std::string mesh_concur("MeshMaxConcurrentRequests");
		if (gSavedSettings.controlExists(mesh_concur))
		{
			U32 setting(llmin(gSavedSettings.getU32(mesh_concur), 256U) / 4U);
			setting = llmax(setting, 2U);
			
			if (setting > 0)
			{
				LLCore::HttpStatus status;
				status = LLCore::HttpRequest::setPolicyClassOption(mPolicyMesh,
																   LLCore::HttpRequest::CP_CONNECTION_LIMIT,
																   setting);
				if (! status)
				{
					LL_WARNS("Init") << "Unable to set mesh fetch concurrency.  Reason:  "
									 << status.toString()
								 << LL_ENDL;
				}
				else
				{
					LL_INFOS("Init") << "Application settings overriding default mesh fetch concurrency.  New value:  "
									 << setting
									 << LL_ENDL;
				}
			}
		}
	}
	
	// Kick the thread
	status = LLCore::HttpRequest::startThread();
	if (! status)
	{
		LL_ERRS("Init") << "Failed to start HTTP servicing thread.  Reason:  "
						<< status.toString()
						<< LL_ENDL;
	}

	mRequest = new LLCore::HttpRequest;
}


void LLAppCoreHttp::requestStop()
{
	llassert_always(mRequest);

	mStopHandle = mRequest->requestStopThread(this);
	if (LLCORE_HTTP_HANDLE_INVALID != mStopHandle)
	{
		mStopRequested = LLTimer::getTotalSeconds();
	}
}


void LLAppCoreHttp::cleanup()
{
	if (LLCORE_HTTP_HANDLE_INVALID == mStopHandle)
	{
		// Should have been started already...
		requestStop();
	}
	
	if (LLCORE_HTTP_HANDLE_INVALID == mStopHandle)
	{
		LL_WARNS("Cleanup") << "Attempting to cleanup HTTP services without thread shutdown"
							<< LL_ENDL;
	}
	else
	{
		while (! mStopped && LLTimer::getTotalSeconds() < (mStopRequested + MAX_THREAD_WAIT_TIME))
		{
			mRequest->update(200000);
			ms_sleep(50);
		}
		if (! mStopped)
		{
			LL_WARNS("Cleanup") << "Attempting to cleanup HTTP services with thread shutdown incomplete"
								<< LL_ENDL;
		}
	}

	delete mRequest;
	mRequest = NULL;

	LLCore::HttpStatus status = LLCore::HttpRequest::destroyService();
	if (! status)
	{
		LL_WARNS("Cleanup") << "Failed to shutdown HTTP services, continuing.  Reason:  "
							<< status.toString()
							<< LL_ENDL;
	}
}


void LLAppCoreHttp::onCompleted(LLCore::HttpHandle, LLCore::HttpResponse *)
{
	mStopped = true;
}