// Copyright (c) 1997-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:

//

/**

 @file

 @internalComponent

*/

#include <obex.h>

#include <obex/internal/obexinternalheader.h>

#include <obex/internal/obexpacket.h>

#include "logger.h"

#include "OBEXUTIL.H"

#include "obexheaderutil.h"

IF_FLOGGING(_LIT8(KLogComponent, "obex");)

/**

Default constructor for ObexObjects

@internalComponent

*/

CObexBaseObject::CObexBaseObject()

	{

	ResetHeaders();

	}

/** 

Destructor. 

*/

CObexBaseObject::~CObexBaseObject()

	{

	FLOG(_L("CObexBaseObject Destructor\r\n"));

	ResetHeaders();

	if (iObexHeader)

		{

		delete iObexHeader;

		}

	delete iHeaderSet;

	}

/**

Sets header mask to 1's (include all), but valid mask to 0's (none valid).

Also reset progress indicators to avoid any un-initialised transfer attempts

@internalComponent

*/

void CObexBaseObject::ResetHeaders()

	{

	iHeaderMask = 0xFFFF;

	iValidHeaders = 0x0000;

	iSendProgress = EError;

	iRecvProgress = EError;

	iRecvBytes = 0;

	if (iHttp)

		{

		iHttp->ResetAndDestroy();

		delete iHttp;

		iHttp = NULL;

		}

	// Here iHeaderSet can be NULL. This method is called in 

	// CObexBaseObject::CObexBaseObject() that is called before the 

	// derived class ConstructL() method. iHeaderSet is constructed in 

	// CreateHeaderStorageDataL() called from ConstructL(). 

	// So, in the constructor it is always NULL.

	// This method is also called in CObexBaseObject::Reset() where iHeaderSet

	// will be valid.

	if (iHeaderSet)

		{

		iHeaderSet->SetMask(NULL);

		while (iHeaderSet->Count())

			{

			iHeaderSet->DeleteCurrentHeader();

			}

		}

	}

/**

@internalComponent

*/

void CObexBaseObject::CreateHeaderStorageDataL()

	{

	__ASSERT_DEBUG(!iHeaderSet, IrOBEXUtil::Panic(ENotNullPointer));	

	iHeaderSet = CObexHeaderSet::NewL();

	if (iObexHeader == NULL)

		{

		iObexHeader = CObexHeader::NewL();

		}

	}

/**

Set the connection id.

This method will check the headerset for a connectionId header. If one if located,

then this will be modified for the new HV value. If not, a new connectionId header

will be added.

@param aFourByte The connectionID to be set

@internalComponent

*/

void CObexBaseObject::SetConnectionIdL(TUint32 aFourByte)

	{

	FLOG(_L(">>CObexBaseObject::SetConnectionIdL"));

	__ASSERT_DEBUG(iHeaderSet, IrOBEXUtil::Panic(ENullPointer));

	//reset the mask so all headers are searched

	//NB. SetMask sets the iterator at the start of the headerset

	iHeaderSet->SetMask(NULL);

	if (iHeaderSet->Find(TObexInternalHeader::EConnectionID, *iObexHeader) == KErrNone)

		{

		iHeaderSet->DeleteCurrentHeader();

		}

    CObexHeader* header = CObexHeader::NewL();

	CleanupStack::PushL(header);

	header->SetFourByte(TObexInternalHeader::EConnectionID, aFourByte);

	//Transfer ownership of pointer to CObexHeaderSet

	LEAVEIFERRORL(iHeaderSet->AddHeader(header));

	CleanupStack::Pop(header);

	iValidHeaders |= KObexHdrConnectionID;

	iHeaderMask |= KObexHdrConnectionID;

	FLOG(_L("<<CObexBaseObject::SetConnectionIdL"));

	}

/**

Returns the connection ID.

@return	Returns KConnIDInvalid if no connectionID is set.

@internalComponent

*/

