/*
* Copyright (c) 2006-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:  CSensrvChannelFinderImpl implementation
*
*/


#include "sensrvchannelfinderimpl.h"
#include "sensrvchannelchangehandler.h"
#include "sensrvtrace.h"

const TInt KDefaultChannelCount = 10;


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


// ---------------------------------------------------------------------------
// C++ constructor
// ---------------------------------------------------------------------------
//
CSensrvChannelFinderImpl::CSensrvChannelFinderImpl()
    {
    COMPONENT_TRACE( ( _L( "Sensrv Client - CSensrvChannelFinderImpl::CSensrvChannelFinderImpl()" ) ) );
    }


// ---------------------------------------------------------------------------
// 2nd phase of construction
// ---------------------------------------------------------------------------
//
void CSensrvChannelFinderImpl::ConstructL()
    {
    COMPONENT_TRACE( ( _L( "Sensrv Client - CSensrvChannelFinderImpl::ConstructL() - Start" ) ) );

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

    iChannelChangeHandler = CSensrvChannelChangeHandler::NewL( iSensrvClient );
    
    COMPONENT_TRACE( ( _L( "Sensrv Client - CSensrvChannelFinderImpl::ConstructL() - Return" ) ) );
    }


// ---------------------------------------------------------------------------
// Destructor
// ---------------------------------------------------------------------------
//
CSensrvChannelFinderImpl::~CSensrvChannelFinderImpl()
    {
    delete iChannelChangeHandler;
    iSensrvClient.Close();    
    }


// ---------------------------------------------------------------------------
// CSensrvChannelFinderImpl::FindChannelsL
// ---------------------------------------------------------------------------
//
void CSensrvChannelFinderImpl::FindChannelsL(
                RSensrvChannelInfoList& aChannelList,
                const TSensrvChannelInfo& aSearchConditions )
    {
    COMPONENT_TRACE( ( _L( "Sensrv Client - CSensrvChannelFinderImpl::FindChannelsL() - Start" ) ) );

    // Create condition buffer
    TSensrvChannelInfoPckgBuf searchConditionsBuf( aSearchConditions );
    
    // Create channel info array
    RSensrvChannelInfoList channelInfoList(KDefaultChannelCount);
    CleanupClosePushL( channelInfoList );
    
    for( TInt i = 0; i < KDefaultChannelCount; i++ )
        {
        channelInfoList.AppendL( TSensrvChannelInfo() );
        }
        
    TInt arraySize = ( sizeof(TSensrvChannelInfo) ) * KDefaultChannelCount;
    TPtr8 arrayPtr( (TUint8*)&channelInfoList[0], arraySize, arraySize );
    
    TInt channelInfoCount(0);
    TSensrvTIntPckgBuf intBuf( channelInfoCount );
    
    
    COMPONENT_TRACE( ( _L( "Sensrv Client - CSensrvChannelFinderImpl::FindChannels() - SendReceive..." ) ) );
    TInt err = iSensrvClient.SendReceiveSync( ESensrvSrvReqQueryChannels, TIpcArgs( &searchConditionsBuf, 
                                                                  &arrayPtr, &intBuf ) );
    
    channelInfoCount = intBuf();
    
    if( err == KErrNone )  // Copy channels info to aChannelList
        {
        for( TInt i = 0; i < channelInfoCount; ++i )
            {
            aChannelList.AppendL( channelInfoList[i] );
            }
        }
                                                                  
    else if( err == KErrOverflow ) // buffer overflow. Allocate new buffer
        {
        COMPONENT_TRACE( ( _L( "Sensrv Client - CSensrvChannelFinderImpl::FindChannels() - KErrOverflow" ) ) );
        
        for( TInt i = KDefaultChannelCount; i < channelInfoCount; i++ )
            {
            channelInfoList.AppendL( TSensrvChannelInfo() );
            }
            
        TInt newArraySize = ( sizeof(TSensrvChannelInfo) ) * channelInfoCount;
        TPtr8 newArrayPtr( (TUint8*)&channelInfoList[0], newArraySize, newArraySize );
        
        // Send new request
        User::LeaveIfError( iSensrvClient.SendReceiveSync( ESensrvSrvReqQueryChannels, 
                                             TIpcArgs( &searchConditionsBuf, &newArrayPtr, &intBuf ) ) );
                                                                  
        channelInfoCount = intBuf();
        
        for( TInt i = 0; i < channelInfoCount; ++i )
            {
            aChannelList.AppendL( channelInfoList[i] );
            }

        }
    else 
        {
        User::Leave( err );
        }
        
    CleanupStack::PopAndDestroy( &channelInfoList );
    
    COMPONENT_TRACE( ( _L( "Sensrv Client - CSensrvChannelFinderImpl::FindChannels() - return" ) ) );  
    }

