/**

 * Copyright (c) 2010 Sasken Communication Technologies Ltd.

 * All rights reserved.

 * This component and the accompanying materials are made available

 * under the terms of the "Eclipse Public License v1.0" 

 * which accompanies  this distribution, and is available

 * at the URL "http://www.eclipse.org/legal/epl-v10.html"

 *

 * Initial Contributors:

 * Chandradeep Gandhi, Sasken Communication Technologies Ltd - Initial contribution

 *

 * Contributors:

 * Manasij Roy, Nalina Hariharan

 * 

 * Description:

 * The Transport Manager Utility class provides the http/https transaction 

 * methods for the smf framework

 *

 */

// Include files

#define EMULATORTESTING

#include <QNetworkAccessManager>

#include <QNetworkReply>

#include <QSettings>

#include <zlib.h>

#ifdef EMULATORTESTING

// For proxy settings on emulator only - REMOVE for device

#include <QNetworkProxy>

#endif

#include "smftransportmanagerutil.h"

#include "smfpluginmanager.h"

// Static Global constants

static const char kSmfUserAgent[] = "SmfFrameWork";

static const char kSmfCacheControl[] = "no-cache";

static const char kSmfAcceptEncoding[] = "gzip";

// Static data initialisation

SmfTransportManagerUtil* SmfTransportManagerUtil::m_myInstance = NULL;

/**

 * Method to get the instance of SmfTransportManagerUtil class

 * @return The instance of SmfTransportManager class

 */

SmfTransportManagerUtil* SmfTransportManagerUtil::getInstance ( )

	{

	if(NULL == m_myInstance)

		m_myInstance = new SmfTransportManagerUtil( );

	return m_myInstance;

	}

/**

 * Constructor with default argument

 * @param aParent The parent object

 */

SmfTransportManagerUtil::SmfTransportManagerUtil ( )

		: m_networkAccessManager ( this )

	{

	// Storage of settings (Only data usage as of now)

	m_settings = new QSettings("Sasken", "SmfTransportManager");

	// Create the settings if no data is stored

	if( !m_settings->contains("Sent Data") )

		m_settings->setValue("Sent Data", 0);

	if( !m_settings->contains("Received Data") )

		m_settings->setValue("Received Data", 0);

#ifdef EMULATORTESTING

	// Reading the keys, CSM Stubbed - START

		{

		qDebug()<<"File to read the windows username and password could not be opened, returning!!!";

		return;

		}

    // For proxy settings on emulator only - REMOVE for device

    //==Classes used from Network Module==

    QNetworkProxy proxy;

    proxy.setType(QNetworkProxy::HttpProxy);

    proxy.setHostName(httpProxy);

    proxy.setPort(httpPort.toInt());

    proxy.setUser(httpUser);

    proxy.setPassword(httpPass);

    QNetworkProxy::setApplicationProxy(proxy);

#endif

	}

/**

 * Destructor

 */

SmfTransportManagerUtil::~SmfTransportManagerUtil ( )

	{

	m_activeNetwReplyList.clear();

	if(m_settings)

		delete m_settings;

	if(m_myInstance)

		delete m_myInstance;

	}

/**

 * Method that does a http GET request. Returns the unique QNetworkReply

 * instance for this transaction to the plugin manager to trace the 

 * proper response.

 * @param aRequest The request formed by the plugin

 * @param aUrlList The list of accessible Urls for this plugin

 * @param aSOPCompliant [out] Output parameter indicating Same Origin 

 * Policy Compliance. Contains true if the request complies to the policy,

 * else false. If it is false, the network request will not performed

 * @return The unique QNetworkReply instance for this transaction

 */

