/*

* Copyright (c) 2002 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:  SyncML Obex client

*

*/

#include "NSmlBTServiceSearcher.h"

//============================================================

// CNSmlBTServiceSearcher definition

//============================================================

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

// CNSmlBTServiceSearcher::CNSmlBTServiceSearcher()

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

CNSmlBTServiceSearcher::CNSmlBTServiceSearcher( const TBTConnInfo& aBTConnInfo )

:  iIsDeviceSelectorConnected(EFalse),

   iBTConnInfo( aBTConnInfo )

    {

	iResponse().SetDeviceAddress( aBTConnInfo.iDevAddr );

    }

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

// CNSmlBTServiceSearcher::~CNSmlBTServiceSearcher()

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

CNSmlBTServiceSearcher::~CNSmlBTServiceSearcher()

    {

    if( iIsDeviceSelectorConnected )

        {

        iDeviceSelector.CancelNotifier( KDeviceSelectionNotifierUid );

        iDeviceSelector.Close();

        }

	Finished();

    delete iSdpSearchPattern;

    iSdpSearchPattern = NULL;

    delete iAgent;

    iAgent = NULL;

    }

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

// CNSmlBTServiceSearcher::SelectDeviceByDiscoveryL( TRequestStatus& aObserverRequestStatus )

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

void CNSmlBTServiceSearcher::SelectDeviceByDiscoveryL( TRequestStatus& aObserverRequestStatus )

    {

     if( !iIsDeviceSelectorConnected )

        {

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

        iIsDeviceSelectorConnected = ETrue;

        }

    //  Request a device selection 

	TBTDeviceClass deviceClass(0 ,0 ,0);

    TBTDeviceSelectionParams parameters;

    parameters.SetDeviceClass(deviceClass);

    TBTDeviceSelectionParamsPckg pckg(parameters);

	pckg().SetUUID( iBTConnInfo.iServiceClass );

    iDeviceSelector.StartNotifierAndGetResponse(

         aObserverRequestStatus, 

         KDeviceSelectionNotifierUid, 

         /*selectionFilter*/pckg, 

         iResponse);

    }

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

// CNSmlBTServiceSearcher::FindServiceL( TRequestStatus& aObserverRequestStatus )

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

void CNSmlBTServiceSearcher::FindServiceL( TRequestStatus& aObserverRequestStatus )

    {

    if( !iResponse().IsValidBDAddr() )

        {

        User::Leave( KErrNotFound );

        }

	iHasFoundService = EFalse;

	// delete any existing agent and search pattern

	delete iSdpSearchPattern;

	iSdpSearchPattern = NULL;

	delete iAgent;

	iAgent = NULL;

	iAgent = CSdpAgent::NewL( *this, BTDevAddr() );

	iSdpSearchPattern = CSdpSearchPattern::NewL();

	iSdpSearchPattern->AddL( iBTConnInfo.iServiceClass ); 

	iAgent->SetRecordFilterL( *iSdpSearchPattern );

	iStatusObserver = &aObserverRequestStatus;

	iAgent->NextRecordRequestL();

	}

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

// CNSmlBTServiceSearcher::NextRecordRequestComplete( TInt aError, TSdpServRecordHandle aHandle, TInt aTotalRecordsCount )

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

void CNSmlBTServiceSearcher::NextRecordRequestComplete( TInt aError, TSdpServRecordHandle aHandle, TInt aTotalRecordsCount )

    {

    TRAPD( error, NextRecordRequestCompleteL( aError, aHandle, aTotalRecordsCount) );

    if ( error != KErrNone ) 

        {

        Panic( EBTServiceSearcherNextRecordRequestComplete );

        }

    }

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

// CNSmlBTServiceSearcher::NextRecordRequestCompleteL( TInt aError, TSdpServRecordHandle aHandle, TInt aTotalRecordsCount )

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

