/*
* Copyright (c) 2010 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 handles connect and disconnect to AccFw.
*
*/

#include <acccongenericid.h>
#include <accpolobjectcon.h>
#include <accpolnamevaluerecord.h>
#include <accconfigfileparser.h>
#include <accpolcommonnamevaluepairs.h>
#include <accessoryservicesinternalpskeys.h>
#include <autoaudiopskeys.h>

#include "cautoaudioasyservice.h"
#include "cautoaudioasypropertyobserver.h"
#include "acc_debug.h"

#define SET_STATE(state) (iState=state)
 
// ----------------------------------------------------------------------------------
// CAutoAudioAsyService::CAutoAudioAsyService() 
// ----------------------------------------------------------------------------------
CAutoAudioAsyService::CAutoAudioAsyService ()
	: CActive ( EPriorityStandard )
    {
    CActiveScheduler::Add ( this );
    }

// ----------------------------------------------------------------------------------
// CAutoAudioAsyService::NewL ()
// ----------------------------------------------------------------------------------
CAutoAudioAsyService* CAutoAudioAsyService::NewL ()
    {
    COM_TRACE_ ( "[AccFW:AutoAudioAsy] CAutoAudioAsyService::NewL" );
    CAutoAudioAsyService* self = new ( ELeave ) CAutoAudioAsyService ();
    CleanupStack::PushL ( self );
    self->ConstructL ();
    CleanupStack::Pop ( self );
    return self;
    }

// ----------------------------------------------------------------------------------
// CAutoAudioAsyService::ConstructL ()
// ----------------------------------------------------------------------------------
void CAutoAudioAsyService::ConstructL ()
    {
    COM_TRACE_ ( "[AccFW:AutoAudioAsy] CAutoAudioAsyService::ConstructL" );
    User::LeaveIfError ( iAccessoryServer.Connect () );
    User::LeaveIfError ( iAccessoryControl.CreateSubSession ( iAccessoryServer ) );
    SET_STATE ( EServiceStateIdle );	
    }

// ----------------------------------------------------------------------------------
// CAutoAudioAsyService::~CAutoAudioAsyService()
// ----------------------------------------------------------------------------------
CAutoAudioAsyService::~CAutoAudioAsyService ()
    {
    COM_TRACE_ ( "[AccFW:AutoAudioAsy] CAutoAudioAsyService::~CAutoAudioAsyService" );
    Cancel ();
	
	delete iPropertyObserver;
    iAccessoryControl.CloseSubSession ();
    iAccessoryServer.Close ();
    
	FreeResources ();
    }
	
void CAutoAudioAsyService::StartL ()
	{
    COM_TRACE_ ( "[AccFW:AutoAudioAsy] CAutoAudioAsyService::StartL" );
	iPropertyObserver = CAutoAudioAsyPropertyObserver::NewL ( KPSUidAccessoryServices, KPSAutoKeyRTPStreamingConnectionStatus, *this );
	}

// ----------------------------------------------------------------------------------
// CAutoAudioAsyService::PropertyChange ()
// Defined in MAutoAudioAsyPropertyListener interface.
// Receives notifications about RTP Streaming channel property changes. Property changes occur
// when accessory is connected or disconnected or headunit attached or detached
// ----------------------------------------------------------------------------------
void CAutoAudioAsyService::PropertyChange ( RProperty& aProperty, TUid aUid, TUint aKey, TInt aStatus )
    {
    COM_TRACE_ ( "[AccFW:AutoAudioAsy] CAutoAudioAsyService::PropertyChange" );

    TInt propValue;
    TInt status = aProperty.Get ( propValue );
    COM_TRACE_1 ( "[AccFW:AutoAudioAsy] CAutoAudioAsyService::PropertyChange -- request property value %d", propValue );
    
    if ( aUid == KPSUidAccessoryServices && aKey == KPSAutoKeyRTPStreamingConnectionStatus )
        {
        // Check if audio accessory has been connected
        if ( ( status == KErrNone ) && ( aStatus == KErrNone ) )
            {
			if ( propValue == EAudioConnectionStatusUnidirectional ) // Current release supports only UniDirectional, so other key values ignored.
				{
				TInt err;
				switch ( iState )
					{
					case EServiceStateIdle:
						TRAP ( err, ConnectAccessoryL () );
						if ( err != KErrNone )
							{
							COM_TRACE_1 ("[AccFW:AutoAudioAsy] ConnectAccessoryL error %d", err );
							FreeResources (); // switch to EServiceStateIdle							
							}
						break;
						
					case EServiceStateConnecting:
					case EServiceStateConnected:
						// Nothing to do
						break;
					}
				return;
				}
            }
			
        // Otherwise assume that it's disconnected
        AccessoryDisconnected ();
        }
    }

// ----------------------------------------------------------------------------------
// CAutoAudioAsyService::AccessoryDisconnected ()
// Called when a disconnect notification is received
// ----------------------------------------------------------------------------------
void CAutoAudioAsyService::AccessoryDisconnected ()
    {
    COM_TRACE_ ( "[AccFW:AutoAudioAsy] CAutoAudioAsyService::AccessoryDisconnected" );
    TRequestStatus status;
    switch ( iState )
        {
        case EServiceStateConnected:
            iAccessoryControl.DisconnectAccessory ( status, iGenericId->GenericID () );
            User::WaitForRequest ( status );
            FreeResources (); // sets state to EServiceStateIdle
            break;

        case EServiceStateConnecting:
            Cancel ();
            break;

        default:
            // nothing to do in this case
            break;
        }
    }