QNetworkReply* SmfTransportManagerUtil::get ( 

		QNetworkRequest &aRequest,

		const QList<QUrl> &aUrlList,

		bool &aSOPCompliant )

	{

	qDebug()<<"Inside SmfTransportManagerUtil::get()";;

	bool found = false;

	QString hostName = aRequest.url().host();

	// Same Origin Policy checking

	// Check if the host name of the url in the request created by the 

	// plugin is among the authorised url host name list

	foreach(QUrl url, aUrlList)

		{

		if(0 == hostName.compare(url.host()))

			{

			found = true;

			break;

			}

		}

	if(found)

		{

		aSOPCompliant = true;

		// Set header to accept gzip encoded data

		aRequest.setRawHeader("Accept-encoding", kSmfAcceptEncoding);

		// Set the cache control

		aRequest.setRawHeader("Cache-Control", kSmfCacheControl);

		// Put the same user agent for all requests sent by Smf

		aRequest.setRawHeader("User-Agent", kSmfUserAgent);

		QNetworkReply* reply = m_networkAccessManager.get(aRequest);

		qDebug()<<"QNetworkReply of get() = "<<(long)reply;

		connect(&m_networkAccessManager, SIGNAL(finished(QNetworkReply *)), 

				this, SLOT(networkReplyFinished(QNetworkReply *)));

		connect(&m_networkAccessManager, SIGNAL(error(QNetworkReply::NetworkError)), 

				this, SLOT(networkReplyError(QNetworkReply::NetworkError)));

		m_activeNetwReplyList.append(reply);

		return reply;

		}

	else

		{

		// Error :: SAME ORIGIN POLICY violation!!!

		aSOPCompliant = false;

		qDebug()<<"SOP violation";

		return NULL;

		}

	}

/**

 * Method that does a http POST request. Returns the unique QNetworkReply

 * instance for this transaction to the plugin manager to trace the 

 * proper response.

 * @param aRequest The request formed by the plugin

 * @param aPostData The data to be posted via http POST request

 * @param aUrlList The list of accessible Urls for this plugin

 * @param aSOPCompliant [out] Output parameter indicating Same Origin 

 * Policy Compliance. Contains true if the request complies to the policy,

 * else false. If it is false, the network request will not performed

 * @return The unique QNetworkReply instance for this transaction

 */

QNetworkReply* SmfTransportManagerUtil::post ( 

		QNetworkRequest &aRequest, 

		const QByteArray& aPostData,

		const QList<QUrl> &aUrlList,

		bool &aSOPCompliant )

	{

	qDebug()<<"Inside SmfTransportManagerUtil::post()";

	bool found = false;

	QString hostName = aRequest.url().host();

	// Same Origin Policy checking

	// Check if the host name of the url in the request created by the 

	// plugin is among the authorised url host name list

	foreach(QUrl url, aUrlList)

		{

		if(0 == hostName.compare(url.host()))

			{

			found = true;

			break;

			}

		}

	if(found)

		{

		aSOPCompliant = true;

		// Set header to accept gzip encoded data

		aRequest.setRawHeader("Accept-encoding", kSmfAcceptEncoding);

		// Set the cache control

		aRequest.setRawHeader("Cache-Control", kSmfCacheControl);

		// Put the same user agent for all requests sent by Smf

		aRequest.setRawHeader("User-Agent", kSmfUserAgent);

#ifdef DETAILEDDEBUGGING

		qDebug()<<"post data size is = "<<aPostData.size();

		qDebug()<<"post data is = "<<QString(aPostData);

#endif

		QNetworkReply* reply = m_networkAccessManager.post(aRequest, aPostData);

		qDebug()<<"QNetworkReply of post() = "<<(long)reply;

		connect(&m_networkAccessManager, SIGNAL(finished(QNetworkReply *)), 

				this, SLOT(networkReplyFinished(QNetworkReply *)));

		connect(&m_networkAccessManager, SIGNAL(error(QNetworkReply::NetworkError)), 

				this, SLOT(networkReplyError(QNetworkReply::NetworkError)));

		m_activeNetwReplyList.append(reply);

		return reply;

		}

	else

		{

		// Error :: SAME ORIGIN POLICY violation!!!

		aSOPCompliant = false;

		qDebug()<<"SOP violation";

		return NULL;

		}

	}

/**

 * Method that does a http HEAD request. Returns the unique QNetworkReply

 * instance for this transaction to the plugin manager to trace the 

 * proper response.

 * @param aRequest The request formed by the plugin

 * @param aUrlList The list of accessible Urls for this plugin

 * @param aSOPCompliant [out] Output parameter indicating Same Origin 

 * Policy Compliance. Contains true if the request complies to the policy,

 * else false. If it is false, the network request will not performed

 * @return The unique QNetworkReply instance for this transaction

 */

