/*
* Copyright (c) 2002-2004 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:  Alert queue and handler
*
*/

#include <nsmldebug.h>

#include "NSmlAlertQueue.h"
#include "nsmlsosserverdefs.h"

//Fix to Remove the Bad Compiler Warnings
#ifndef __WINS__
// This lowers the unnecessary compiler warning (armv5) to remark.
// "Warning:  #174-D: expression has no effect..." is caused by 
// DBG_ARGS8 macro in no-debug builds.
#pragma diag_remark 174
#endif

// ============================ MEMBER FUNCTIONS ===============================

// ---------------------------------------------------------
// CNSmlAlertHandler::NewL(MNSmlMessageHandler* aMsgHandler)
// Two phase constructor
// ---------------------------------------------------------
//
CNSmlAlertHandler* CNSmlAlertHandler::NewL( MNSmlMessageHandler* aMsgHandler )
	{
	CNSmlAlertHandler* self = new (ELeave) CNSmlAlertHandler;
	CleanupStack::PushL( self );
	self->ConstructL( aMsgHandler );
	CleanupStack::Pop();
	return self;
	}

// ---------------------------------------------------------
// CNSmlAlertHandler::CNSmlAlertHandler()
// Constructor
// ---------------------------------------------------------
CNSmlAlertHandler::CNSmlAlertHandler()
: CActive(0), iNewEntry( EFalse )
	{
	CActiveScheduler::Add( this );
	}

// ---------------------------------------------------------
// CNSmlAlertHandler::~CNSmlAlertHandler()
// Destructor
// ---------------------------------------------------------
CNSmlAlertHandler::~CNSmlAlertHandler()
	{

	Cancel();
	if( !iHistoryArray )
	{
	iHistoryArray->SetOwnerShip( ETrue );
	delete iHistoryArray;
	}
	delete iAlertParser;			
		
	if ( ! iNewEntry )
		{
		delete iAlertInfo;
		delete iHistoryInfo;
		}
	}

// ---------------------------------------------------------
// CNSmlAlertHandler::DoCancel()
// Method from base class
// ---------------------------------------------------------
void CNSmlAlertHandler::DoCancel()
	{
	
	}

// ---------------------------------------------------------
// CNSmlAlertHandler::ProcessAlert()
// Activates alert handler
// ---------------------------------------------------------
void CNSmlAlertHandler::ProcessAlert()
	{
	if ( IsActive() )
		{
		return;
		}
	SetActive();
	TRequestStatus* pStatus = &iStatus;
	User::RequestComplete(pStatus, KErrNone);
	}

// ---------------------------------------------------------
// CNSmlAlertHandler::ConstructL( MNSmlMessageHandler* aMsgHandler )
// Second phase constructor
// ---------------------------------------------------------
void CNSmlAlertHandler::ConstructL( MNSmlMessageHandler* aMsgHandler )
	{
	User::LeaveIfNull(aMsgHandler);
	iMsgHandler = aMsgHandler;
	
    iHistoryInfo = CSyncMLHistoryPushMsg::NewL();

	iAlertInfo = new ( ELeave ) CSmlAlertInfo;

	iHistoryArray = CNSmlHistoryArray::NewL();
	iHistoryArray->SetOwnerShip( EFalse ); // move ownership to history array
	}

// ---------------------------------------------------------
// CNSmlAlertHandler::RunL()
// Method from base class
// ---------------------------------------------------------
void CNSmlAlertHandler::RunL()
    {
    TRAP_IGNORE( DoRunL() );    
    };

