/*

* Copyright (c) 2007-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:  Obex Server image receiver module implementation

*

*/

// INCLUDE FILES

#include    "BIPController.h"

#include    "BIPCapabilityHandler.h"

#include    "BIPImageHandler.h"

#include    <e32base.h>

#include    <obexutilsmessagehandler.h>

#include    <sysutil.h>

#include    <bautils.h>

#include    <driveinfo.h>                   

#include    <btengdomaincrkeys.h> 

#include    <e32math.h> 

#include    <es_sock.h>

#include    <bt_sock.h>

#include    <msvids.h>

#include    "debug.h"

#include    <bluetoothdevicedialogs.h>

#include    "btconversationviewlauncher.h"

// CONSTANTS

_LIT8(KBipCapabilityType, "x-bt/img-capabilities\0");

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

const TInt    KBufferSize = 0x10000;  // 64 kB

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

const TInt KMaxDisplayFileName = 20; 

const TInt KMinStringSize = 11;

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

CBIPController* CBIPController::NewL()

    {

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

	CleanupStack::PushL( self );

	self->ConstructL();

	CleanupStack::Pop(self); 

	return self;

    }

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

// CBIPController()

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

//

CBIPController::CBIPController()

    {

    }

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

// ConstructL()

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

//

void CBIPController::ConstructL()

    {

    TRACE_FUNC_ENTRY

    iBIPImageHandler = CBIPImageHandler::NewL();

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

    TRACE_FUNC_EXIT

    }

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

// ~CBIPController()

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

//

CBIPController::~CBIPController()

    {   

    TRACE_FUNC_ENTRY    

    delete iGetObject;    

    delete iBIPCapabilityHandler;    

    delete iBIPImageHandler;    

    delete iLowMemoryActiveCDrive;    

    delete iLowMemoryActiveMMC;    

    delete iBuf;

    delete iBTObject;

    delete iDevMan;

    if (iResultArray)

        {

        iResultArray->ResetAndDestroy();

        delete iResultArray;

        }

    iFs.Close();

    delete iProgressDialog;

    delete iFailureDialog;

    delete iRecvDoneDialog;

    delete iMemoryFullDailog;

    delete iBtCnvViewLauncher;

    TRACE_FUNC_EXIT    

    }

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

// ErrorIndication()

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

//

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

    {

    TRACE_FUNC_ENTRY

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

    HandleError(EFalse); // false because this is not an explicit abort

    TRACE_FUNC_EXIT

    }

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

// AbortIndication()

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

//

void CBIPController::AbortIndication()

    {

    TRACE_FUNC_ENTRY

    HandleError(ETrue); // true because this is an explicit abort

    TRACE_FUNC_EXIT

    }

void CBIPController::HandleError(TBool aAbort)

    {

    TRACE_FUNC_ENTRY

    iReceivingFailed = ETrue;

    iShowRecvCompleteDialog = EFalse;

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

        {

        CancelTransfer();

        TRAP_IGNORE( 

                    LaunchFailureDialogL();

                );

        if(iBTObject)

            {

            iBTObject->Reset();

            }

        } 

    delete iBuf;

    iBuf = NULL;

    iBTTransferState = ETransferIdle;

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

    TRAP_IGNORE(TObexUtilsMessageHandler::RemoveTemporaryRFileL(iFullPathFilename));

    TRACE_FUNC_EXIT

    }

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

// CancelTransfer()

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

//

void CBIPController::CancelTransfer()

    {

    TRACE_FUNC_ENTRY

    CloseReceivingIndicator();

    if(iBTTransferState == ETransferPut)

        {

        iBTTransferState = ETransferPutCancel;

        }

    else // go to idle for all other states

        {

        iBTTransferState = ETransferIdle;

        }

    }

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

// TransportUpIndication()

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

//

void CBIPController::TransportUpIndication()

    {

    TRACE_FUNC

    iReceivingFailed = EFalse;

    if (!iFs.Handle())

        {

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

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

            {

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

            }

        }

    iFile = RFile();

    iFullPathFilename.Zero();

    iCapabilityFileName.Zero();

    }

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

// ObexConnectIndication()

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

//

