/*

* Copyright (c) 2004-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:  Implementation of CBtListenActive

*

*/

// INCLUDE FILES

#include    "oppcontroller.h"

#include    "btengdevman.h"

#include    <obexutilsmessagehandler.h>

#include    "debug.h"

#include    <bautils.h>

#include    <btengdomaincrkeys.h>

#include    <sysutil.h>

#include    <btengdomaincrkeys.h> 

#include    <msvids.h>

#include    <driveinfo.h>

#include    <es_sock.h>

#include    <bt_sock.h>

#include    <bluetoothdevicedialogs.h>

#include    "btconversationviewlauncher.h"

// CONSTANTS

const TInt    KBufferSize = 0x10000;  // 64 kB

const TInt KFileManagerUID3 = 0x101F84EB; /// File Manager application UID3

_LIT( KBTDevDialogId, "com.nokia.hb.btdevicedialog/1.0" );

const TInt KMaxDisplayFileName = 20;

const TInt KMinStringSize = 11;

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

COPPController* COPPController::NewL()

    {

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

	CleanupStack::PushL( self );

	self->ConstructL();

	CleanupStack::Pop( self );

	return self;

    }

COPPController::COPPController()

	{

    TRACE_FUNC

	}

void COPPController::ConstructL()	

	{

    TRACE_FUNC

    iObexTransferState = ETransferIdle;

    iLowMemoryActiveCDrive = CObexUtilsPropertyNotifier::NewL(this, ECheckPhoneMemory);

    iLowMemoryActiveMMC = CObexUtilsPropertyNotifier::NewL(this, ECheckMMCMemory);        

    iDevMan=CBTEngDevMan::NewL(this);  

    iResultArray = new (ELeave) CBTDeviceArray(1);

    // Get default folder from CenRep 

    TObexUtilsMessageHandler::GetCenRepKeyStringValueL(KCRUidBluetoothEngine, 

                                                       KLCReceiveFolder,

                                                       iCenRepFolder);

    iBtCnvViewLauncher = CBtConversationViewLauncher::NewL();

	} 

COPPController::~COPPController()

    {

    TRACE_FUNC

    delete iObexObject;

    delete iBuf;

    delete iLowMemoryActiveCDrive;

    delete iLowMemoryActiveMMC;

    delete iDevMan;

    if (iResultArray)

        {

        iResultArray->ResetAndDestroy();

        delete iResultArray;

        }

    iFs.Close();

    delete iProgressDialog;

    delete iFailureDialog;

    delete iRecvDoneDialog;

    delete iMemoryFullDailog;

    delete iBtCnvViewLauncher;

    }

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

// ErrorIndication()

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

//

void COPPController::ErrorIndication( TInt TRACE_ONLY(aError) )

    {

    TRACE_FUNC

    TRACE_ERROR((_L( "[oppreceiveservice] COPPController: ErrorIndication error:\t %d" ),aError));

    HandleError(EFalse); // false because not explicit abort

    }

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

// AbortIndication() 

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

//

void COPPController::AbortIndication()

	{

	TRACE_FUNC

	HandleError(ETrue); // true because explicit abort

	}

void COPPController::HandleError(TBool aAbort)

    {

    TRACE_ERROR((_L( "[oppreceiveservice] COPPController:HandleError" )));

    iReceivingFailed = ETrue;

    iShowRecvCompleteDialog = EFalse;

    if( iObexTransferState == ETransferPut || (!aAbort && iObexTransferState == ETransferPutDiskError) )

        {        

        CancelTransfer();

        if(iMediaType == ESrcsMediaBT)

            {

            TRAP_IGNORE(

                    LaunchFailureDialogL();

                    );

            }

        TRACE_ASSERT(iMediaType != ESrcsMediaIrDA, KErrNotSupported)

        if(iObexObject)

            {

            iObexObject->Reset();

            }

        }

    delete iBuf;

    iBuf = NULL;

    iObexTransferState = ETransferIdle;

    TRAP_IGNORE(TObexUtilsMessageHandler::RemoveInboxEntriesL(iObexObject, iMsvIdParent));

    TRAP_IGNORE(TObexUtilsMessageHandler::RemoveTemporaryRFileL (iFullPathFilename));

    }

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

// TransportUpIndication()

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

//

void COPPController::TransportUpIndication()

	{

	TRACE_FUNC    

	iReceivingFailed = EFalse;

    iObexTransferState = ETransferIdle;	

	if ( !iFs.Handle() )

	    {

	    TRACE_INFO( (_L( "[oppreceiveservice] TransportUpIndication iFs.Connect()" )) ); 

	    if ( iFs.Connect() )   // error value not preserved, iFs.Handle() checked one more time before first useage

	        {

	        TRACE_INFO( (_L( "[oppreceiveservice] TransportUpIndication iFs.Connect() failed" )) ); 

	        }

	    }

    iFile = RFile();

    iFullPathFilename.Zero();

	}

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

// ObexConnectIndication()

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

//

