/*

* Copyright (c) 2008 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:  Observer of accessory connection.

*

*/

#include "fmradiovariant.hrh" // include first for variation

#include <AccessoryServer.h>

#include <AccessoryConnection.h>

#include <AccPolGenericIDArray.h>

#include "fmradioaccessoryconnection.h"

#include "fmradioheadseteventobserver.h"

#include "debug.h"

#ifdef __FMRADIO_ADVANCED_AUTO_RESUME // same flag can be used to determine correct mask

#include <internal/accpolpropgenericid.h>

const TUint KPhysicalConnectionBitmask = KPCNokiaAV | KPCWired;

#else 

const TUint KPhysicalConnectionBitmask = KPCWired;

#endif // __FMRADIO_ADVANCED_AUTO_RESUME

// ---------------------------------------------------------------------------

// CFMRadioAccessoryConnection::CFMRadioAccessoryConnection

// ---------------------------------------------------------------------------

//

CFMRadioAccessoryConnection::CFMRadioAccessoryConnection() :

    CActive(EPriorityStandard), iObserver ( NULL ),

        iWiredHeadsetConnected ( EFalse ), iAccessoryCount( 0 )

    {

    }

// ---------------------------------------------------------------------------

// CFMRadioAccessoryConnection::NewL

// ---------------------------------------------------------------------------

//

CFMRadioAccessoryConnection* CFMRadioAccessoryConnection::NewL()

    {

    CFMRadioAccessoryConnection* self = new (ELeave) CFMRadioAccessoryConnection();

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(); // self;

    return self;

    }

// ---------------------------------------------------------------------------

// CFMRadioAccessoryConnection::ConstructL

// ---------------------------------------------------------------------------

//

void CFMRadioAccessoryConnection::ConstructL()

    {

    FTRACE( FPrint(_L("CFMRadioAccessoryConnection::ConstructL() -- ENTER") ) )

    // Creates a new session and sub-session.

    User::LeaveIfError( iAccessoryServer.Connect() );

    User::LeaveIfError( iAccessoryConnection.CreateSubSession( iAccessoryServer ) );

    User::LeaveIfError( iAccessoryConnection.GetAccessoryConnectionStatus( iAccessoryArray ) );

    iWiredHeadsetConnected = WiredHeadsetInArrayL();

    iAccessoryCount = iAccessoryArray.Count();

    CActiveScheduler::Add(this); // Add to scheduler

    iAccessoryConnection.NotifyAccessoryConnectionStatusChanged( iStatus, iAccessoryArray );

    SetActive(); // Tell scheduler a request is active

    }

// ---------------------------------------------------------------------------

// CFMRadioAccessoryConnection::~CFMRadioAccessoryConnection

// ---------------------------------------------------------------------------

//

CFMRadioAccessoryConnection::~CFMRadioAccessoryConnection()

    {

    Cancel(); // Cancel any request, if outstanding

    iAccessoryConnection.CloseSubSession();

    iAccessoryServer.Close();

    }

// ---------------------------------------------------------------------------

// CFMRadioAccessoryConnection::DoCancel

// ---------------------------------------------------------------------------

//

void CFMRadioAccessoryConnection::DoCancel()

    {

    iAccessoryConnection.CancelNotifyAccessoryConnectionStatusChanged();

    }

// ---------------------------------------------------------------------------

// CFMRadioAccessoryConnection::WiredHeadsetInArrayL

// ---------------------------------------------------------------------------

//

