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

//

#include <s32mem.h>

#include <e32svr.h>

// KMimeVCardExtension is defined in miutmsg.h however including miutmsg.h also includes

// flogger.h and conflicts with our inclusion of commsdebug via btaccesshostlog.h

//#include <miutmsg.h>

_LIT(KMimeVCardExtension, ".vcf");

#include <bt_sock.h>

#include <obex.h>

#include <obexbttransportinfo.h>

#include <cntdb.h>

#include "clientserver.h"

#include "pbapserver.h"

#include "pbapsession.h"

#include "pbapappheader.h"

#include "pbapfoldertree.h"

#include "pbapfoldertelecom.h"

#include "pbapfolderroot.h"

#include "pbapfoldernodepb.h"

#include "pbapfoldernodech.h"

#include "pbapfoldersim.h"

#include "pbapcontactdbviews.h"

#include "pbapauthpasswordgetter.h"

#include "pbapxml.h"

#include "pbapserversecuritypolicy.h"

#include "pbaplogeng.h"

#include "btaccesshostlog.h"

_LIT8(KPBAPLocalWho, "\x79\x61\x35\xf0\xf0\xc5\x11\xd8\x09\x66\x08\x00\x20\x0c\x9a\x66");

const TInt KBufGranularity = 100;

const TInt KContactsDbOpenAttempts = 10;

const TInt KContactsDbOpenDelay = 100000; //0.1 secs

//

// TCleanupItem operations - CPbapServer::ReleaseObex()

//

void PbapServerReleaseObex(TAny* aPtr)

	{

	LOG_STATIC_FUNC

	reinterpret_cast<CPbapServer*>(aPtr)->ReleaseObex();

	}

void CleanupPbapServerReleaseObexPushL(CPbapServer& aPbapServer)

	{		 

	LOG_STATIC_FUNC

	TCleanupItem item(PbapServerReleaseObex, &aPbapServer);

	CleanupStack::PushL(item);

	}	

//

// CPbapServerShutdown

//

/*static*/ CPbapServerShutdown* CPbapServerShutdown::NewL()

	{

	LOG_STATIC_FUNC

	CPbapServerShutdown* self=new(ELeave) CPbapServerShutdown;

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	}

inline CPbapServerShutdown::CPbapServerShutdown()

	: CTimer(EPriorityLow)

	{

	LOG_FUNC

	CActiveScheduler::Add(this);

	}

inline void CPbapServerShutdown::ConstructL()

	{

	LOG_FUNC

	CTimer::ConstructL();

	}

inline void CPbapServerShutdown::Start()

	{

	LOG_FUNC

	After(KPbapServerShutdownDelay);

	}

void CPbapServerShutdown::RunL()

	{

	LOG_FUNC

	CActiveScheduler::Stop();

	}

//

// CPbapServer

//

/*static*/ CPbapServer* CPbapServer::NewL()

	{

	LOG_STATIC_FUNC

	CPbapServer* self=new(ELeave) CPbapServer;

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	}

CPbapServer::CPbapServer()

: CPolicyServer(EPriorityStandard, KPbapServerPolicy, ESharableSessions)

	{

	LOG_FUNC

	}

CPbapServer::~CPbapServer()

	{

	LOG_FUNC

	// delete the obex server first because its destructor may call

	// functions which this class implements

	ReleaseObex();

	if (iAsyncRestartObex)

		{

		iAsyncRestartObex->Cancel();

		delete iAsyncRestartObex;

		}

	delete iPasswordGetter;

	delete iPassword;

	delete iOutboundObject;

	delete iOutboundBuffer;

	delete iVCardExporter;

	delete iShutdown;

	// the database must still be open when closing contact views so always 

	// delete the object owning the views before the database

	delete iContactViews;

	delete iFolderTree;

	delete iLogWrapper;

	delete iContacts;

	iFs.Close();

	iBufStreamer.Close();

	iAppHeaderDetails.Close();

	}

