/*
* Copyright (c) 2005-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:  Implementation of Query state.
*
*/


// INCLUDE FILES
#include <AccPolGenericIdDefinitions.h>     //device type definitions
#include "basrvaccstatequery.h"
#include "basrvaccstateconnect.h"
#include "basrvaccstatedisconnect.h"
#include "basrvaccstateattach.h"
#include "basrvaccstateattached.h"
#include "debug.h"

// ================= MEMBER FUNCTIONS =======================

CBasrvAccStateQuery* CBasrvAccStateQuery::NewL(CBasrvAcc& aParent, TBool aConnectingRequest)
    {
    CBasrvAccStateQuery* self=new(ELeave) CBasrvAccStateQuery(aParent, aConnectingRequest);
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self);
    return self;
    }

CBasrvAccStateQuery::~CBasrvAccStateQuery()
    {
    delete iQuery;
    TRACE_FUNC
    }

void CBasrvAccStateQuery::EnterL()
    {
    StatePrint(_L("Query"));
    // (NOT iConnecting) -> Headset connects to phone, SDP failure is tolerated. 
    iQuery->QueryAccInfoL(AccInfo().iAddr, !iConnecting);    
    Parent().RequestActiveMode();
    Parent().PreventLowPowerMode();
    }

CBasrvAccState* CBasrvAccStateQuery::ErrorOnEntry(TInt aReason)
    {
    TRACE_FUNC
    if (iConnecting)
        {
        TRAP_IGNORE(Parent().AccMan().ConnectCompletedL(AccInfo().iAddr, aReason, 0));
        }
    return NULL;
    }

TBTEngConnectionStatus CBasrvAccStateQuery::ConnectionStatus() const
    {
    return EBTEngConnecting;
    }

void CBasrvAccStateQuery::CancelConnect()
    {
    TRACE_FUNC
    if (iConnecting)
        {
        delete iQuery;
        iQuery = NULL;
        TRAP_IGNORE(Parent().ChangeStateL(NULL));
        }
    }

void CBasrvAccStateQuery::DisconnectL()
    {
    TRACE_FUNC
    delete iQuery;
    iQuery = NULL;
    if (AccInfo().iConnProfiles)
        {
        Parent().ChangeStateL(CBasrvAccStateDisconnect::NewL(Parent()));
        }
    else
        {
        Parent().ChangeStateL(NULL);
        }
    }
    
void CBasrvAccStateQuery::AccessoryDisconnectedL(TProfiles aProfile)
    {
    TRACE_FUNC
    ProfileDisconnected(aProfile);
    AccClosedAudio(aProfile);
    StatePrint(_L("Query"));
    if (!AccInfo().iConnProfiles && !iConnecting)
        {
        delete iQuery;
        iQuery = NULL;
        Parent().ChangeStateL(NULL);
        }
    }

void CBasrvAccStateQuery::GetAccInfoCompletedL(TInt aErr, const TAccInfo* aAcc, const TBTDeviceClass* aCod)
    {
    TRACE_FUNC
    CBasrvAccState* next = NULL;
    if ( ( aErr || !aAcc || !(aAcc->iSuppProfiles & EAnyAudioProfiles) ) &&
        ( iConnecting || !(AccInfo().iConnProfiles ) ))
        {
        TInt err = (aErr) ? aErr : KErrNotSupported;
        Parent().AccMan().ConnectCompletedL(AccInfo().iAddr, err, 0);
        Parent().ChangeStateL(next);
        return;
        }

    if (aAcc)
        {
        TInt exist_conns = AccInfo().iConnProfiles;
        TInt exist_audios = AccInfo().iAudioOpenedProfiles;
        AccInfo() = *aAcc;
        AccInfo().iAudioOpenedProfiles = exist_audios;
        AccInfo().iConnProfiles = exist_conns;
        AccInfo().iSuppProfiles |= exist_conns;
        }
    
    // Take HFP supported feature from BTMAC if it is not available
    if ( ( AccInfo().iConnProfiles & EHFP ) && 
         AccInfo().iSupportedFeatures[TAccInfo::EHFPIndex] == 0 )
        {
        CBTAccPlugin* plugin = Parent().AccMan().PluginMan().Plugin(EHFP);;
        AccInfo().SetSupportedFeature((TUint16)plugin->GetRemoteSupportedFeature(), TAccInfo::EHFPIndex);
        }
    
    // if e.g. A2DP is supported by headset but BTSAC is not in ROM, filter it.
    Parent().AccMan().FilterProfileSupport(AccInfo());

    RArray<TBTDevAddr> conflicts;
    CleanupClosePushL(conflicts);
    ResolveConflicts(conflicts);
    if (conflicts.Count())
        {
        if (iConnecting)
            {
            Parent().AccMan().ConnectCompletedL(AccInfo().iAddr, KErrAlreadyExists, 0, &conflicts);
            }
        if (AccInfo().iConnProfiles)
            {
            next = CBasrvAccStateDisconnect::NewL(Parent());
            }
        }
    else
        {
        // Guess if this is a carkit or headset using the CoD info
    	if (aCod && (aCod->MajorServiceClass() & EMajorServiceAudioService) &&
                    (aCod->MajorDeviceClass() & EMajorDeviceAudioDevice ))
        	{
            if (aCod->MinorDeviceClass() == EMinorDeviceAVHandsfree ||
                aCod->MinorDeviceClass() == EMinorDeviceAVCarAudio)
                {
                AccInfo().SetDeviceType(KDTCarKit);
                TRACE_INFO((_L("Device is a carkit.")));
                }
            else
                {
                AccInfo().SetDeviceType(KDTHeadset);
                TRACE_INFO((_L("Device is a headset.")));
                }
        	}
    	else
    		{
    		AccInfo().SetDeviceType(KDTHeadset);
            TRACE_INFO((_L("Device is a headset.")));
    		}
        
        if (iConnecting)
            {
            next = CBasrvAccStateConnect::NewL(Parent());
            }
        else if (AccInfo().iConnProfiles)
            {
            next = CBasrvAccStateAttach::NewL(Parent(), iConnecting);
            }
        }
    CleanupStack::PopAndDestroy(&conflicts);
    Parent().ChangeStateL(next);    
    }

CBasrvAccStateQuery::CBasrvAccStateQuery(CBasrvAcc& aParent, TBool aConnectingRequest)
    : CBasrvAccState(aParent), iConnecting(aConnectingRequest)
    {
    }

void CBasrvAccStateQuery::ConstructL()
    {
    iQuery = CBasrvSdpQuery::NewL(*this);    
    }
    
void CBasrvAccStateQuery::ResolveConflicts(RArray<TBTDevAddr>& aConflicts)
    {
    RPointerArray<const TAccInfo> infos;
    TInt err = Parent().AccMan().AccInfos(infos);
    
    if (err == KErrNone)
        {
        TInt supportedByThis = AccInfo().iSuppProfiles;
        
        // HFP and HSP are mutual exclusive, i.e. can only have one connected at a time.
        if (supportedByThis & EAnyMonoAudioProfiles)
            {
            supportedByThis |= EAnyMonoAudioProfiles;
            }
        
        for (TInt i = 0; i < infos.Count(); i++)
            {
            if ((infos[i]->iAddr != AccInfo().iAddr) &&
                (infos[i]->iSuppProfiles & supportedByThis))
                {
                aConflicts.Append(infos[i]->iAddr);
                }
            }
        
        infos.Close();
        }
    }