/*
* 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: 
*
*/
#include "btdelegatedisconnect.h"
#include "btuiutil.h"
#include "btuiiconutil.h"
#include <QModelIndex>
#include <hblabel.h>
#include <btsettingmodel.h>
#include <btdevicemodel.h>
#include <hbnotificationdialog.h>

BtDelegateDisconnect::BtDelegateDisconnect(            
        BtSettingModel* settingModel, 
        BtDeviceModel* deviceModel, QObject *parent) :
    BtAbstractDelegate(settingModel, deviceModel, parent), mBtengConnMan(0), mPhyLinks(0),
	 mMajorRole(0), mActiveHandling(false), mAddrArrayIndex(0), mDisconOpt(DisconUnknown)
{
    
}

BtDelegateDisconnect::~BtDelegateDisconnect()
{
    delete mBtengConnMan;
    delete mPhyLinks;
    mSocketServ.Close();
}

void BtDelegateDisconnect::exec( const QVariant &params )
{
    int err;
    if ( ! mBtengConnMan ){
        TRAP( err, mBtengConnMan = CBTEngConnMan::NewL(this) );
    }
    if(err) {
        emit commandCompleted(err);
        return;
    }
    if (params.canConvert<int>()){
        mDisconOpt = (DisconnectOption)params.toInt();
        mActiveHandling = true;
        
        if (mDisconOpt == AllOngoingConnections){
            err = mBtengConnMan->GetConnectedAddresses(mDevAddrArray);
            disconnectAllConnections_service();
        }
        if(err) {
            emit commandCompleted(err);
        }
    }
    else{
        QList<QVariant> paramList = params.value< QList<QVariant> >(); 
        QVariant indexVariant = paramList.at(0); 
        QModelIndex index = indexVariant.value<QModelIndex>();
        QVariant optionVariant = paramList.at(1); 
        mDisconOpt = (DisconnectOption)optionVariant.toInt();
        int error = KErrNone;
        
        mActiveHandling = true;
        mDeviceName = getDeviceModel()->data(index,BtDeviceModel::NameAliasRole).toString();
        mMajorRole = (index.data(BtDeviceModel::MajorPropertyRole)).toInt();
        
        QString strBtAddr = getDeviceModel()->data(index,BtDeviceModel::ReadableBdaddrRole).toString();
        
        // todo: address converting should be simplified. check other delegates for example.
        
        TPtrC ptrName(reinterpret_cast<const TText*>(strBtAddr.constData()));
            
        RBuf16 btName;
        error = btName.Create(ptrName.Length());
        
        if(error == KErrNone) {
            btName.Copy(ptrName);
            mBtEngAddr.SetReadable(btName);
            if (mDisconOpt == ServiceLevel){
                disconnectSeviceLevel();
            }
            else if (mDisconOpt == PhysicalLink){
                disconnectPhysicalLink();       
            }
        }
        btName.Close();
        
        if(error) {
            emit commandCompleted(error);
        }
    }  
}


void BtDelegateDisconnect::disconnectAllConnections_service(){
    
        TBuf<KBTDevAddrSize*3> addrBuf;
        mDevAddrArray[mAddrArrayIndex].GetReadable(addrBuf);
        QString btStringAddr= QString::fromUtf16( addrBuf.Ptr(), addrBuf.Length());
        QModelIndex start = getDeviceModel()->index(0,0);
        QModelIndexList indexList = getDeviceModel()->match(start,BtDeviceModel::ReadableBdaddrRole, btStringAddr);
        QModelIndex index = indexList.at(0);
        
        mDeviceName = getDeviceModel()->data(index,BtDeviceModel::NameAliasRole).toString();
        mBtEngAddr = mDevAddrArray[mAddrArrayIndex];
        mMajorRole = (index.data(BtDeviceModel::MajorPropertyRole)).toInt();
        
        disconnectSeviceLevel();        
}

void BtDelegateDisconnect::disconnectAllConnections_physical(){
    
        TBuf<KBTDevAddrSize*3> addrBuf;
        mDevAddrArray[mAddrArrayIndex].GetReadable(addrBuf);
        QString btStringAddr= QString::fromUtf16( addrBuf.Ptr(), addrBuf.Length());
        QModelIndex start = getDeviceModel()->index(0,0);
        QModelIndexList indexList = getDeviceModel()->match(start,BtDeviceModel::ReadableBdaddrRole, btStringAddr);
        QModelIndex index = indexList.at(0);
        
        mDeviceName = getDeviceModel()->data(index,BtDeviceModel::NameAliasRole).toString();
        mBtEngAddr = mDevAddrArray[mAddrArrayIndex];
        
        disconnectPhysicalLink();
        
}
void BtDelegateDisconnect::disconnectSeviceLevel(){
    int err;
    TBTEngConnectionStatus connStatus = EBTEngNotConnected;
    err = mBtengConnMan->IsConnected(mBtEngAddr, connStatus);
    if (connStatus == EBTEngConnected){
        err = mBtengConnMan->Disconnect(mBtEngAddr, EBTDiscGraceful);
    }
    if(err) {
        if (mDisconOpt == AllOngoingConnections){
            disconnectServiceLevelCompleted(err);
        }
        else{ 
            emit commandCompleted(err);
        }
    }
}
        