void CPbapServer::ConstructL()

	{

	LOG_FUNC

	StartL(KPbapServerName);

	// ensure that the server will exit even if the 1st client fails to connect

	iShutdown = CPbapServerShutdown::NewL();

	// create buffers ready for first obex get request

	iOutboundBuffer = CBufFlat::NewL(KBufGranularity);

	iOutboundObject = CObexBufObject::NewL(iOutboundBuffer);

	OpenContactsDbL();

	// create contact database view manager

	iContactViews = CPbapContactDbViews::NewL(*iContacts);

	// if there is a problem with creating a logeng client then we will continue

	// but without any call history folders

	TRAP_IGNORE(CreateLogEngineClientL());

	// create vCard exporter

	iVCardExporter = CPbapVCardExporterUtil::NewL(*iContacts, iLogWrapper);

	// create the restart obex callback used when an obex error occurs

 	TCallBack callback(RestartObex, this);

	iAsyncRestartObex = new(ELeave) CAsyncCallBack(callback, CActive::EPriorityStandard);

	// start shutdown timer now

	iShutdown->Start();

	}

void CPbapServer::OpenContactsDbL()

	{

	LOG_FUNC

	TInt attempts=0;

	TInt error=KErrNone;

	while (attempts < KContactsDbOpenAttempts)

		{

		TRAP(error, iContacts = CContactDatabase::OpenL());

		if (error==KErrLocked || error==KErrInUse)

			{

			// db maybe locked due to race condition so try again

			++attempts;

			User::After(KContactsDbOpenDelay);

			}

		else

			{

			// success or not a db locked error so exit loop

			break;

			}

		}

	if (error)

		{

		LOG1(_L("Contacts database failed to open, error=%d"), error);

		User::Leave(error);	

		}

	}

void CPbapServer::CreateLogEngineClientL()

	{

	LOG_FUNC

	User::LeaveIfError(iFs.Connect());

	// create access to call history information

	iLogWrapper = CPbapLogWrapper::NewL(iFs);

	}

void CPbapServer::BuildVirtualFolderTreeL()

	{

	LOG_FUNC

	// create the root folder

	CVirtualFolders* rootFolder = CVirtualFolders::NewLC();

	rootFolder->PlaceFolderL(CFolderRoot::NewL(*this)); //ownership passed

	rootFolder->AttachSubtree(TelecomSubTreeL()); //ownership passed

#ifdef __INCLUDE_SIM1_FOLDERS__

	// create the SIM1 folder below root			

	CVirtualFolders* sim1Folder = CVirtualFolders::NewLC();

	sim1Folder->PlaceFolderL(CFolderSIM1::NewL(*this)); //ownership passed

	sim1Folder->AttachSubtree(SIMTelecomSubTreeL()); //ownership passed

	rootFolder->AttachSubtree(sim1Folder); //ownership passed

	CleanupStack::Pop(sim1Folder);

#endif // __INCLUDE_SIM1_FOLDERS__

	CleanupStack::Pop(rootFolder);	

	iFolderTree = rootFolder;

	iCurrentFolder = iFolderTree;

	}