TInt COPPController::ObexConnectIndication( const TObexConnectInfo& aRemoteInfo,

                                            const TDesC8& aInfo)

    {

    TRACE_FUNC

    (void) aRemoteInfo;

    (void) aInfo;

    if ( iMediaType == ESrcsMediaBT )

        {

        TRACE_INFO( _L( "[oppreceiveservice] ObexConnectIndication: BT media \t" ) );

        // Get remote device socket address and bluetooth name

        // Remote bluetooth name will be displayed in the new message in inbox.

        //

        TSockAddr addr;

        iObexServer->RemoteAddr(addr);

        TBTDevAddr tBTDevAddr = static_cast<TBTSockAddr>(addr).BTAddr();

        TBTRegistrySearch nameSearch;

        nameSearch.FindAddress(tBTDevAddr);

        iResultArray->Reset();

        // ignore any errors here, if we don't get the name, we don't get the name

        static_cast<void>(iDevMan->GetDevices(nameSearch, iResultArray));

        }

    return KErrNone;

    }

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

// ObexDisconnectIndication(

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

//

void COPPController::ObexDisconnectIndication(const TDesC8& aInfo)

    {

    TRACE_FUNC

    (void) aInfo;

    }

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

// TransportDownIndication()

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

//

void COPPController::TransportDownIndication()

    {

    TRACE_FUNC

    if(!iReceivingFailed && iShowRecvCompleteDialog)

        {

        TFileName shortname;

        if ( iReceivingFileName.Length() > KMaxDisplayFileName ) 

            {

            // Filename is too long, 

            // We make it shorter. Hiding the chars in the middle part of filename. 

            shortname = iReceivingFileName.Mid(0,KMaxDisplayFileName/2);

            shortname.Append(_L("..."));

            shortname.Append(iReceivingFileName.Mid(iReceivingFileName.Length() - KMaxDisplayFileName/2, KMaxDisplayFileName/2));

            }

        else

            {

            shortname.Copy(iReceivingFileName);

            }

        //Launch recevice completed dialog.

        iRecvDoneDialog = CHbDeviceDialogSymbian::NewL();

        iRecvDoneDialog->SetObserver(this);

        CHbSymbianVariantMap* variantMap = CHbSymbianVariantMap::NewL();

        CleanupStack::PushL(variantMap);

        TInt dialogIdx = TBluetoothDialogParams::EReceiveDone;

        AddParamL(TBluetoothDialogParams::EDialogType, (TAny*) &dialogIdx,

                CHbSymbianVariant::EInt, *variantMap);

        AddParamL(TBluetoothDeviceDialog::EDeviceName, (TAny*) &iRemoteDeviceName,

                CHbSymbianVariant::EDes, *variantMap);

        AddParamL(TBluetoothDeviceDialog::EReceivingFileName, (TAny*) &shortname,

                CHbSymbianVariant::EDes, *variantMap);

        AddParamL(TBluetoothDeviceDialog::EReceivingFileSize, (TAny*) &iTotalSizeByte,

                CHbSymbianVariant::EInt, *variantMap);

        AddParamL(TBluetoothDeviceDialog::EReceivedFileCount, (TAny*) &iFileCount,

                CHbSymbianVariant::EInt, *variantMap);

        TBuf<KMinStringSize> key(_L("OpenCnvView"));

        TBool option = ETrue;

        CHbSymbianVariant* value = CHbSymbianVariant::NewL( (TAny*) &option, CHbSymbianVariant::EBool );

        CleanupStack::PushL(value);

        variantMap->Add(key, value);

        CleanupStack::Pop(value);

        iRecvDoneDialog->Show( KBTDevDialogId(), *variantMap, this );

        CleanupStack::PopAndDestroy(variantMap);

        iShowRecvCompleteDialog = EFalse;

        }

    // Remove receiving buffer and files used during file receiving.

    //

    delete iObexObject;

    iObexObject = NULL;

    TRAP_IGNORE(TObexUtilsMessageHandler::RemoveTemporaryRFileL (iFullPathFilename)); 

    iFs.Close();

    iFileCount = 0;

    }

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

// PutRequestIndication()

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

//

CObexBufObject* COPPController::PutRequestIndication()

    {

    TRACE_FUNC

    iLengthHeaderReceived = EFalse; // New put request so clear header based state

    iObexTransferState = ETransferPut;

    // Checking if backup is running now - if backup process is active, then we

    // need to cancel transfer - otherwise phone will freeze during receiving

    // data

    if ( IsBackupRunning() )

        {

        TRACE_INFO ( _L ("Backup in progress! Canceling incoming transfer."));

        iObexTransferState = ETransferPutInitError;

        return NULL;

        }

    TRAPD(err, HandlePutRequestL());

    if(err == KErrNone)

        {

        return iObexObject;

        }

    TRACE_INFO( _L( "[oppreceiveservice] COPPController: PutRequestIndication end\t" ) );

    if (iObexTransferState != ETransferPutInitError)

        {

        iObexTransferState = ETransferPutDiskError;

        }

    return NULL;

    }

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

// PutPacketIndication()    

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

//