// ---------------------------------------------------------------------------
// CSensrvChannelFinderImpl::SetChannelListenerL
// ---------------------------------------------------------------------------
//
void CSensrvChannelFinderImpl::SetChannelListenerL( MSensrvChannelListener* aChannelListener,
                                                    const TSensrvChannelInfo& aSearchParameters )
    {
    COMPONENT_TRACE( ( _L( "Sensrv Client - CSensrvChannelFinderImpl::SetChannelListenerL() - Start" ) ) );

    if( iChannelChangeListener && aChannelListener )
        {
        ERROR_TRACE( ( _L( "Sensrv Client - CSensrvChannelFinderImpl::SetChannelListenerL() -  ERROR: Already listening: return KErrAlreadyExists" ) ) );
        User::Leave( KErrAlreadyExists );
        }
        
    iChannelChangeListener = aChannelListener;
    
    if( iChannelChangeListener )
        {
        iChannelChangeHandler->StartListening( this, aSearchParameters );
        }
    else
        {
        if( iChannelChangeHandler->IsActive() )
            {
            iChannelChangeHandler->Cancel();
            }
        else
            {
            TInt ignore = iSensrvClient.SendReceiveSync( ESensrvSrvReqStopChannelChangeListening, 
                                                         TIpcArgs() );
            }
        }
    
    COMPONENT_TRACE( ( _L( "Sensrv Client - CSensrvChannelFinderImpl::SetChannelListenerL() - Return" ) ) );
    }


// ---------------------------------------------------------------------------
// CSensrvChannelFinderImpl::ChannelChangeDetected
// ---------------------------------------------------------------------------
//
void CSensrvChannelFinderImpl::ChannelChangeDetected( const TSensrvChannelInfo& aDetectedChannel,
                                                      TSensrvChannelChangeType aChangeType  )
    {
    COMPONENT_TRACE( ( _L( "Sensrv Client - CSensrvChannelFinderImpl::ChannelChangeDetected()" ) ) );
    
    if( iChannelChangeListener )
        {
        iChannelChangeListener->ChannelChangeDetected( aDetectedChannel, aChangeType );
        }
        
    COMPONENT_TRACE( ( _L( "Sensrv Client - CSensrvChannelFinderImpl::ChannelChangeDetected - return" ) ) );
    }
    
// ---------------------------------------------------------------------------
// CSensrvChannelFinderImpl::ChannelDetectionError
// ---------------------------------------------------------------------------
//
void CSensrvChannelFinderImpl::ChannelDetectionError( TSensrvErrorSeverity aError )
    {
    COMPONENT_TRACE( ( _L( "Sensrv Client - CSensrvChannelFinderImpl::ChannelDetectionError()" ) ) );
    
    if( aError == ESensrvErrorSeverityFatal )
        {
        iSensrvClient.Close();
        }
        
    if( iChannelChangeListener )
        {
        iChannelChangeListener->ChannelDetectionError( *this, aError );
        }
        
    COMPONENT_TRACE( ( _L( "Sensrv Client - CSensrvChannelFinderImpl::ChannelDetectionError - return" ) ) );
    }