// ---------------------------------------------------------
// CNSmlAlertHandler::DoRunL()
// Method from base class
// ---------------------------------------------------------
void CNSmlAlertHandler::DoRunL()
	{

    // Delete member variables
    iHistoryArray->SetOwnerShip( ETrue );
	delete iHistoryArray;
	iHistoryArray = NULL;
	delete iAlertParser;			
	iAlertParser = NULL;

    // These are deleted by iHistoryArray
	iAlertInfo = NULL;
	iHistoryInfo = NULL;

    // Create member variables	
	iHistoryInfo = CSyncMLHistoryPushMsg::NewL();
	iAlertInfo = new ( ELeave ) CSmlAlertInfo;
	iHistoryArray = CNSmlHistoryArray::NewL();
	iHistoryArray->SetOwnerShip( EFalse ); // move ownership to history array
	
	
	// Continue DoRunL method
	TBool message( EFalse );
	TBool quit( ETrue );
	TBool doPop( EFalse );
	
	TPtrC8 pPackage;
	TSmlUsageType type;
	TSmlProtocolVersion version;
	TSmlTransportId bearerType;
	
	//check message
	iMsgHandler->CheckMessage( message, type, version, bearerType );
	iAlertInfo->SetJobControl( CSmlAlertInfo::EDoNotCreateJob );
	iAlertInfo->SetTransportId( bearerType );
	#ifdef __NSML_DEBUG__
		DBG_ARGS(_S("CNSmlAlertHandler::RunL(): TransportId : '%d'"), bearerType );
	#endif // __NSML_DEBUG__

	TInt err( KErrNone );
	
	if ( message )
	    {
	    		
    	iAlertParser = NSmlParserFactory::CreateAlertParserL( type, version, *iAlertInfo, *iHistoryInfo );
    	iAlertParser->CreateBufferL( iMsgHandler->MessageSize() );
    	iMsgHandler->AlertMessage( iAlertParser->Message() );
    					
    	TRAP(err, iAlertParser->ParseMessageL());
    	DBG_FILE_CODE(err, _S8("CNSmlAlertHandler::RunL() : Alert result"));
    	iAlertInfo->SetErrorCode( err );
    	
    	iNewEntry = ETrue;
    	
    	if ( err != KErrNone)
    		{
    		iNewEntry = EFalse;
    		iAlertInfo->SetJobControl( CSmlAlertInfo::EDoNotCreateJob );
    		
    		// Close local connection
    		if ( bearerType != KUidNSmlMediumTypeInternet.iUid )
    			{
    			iMsgHandler->DoDisconnect();	
    			}
    	   		
    		if ( err == KErrCorrupt )
    			{
    			return; 
    			}
    		}
    	else
    		{
    		CheckDigestL( iAlertInfo->Profile(), iHistoryInfo->MsgDigest() );
    					
    		CheckProtocolAndChangeL( version );
    		    					
    		if ( ( type == ESmlDataSync )  && ( version == ESmlVersion1_1_2 ) )
    			{
    			iAlertInfo->SetConfirmation( ETrue );
    			pPackage.Set( iAlertParser->DoMessageCopyLC() );
    			doPop = ETrue;
    			}
    		}

    	delete iAlertParser;
    	iAlertParser = NULL;
	    }
	    
	iAlertInfo->SetConfirmation( FinalizeBeforeJobCreationL() );
	iMsgHandler->CreateJobL( *iAlertInfo, quit, pPackage);                
		
	if ( doPop )
		{
		CleanupStack::PopAndDestroy(); // DoMessageCopyLC()
		}
	
	
	if (! quit)
		{
		ProcessAlert();
		}
	
	}