TUint32 CObexBaseObject::ConnectionID()

	{

	if (iValidHeaders & KObexHdrConnectionID)

		{

		__ASSERT_DEBUG(iHeaderSet, IrOBEXUtil::Panic(ENullPointer));

		//reset the mask so all headers are searched

		//NB. SetMask sets the iterator at the start of the headerset

		iHeaderSet->SetMask(NULL);

		if (iHeaderSet->Find(TObexInternalHeader::EConnectionID, *iObexHeader) == KErrNone)

			{

			return (iObexHeader->AsFourByte());

			}

		else

			{

			return KConnIDInvalid;

			}

		}

	else

		{

		return KConnIDInvalid;

		}

	}

/** 

Sets the Name attribute of the object.

The Name is used to identify the object to the remote machine (or to identify 

a received object). Note that in general, this is quite distinct from the 

CObexFileObject::DataFile() attribute, which specifies where the body of the 

object is stored. 

@param aDesc Name attribute 

@publishedAll

@released

*/

EXPORT_C void CObexBaseObject::SetNameL (const TDesC& aDesc)

	{

	LOG_LINE

	LOG_FUNC

	__ASSERT_DEBUG(iHeaderSet, IrOBEXUtil::Panic(ENullPointer));

	//reset the mask so all headers are searched

	//NB. SetMask sets the iterator at the start of the headerset

	iHeaderSet->SetMask(NULL);

	if (iHeaderSet->Find(TObexInternalHeader::EName, *iObexHeader) == KErrNone)

		{

		iHeaderSet->DeleteCurrentHeader();

		}

    CObexHeader* header = CObexHeader::NewL();

	CleanupStack::PushL(header);

	header->SetUnicodeL(TObexInternalHeader::EName, aDesc);

	//Transfer ownership of pointer to CObexHeaderSet

	LEAVEIFERRORL(iHeaderSet->AddHeader(header));

	CleanupStack::Pop(header);

	iValidHeaders |= KObexHdrName;

	}

/** 

Sets the Type attribute of the object. 

This should be in the form of a valid IANA media type (see http://www.iana.org/assignments/media-types/index.html).

@param aDesc Type attribute 

@publishedAll

@released

*/

EXPORT_C void CObexBaseObject::SetTypeL (const TDesC8& aDesc)

	{

	LOG_LINE

	LOG_FUNC

	TInt len = aDesc.Length();

	// make sure length does not include any null terms

	while(len && aDesc[len - 1] == 0)

		{

		--len;

		};

	TPtrC8 src = aDesc.Left(len);

	//leave room for exactly one null term

	HBufC8* buf = HBufC8::NewL(src.Length() + 1);

	CleanupStack::PushL(buf);

	TPtr8 type(buf->Des());

	type.Copy(src);

	type.Append(0);

	__ASSERT_DEBUG(iHeaderSet, IrOBEXUtil::Panic(ENullPointer));

	//reset the mask so all headers are searched

	//NB. SetMask sets the iterator at the start of the headerset

	iHeaderSet->SetMask(NULL);

	if (iHeaderSet->Find(TObexInternalHeader::EType, *iObexHeader) == KErrNone)

		{

		iHeaderSet->DeleteCurrentHeader();

		}

    CObexHeader* header = CObexHeader::NewL();

	CleanupStack::PushL(header);

	header->SetByteSeqL(TObexInternalHeader::EType, type);

	//Transfer ownership of pointer to CObexHeaderSet

	LEAVEIFERRORL(iHeaderSet->AddHeader(header));

	CleanupStack::Pop(header);

	CleanupStack::PopAndDestroy(buf);

	iValidHeaders |= KObexHdrType;

	}

/** 

Sets the Length attribute of the object, in bytes. 

Note that this does not necessarily have to match the exact size of the body 

data, but is used to give an indication of the size to the receiving end.

@param aLength Length attribute of the object 

@publishedAll

@released

*/