TBool CFMRadioAccessoryConnection::WiredHeadsetInArrayL()

    {

    FTRACE(FPrint(_L("CFMRadioAccessoryConnection::WiredHeadsetInArray()-- ENTER")));

    TAccPolGenericID genId;

    TUint32 devCaps;

    TUint32 phyCaps;

    for ( TInt i = 0; i < iAccessoryArray.Count(); i++ )

        {

        genId = iAccessoryArray.GetGenericIDL( i );

        devCaps = genId.DeviceTypeCaps();

        phyCaps = genId.PhysicalConnectionCaps();

        FTRACE(FPrint(_L("CFMRadioAccessoryConnection::devCaps-- %u"), devCaps ));

        FTRACE(FPrint(_L("CFMRadioAccessoryConnection::phyCaps()-- %u"), phyCaps ));

        //we're explicitly interested about wired headset type, without extra caps masked in

        if ( devCaps == KDTHeadset && phyCaps == KPhysicalConnectionBitmask )

            {

            return ETrue;

            }

        }

    return EFalse;

    }

// ---------------------------------------------------------------------------

// CFMRadioAccessoryConnection::WiredHeadsetConnected

// ---------------------------------------------------------------------------

//

TBool CFMRadioAccessoryConnection::WiredHeadsetConnected()

    {

#ifdef __WINS__

    return ETrue;

#else

    return iWiredHeadsetConnected;

#endif

    }

// ---------------------------------------------------------------------------

// CFMRadioAccessoryConnection::WiredHeadsetFirstInArray

// ---------------------------------------------------------------------------

//

TBool CFMRadioAccessoryConnection::WiredHeadsetFirstInArrayL()

    {

    FTRACE(FPrint(_L("CFMRadioAccessoryConnection::WiredHeadsetFirstInArrayL()-- ENTER")));

    if ( iAccessoryArray.Count() > 0 )

        {

        TAccPolGenericID genId = iAccessoryArray.GetGenericIDL( 0 );

        TUint32 devCaps = genId.DeviceTypeCaps();

        TUint32 phyCaps = genId.PhysicalConnectionCaps();

        FTRACE(FPrint(_L("CFMRadioAccessoryConnection::devCaps-- %u"), devCaps ));

        FTRACE(FPrint(_L("CFMRadioAccessoryConnection::phyCaps-- %u"), phyCaps ));

        //we're explicitly interested about wired headset type, without extra caps masked in

        if ( devCaps == KDTHeadset && phyCaps == KPhysicalConnectionBitmask )

            {

            return ETrue;

            }

        }

    return EFalse;

    }

// ---------------------------------------------------------------------------

// CFMRadioAccessoryConnection::RunL

// ---------------------------------------------------------------------------

//

void CFMRadioAccessoryConnection::RunL()

    {

    FTRACE(FPrint(_L("CFMRadioAccessoryConnection::RunL()-- ENTER")));

    if ( iStatus == KErrNone )

        {

        if ( iAccessoryCount < iAccessoryArray.Count() )

            { //accessory has been added

            if ( WiredHeadsetFirstInArrayL() ) //and it is a wired headset

                {

                iWiredHeadsetConnected = ETrue;

                if ( iObserver )

                    {

                    iObserver->HeadsetAccessoryConnectedCallbackL();

                    }

                }

            }

        else

            { //accessory has been removed

            if ( !WiredHeadsetInArrayL() ) // and it is a wired headset

                {

                iWiredHeadsetConnected = EFalse;

                if ( iObserver )

                    {

                    iObserver->HeadsetAccessoryDisconnectedCallbackL();

                    }

                }

            }

        iAccessoryCount = iAccessoryArray.Count();

        }

    //reassign the notification request

    iAccessoryConnection.NotifyAccessoryConnectionStatusChanged( iStatus, iAccessoryArray );

    SetActive(); // Tell scheduler a request is active

    FTRACE(FPrint(_L("CFMRadioAccessoryConnection::RunL()-- EXIT")));

    }

// ---------------------------------------------------------------------------

// CFMRadioAccessoryConnection::SetObserver

// ---------------------------------------------------------------------------

//

void CFMRadioAccessoryConnection::SetObserver( MFMRadioHeadsetEventObserver* aObserver )

    {

    iObserver = aObserver;

    }

//end of file