// 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 "asaltrequestsetalarm.h"
#include "ASAltClientSession.h"
#include "ASSrvAlarmQueue.h"
#include "ASSrvSessionCollection.h"

CASAltRequestSetAlarm::CASAltRequestSetAlarm(RASAltClientSession& aSession, CASSrvNotificationCoordinator& aParent, CASSrvAlarmQueue& aQueue, MASSrvSessionCollection& aSessionCollection)
:	CActive(CActive::EPriorityHigh), iSession(aSession), iParent(aParent), iQueue( aQueue ), iSessionCollection( aSessionCollection )
	{
	CActiveScheduler::Add(this);
	}


CASAltRequestSetAlarm::~CASAltRequestSetAlarm()
	{
	Cancel();
	delete iAlarmCopy;
	delete iAlarmDataCopy;
	iRequestedAlarmIds.Reset();
	}

void CASAltRequestSetAlarm::RequestSetAlarm(TAlarmId aId)
	{
	if (!IsActive())
		{
		RequestNextAlarm(aId);
		}
	else
		{
		// Non-leaving version of Append intentionaly used here
		// Space for 8 elements has been reserved in ConstructL
		iRequestedAlarmIds.Append(aId);
		}
	}

void CASAltRequestSetAlarm::RequestNextAlarm(TAlarmId aId)
    {
    ASSERT(!IsActive());
    
	// Get the alarm details from the queue and prepare any associated data
    const TASSrvAlarm* alarm = iQueue.QueueAlarmById(aId);
	if  (alarm)
	    {
    	// Notify the alarm alert server about the alarm and its associated
    	// data (if it has any)
    	TPtrC8 pAlarmData(KNullDesC8);
    	if (alarm->HasAssociatedData())
    		{
    		pAlarmData.Set(alarm->Data());
    		}

        // Get alarm owner
    	TFullName owner(KNullDesC);
    	iSessionCollection.MASSessionCollectionAlarmOwner(aId, owner);

        // Get alarm data
    	delete iAlarmDataCopy;
    	iAlarmDataCopy = NULL;
    	TRAPD(err, iAlarmDataCopy = pAlarmData.AllocL());
     	
     	// Queue alarm with alert server
     	*iAlarmCopy = *alarm;
        
     	if  (iAlarmDataCopy && err == KErrNone)
     		{
     		iSession.SetAlarm(iStatus, *iAlarmCopy, owner, *iAlarmDataCopy);
     		}
     	else
     		{
      		iSession.SetAlarm(iStatus, *iAlarmCopy, owner, KNullDesC8());
    		}
    	
    	SetActive();
	    }
    }
    
void CASAltRequestSetAlarm::ConstructL()
	{
	iAlarmCopy = new(ELeave) TASShdAlarm;
	iRequestedAlarmIds.ReserveL(8);
	}

CASAltRequestSetAlarm* CASAltRequestSetAlarm::NewL(RASAltClientSession& aSession, CASSrvNotificationCoordinator& aParent, CASSrvAlarmQueue& aQueue, MASSrvSessionCollection& aSessionCollection)
	{
	CASAltRequestSetAlarm* self = new(ELeave) CASAltRequestSetAlarm(aSession, aParent, aQueue, aSessionCollection);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

void CASAltRequestSetAlarm::RequestSetAlarmCancel(TAlarmId aId)
    {
    if  (IsActive() && (iAlarmCopy->Id() == aId))
        {
        iCancelledCurrentRequest = ETrue;
        }
    else
        {
		const TInt KPosition(iRequestedAlarmIds.Find(aId));
		
		if (KPosition != KErrNotFound)
			{
			iRequestedAlarmIds.Remove(KPosition);
			}
        }
    }
    

void CASAltRequestSetAlarm::RunL()
	{
	if (!iCancelledCurrentRequest)
	    {
    	iParent.CompleteUpdateAlarmAlertServer(iAlarmCopy);
	    }
	    
	// Do we have more items to request?
	if (iRequestedAlarmIds.Count() > 0)
		{
		// Request next item
		const TAlarmId KHeadItem = iRequestedAlarmIds[0];
		iRequestedAlarmIds.Remove(0);
		RequestNextAlarm(KHeadItem);
		}
		
	iCancelledCurrentRequest = EFalse;
	}
	
void CASAltRequestSetAlarm::DoCancel()
	{
	}