void CNSmlBTServiceSearcher::NextRecordRequestCompleteL( TInt aError, TSdpServRecordHandle aHandle, TInt aTotalRecordsCount )

    {

    if ( aError == KErrEof )

        {

        Finished();

        return;

        }

    if ( aError != KErrNone )

        {

        Finished( aError );

        return;

        }

    if ( aTotalRecordsCount == 0 )

        {

        Finished( KErrNotFound );

        return;

        }

    //  Request its attributes

    iAgent->AttributeRequestL( aHandle, KSdpAttrIdProtocolDescriptorList );

    }

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

// CNSmlBTServiceSearcher::AttributeRequestResult()

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

void CNSmlBTServiceSearcher::AttributeRequestResult(

    TSdpServRecordHandle aHandle, 

    TSdpAttributeID aAttrID, 

    CSdpAttrValue* aAttrValue)

    {

    TRAPD( error, AttributeRequestResultL( aHandle, aAttrID, aAttrValue ) );

    //deleted because ownership has been transferred    

    delete aAttrValue;

    aAttrValue = NULL;

    if( error != KErrNone )

        {

        Panic(EBTServiceSearcherAttributeRequestResult);

        }

    }

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

// CNSmlBTServiceSearcher::AttributeRequestResultL()

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

void CNSmlBTServiceSearcher::AttributeRequestResultL(

    TSdpServRecordHandle /*aHandle*/, 

    TSdpAttributeID aAttrID, 

    CSdpAttrValue* aAttrValue)

    {

    ASSERT( aAttrID == KSdpAttrIdProtocolDescriptorList );

    TSdpAttributeParser parser( ProtocolList(), *this );

    // Validate the attribute value, and extract the RFCOMM channel

    aAttrValue->AcceptVisitorL( parser );

    if ( parser.HasFinished() )

        {

        // Found a suitable record so change state

        iHasFoundService = ETrue;

        }

    }

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

// CNSmlBTServiceSearcher::AttributeRequestComplete()

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

void CNSmlBTServiceSearcher::AttributeRequestComplete(TSdpServRecordHandle aHandle, TInt aError)

    {

    TRAPD( error, AttributeRequestCompleteL( aHandle, aError ) );

    if( error != KErrNone )

        {

        Panic( EBTServiceSearcherAttributeRequestComplete );

        }

    }

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

// CNSmlBTServiceSearcher::AttributeRequestCompleteL()

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

void CNSmlBTServiceSearcher::AttributeRequestCompleteL(TSdpServRecordHandle /*aHandle*/, TInt aError)

    {

    if ( aError != KErrNone )

        {

        }

    else if( !HasFinishedSearching() )

        {

        // have not found a suitable record so request another

        iAgent->NextRecordRequestL();

        }

    else

        {

        Finished();

        }

    }

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

// CNSmlBTServiceSearcher::Finished()

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

void CNSmlBTServiceSearcher::Finished(TInt aError /* default = KErrNone */)

    {

    if( aError == KErrNone && !HasFoundService() )

        {

        aError = KErrNotFound;

        }

	if ( iStatusObserver )

		{

		if ( *iStatusObserver == KRequestPending )

			{

			User::RequestComplete( iStatusObserver, aError );

			}

		}

    }

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

// CNSmlBTServiceSearcher::HasFinishedSearching()

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

TBool CNSmlBTServiceSearcher::HasFinishedSearching() const

    {

    return EFalse;

    }

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

// CNSmlBTServiceSearcher::BTDevAddr()

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

const TBTDevAddr& CNSmlBTServiceSearcher::BTDevAddr()

    {

    return iResponse().BDAddr();

    }

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

// CNSmlBTServiceSearcher::ResponseParams()

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

const TBTDeviceResponseParams& CNSmlBTServiceSearcher::ResponseParams()

    {

    return iResponse();

    }

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

// CNSmlBTServiceSearcher::HasFoundService()

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

TBool CNSmlBTServiceSearcher::HasFoundService() const

    {

    return iHasFoundService;

    }