// Copyright (c) 1999-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 "NbsWatcher.h"
#include <biodb.h>

#include "NBSSocketWatcher.h"

#include <e32test.h>
#include <watcher.h>

//
// DLL Global Methods
//


#include <ecom/implementationproxy.h>

const TImplementationProxy ImplementationTable[] = 
	{
		IMPLEMENTATION_PROXY_ENTRY(0x10008C66, CNbsWatcher::NewL)
	};

EXPORT_C const TImplementationProxy* ImplementationGroupProxy(TInt& aTableCount)
	{
	aTableCount = sizeof(ImplementationTable) / sizeof(TImplementationProxy);

	return ImplementationTable;
	}


//
// NbsWatcher
//

//
// Construction
//
CNbsWatcher::CNbsWatcher(RFs& aFs, CWatcherLog& aLog)
: CSmsBaseWatcher(aFs, aLog, EPriorityStandard + 1)
	{
	}
	
CNbsWatcher::~CNbsWatcher()
	{
	}

//
CNbsWatcher* CNbsWatcher::NewL(TAny* aWatcherParams)
	{
	TWatcherParams* params = reinterpret_cast<TWatcherParams*>(aWatcherParams);
	CNbsWatcher* self= new (ELeave) CNbsWatcher(params->iFs, params->iLog);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}
	
void CNbsWatcher::ConstructL()
	{
	// CSmsBaseWatcher::ConstructL calls SetActive
	CSmsBaseWatcher::ConstructL();
	}

//
// Construction/destruction

void CNbsWatcher::StartL()
	{
	CSmsBaseWatcher::StartL();

	GetBioServiceId(*iSession, iBioServiceId, iSmsServiceId);

	CreateSocketWatchersFromBioDbL(EBioMsgIdNbs);

	// Set up a SMS Watcher for Special Messages
	SetupSpecialWatcherL(ESmsAddrMessageIndication);

	// Set up a SMS Watcher for Status Reports
	SetupSpecialWatcherL(ESmsAddrStatusReport);

	// Set up the default NULL SMS message
	CBaseSmsActiveSocketWatcher* nbsWatcher = CNbsSmsSocketWatcher::NewLC(iBioServiceId, iSmsServiceId, *iBioDb, iWatcherLog, Priority(), KNullUid, iFs, KNullDesC, ESmsAddrRecvAny);
	TInt error = SetupAndAppendL(*nbsWatcher, *iSocketWatchers);
	User::LeaveIfError(error); //need to make sure the ReceiveAny watcher is working
	iReceiveAnySocket = nbsWatcher;
	CleanupStack::Pop(); //nbsWatcher

	StartSocketWatchersL();

	ResetDb(); //these members are only required during construction

	// delete the session with the message server
	delete iSession;
	iSession = NULL;	
	}

CBaseSmsActiveSocketWatcher* CNbsWatcher::CreateSocketWatcherLC(const TUid aBioUid, const TBioMsgId& aBioMsg)
	{
	if (!SupportBioMsgId(aBioMsg))
		User::Leave(KErrNotSupported);

	__ASSERT_DEBUG(iBioDb, PanicWatcher(EObjectNotConstructed));

	return CNbsSmsSocketWatcher::NewLC(iBioServiceId, iSmsServiceId, *iBioDb, iWatcherLog, Priority(), aBioUid, iFs, aBioMsg.iText);
	}

TBool CNbsWatcher::SupportBioMsgId(const TBioMsgId& aBioMsg) const
	{
	return aBioMsg.iType == EBioMsgIdNbs && aBioMsg.iPort <= 0 && aBioMsg.iText.Length();
	}

void CNbsWatcher::AddBifL(TUid aBioID)
	{
	BIOWATCHERLOG(iWatcherLog.Printf(_L8("BioNbs: AddBifL(BioUid: %d)"), aBioID.iUid));

	// Handle the case where the watchers are not working
	if (!iReceiveAnySocket)
		User::Leave(KErrNotSupported);

	iReceiveAnySocket->Cancel();

	TRAPD(err, AddBifWithTypeL(EBioMsgIdNbs, aBioID));

	iReceiveAnySocket->SetupL();
	iReceiveAnySocket->StartL();

	ResetDb();

	User::LeaveIfError(err);
	}

void CNbsWatcher::SetupSpecialWatcherL(TSmsAddrFamily aAddrFamily)
	{
	CBaseSmsActiveSocketWatcher* nbsWatcher = NULL;

	//The following function will leave with KErrNotSupported
	//if the CSmsSettings stored against the SMS Service indicates
	//that this message type should not be watched

	BIOWATCHERLOG(iWatcherLog.Printf(_L8("BioNbs: SetupSpecialWatcher [aAddrFamily=%d]"), aAddrFamily));
	__ASSERT_DEBUG(iBioDb, PanicWatcher(EObjectNotConstructed));

	TRAPD(error, nbsWatcher = CSpecialNbsSmsSocketWatcher::NewL(iBioServiceId, iSmsServiceId, *iBioDb, iWatcherLog, Priority(), KNullUid, iFs, KNullDesC, aAddrFamily));

	if (error == KErrNone)
		{
		CleanupStack::PushL(nbsWatcher);
		error = SetupAndAppendL(*nbsWatcher, *iSocketWatchers); //Returns either KErrNotFound or KErrAlreadyExists, otherwise leaves

		if (error != KErrNone)
			CleanupStack::PopAndDestroy(nbsWatcher);
		else
			CleanupStack::Pop(nbsWatcher);
		}

	if (error != KErrNone)
		{
		BIOWATCHERLOG(iWatcherLog.Printf(_L8("BioNbs: SetupSpecialWatcher Failed [error=%d]"), error));

		if (error == KErrNoMemory)
			User::Leave(error);
		//else ignore the error
		}
	}