/*
* Copyright (c) 2006 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:   This class is the main interface to the TelephonyAudioRoutingServer. 
*				 It implements the client-side session.
*
*/


                                                           
#include <e32math.h>    
#include <s32mem.h> 
#include "TelephonyAudioRoutingClientServer.h"          
#include "TelephonyAudioRoutingSession.h"      
#include "TelephonyAudioRoutingRequest.h"
#include "TelephonyAudioRoutingPolicyRequest.h"     

const TInt KReqSetOutput					= 0;
const TInt KReqNotifyIfOutputChanged		= 1;
const TInt KReqNotifyIfAvailOutputsChanged	= 2; 
const TInt KReqMaxSize 						= 3;    
                                       
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::RTelephonyAudioRoutingSession
// C++ default constructor can NOT contain any code, that
// might leave.
// -----------------------------------------------------------------------------
//                                                                                                 
EXPORT_C RTelephonyAudioRoutingSession::RTelephonyAudioRoutingSession()                                                         
	: RSessionBase(), iConnected(EFalse)                                                                    
    {                                                                                            
    // No implementation required  
                                                         
    }                                                                                            
                                                                                                 
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::ConnectL
// Connects a client to the  server
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//                                                                                                
EXPORT_C TInt RTelephonyAudioRoutingSession::ConnectL(
	CTelephonyAudioRouting& aAudioRouting,
	MTelephonyAudioRoutingObserver& aObserver)                                                               
    {
    	
    TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t TelephonyAudioRoutingSession::ConnectL "));
    
	TInt retry=2;
  	TInt err = KErrGeneral;
  	
 
	for (;;)
		{
		err=CreateSession(KTelAudRtngServName,TVersion(0,0,0));		
		if (err!=KErrNotFound && err!=KErrServerTerminated && err!=KErrPermissionDenied)
		break;
		
		if (--retry==0)
		break;
		} 
	
	if ( err == KErrNone )
		{
		// Create active object receive handlers and add it to scheduler
		TRAP(err, StartRequestHandlersL(aAudioRouting, aObserver));
		if ( err == KErrNone )
			{
			iConnected = ETrue;
			}
			
		SendReceive(ETelAudRtngServInitialize, TIpcArgs());

		}
	
	return err;                                                                                           
                                                                              
    }        
  
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::Close
// Closes connection to the server.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//  
EXPORT_C void RTelephonyAudioRoutingSession::Close()
	{
	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingSession[%x]::Close "),this);		
	if ( iConnected )
		{
				
		for (TInt i = 0; i < KReqMaxSize; i++)
		{
			delete iRequests[i];
		}
		iRequests.Close();		
		iAvailableOutputs.Close();
		RSessionBase::Close();
		iConnected = EFalse;
		
		}
		
	}                                                                                       
                                                                                                 
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::Version
// Gets the client side version number.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//                                                                                            
EXPORT_C TVersion RTelephonyAudioRoutingSession::Version() const                                                     
    {                                                                                            
    return(TVersion(0,0,0));                                               
    }   
           
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::GetDefaultValues
// Gets default values for current audio output, previous audio output, and 
// show note mode from the server.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//                                                                                         
EXPORT_C void RTelephonyAudioRoutingSession::GetDefaultValuesL()                                        
    {
	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingSession[%x]::GetDefaultValuesL "),this);	   
		
	User::LeaveIfError( SendReceive(ETelAudRtngServGetDefaultValues, TIpcArgs(&iDefaultValuePkg)) ); 
	
	// Set session attributes with values retrieved from Server:
	TTelephonyAudioRoutingDefaultParams defParams = iDefaultValuePkg();
	
	CTelephonyAudioRouting::TAudioOutput currentAudioOutput = defParams.iCurrentAudio;
	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t GetDefaultValuesL: current audio output = %d "), currentAudioOutput);	
	iCurrentAudioOutputPkg() = currentAudioOutput;	 
	
	CTelephonyAudioRouting::TAudioOutput previousAudioOutput = defParams.iPreviousAudio;
	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t GetDefaultValuesL: Previous audio output = %d "), previousAudioOutput);	
	iPreviousAudioOutputPkg() = previousAudioOutput;
	
	TBool showNoteMode = defParams.iShowNoteMode;
	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t GetDefaultValuesL: showNoteMode = %d "), showNoteMode);	
	iShowNoteModePkg() = showNoteMode;	 		 	                           
    
 	} 
                                                                                                    
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::SetOutput
// Send a SetOutput request to server.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//                                                                                         
EXPORT_C void RTelephonyAudioRoutingSession::SetOutput(
	CTelephonyAudioRouting::TAudioOutput aOutput, TBool aShowNote)                                        
    {
	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingSession[%x]::SetOutput "),this);	   

	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingSession::SetOutput: ShowNote = %d "), aShowNote);	   

	iRequests[KReqSetOutput]->Cancel();
                                                                          
	iCurrentAudioOutputPkg() = aOutput;  
	iPreviousAudioOutputPkg() = CTelephonyAudioRouting::ENone; 
	iErrPkg() = KErrNone;  	
	iShowNoteModePkg() = aShowNote;
	
  	iRequests[KReqSetOutput]->SetActive();	
	SendReceive(ETelAudRtngServDoSetOutput, TIpcArgs(&iCurrentAudioOutputPkg, &iPreviousAudioOutputPkg, &iErrPkg, &iShowNoteModePkg), iRequests[KReqSetOutput]->iStatus);  	                            
    
    } 

// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::GetAvailableOutputsL
// Get the available audio outputs from the server.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C void RTelephonyAudioRoutingSession::GetAvailableOutputsL()
	{
	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingSession[%x]::GetAvailableOutputsL"),this);		
	iAvailableOutputs.Reset();

	TPckgBuf<TInt> numOfOutputs;
	User::LeaveIfError(SendReceive(ETelAudRtngServGetNoOutputs, TIpcArgs(&numOfOutputs)));
	HBufC8* buf = HBufC8::NewLC(numOfOutputs()*sizeof(CTelephonyAudioRouting::TAudioOutput));
	TPtr8 ptr = buf->Des();
	
	User::LeaveIfError(SendReceive(ETelAudRtngServGetAvailableOutputs, TIpcArgs(&ptr)));
	RDesReadStream stream(ptr);
	CleanupClosePushL(stream);

	for (TInt i=0; i<numOfOutputs(); i++)
		{
		TInt err = iAvailableOutputs.Append((CTelephonyAudioRouting::TAudioOutput)stream.ReadInt32L());
		if (err)
			{
			iAvailableOutputs.Reset();
			User::Leave(err);
			}
		}
	
	CleanupStack::PopAndDestroy(2, buf);//stream, buf
		
	}
	
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::NotifyIfOutputChanged
// Send a request to server to receive notification whenever current audio output changes.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C void RTelephonyAudioRoutingSession::NotifyIfOutputChanged()
	{
	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingSession[%x]::NotifyIfOutputChanged"),this);	 

	iRequests[KReqNotifyIfOutputChanged]->Cancel();
	
	SendReceive(ETelAudRtngServNotifyIfOutputChanged, TIpcArgs(&iCurrentAudioOutputPkg, &iPreviousAudioOutputPkg, &iErrPkg, &iShowNoteModePkg), iRequests[KReqNotifyIfOutputChanged]->iStatus);
	iRequests[KReqNotifyIfOutputChanged]->SetActive();
	
	}

// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::NotifyIfAvailableOutputsChanged
// Send a request to server to receive notification whenever available audio output changes.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C void RTelephonyAudioRoutingSession::NotifyIfAvailableOutputsChanged()
	{
	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingSession[%x]::NotifyIfAvailbleOutputsChanged"),this);	
	iRequests[KReqNotifyIfAvailOutputsChanged]->Cancel();
	     
	SendReceive(ETelAudRtngServNotifyIfAvailOutputsChanged, TIpcArgs(&iCurrentAudioOutputPkg), iRequests[KReqNotifyIfAvailOutputsChanged]->iStatus);
	iRequests[KReqNotifyIfAvailOutputsChanged]->SetActive();
	
	}
	
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::CancelRequest
// Cancel a previously sent request.
// aRequestOpcode = index into array as to which request object to cancel. 
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//	
EXPORT_C void RTelephonyAudioRoutingSession::CancelRequest(TTelAudRtngServRqst aRequestOpcode)
	{
	TPckgBuf<TInt> request;   
  	request() = aRequestOpcode;

	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t CTelephonyAudioRoutingSession::CancelRequest Number: %d"), aRequestOpcode);
	SendReceive(ETelAudRtngServCancelRequest, TIpcArgs(&request));	
	
	}
	
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::CurrentAudioOutputPkg
// Accessor method returns iCurrentAudioOutputPkg to caller.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//	
EXPORT_C TPckgBuf<CTelephonyAudioRouting::TAudioOutput>& RTelephonyAudioRoutingSession::CurrentAudioOutputPkg()
	{
		return iCurrentAudioOutputPkg;
	}
	
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::PreviousAudioOutputPkg
// Accessor method returns iPreviousAudioOutputPkg to caller.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//	
EXPORT_C TPckgBuf<CTelephonyAudioRouting::TAudioOutput>& RTelephonyAudioRoutingSession::PreviousAudioOutputPkg()
	{
		return iPreviousAudioOutputPkg;
	}
	
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::ErrPkg
// Accessor method returns iErrPkg to caller. 
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//	
EXPORT_C TPckgBuf<TInt>& RTelephonyAudioRoutingSession::ErrPkg()
	{
		return iErrPkg;
	}
	
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::AvailableOutputs
// Accessor method returns iAvailableOutputs to caller.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//	
EXPORT_C RArray<CTelephonyAudioRouting::TAudioOutput>& RTelephonyAudioRoutingSession::AvailableOutputs()
	{
		return iAvailableOutputs;
	}					

// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::StartRequestHandlersL
// Start asynchronous request handlers.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void RTelephonyAudioRoutingSession::StartRequestHandlersL(
	CTelephonyAudioRouting& aAudioRouting,	
	MTelephonyAudioRoutingObserver& aObserver )
	{
	
	CTelephonyAudioRoutingRequest* req = NULL;

	req = CTelephonyAudioRoutingRequest::NewL(*this, aObserver, aAudioRouting, ETelAudRtngServDoSetOutput);
	User::LeaveIfError( iRequests.Append(req) );

	req = CTelephonyAudioRoutingRequest::NewL(*this, aObserver, aAudioRouting, ETelAudRtngServNotifyIfOutputChanged);
	User::LeaveIfError( iRequests.Append(req) );

	req = CTelephonyAudioRoutingRequest::NewL(*this, aObserver, aAudioRouting, ETelAudRtngServNotifyIfAvailOutputsChanged);
	User::LeaveIfError( iRequests.Append(req) );

	}
	
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::SetShowNoteMode
// Sets session flag iOkToGetShowNoteMode to indicate that it is OK to retrieve value of
// iShowNoteMode from the server.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//	
EXPORT_C void RTelephonyAudioRoutingSession::SetShowNoteMode()
	{
	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingSession[%x]::SetShowNoteMode"),this);	
	iOkToGetShowNoteMode = ETrue;
	}
	
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::ShowNoteMode
// Provide caller with value of iShowNoteModePkg from server
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//	
EXPORT_C TPckgBuf<TBool>& RTelephonyAudioRoutingSession::ShowNoteMode()
	{	
	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingSession[%x]::ShowNoteMode"),this);
	
	return iShowNoteModePkg;
	}
	
	
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::ResetShowNoteMode
// Resets the session flag iOkToGetShowNoteMode to indicate it's not ok to retrieve
// value of iSetShowNoteMode from server. (Client can only retrieve it once after a
// SetOutputComplete call). (But it can be set internally from an OutputChanged call).
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//	
EXPORT_C void RTelephonyAudioRoutingSession::ResetShowNoteMode()
	{
	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingSession[%x]::ResetShowNoteMode"),this);	
	iOkToGetShowNoteMode = EFalse;
	}
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::OkToGetShowNoteMode
// Provide caller with value of iOkToGetShowNoteMode
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//	
EXPORT_C TBool RTelephonyAudioRoutingSession::OkToGetShowNoteMode()
	{		
	return iOkToGetShowNoteMode;
	}	
// End of File