// ---------------------------------------------------------
// CNSmlAlertHandler::FinalizeBeforeJobCreationL()
// Connects to notifier plug in to show confirmation note and
// waits for the response.
// ---------------------------------------------------------
TBool CNSmlAlertHandler::FinalizeBeforeJobCreationL()
	{
	
	if ( iAlertInfo->Profile() < KMaxDataSyncID )		
		{
		CNSmlDSSettings* settings = CNSmlDSSettings::NewLC();
		
		CNSmlDSProfile* profile = settings->ProfileL( iAlertInfo->Profile() );
		
		if ( !profile )
			{
			CleanupStack::PopAndDestroy(); //settings
			return EFalse;
			}
			
		CleanupStack::PushL( profile );
		
		iAlertInfo->SetTransportId( profile->IntValue( EDSProfileTransportId) );
		iAlertInfo->SetConnectionId( profile->IntValue( EDSProfileTransportId) );
		
		CleanupStack::PopAndDestroy(2); //profile, settings
		}
	else
		{
		CNSmlDMSettings* settings = CNSmlDMSettings::NewLC();
		
		CNSmlDMProfile* profile = settings->ProfileL( iAlertInfo->Profile() );
		
		if ( !profile )
			{
			CleanupStack::PopAndDestroy(); //settings
			return EFalse;
			}
		
		CleanupStack::PushL( profile );
        profile->SetIntValue( EDMProfileSessionId, iAlertInfo->SessionId() );
        profile->SaveL();

		iAlertInfo->SetTransportId( profile->IntValue( EDMProfileTransportId) );
		iAlertInfo->SetConnectionId( profile->IntValue( EDMProfileTransportId) );
		
		CleanupStack::PopAndDestroy(2); //profile, settings
		}
	
	SaveAlertInfoL();
	
	if ( ! iAlertInfo->CreateSession() )
		{
		return ETrue;
		}
	
	return ETrue;
	}

// ---------------------------------------------------------
// CheckDigestL( const TInt aProfileId, const TDesC8& aDigest )
// Checks whether alert has already been handled. Receive count
// is updated if handled before.
// ---------------------------------------------------------
void CNSmlAlertHandler::CheckDigestL( const TInt aProfileId, const TDesC8& aDigest )
	{
	
	if ( aProfileId < KMaxDataSyncID )		
		{
		CNSmlDSSettings* settings = CNSmlDSSettings::NewLC();
		
		CNSmlDSProfile* profile = settings->ProfileL(aProfileId);
		CleanupStack::PushL(profile);
		
		if ( ! profile->HasLogL() )
			{
			CleanupStack::PopAndDestroy(2); //profile, settings
			return;
			}
		
		RReadStream& readStream = profile->LogReadStreamL();
		CleanupClosePushL( readStream );
		
		iHistoryArray->InternalizeL(readStream);
		
		CleanupStack::PopAndDestroy(); //readStream
		
		for (TInt i = 0; i < iHistoryArray->Count(); i++)
			{
			CSyncMLHistoryEntry& hEntry = iHistoryArray->Entry(i);
			CSyncMLHistoryPushMsg * pushMsg = CSyncMLHistoryPushMsg::DynamicCast(&hEntry);
			
			if (pushMsg == NULL)
				continue;
			
			if ( aDigest.Compare( pushMsg->MsgDigest() ) == 0)
				{
				pushMsg->IncReceivedCount();
				iNewEntry = EFalse;
				iAlertInfo->SetConfirmation( iNewEntry );
				}
			}
	
		CleanupStack::PopAndDestroy(2); //profile, settings
		}
	else
		{
		CNSmlDMSettings* settings = CNSmlDMSettings::NewLC();
		
		CNSmlDMProfile* profile = settings->ProfileL(aProfileId);
		CleanupStack::PushL(profile);
		
		if ( ! profile->HasLogL() )
			{
			CleanupStack::PopAndDestroy(2); //profile, settings
			return;
			}
			
		RReadStream& readStream = profile->LogReadStreamL();
		CleanupClosePushL( readStream );

		iHistoryArray->InternalizeL( readStream );
		
		CleanupStack::PopAndDestroy(); //readStream
		
		for (TInt i = 0; i < iHistoryArray->Count(); i++)
			{
			CSyncMLHistoryEntry& hEntry = iHistoryArray->Entry(i);
			CSyncMLHistoryPushMsg * pushMsg = CSyncMLHistoryPushMsg::DynamicCast(&hEntry);
			
			if (pushMsg == NULL)
				continue;
			
			if ( aDigest.Compare( pushMsg->MsgDigest() ) == 0)
				{
				pushMsg->IncReceivedCount();
				iNewEntry = EFalse;
				iAlertInfo->SetConfirmation( iNewEntry );
				}
			}
		CleanupStack::PopAndDestroy(2); //profile, settings
		}
	}