EXPORT_C void CObexBaseObject::SetLengthL (const TUint32 aLength)

	{

	LOG_LINE

	LOG_FUNC

	__ASSERT_DEBUG(iHeaderSet, IrOBEXUtil::Panic(ENullPointer));

	//reset the mask so all headers are searched

	//NB. SetMask sets the iterator at the start of the headerset

	iHeaderSet->SetMask(NULL);

	if (iHeaderSet->Find(TObexInternalHeader::ELength, *iObexHeader) == KErrNone)

		{

		iHeaderSet->DeleteCurrentHeader();

		}

    CObexHeader* header = CObexHeader::NewL();

	CleanupStack::PushL(header);

	header->SetFourByte(TObexInternalHeader::ELength, aLength);

	//Transfer ownership of pointer to CObexHeaderSet

	LEAVEIFERRORL(iHeaderSet->AddHeader(header));

	CleanupStack::Pop(header);

	iValidHeaders |= KObexHdrLength;

	}

/** 

Sets the Time attribute of the object (stored in UTC).

@param aLocalTime Time attribute in local time

@publishedAll

@released

*/

EXPORT_C void CObexBaseObject::SetTimeL (const TTime aLocalTime)

	{

	LOG_LINE

	LOG_FUNC

	// Convert local time to UTC

	TTime utcTime(aLocalTime);

	utcTime -= User::UTCOffset();

	SetUtcTimeL(utcTime);

	}

/** 

Sets the Time attribute of the object (stored in UTC).

@param aUtcTime Time attribute in local time

*/

void CObexBaseObject::SetUtcTimeL (const TTime aUtcTime)

	{

	LOG_LINE

	LOG_FUNC

	TBuf<16> timebuf;

	aUtcTime.FormatL(timebuf, _L("%F%Y%M%DT%H%T%SZ"));

	TBuf8<16> narrowBuf;

	narrowBuf.Copy(timebuf);

	SetTimeHeaderL(narrowBuf);

	iValidHeaders |= KObexHdrTime;

	}

/**

Add a descriptor as the one and only Time header in an object.

@param aTimeDes A narrow descriptor which will be stored in the object.

*/

void CObexBaseObject::SetTimeHeaderL(const TDesC8& aTimeDes)

	{

	LOG_LINE

	LOG_FUNC

	__ASSERT_DEBUG(iHeaderSet, IrOBEXUtil::Panic(ENullPointer));

	//reset the mask so all headers are searched

	//NB. SetMask sets the iterator at the start of the headerset

	iHeaderSet->SetMask(NULL);

	if (iHeaderSet->Find(TObexInternalHeader::ETime, *iObexHeader) == KErrNone)

		{

		iHeaderSet->DeleteCurrentHeader();

		}

	CObexHeader* header = CObexHeader::NewL();

	CleanupStack::PushL(header);

	header->SetByteSeqL(TObexInternalHeader::ETime, aTimeDes);

	//Transfer ownership of pointer to CObexHeaderSet

	LEAVEIFERRORL(iHeaderSet->AddHeader(header));

	CleanupStack::Pop(header);

	}

/** 

Sets the Description attribute of the object. 

This is currently the easiest way to send proprietary information along with 

an object.

@param aDesc Description attribute 

@publishedAll

@released

*/

EXPORT_C void CObexBaseObject::SetDescriptionL (const TDesC& aDesc)

	{

	LOG_LINE

	LOG_FUNC

	__ASSERT_DEBUG(iHeaderSet, IrOBEXUtil::Panic(ENullPointer));

	//reset the mask so all headers are searched

	//NB. SetMask sets the iterator at the start of the headerset

	iHeaderSet->SetMask(NULL);

	if (iHeaderSet->Find(TObexInternalHeader::EDescription, *iObexHeader) == KErrNone)

		{

		iHeaderSet->DeleteCurrentHeader();

		}

    CObexHeader* header = CObexHeader::NewL();

	CleanupStack::PushL(header);

	header->SetUnicodeL(TObexInternalHeader::EDescription, aDesc);

	//Transfer ownership of pointer to CObexHeaderSet

	LEAVEIFERRORL(iHeaderSet->AddHeader(header));

	CleanupStack::Pop(header);

	iValidHeaders |= KObexHdrDescription;

	}