CVirtualFolders* CPbapServer::TelecomSubTreeL()

	{

	LOG_FUNC

	// create telecom folder

	CVirtualFolders* telecomFolder = CVirtualFolders::NewLC();

	telecomFolder->PlaceFolderL(CFolderTelecom::NewL(*this)); //ownership passed

	// create pb sub folder

	CVirtualFolders* pbFolder = CVirtualFolders::NewLC();

	pbFolder->PlaceFolderL(CFolderNodePb::NewL(*this)); //ownership passed

	telecomFolder->AttachSubtree(pbFolder); //ownership passed

	CleanupStack::Pop(pbFolder);

	// make sure that we successfully created a logeng client

	if (iLogWrapper && (iLogWrapper->ClientAvailable()))

		{

		// create ich sub folder

		CVirtualFolders* ichFolder = CVirtualFolders::NewLC();

		ichFolder->PlaceFolderL(CFolderNodeIch::NewL(*this)); //ownership passed

		telecomFolder->AttachSubtree(ichFolder); //ownership passed

		CleanupStack::Pop(ichFolder);

		//create och sub folder

		CVirtualFolders* ochFolder = CVirtualFolders::NewLC();

		ochFolder->PlaceFolderL(CFolderNodeOch::NewL(*this)); //ownership passed

		telecomFolder->AttachSubtree(ochFolder); //ownership passed

		CleanupStack::Pop(ochFolder);

		// create mch sub folder

		CVirtualFolders* mchFolder = CVirtualFolders::NewLC();

		mchFolder->PlaceFolderL(CFolderNodeMch::NewL(*this)); //ownership passed

		telecomFolder->AttachSubtree(mchFolder); //ownership passed

		CleanupStack::Pop(mchFolder);

		// create cch sub folder

		CVirtualFolders* cchFolder = CVirtualFolders::NewLC();

		cchFolder->PlaceFolderL(CFolderNodeCch::NewL(*this)); //ownership passed

		telecomFolder->AttachSubtree(cchFolder); //ownership passed

		CleanupStack::Pop(cchFolder);

		}

	CleanupStack::Pop(telecomFolder);	

	return telecomFolder;

	}

#ifdef __INCLUDE_SIM1_FOLDERS__

CVirtualFolders* CPbapServer::SIMTelecomSubTreeL()

	{

	LOG_FUNC

	// create SIM1 telecom folder

	CVirtualFolders* telecomFolder = CVirtualFolders::NewLC();

	telecomFolder->PlaceFolderL(CFolderSIM1Telecom::NewL(*this)); //ownership passed

	// create SIM1 pb sub folder

	CVirtualFolders* pbFolder = CVirtualFolders::NewLC();

	pbFolder->PlaceFolderL(CFolderSIM1NodePb::NewL(*this)); //ownership passed

	telecomFolder->AttachSubtree(pbFolder); //ownership passed

	CleanupStack::Pop(pbFolder);

	// create SIM1 ich sub folder

	CVirtualFolders* ichFolder = CVirtualFolders::NewLC();

	ichFolder->PlaceFolderL(CFolderSIM1NodeIch::NewL(*this)); //ownership passed

	telecomFolder->AttachSubtree(ichFolder); //ownership passed

	CleanupStack::Pop(ichFolder);

	// create SIM1 och sub folder

	CVirtualFolders* ochFolder = CVirtualFolders::NewLC();

	ochFolder->PlaceFolderL(CFolderSIM1NodeOch::NewL(*this)); //ownership passed

	telecomFolder->AttachSubtree(ochFolder); //ownership passed

	CleanupStack::Pop(ochFolder);

	// create SIM1 mch sub folder

	CVirtualFolders* mchFolder = CVirtualFolders::NewLC();

	mchFolder->PlaceFolderL(CFolderSIM1NodeMch::NewL(*this)); //ownership passed

	telecomFolder->AttachSubtree(mchFolder); //ownership passed

	CleanupStack::Pop(mchFolder);

	// create SIM1 cch sub folder

	CVirtualFolders* cchFolder = CVirtualFolders::NewLC();

	cchFolder->PlaceFolderL(CFolderSIM1NodeCch::NewL(*this)); //ownership passed

	telecomFolder->AttachSubtree(cchFolder); //ownership passed

	CleanupStack::Pop(cchFolder);

	CleanupStack::Pop(telecomFolder);

	return telecomFolder;

	}

#endif // __INCLUDE_SIM1_FOLDERS__

/*virtual*/ CContactDatabase& CPbapServer::ContactDB() const

	{

	LOG_FUNC

	return *iContacts;

	}

/*virtual*/ CPbapContactDbViews& CPbapServer::ContactDbViews()

	{

	LOG_FUNC

	return *iContactViews;

	}

/*virtual*/ CPbapLogWrapper& CPbapServer::LogClient() const

	{

	LOG_FUNC

	return *iLogWrapper;

	}

/*virtual*/ MPbapExporter& CPbapServer::Exporter()

	{

	LOG_FUNC

	return *static_cast<MPbapExporter*>(this);

	}