QNetworkReply* SmfTransportManagerUtil::head ( 

		QNetworkRequest& aRequest,

		const QList<QUrl> &aUrlList,

		bool &aSOPCompliant )

	{

	qDebug()<<"Inside SmfTransportManagerUtil::head()";

	bool found = false;

	QString hostName = aRequest.url().host();

	// Same Origin Policy checking

	// Check if the host name of the url in the request created by the 

	// plugin is among the authorised url host name list

	foreach(QUrl url, aUrlList)

		{

		if(0 == hostName.compare(url.host()))

			{

			found = true;

			break;

			}

		}

	if(found)

		{

		aSOPCompliant = true;

		// Set header to accept gzip encoded data

		aRequest.setRawHeader("Accept-encoding", kSmfAcceptEncoding);

		// Set the cache control

		aRequest.setRawHeader("Cache-Control", kSmfCacheControl);

		// Put the same user agent for all requests sent by Smf

		aRequest.setRawHeader("User-Agent", kSmfUserAgent);

		QNetworkReply* reply = m_networkAccessManager.head(aRequest);

		qDebug()<<"QNetworkReply of head() = "<<(long)reply;

		connect(&m_networkAccessManager, SIGNAL(finished(QNetworkReply *)), 

				this, SLOT(networkReplyFinished(QNetworkReply *)));

		connect(&m_networkAccessManager, SIGNAL(error(QNetworkReply::NetworkError)), 

				this, SLOT(networkReplyError(QNetworkReply::NetworkError)));

		m_activeNetwReplyList.append(reply);

		return reply;

		}

	else

		{

		// Error :: SAME ORIGIN POLICY violation!!!

		aSOPCompliant = false;

		qDebug()<<"SOP violation";

		return NULL;

		}

	}

/**

 * Method that does a http PUT request. Returns the unique QNetworkReply

 * instance for this transaction to the plugin manager to trace the 

 * proper response.

 * @param aRequest The request formed by the plugin

 * @param aPostData The data to be posted via http PUT request

 * @param aUrlList The list of accessible Urls for this plugin

 * @param aSOPCompliant [out] Output parameter indicating Same Origin 

 * Policy Compliance. Contains true if the request complies to the policy,

 * else false. If it is false, the network request will not performed

 * @return The unique QNetworkReply instance for this transaction

 */

QNetworkReply* SmfTransportManagerUtil::put ( 

		QNetworkRequest &aRequest,

		const QByteArray& aPostData,

		const QList<QUrl> &aUrlList,

		bool &aSOPCompliant )

	{

	qDebug()<<"Inside SmfTransportManagerUtil::put()";

	bool found = false;

	QString hostName = aRequest.url().host();

	// Same Origin Policy checking

	// Check if the host name of the url in the request created by the 

	// plugin is among the authorised url host name list

	foreach(QUrl url, aUrlList)

		{

		if(0 == hostName.compare(url.host()))

			{

			found = true;

			break;

			}

		}

	if(found)

		{

		aSOPCompliant = true;

		// Set header to accept gzip encoded data

		aRequest.setRawHeader("Accept-encoding", kSmfAcceptEncoding);

		// Set the cache control

		aRequest.setRawHeader("Cache-Control", kSmfCacheControl);

		// Put the same user agent for all requests sent by Smf

		aRequest.setRawHeader("User-Agent", kSmfUserAgent);

		QNetworkReply* reply = m_networkAccessManager.put(aRequest, aPostData);

		qDebug()<<"QNetworkReply of put() = "<<(long)reply;

		connect(&m_networkAccessManager, SIGNAL(finished(QNetworkReply *)), 

				this, SLOT(networkReplyFinished(QNetworkReply *)));

		connect(&m_networkAccessManager, SIGNAL(error(QNetworkReply::NetworkError)), 

				this, SLOT(networkReplyError(QNetworkReply::NetworkError)));

		m_activeNetwReplyList.append(reply);

		return reply;

		}

	else

		{

		// Error :: SAME ORIGIN POLICY violation!!!

		aSOPCompliant = false;

		qDebug()<<"SOP violation";

		return NULL;

		}

	}

