/*

* Copyright (c) 2004 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 <hbtextresolversymbian.h>

// CONSTANTS

const TInt    KBufferSize = 0x10000;  // 64 kB

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

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

_LIT(KLocFileName, "btdialogs_");

_LIT(KPath, "z:/resource/qt/translations/");  

// ================= 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);

    iDialog = CObexUtilsDialog::NewL(this);

    TBool ok = HbTextResolverSymbian::Init(KLocFileName, KPath);

    if (!ok) 

        {

        User::Leave( KErrNotFound );

        }

	} 

COPPController::~COPPController()

    {

    TRACE_FUNC

    delete iObexObject;

    delete iBuf;

    delete iLowMemoryActiveCDrive;

    delete iLowMemoryActiveMMC;

    delete iDevMan;

    if (iResultArray)

        {

        iResultArray->ResetAndDestroy();

        delete iResultArray;

        }

    iFs.Close();

    delete iDialog;

    delete iProgressDialog;

    delete iRecvDoneDialog;

    }

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

// 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 || iObexTransferState == ETransferPutDiskError )

        {        

        if(iObexObject)

            {

            iObexObject->Reset();

            }

        CancelTransfer();

        if(!aAbort)

        	{

			if(iMediaType == ESrcsMediaBT)

				{

                TRAP_IGNORE(

                        HBufC* note = HbTextResolverSymbian::LoadLC(_L("txt_bt_dpophead_receiving_failed"));

                        iDialog->ShowErrorNoteL(note->Des());

                        CleanupStack::PopAndDestroy(note);

                        );

				}

			TRACE_ASSERT(iMediaType != ESrcsMediaIrDA, KErrNotSupported)

        	}

        }

    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)

        {

        //Launch recevice completed dialog.

        iRecvDoneDialog = CHbDeviceDialogSymbian::NewL();

        iRecvDoneDialog->SetObserver(this);

        CHbSymbianVariantMap* variantMap = CHbSymbianVariantMap::NewL();

        CleanupStack::PushL(variantMap);

        TInt dialogIdx = TBluetoothDialogParams::EReceiveDone;

        CHbSymbianVariant* dialogType = CHbSymbianVariant::NewL( (TAny*) &(dialogIdx), 

                                                            CHbSymbianVariant::EInt );

        CleanupStack::PushL(dialogType);

        TBuf16<6> dialogTypeKey;

        dialogTypeKey.Num(TBluetoothDialogParams::EDialogType);

        User::LeaveIfError(variantMap->Add(dialogTypeKey, dialogType));

        CleanupStack::Pop(dialogType);

        CHbSymbianVariant* deviceName = CHbSymbianVariant::NewL( (TAny*) (&iRemoteDeviceName), 

                                                            CHbSymbianVariant::EDes );

        CleanupStack::PushL(deviceName);

        TBuf16<6> deviceNameKey;

        deviceNameKey.Num(TBluetoothDeviceDialog::EDeviceName);

        User::LeaveIfError(variantMap->Add(deviceNameKey, deviceName));

        CleanupStack::Pop(deviceName);

        CHbSymbianVariant* fileName = CHbSymbianVariant::NewL( (TAny*) (&iReceivingFileName), 

                                                            CHbSymbianVariant::EDes );

        CleanupStack::PushL(fileName);

        TBuf16<6> fileNameKey;

        fileNameKey.Num(TBluetoothDeviceDialog::EReceivingFileName);

        User::LeaveIfError(variantMap->Add(fileNameKey, fileName));

        CleanupStack::Pop(fileName);

        CHbSymbianVariant* fileSz = CHbSymbianVariant::NewL( (TAny*) &iTotalSizeByte, 

                                                            CHbSymbianVariant::EInt );

        CleanupStack::PushL(fileSz);

        TBuf16<6> fileSzKey;

        fileSzKey.Num(TBluetoothDeviceDialog::EReceivingFileSize);

        User::LeaveIfError(variantMap->Add(fileSzKey, fileSz));

        CleanupStack::Pop(fileSz);

        CHbSymbianVariant* fileCnt = CHbSymbianVariant::NewL( (TAny*) &iFileCount, 

                                                            CHbSymbianVariant::EInt );

        CleanupStack::PushL(fileCnt);

        TBuf16<6> fileCntKey;

        fileCntKey.Num(TBluetoothDeviceDialog::EReceivedFileCount);

        User::LeaveIfError(variantMap->Add(fileCntKey, fileCnt));

        CleanupStack::Pop(fileCnt);

        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)

            {

            //TRAP_IGNORE(TObexUtilsUiLayer::ShowGlobalConfirmationQueryL(R_OUT_OF_MEMORY));

            //todo: Need to use Localized string.

            _LIT(KText, "Not enough memory to execute operation. Delete some documents and try again.");

            TRAP_IGNORE(iDialog->ShowErrorNoteL(KText));

            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 ))

        {

        //TRAP_IGNORE(TObexUtilsUiLayer::ShowGlobalConfirmationQueryL(R_OUT_OF_MEMORY));

        //todo: Need to use Localized string.

        _LIT(KText, "Not enough memory to execute operation. Delete some documents and try again.");

        TRAP_IGNORE(iDialog->ShowErrorNoteL(KText));

        User::Leave(KErrGeneral);

        }

    TRACE_INFO( (_L( "[oppreceiveservice] HandlePutRequestL %d\t" ),iDrive ) );