// ---------------------------------------------------------
// CNSmlAlertHandler::SaveAlertInfoL( )
// Saves the result to profile history log and adds new entry
// ---------------------------------------------------------
void CNSmlAlertHandler::SaveAlertInfoL( )
	{
	
	TInt profileId( iAlertInfo->Profile() );
	
	if ( profileId == KNSmlNullId )
		{
		return;
		}
		
	if ( profileId < KMaxDataSyncID )
		{
		CNSmlDSSettings* settings = CNSmlDSSettings::NewLC();
		
		CNSmlDSProfile* profile = settings->ProfileL( profileId );
		CleanupStack::PushL( profile );
		RWriteStream& stream = profile->LogWriteStreamL();
		CleanupClosePushL( stream );
		
		if ( iNewEntry )
			{
			RPointerArray<CSmlAlertInfo> alertInfoArray;
			CleanupClosePushL( alertInfoArray );
			
			alertInfoArray.AppendL( iAlertInfo );
			
			iHistoryInfo->AddAlertsL( alertInfoArray );
			iHistoryArray->AppendEntryL( iHistoryInfo );
			CleanupStack::PopAndDestroy(); //alertInfoArray	
			}
			
		iHistoryArray->ExternalizeL(stream);
		
		CleanupStack::PopAndDestroy(); //stream
		
		profile->WriteStreamCommitL();
	
		CleanupStack::PopAndDestroy(2); // profile, settings
		}
	else
		{
		CNSmlDMSettings* settings = CNSmlDMSettings::NewLC();
		
		CNSmlDMProfile* profile = settings->ProfileL( profileId );
		CleanupStack::PushL( profile );
		
		RWriteStream& stream = profile->LogWriteStreamL();
		CleanupClosePushL( stream );
		
		if ( iNewEntry )
			{
			RPointerArray<CSmlAlertInfo> alertInfoArray;
			CleanupClosePushL( alertInfoArray );
			
			alertInfoArray.AppendL( iAlertInfo );
		
			iHistoryInfo->AddAlertsL( alertInfoArray );
			iHistoryArray->AppendEntryL( iHistoryInfo );
			
			CleanupStack::PopAndDestroy(); //alertInfoArray	
			}
			
		iHistoryArray->ExternalizeL( stream );
		CleanupStack::PopAndDestroy(); //stream
		
		profile->WriteStreamCommitL();
		
		CleanupStack::PopAndDestroy(2); // profile, settings
		}
	}


// ---------------------------------------------------------
// CheckProtocolAndChange(TSmlProtocolVersion& aVersion)
// Checks if profile has different version and chages to alert's
// version if different.
// ---------------------------------------------------------
void CNSmlAlertHandler::CheckProtocolAndChangeL( TSmlProtocolVersion& aVersion ) const
	{
	TInt profileId( iAlertInfo->Profile() );
	
	if ( profileId == KNSmlNullId )
		{
		return;
		}
		
	if ( profileId < KMaxDataSyncID )
		{
		CNSmlDSSettings* settings = CNSmlDSSettings::NewLC();
		CNSmlDSProfile* profile = settings->ProfileL( profileId );
		CleanupStack::PushL( profile );
		
		if ( profile->IntValue( EDSProfileProtocolVersion ) != aVersion )
			{
			profile->SetIntValue( EDSProfileProtocolVersion, (TInt) aVersion );
			profile->SaveL();
			}
			
		CleanupStack::PopAndDestroy(2); // profile, settings
		}
	}

//End of File