/**

 * Method that does a http DELETE request. Returns the unique QNetworkReply

 * instance for this transaction to the plugin manager to trace the 

 * proper response.

 * @param aRequest The request formed by the plugin

 * @param aUrlList The list of accessible Urls for this plugin

 * @param aSOPCompliant [out] Output parameter indicating Same Origin 

 * Policy Compliance. Contains true if the request complies to the policy,

 * else false. If it is false, the network request will not performed

 * @return The unique QNetworkReply instance for this transaction

 */

QNetworkReply* SmfTransportManagerUtil::deleteResource ( 

		QNetworkRequest &aRequest,

		const QList<QUrl> &aUrlList,

		bool &aSOPCompliant )

	{

	qDebug()<<"Inside SmfTransportManagerUtil::deleteResource()";

	bool found = false;

	QString hostName = aRequest.url().host();

	// Same Origin Policy checking

	// Check if the host name of the url in the request created by the 

	// plugin is among the authorised url host name list

	foreach(QUrl url, aUrlList)

		{

		if(0 == hostName.compare(url.host()))

			{

			found = true;

			break;

			}

		}

	if(found)

		{

		aSOPCompliant = true;

		// Set header to accept gzip encoded data

		aRequest.setRawHeader("Accept-encoding", kSmfAcceptEncoding);

		// Set the cache control

		aRequest.setRawHeader("Cache-Control", kSmfCacheControl);

		// Put the same user agent for all requests sent by Smf

		aRequest.setRawHeader("User-Agent", kSmfUserAgent);

		QNetworkReply* reply = m_networkAccessManager.deleteResource(aRequest);

		qDebug()<<"QNetworkReply of deleteResource() = "<<(long)reply;

		connect(&m_networkAccessManager, SIGNAL(finished(QNetworkReply *)), 

				this, SLOT(networkReplyFinished(QNetworkReply *)));

		connect(&m_networkAccessManager, SIGNAL(error(QNetworkReply::NetworkError)), 

				this, SLOT(networkReplyError(QNetworkReply::NetworkError)));

		m_activeNetwReplyList.append(reply);

		return reply;

		}

	else

		{

		// Error :: SAME ORIGIN POLICY violation!!!

		aSOPCompliant = false;

		qDebug()<<"SOP violation";

		return NULL;

		}

	}

/**

 * Method that cancels the service request by cancelling the current 

 * http transaction.

 * @param aCancelReply The QNetworkReply instance whose transaction 

 * has to be cancelled

 * @return Returns true for success, else false 

 */

bool SmfTransportManagerUtil::cancelRequest ( 

		QNetworkReply *aCancelReply )

	{

	qDebug()<<"Inside SmfTransportManagerUtil::cancelRequest()";

	// Checks if this transaction is running

	if( aCancelReply->isRunning() )

		{

		// Aborts the running transaction

		aCancelReply->abort();

		}

	// Close the connection

	aCancelReply->close();

	int index = m_activeNetwReplyList.indexOf(aCancelReply);

	if( index >= 0 )

		m_activeNetwReplyList.removeAt(index);

	return true;

	}

/*

 * Method that is called whenever a new network configuration is added to the system.

 * @param aResult SmfTransportResult

 */

void SmfTransportManagerUtil::configurationAdded ( const SmfTransportResult &aResult )

	{

	// Inform PM and plugins that a new IAP ia added, and hence resend the request

	SmfPluginManager::getInstance()->responseAvailable ( aResult, NULL, NULL );

	}

/*

 * Method that is called when the state of the network configuration changes.

 * @param aResult SmfTransportResult

 */

void SmfTransportManagerUtil::configurationChanged ( const SmfTransportResult &aResult )

	{

	// Inform PM and plugins that the IAP is changed, and hence resend the request

	SmfPluginManager::getInstance()->responseAvailable ( aResult, NULL, NULL );