TInt COPPController::PutPacketIndication()

    {

    TRACE_FUNC

    if(iObexTransferState == ETransferPutCancel)

        {

        // User cancelled the put request, so error the next packet to terminate the put request.

        // BIP considers the Unauthorized error response suitable for this...

        HandleError(ETrue); // reset state and clear up

        return KErrIrObexRespUnauthorized;

        }

    iTotalSizeByte = iObexObject->Length();     // get size of receiving file

    iReceivingFileName = iObexObject->Name();   // get name of receiving file

    // Check that capacity is suitable as soon as possible

    if(!iLengthHeaderReceived && iTotalSizeByte > 0)

        {

        iLengthHeaderReceived = ETrue; // total size value is from length header

        TBool capacity = ETrue;

        TRAPD(retTrap, capacity = CheckCapacityL());

        if(retTrap != KErrNone)

            {

            return KErrGeneral;

            }

        if(!capacity)

            {

            LaunchMemoryFullDialogL(iDrive);

            return KErrDiskFull;

            }

        }

    if(iObexObject->Name().Length() > KMaxFileName)

        {

        return KErrAccessDenied;

        }

    if(iObexTransferState == ETransferPutDiskError)

        {

        return KErrDiskFull;

        }

    // successfully received put packet if we reached here

    iObexTransferState = ETransferPut;

    // Now we need to either create (in the first instance) or update the dialog on the UI.

    if(ReceivingIndicatorActive())

        {

        TRAPD(err, UpdateReceivingIndicatorL());

        if(err < KErrNone)

            {

            return err;

            }

        }

    else if(!iNoteDisplayed)

        {

        // No note launched yet, so try to launch

        TRAPD(err, LaunchReceivingIndicatorL());

        iNoteDisplayed = (err == KErrNone);

        }

    return KErrNone;

    }

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

// PutCompleteIndication()

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

//

TInt COPPController::PutCompleteIndication()

    {

    TRACE_FUNC

    TInt retVal = KErrNone;

    if(iObexTransferState == ETransferPutCancel)

        {

        retVal = KErrIrObexRespUnauthorized;

        HandleError(ETrue);

        }

    else

        {

        retVal = HandlePutCompleteIndication();

        iObexTransferState = ETransferIdle;

        CloseReceivingIndicator();

        iFileCount++;

        iShowRecvCompleteDialog = ETrue;

        }

    TRACE_FUNC_EXIT

    return retVal;

    }

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

// GetRequestIndication()

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

//

CObexBufObject* COPPController::GetRequestIndication( CObexBaseObject* aRequiredObject)

    {

    TRACE_FUNC

    (void) aRequiredObject;

    return NULL;

    }

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

// GetPacketIndication()

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

//

TInt COPPController::GetPacketIndication()

    {

    TRACE_FUNC

    return KErrNone;

    }

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

// GetCompleteIndication()

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

//

TInt COPPController::GetCompleteIndication()

    {

    TRACE_FUNC

    return KErrNone;

    }

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

// SetPathIndication()

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

//

TInt COPPController::SetPathIndication( const CObex::TSetPathInfo& aPathInfo, 

                                        const TDesC8& aInfo)

    {

    TRACE_FUNC

    (void) aPathInfo;

    (void) aInfo;

    // SetPath is not implemented in OPP - so following IrOBEX guidance, return

    // the Forbidden response code.

    return KErrIrObexRespForbidden;

    }

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

// HandleNotifyL()

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

//

void COPPController::HandleNotifyL( TMemoryPropertyCheckType aCheckType )

    {    

    TRACE_FUNC        

    // Only interested on this notification if we are receiving something

    if ( iObexTransferState == ETransferPut )

        {

        // Check the keys, what has been changed.

        TRACE_INFO( _L( "[oppreceiveservice] COPPController::HandleNotifyL\t" ) );

        if ( aCheckType == ECheckPhoneMemory )

            {            

            if ( SysUtil::FFSSpaceBelowCriticalLevelL( NULL, 0 ) )

                {

                TRACE_INFO( _L( "[oppreceiveservice] COPPController: Obex Server error diskfull\t" ) );

                iObexTransferState = ETransferPutDiskError;                    

                }

            }

        else if ( aCheckType == ECheckMMCMemory )

            {                                

            if ( SysUtil::MMCSpaceBelowCriticalLevelL( NULL, 0 ) )

                {                        

                TRACE_INFO( _L( "[oppreceiveservice] COPPController: Obex Server error diskfull\t" ) );

                iObexTransferState = ETransferPutDiskError;

                }

            }            

        }        

    }

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

// HandlePutRequestL()

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

//

void COPPController::HandlePutRequestL()

    {

    TRACE_FUNC

    delete iObexObject;

    iObexObject = NULL;

    iFile = RFile();

    if ( !iFs.Handle() )

        {

        User::Leave(KErrGeneral);

        }

    // Assign an initial value to iDrive

    iDrive = GetDriveWithMaximumFreeSpaceL();    

    // If iDrive is at critical space level, we immediately show out_of_memory.

    //

    if (SysUtil::DiskSpaceBelowCriticalLevelL( &iFs, 0, iDrive ))

        {