void BtDelegateDisconnect::disconnectPhysicalLink(){
    int err;
    if ( !mSocketServ.Handle() ) {
        err = mSocketServ.Connect();
    }
    if ( !err && !mPhyLinks ) {
        TRAP( err, 
            mPhyLinks = CBluetoothPhysicalLinks::NewL( *this, mSocketServ ) );
        Q_CHECK_PTR( mPhyLinks );
    }
    err = mPhyLinks->Disconnect( mBtEngAddr );
    if(err) {
        if (mDisconOpt == AllOngoingConnections){
            disconnectPhysicalLinkCompleted(err);
        }
        else{ 
            emit commandCompleted(err);
        }
    }
    
}

void BtDelegateDisconnect::disconnectServiceLevelCompleted(int err){
    if (mDisconOpt == ServiceLevel){
        mActiveHandling = false;
        emit commandCompleted(err);
    }
    else if (mDisconOpt == AllOngoingConnections){
        if (err){
            mActiveHandling = false;
            emit commandCompleted(err);
        }
        else{
            mAddrArrayIndex++;
            if ( mAddrArrayIndex < mDevAddrArray.Count()){
                disconnectAllConnections_service();
            }
            else{
                mDevAddrArray.Reset();
                err = mBtengConnMan->GetConnectedAddresses(mDevAddrArray);
                if(err) {
                    emit commandCompleted(err);
                    return;
                }
                mAddrArrayIndex = 0;
                //connect( mDisconnectDelegate, SIGNAL(commandCompleted(int)), this, SLOT(disconnectPhysicalLinkCompleted(int)) );         
                disconnectAllConnections_physical();
            }
        }
    }
}

void BtDelegateDisconnect::disconnectPhysicalLinkCompleted(int err){
    if (mDisconOpt == PhysicalLink){
        //emitCommandComplete(err);
        mActiveHandling = false;
        emit commandCompleted(err);
    }
    else if (mDisconOpt == AllOngoingConnections){
        if (err){
            mActiveHandling = false;
            emit commandCompleted(err);
        }
        else{
            mAddrArrayIndex++;
            if ( mAddrArrayIndex < mDevAddrArray.Count()){
                disconnectAllConnections_physical();
            }
            else{
                //TODO: check if there is still ongoing connection from BTEngVonnMan. and close them again if there is any new 
                mActiveHandling = false;
                emit commandCompleted(err);
            }
        }
        
    }
    
}
void BtDelegateDisconnect::ConnectComplete( TBTDevAddr& aAddr, TInt aErr, 
                                   RBTDevAddrArray* aConflicts )
{
    Q_UNUSED(aAddr);
    Q_UNUSED(aConflicts);  
    Q_UNUSED(aErr);
}

void BtDelegateDisconnect::DisconnectComplete( TBTDevAddr& aAddr, TInt aErr )
{
    if ( mBtEngAddr != aAddr || !mActiveHandling ) {  
        return;
    }
    DisplayCommandCompleteNotif(aErr);
    disconnectServiceLevelCompleted(aErr);    
}


void BtDelegateDisconnect::cancel()
{
    
}

void BtDelegateDisconnect::HandleCreateConnectionCompleteL( TInt err ){
    Q_UNUSED( err );
}

void BtDelegateDisconnect::HandleDisconnectCompleteL( TInt err ){
    if ( !mActiveHandling ) {  
        return;
    } 
    disconnectPhysicalLinkCompleted(err);
          
}

void BtDelegateDisconnect::HandleDisconnectAllCompleteL( TInt err ){
    Q_UNUSED( err );
}

void BtDelegateDisconnect::DisplayCommandCompleteNotif(int error)
{
    
    if(error == KErrNone) {
        // success, show indicator with connection status
        HbIcon icon = getBadgedDeviceTypeIcon( mCod, mMajorRole, 0 );  // no badging required, only icon
        QString str( hbTrId("txt_bt_dpopinfo_disconnected_from_1") );
        HbNotificationDialog::launchDialog( icon, hbTrId("txt_bt_dpophead_disconnected"), 
            str.arg(mDeviceName) );  
    }
	
}