// ----------------------------------------------------------------------------------
// CAutoAudioAsyService::ConnectAccessoryL ()
// Notifies the accessory server and switches to EServiceStateConnecting state.
// ----------------------------------------------------------------------------------
void CAutoAudioAsyService::ConnectAccessoryL ()
    {
    COM_TRACE_ ( "[AccFW:AutoAudioAsy] CAutoAudioAsyService::ConnectAccessoryL" );

    RArray<TAccPolNameValueRecord> nameValueArray;
    CleanupClosePushL ( nameValueArray );

    // Set GenericID header
    COM_TRACE_ ( "[AccFW:AutoAudioAsy] Set generic header" );
    iGenericIDHeader.iAccessoryDeviceType   = KDTCarKit;
    iGenericIDHeader.iPhysicalConnection    = KPCUSB;
    iGenericIDHeader.iApplicationProtocol   = 0x0;
    iGenericIDHeader.iCapabilitiesSubblocks = KSBAudioSubblock;
    iGenericIDHeader.iHWDeviceID            = 0x0;
    iGenericIDHeader.iHWModelID				= KNullDesC;

    iGenericId = CAccConGenericID::NewL ();

    COM_TRACE_ ( "[AccFW:AutoAudioAsy] Set capabilities" );
    
    // Set "Audio Output Type" capability
	COM_TRACE_ ( "[AccFW:AutoAudioAsy] KAccAudioOutputType " );
    nameValueArray.AppendL ( TAccPolNameValueRecord ( KAccAudioOutputType,
        EAccAudioOutPutTypePublic, EAPVInt, EAPVPolicy ) );

    // Set "Audio stereo" capability
	COM_TRACE_ ( "[AccFW:AutoAudioAsy] KAccStereoAudio " );
	nameValueArray.AppendL ( TAccPolNameValueRecord ( KAccStereoAudio ) );

    // Set "Integrated audio output"
	COM_TRACE_ ( "[AccFW:AutoAudioAsy] KAccIntegratedAudioOutput " );
	nameValueArray.AppendL ( TAccPolNameValueRecord ( KAccIntegratedAudioOutput ) );

	// Set "RTP streaming"
	COM_TRACE_ ( "[AccFW:AutoAudioAsy] KAccRTPStreaming " );
	nameValueArray.AppendL ( TAccPolNameValueRecord ( KAccRTPStreaming ) );

    // Make generic id
    CAccConfigFileParser* accConfigFileParser = CAccConfigFileParser::NewL ( KNullDesC );
    CleanupStack::PushL ( accConfigFileParser );
    accConfigFileParser->ParseGenericIDL ( iGenericId, iGenericIDHeader, nameValueArray );

    // Connect accessory
    COM_TRACE_ ( "[AccFW:AutoAudioAsy] Connecting accessory..." );
    iAccessoryControl.ConnectAccessory ( iStatus, iGenericId, EFalse );
    SET_STATE ( EServiceStateConnecting );
    SetActive ();

    CleanupStack::PopAndDestroy ( accConfigFileParser );
    CleanupStack::PopAndDestroy ( &nameValueArray );
    }    

// ----------------------------------------------------------------------------------
// CActive methods
// ----------------------------------------------------------------------------------
void CAutoAudioAsyService::DoCancel ()
    {
    COM_TRACE_ ( "[AccFW:AutoAudioAsy] CAutoAudioAsyService::DoCancel" );
    iAccessoryControl.CancelConnectAccessory ();
    FreeResources ();
    }

TInt CAutoAudioAsyService::RunError ( TInt /*aError*/ )
    {
    COM_TRACE_ ( "[AccFW:AutoAudioAsy] CAutoAudioAsyService::RunError" );
    return KErrNone;
    }

void CAutoAudioAsyService::RunL ()
    {
    COM_TRACE_ ( "[AccFW:AutoAudioAsy] CAutoAudioAsyService::RunL" );
	TInt retVal ( iStatus.Int () );
	COM_TRACE_1 ( "[AccFW:AutoAudioAsy] Connected with return value %d", retVal );
	
    if ( KErrNone == retVal )
		{
			switch ( iState )
			{
			case EServiceStateConnecting:				
				SET_STATE ( EServiceStateConnected );
				break;
			
			case EServiceStateIdle:
			case EServiceStateConnected:
			default:
				COM_TRACE_ ( "State machine broken" );
				break;
			}
		}
	else
		{
		COM_TRACE_ ( "[AccFW:AutoAudioAsy] Accessory Server failed to accept connection, freeing up resources" );		
		FreeResources ();
		}
	}	
	
// ----------------------------------------------------------------------------------
// Frees resources and set state to EServiceStateIdle
// ----------------------------------------------------------------------------------
void CAutoAudioAsyService::FreeResources ()
    {
    COM_TRACE_ ( "[AccFW:AutoAudioAsy] CAutoAudioAsyService::FreeResources" );

    if ( iState != EServiceStateIdle )
        {
        SET_STATE ( EServiceStateIdle );
        }

    delete iGenericId;
    iGenericId = NULL;
    }