TInt CBIPController::ObexConnectIndication( const TObexConnectInfo& aRemoteInfo, const TDesC8& aInfo )

    {

    TRACE_FUNC

    (void) aRemoteInfo;

    (void) aInfo;

    // Get remote device socket address and bluetooth name

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

    //

    TSockAddr addr;

    iBTObexServer->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.

    // It is also possible that the name is received too late....

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

    return KErrNone;

    }

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

// ObexDisconnectIndication()

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

//

void CBIPController::ObexDisconnectIndication(const TDesC8& aInfo)

    {

    TRACE_FUNC

    (void) aInfo;

    }

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

// TransportDownIndication()

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

//

void CBIPController::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 iBTObject;

    iBTObject = NULL;

    TRAP_IGNORE(TObexUtilsMessageHandler::RemoveTemporaryRFileL (iFullPathFilename));  

    iFs.Close();

    iFileCount = 0;

    }

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

// PutRequestIndication()

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

//

CObexBufObject* CBIPController::PutRequestIndication()

    {   

    TRACE_FUNC_ENTRY

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

    iBTTransferState = 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."));

        iBTTransferState = ETransferPutInitError;

        return NULL;

        }

    TRAPD(err, HandlePutImageRequestL());

    if (err == KErrNone)

        {

        return iBTObject;

        }

    if (iBTTransferState != ETransferPutInitError)

        {

        iBTTransferState = ETransferPutDiskError;

        }

    TRACE_FUNC_EXIT

    return NULL;

    }

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

// PutPacketIndication() 

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

//

TInt CBIPController::PutPacketIndication()

    {

    TRACE_FUNC_ENTRY

    if(iBTTransferState == 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;

        }

    if (iBTObject)

        {

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

        iReceivingFileName = iBTObject->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));

                LaunchMemoryFullDialogL(iDrive);

                return KErrDiskFull;

                }

            }

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

            {

            return KErrAccessDenied;

            }

        if(iBTTransferState == ETransferPutDiskError)

            {

            return KErrDiskFull;

            }

        // successfully received put packet if we reached here

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

            }

        }

    TRACE_FUNC_EXIT

    return KErrNone;

    }

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

// PutCompleteIndication() 

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

//

TInt CBIPController::PutCompleteIndication()  // Once receive has completed.

    {

    TRACE_FUNC_ENTRY

    TInt retVal = KErrNone;

    if(iBTTransferState == ETransferPutCancel)

        {

        retVal = KErrIrObexRespUnauthorized;

        HandleError(ETrue);

        }

    else

        {

        retVal = HandlePutCompleteIndication();

        iBTTransferState = ETransferIdle;

        CloseReceivingIndicator();

        iFileCount++;

        iShowRecvCompleteDialog = ETrue;

        }

    TRACE_FUNC_EXIT

    return retVal;

    }

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

// GetRequestIndication()

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

//

CObexBufObject* CBIPController::GetRequestIndication( CObexBaseObject* aRequiredObject )

    {

    TRACE_FUNC_ENTRY

    iBTTransferState = ETransferGet;

    TInt err = RemoveCapabilityObject();

    if (err == KErrNone)

        {

        if( aRequiredObject->Type() == KBipCapabilityType )

            {

            TRAP( err, HandleGetCapabilityRequestL( ) );

            if( err == KErrNone )

                {

                return iGetObject;

                }

            }

        }

    TRACE_FUNC_EXIT

    return NULL;

    }

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

// GetPacketIndication()

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

//

TInt CBIPController::GetPacketIndication()

    {

    TRACE_FUNC_ENTRY

    return KErrNone;

    }

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

// GetCompleteIndication()

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

//

TInt CBIPController::GetCompleteIndication()

    {

    TRACE_FUNC_ENTRY

    delete iGetObject;

    iGetObject=NULL;

    TInt err = RemoveCapabilityObject();

    if (err != KErrNone)

        {

        err = KErrGeneral;

        }

    iBTTransferState = ETransferIdle;

    TRACE_FUNC_EXIT

    return err;

    }

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

// SetPathIndication()

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

//

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

                                        const TDesC8& aInfo)

    {

    TRACE_FUNC

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

    // the Forbidden response code.

    (void) aPathInfo;