/*
* 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:   This class is the main interface to the TelephonyAudioRoutingServer.
*			   : Specifically handles TelephonyAudioRoutingManager sessions.
*
*/


                                                           
#include <e32math.h>    
#include <s32mem.h> 
#include "TelephonyAudioRoutingClientServer.h"          
#include "TelephonyAudioRoutingManagerSession.h"      
#include "TelephonyAudioRoutingPolicyRequest.h"     

                                                                                                                                                                      
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingManagerSession::RTelephonyAudioRoutingManagerSession
// C++ default constructor can NOT contain any code, that
// might leave.
// -----------------------------------------------------------------------------
//                                                                                                 
EXPORT_C RTelephonyAudioRoutingManagerSession::RTelephonyAudioRoutingManagerSession()                                                         
	: RSessionBase(), iConnected(EFalse)                                                                    
    {                                                                                            
    // No implementation required  
                                                         
    }                                                                                            
                                                                                                    
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::Connect
// Connects a policy client to the server.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C TInt RTelephonyAudioRoutingManagerSession::Connect(
	CTelephonyAudioRoutingManager& aAudioRoutingManager,
	MTelephonyAudioRoutingPolicyObserver& aPolicyObserver)                                                               
    {
    	
    TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::Connect"));
    
	TInt retry=2;
  	TInt err = KErrGeneral;
  
	for (;;)
		{
		err=CreateSession(KTelAudRtngServName,TVersion(0,0,0)); // RSessionBase::CreateSession
		
		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, StartPolicyRequestHandlersL(aAudioRoutingManager, aPolicyObserver));
		if ( err == KErrNone )
			{
			iConnected = ETrue;
			}

		SendReceive(ETelAudRtngServInitialize, TIpcArgs());

		}
	
	return err;                                                                                           
                                                                              
    }     
  
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingManagerSession::Close
// Closes connection to the server.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//  
EXPORT_C void RTelephonyAudioRoutingManagerSession::Close()
	{
	TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::Close"));	
	if ( iConnected )
		{

		delete iPolicyRequest;
		RSessionBase::Close();
		iConnected = EFalse;
		
		
		}
		
	}                                                                                       
                                                                                                 
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingManagerSession::OutputChangeCompleted
// Used by policy to notify server that requested output change completed
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C void RTelephonyAudioRoutingManagerSession::OutputChangeCompleted(
	CTelephonyAudioRouting::TAudioOutput aOutput,
	TInt aError)                                        
    { 
 	TPckgBuf<CTelephonyAudioRouting::TAudioOutput> audioOutputPkg;
	audioOutputPkg() = aOutput;  
	TPckgBuf<TInt> errPkg;
	errPkg() = aError;
	 
 	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::OutputChangeCompleted to %d"), aOutput); 	                 
	SendReceive(ETelAudRtngServOutputChangeComplete, TIpcArgs(&audioOutputPkg, &errPkg));  	                                         	    
    }
    
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingManagerSession::OutputChanged
// Used by policy to notify server of audio output changes initiated by policy.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C void RTelephonyAudioRoutingManagerSession::OutputChanged(
	CTelephonyAudioRouting::TAudioOutput aOutput)                                        
    { 
 	TPckgBuf<CTelephonyAudioRouting::TAudioOutput> audioOutputPkg;    
	audioOutputPkg() = aOutput;  
//	iAudioOutput = aOutput;  
 	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::OutputChanged to %d"), aOutput); 	                 
	SendReceive(ETelAudRtngServOutputChangedByPolicy, TIpcArgs(&audioOutputPkg));  
	                                         	    
    }
    
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingManagerSession::AvailableOutputsChangedL
// Used by policy session to notify server if the available audio output change.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//  
EXPORT_C void RTelephonyAudioRoutingManagerSession::AvailableOutputsChangedL(
	const TArray<CTelephonyAudioRouting::TAudioOutput>& aOutputs)
    {
    TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::AvailableOutputsChangedL"));  	       
	TPckgBuf<TInt> numOfOutputs;
	numOfOutputs()= aOutputs.Count();
	
	TInt count = aOutputs.Count();
	TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t AvailableOutputsChangedL: Count = %d "),count);
	for(TInt i = 0; i < count; i++)
	{
		TELAUDRTNG_RDEBUG1(_L("[TELAUDRTNG]\t AvailableOutputsChangedL: aOutputs[i] = %d "),aOutputs[i]);
	}	
	
	TInt KBufExpandSize8 = 8;//two TInts
	CBufFlat* dataCopyBuffer = CBufFlat::NewL(KBufExpandSize8);
	CleanupStack::PushL(dataCopyBuffer);
	RBufWriteStream stream;
	stream.Open(*dataCopyBuffer);
	CleanupClosePushL(stream);
	
	for (TInt i=0;i<aOutputs.Count();i++)
		{
		stream.WriteInt16L(aOutputs[i]);		
		}
	
	TPtr8 ptr = dataCopyBuffer->Ptr(0);
	
	SendReceive(ETelAudRtngDoAvailableOutputsChanged, TIpcArgs(&numOfOutputs, &ptr));
	stream.Close();
	CleanupStack::PopAndDestroy(2);//stream, buf                    
       	    
    } 
    
// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingManagerSession::SetPolicySessionIdL
// Sets policy session Id.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C void RTelephonyAudioRoutingManagerSession::SetPolicySessionIdL()
	{
	User::LeaveIfError(SendReceive(ETelAudRtngServSetPolicySessionId, TIpcArgs()));
	}

// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingManagerSession::MonitorOutputChangeRequest
// Used by policy session to get notification whenever any of the clients sends
// a SetOutput request.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C void RTelephonyAudioRoutingManagerSession::MonitorOutputChangeRequest()
	{
	TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::MonitorOutputChangeRequest "));

	iPolicyRequest->Cancel();
	
	SendReceive(ETelAudRtngServMonitorOutputChange, TIpcArgs(&iAudioOutputPkg), iPolicyRequest->iStatus);
	iPolicyRequest->SetActive();
		
	}

// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingManagerSession::CancelRequest
// Cancel a previously send request.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//	
EXPORT_C void RTelephonyAudioRoutingManagerSession::CancelRequest(TTelAudRtngServRqst aRequest)
	{
	TELAUDRTNG_RDEBUG(_L("[TELAUDRTNG]\t RTelephonyAudioRoutingManagerSession::CancelRequest "));	
	TPckgBuf<TInt> request;
   	request() = aRequest;
	SendReceive(ETelAudRtngServCancelRequest, TIpcArgs(&request));
	}

// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingSession::AudioOutputPkg
// Accessor method returns iAudioOutputPkg to caller.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//	
EXPORT_C TPckgBuf<CTelephonyAudioRouting::TAudioOutput>& RTelephonyAudioRoutingManagerSession::AudioOutputPkg()
	{
		return iAudioOutputPkg;
	}

// -----------------------------------------------------------------------------
// RTelephonyAudioRoutingManagerSession::StartPolicyRequestHandlersL
// Start asynchronous request handlers.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void RTelephonyAudioRoutingManagerSession::StartPolicyRequestHandlersL( 
	CTelephonyAudioRoutingManager& aAudioRoutingManager, 
	MTelephonyAudioRoutingPolicyObserver& aPolicyObserver )
	{
		iPolicyRequest = CTelephonyAudioRoutingPolicyRequest::NewL(*this, aPolicyObserver, aAudioRoutingManager, ETelAudRtngServMonitorOutputChange);
	}