/**	

Sets the Application Parameters attribute of the object.

  This is expected to be of the format Tag-Length-Value, but this is not enforced.

@param aDesc Application Parameters attribute 

@publishedAll

@released

*/

EXPORT_C void CObexBaseObject::SetAppParamL (const TDesC8& aDesc)

	{

	LOG_LINE

	LOG_FUNC

	FLOG(_L("CObexBaseObject::SetAppParamL"));

	__ASSERT_DEBUG(iHeaderSet, IrOBEXUtil::Panic(ENullPointer));

	//reset the mask so all headers are searched

	//NB. SetMask sets the iterator at the start of the headerset

	iHeaderSet->SetMask(NULL);

	if (iHeaderSet->Find(TObexInternalHeader::EAppParam, *iObexHeader) == KErrNone)

		{

		iHeaderSet->DeleteCurrentHeader();

		}

	CObexHeader* header = CObexHeader::NewL();

	CleanupStack::PushL(header);

	header->SetByteSeqL(TObexInternalHeader::EAppParam, aDesc);

	//Transfer ownership of pointer to CObexHeaderSet

	LEAVEIFERRORL(iHeaderSet->AddHeader(header));

	CleanupStack::Pop(header);

	iValidHeaders |= KObexHdrAppParam;

	}

/** 

Sets the Target attribute of the object.

Generally, this will only have any useful meaning if the session Who attribute 

of the remote machine is recognised, and particularly, when connected to a 

strict peer (see CObex::IsStrictPeer()).

@param aDesc Target attribute 

@publishedAll

@released

*/

EXPORT_C void CObexBaseObject::SetTargetL (const TDesC8& aDesc)

	{

	LOG_LINE

	LOG_FUNC

	__ASSERT_DEBUG(iHeaderSet, IrOBEXUtil::Panic(ENullPointer));

	//reset the mask so all headers are searched

	//NB. SetMask sets the iterator at the start of the headerset

	iHeaderSet->SetMask(NULL);

	if (iHeaderSet->Find(TObexInternalHeader::ETarget, *iObexHeader) == KErrNone)

		{

		iHeaderSet->DeleteCurrentHeader();

		}

	CObexHeader* header = CObexHeader::NewL();

	CleanupStack::PushL(header);

	header->SetByteSeqL(TObexInternalHeader::ETarget, aDesc);

	//Transfer ownership of pointer to CObexHeaderSet

	LEAVEIFERRORL(iHeaderSet->AddHeader(header));

	CleanupStack::Pop(header);

	iValidHeaders |= KObexHdrTarget;

	}

/** 

Add an Http header.

@param aDesc HTTP header to be added to the object's collection of HTTP headers 

@publishedAll

@released

*/

EXPORT_C void CObexBaseObject::AddHttpL (const TDesC8& aDesc)

	{

	LOG_LINE

	LOG_FUNC

    CObexHeader* header = CObexHeader::NewL();

	CleanupStack::PushL(header);

	header->SetByteSeqL(TObexInternalHeader::EHttp, aDesc);

	__ASSERT_DEBUG(iHeaderSet, IrOBEXUtil::Panic(ENullPointer));

	//Transfer ownership of pointer to CObexHeaderSet

	LEAVEIFERRORL(iHeaderSet->AddHeader(header));

	CleanupStack::Pop(header);

	if (!iHttp)

		{

		iHttp = new(ELeave) RPointerArray<HBufC8>(2);

		}

	HBufC8* buf = aDesc.AllocLC();

	LEAVEIFERRORL(iHttp->Append(buf));

	CleanupStack::Pop(buf);

	iValidHeaders |= KObexHdrHttp;  

	}

/**

Adds a CObexHeader into the CObexHeaderSet

@param aHeader A Pointer to a CObexHeader to be added to the CObexHeaderSet

@publishedAll

@released

*/

EXPORT_C void CObexBaseObject::AddHeaderL(CObexHeader& aHeader)