/*virtual*/ MPbapErrorReporter& CPbapServer::ErrorReporter()

	{

	LOG_FUNC

	return *static_cast<MPbapErrorReporter*>(this);

	}

/*virtual*/ void CPbapServer::StartExport()

	{

	LOG_FUNC

	__ASSERT_ALWAYS(!iExportInProgress, Panic(EPbapServerPanicExportInProgress));

	// open the obex stream ready for export

	iBufStreamer.Open(*iOutboundBuffer);

	// set flag to indicate export started

	iExportInProgress=ETrue;

	}

/*virtual*/ void CPbapServer::ExportListingBeginL()

	{

	LOG_FUNC

	if(iExportInProgress == EFalse)

		{

		__ASSERT_DEBUG(EFalse, Panic(EPbapServerPanicNotReadyForExport));

		User::Leave(KErrNotReady);

		}

	if (iExportInProgress)

		{	

		// write the XML DTD header

		PbapDTD::WriteBeginL(iBufStreamer);

		}

	}

/*virtual*/ void CPbapServer::ExportListingEntryL(TInt aHandle, const TDesC& aName)

	{

	LOG_FUNC

	if(iExportInProgress == EFalse)

		{

		__ASSERT_DEBUG(EFalse, Panic(EPbapServerPanicNotReadyForExport));

		User::Leave(KErrNotReady);

		}

	if (iExportInProgress)

		{

		// write listing entry to stream

		PbapDTD::WriteListingEntryL(iBufStreamer, aHandle, aName);

		}

	}

/*virtual*/ void CPbapServer::ExportListingEndL()

	{

	LOG_FUNC

	if(iExportInProgress == EFalse)

		{

		__ASSERT_DEBUG(EFalse, Panic(EPbapServerPanicNotReadyForExport));

		User::Leave(KErrNotReady);

		}

	if (iExportInProgress)

		{

		// write the XML DTD end tag

		PbapDTD::WriteEndL(iBufStreamer);

		}

	}

/*virtual*/ void CPbapServer::ExportCallHistoryL(const CLogEvent& aEvent, TVCardVersion aFormat, TUint64 aFilter)

	{

	LOG_FUNC

	if(iExportInProgress == EFalse)

		{

		__ASSERT_DEBUG(EFalse, Panic(EPbapServerPanicNotReadyForExport));

		User::Leave(KErrNotReady);

		}

	if (iExportInProgress)

		{

		// convert log event to a vCard and add to stream

		iVCardExporter->ExportCallHistoryL(aEvent, iBufStreamer, aFormat, aFilter);

		}

	}

/*virtual*/ void CPbapServer::ExportContactL(TContactItemId aContactId, TVCardVersion aFormat, TUint64 aFilter)

	{

	LOG_FUNC

	if(iExportInProgress == EFalse)

		{

		__ASSERT_DEBUG(EFalse, Panic(EPbapServerPanicNotReadyForExport));

		User::Leave(KErrNotReady);

		}

	if (iExportInProgress)

		{	

		// convert contact to a vCard and add to stream

		iVCardExporter->ExportContactL(aContactId, iBufStreamer, aFormat, aFilter);

		}

	}

/*virtual*/ void CPbapServer::ExportEmptyVCardL(TVCardVersion aFormat)

	{

	LOG_FUNC

	if(iExportInProgress == EFalse)

		{

		__ASSERT_DEBUG(EFalse, Panic(EPbapServerPanicNotReadyForExport));

		User::Leave(KErrNotReady);

		}

	if (iExportInProgress)

		{	

		// create empty vCard and add to stream

		iVCardExporter->ExportEmptyVCardL(iBufStreamer, aFormat);

		}	

	}

/*virtual*/ void CPbapServer::ExportPhonebookSizeL(TInt aCount)

	{

	LOG_FUNC

	if(iExportInProgress == EFalse)

		{

		__ASSERT_DEBUG(EFalse, Panic(EPbapServerPanicNotReadyForExport));

		User::Leave(KErrNotReady);

		}