// Copyright (c) 2005-2009 Nokia Corporation and/or its subsidiary(-ies).
// All rights reserved.
// This component and the accompanying materials are made available
// under the terms of "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:
// Nokia Corporation - initial contribution.
//
// Contributors:
//
// Description:
// A transport that logs the ocsp requests made to a file and then calls another
// transport to send the request.
// 
//

#include "requestlogger.h"

#include <f32file.h>

CTOCSPRequestLogger* CTOCSPRequestLogger::NewL(const TDesC& aRequestFile, MOCSPTransport* aTransport)
	{
	CTOCSPRequestLogger* self = new (ELeave) CTOCSPRequestLogger;
	CleanupStack::PushL(self);
	self->ConstructL(aRequestFile, aTransport);
	CleanupStack::Pop(self);
	return self;
	}


CTOCSPRequestLogger::CTOCSPRequestLogger()	
	{
	}


void CTOCSPRequestLogger::ConstructL(const TDesC& aRequestFile, MOCSPTransport* aTransport)
	{
	User::LeaveIfError(iFs.Connect());

	TInt err = iFs.MkDirAll(aRequestFile);
	if (err != KErrAlreadyExists)
		{
		User::LeaveIfError(err);
		}

	User::LeaveIfError(iWriteStream.Replace(iFs, aRequestFile, EFileWrite | EFileShareExclusive));

	// Initially we write a request count of zero, this gets updates as each
	// request is logged
	iWriteStream.WriteUint32L(0);

	iTransport = aTransport;
	}


CTOCSPRequestLogger::~CTOCSPRequestLogger()
	{
	iWriteStream.Close();
	iFs.Close();
	delete iTransport;
	}


void CTOCSPRequestLogger::SendRequest(const TDesC8& aURI,
									  const TDesC8& aRequest, 
									  const TInt aTimeout,
									  TRequestStatus& aStatus)
	{
	TRAPD(err, LogRequestL(aURI, aRequest));

	if (err == KErrNone)
		{
		iTransport->SendRequest(aURI, aRequest, aTimeout, aStatus);
		}
	else
		{
		TRequestStatus* status = &aStatus;
		User::RequestComplete(status, err);
		}
	}

void CTOCSPRequestLogger::LogRequestL(const TDesC8& aURI,
									  const TDesC8& aRequest)
	{
	++iTotalRequests;

	MStreamBuf* sink = iWriteStream.Sink();

	sink->SeekL(MStreamBuf::EWrite, EStreamBeginning, 0);
	iWriteStream.WriteUint32L(iTotalRequests);

	sink->SeekL(MStreamBuf::EWrite, EStreamEnd, 0);
	iWriteStream.WriteUint32L(aURI.Length());
	iWriteStream.WriteL(aURI);
	iWriteStream.WriteUint32L(aRequest.Length());
	iWriteStream.WriteL(aRequest);

	iWriteStream.CommitL();
	}


void CTOCSPRequestLogger::CancelRequest()
	{
	iTransport->CancelRequest();
	}


TPtrC8 CTOCSPRequestLogger::GetResponse() const
	{
	return iTransport->GetResponse();
	}