/*

* Copyright (c) 2005-2009 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:  File Transfer Profile Plug-in implementation

*

*/

// INCLUDE FILES

#ifdef SYMBIAN_ENABLE_SPLIT_HEADERS

#include <obexconstantsinternal.h>

#endif

#include "sconftpplugin.h"

#include "sconftp.h"

#include "sconftppluginutils.h"

#include "sconservicetimer.h"

#include "debug.h"

// CONSTANTS

_LIT(KSConFTPLibName, "sconftp.dll");

const TInt KSConFTPUidValue = 0x10009D8D;

const TUid KSConFTPUid = {KSConFTPUidValue};

// Folder listing type from IrObex specification

_LIT8( KSConFolderListType, "x-obex/folder-listing" );

_LIT( K_C_ROOT, "C:\\" );

const TInt KSConBufSize = 262144; // 256KB

// Time (in milliseconds) for the timer

const TInt KSConTimeOutValue =  60000000;

// Flags used to indicate SetPath commands

const TInt KSConNULLSetPath =   0x00;

const TInt KSConHeaderMaxLength = 256;

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

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

// CSConFTPplugin::NewL()

// Two-phase constructor

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

//

CSConFTPplugin* CSConFTPplugin::NewL()

    {

    TRACE_FUNC_ENTRY;

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

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    TRACE_FUNC_EXIT;

    return( self );

    }

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

// CSConFTPplugin::~CSConFTPplugin()

// Destructor

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

//

CSConFTPplugin::~CSConFTPplugin()

    {

    TRACE_FUNC_ENTRY;

    // Disconnect from services.

    Disconnect();

    if ( iFTPHandler )

        {

        delete iFTPHandler;

        iFTPHandler = NULL;

        iFTPlib.Close();

        }

    delete iBuffer;

    iBuffer = NULL;

    delete iObject;

    iObject = NULL;

    if ( iServiceTimer )

        {

        iServiceTimer->Cancel();

        }

    delete iServiceTimer;

    iServiceTimer = NULL;

    if ( iFileObject )

        {

        delete iFileObject;

        iFileObject = NULL;

        }

    delete iShutdownWatcher;

    iShutdownWatcher = NULL;

    TRACE_FUNC_EXIT;

    }

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

// CSConFTPplugin::IsOBEXActive()

// Returns active status of OBEX session

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

//

TBool CSConFTPplugin::IsOBEXActive()

    {

    TRACE_FUNC;

    return iSessionActive;

    }

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

// CSConFTPplugin::NotifyShutdown()

// System is shutting down

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

//

void CSConFTPplugin::NotifyShutdown()

    {

    TRACE_FUNC;

    iShutdownInProgress = ETrue;

    }

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

// CSConFTPplugin::LoadFTPDllL()

// Loads sconftp.dll module

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

//

void CSConFTPplugin::LoadFTPDllL()

    {

    TRACE_FUNC_ENTRY;

    // Dynamically load DLL

    User::LeaveIfError( iFTPlib.Load( KSConFTPLibName ) );

    if ( iFTPlib.Type()[1] != KSConFTPUid )

        {

        LOGGER_WRITE( "KSConFTPUidValue incorrect" );

        iFTPlib.Close();

        User::Leave( KErrNotFound );

        }

    TSConCreateCSConFTPFunc CreateCSConFTPL =

    (TSConCreateCSConFTPFunc)iFTPlib.Lookup(1);

    iFTPHandler = (CSConFTP*)CreateCSConFTPL();

    TRACE_FUNC_EXIT;

    }

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

// CSConFTPplugin::Disconnect()

// Closes initialized services

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

//

void CSConFTPplugin::Disconnect()

    {

    TRACE_FUNC_ENTRY;

    iLinkAdapter.Close();

    iSocketServer.Close();

    if ( iStartTimer != EFalse )

        {

        iServiceTimer->Cancel();

        iServiceTimer->StartTimer();

        }

    delete iObject;

    iObject = NULL;

    if ( iFileObject )

        {

        delete iFileObject;

        iFileObject = NULL;

        }

    if ( iFTPHandler )

        {

        delete iFTPHandler;

        iFTPHandler = NULL;

        iFTPlib.Close();

        }

    TRACE_FUNC_EXIT

    }

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

// CSConFTPplugin::ErrorIndication( TInt aError )

// MObexServerNotify implementation

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

//

void CSConFTPplugin::ErrorIndication( TInt aError )

    {

    TRACE_FUNC_ENTRY;

    LOGGER_WRITE_1( "aError : %d", aError );

    if ( iFTPHandler )

        {

        iFTPHandler->AbortFileTransfer( iObject );

        }

    if ( iObject )

        {

        delete iObject;

        iObject = NULL;

        }

    if ( iFileObject )

        {

        iFileObject->Reset();

        delete iFileObject;

        iFileObject = NULL;

        }

    // Keep compiler happy

    (void)aError;

    delete iShutdownWatcher;

    iShutdownWatcher = NULL;

	if ( iLinkAdapter.IsOpen() )

        {

        // Cancel ActivateActiveRequester & allow going to low power mode

        TInt err2 = iLinkAdapter.CancelLowPowerModeRequester();

        LOGGER_WRITE_1( "iLinkAdapter.CancelLowPowerModeRequester() err: %d", err2 );

        }

    TRACE_FUNC_EXIT;

    }

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

// CSConFTPplugin::AbortIndication()

// MObexServerNotify implementation

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

//

void CSConFTPplugin::AbortIndication()

    {

    TRACE_FUNC_ENTRY;

    if ( iFTPHandler )

        {

        iFTPHandler->AbortFileTransfer( iObject );

        }

    if ( iObject )

        {

        delete iObject;

        iObject = NULL;

        }

    if ( iFileObject )

        {

        iFileObject->Reset();

        delete iFileObject;

        iFileObject = NULL;

        }

    delete iShutdownWatcher;

    iShutdownWatcher = NULL;

    if ( iLinkAdapter.IsOpen() )

        {

        // Cancel ActivateActiveRequester & allow going to low power mode

        TInt err = iLinkAdapter.CancelLowPowerModeRequester();

        LOGGER_WRITE_1( "iLinkAdapter.CancelLowPowerModeRequester() err: %d", err );

        }

    TRACE_FUNC_EXIT;

    }

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

// CSConFTPplugin::TransportUpIndication()

// MObexServerNotify implementation

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

//

void CSConFTPplugin::TransportUpIndication()

    {

    TRACE_FUNC;

    }

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

// CSConFTPplugin::ObexConnectIndication( const TObexConnectInfo& aRemoteInfo,

// const TDesC8& aInfo )

// MObexServerNotify implementation

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

//

TInt CSConFTPplugin::ObexConnectIndication(

                        const TObexConnectInfo& /*aRemoteInfo*/,

                        const TDesC8& /*aInfo*/ )

    {

    TRACE_FUNC_ENTRY;

    TInt err( KErrNone );

    iStartTimer = ETrue;

    if ( iMediaType == ESrcsMediaBT && iObexServer )

        {

        TSockAddr remoteAddr;

        iObexServer->RemoteAddr( remoteAddr );

        TBTSockAddr btSockAddr( remoteAddr );

        TBTDevAddr devAddr = btSockAddr.BTAddr();

        err = iSocketServer.Connect();

        LOGGER_WRITE_1("iSocketServer.Connect err: %d", err );

        if ( !err )

            {

            err = iLinkAdapter.Open( iSocketServer, devAddr );

            LOGGER_WRITE_1("iLinkAdapter.Open err: %d", err );

            }

        // Ignore all BT link errors

        err = KErrNone;

        }

    if ( err == KErrNone && !iFTPHandler )

        {

        TRAP( err, LoadFTPDllL() );

        LOGGER_WRITE_1( "LoadFTPDllL returned : %d", err );

        }

    if ( err == KErrNone )

        {

        iFTPHandler->SetProfile( EStandard );

        LOGGER_WRITE( "CSConFTPplugin::ObexConnectIndication() : iServiceTimer->StopTimer()" );

        iServiceTimer->Cancel();

        iServiceTimer->StopTimer();

        }

    TRACE_FUNC_EXIT;

    LOGGER_WRITE_1( "CSConFTPplugin::ObexConnectIndication returned %d", err );

    return TFTPpluginUtils::ConvertFTPResponseCode( err );

    }

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

// CSConFTPplugin::ObexDisconnectIndication( const TDesC8& )

// MObexServerNotify implementation

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

//

void CSConFTPplugin::ObexDisconnectIndication( const TDesC8& )

    {

    TRACE_FUNC_ENTRY;

    Disconnect();

    TRACE_FUNC_EXIT;

    }

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

// CSConFTPplugin::TransportDownIndication()

// MObexServerNotify implementation

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

//

void CSConFTPplugin::TransportDownIndication()

    {

    TRACE_FUNC_ENTRY;

    Disconnect();

    if ( iBuffer )

        {

        iBuffer->Reset();

        }

    TRACE_FUNC_EXIT;

    }

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

// CSConFTPplugin::PutRequestIndication()

// MObexServerNotify implementation

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

//

CObexBufObject* CSConFTPplugin::PutRequestIndication()

    {

    TRACE_FUNC_ENTRY;

    TInt ret( KErrNone );

    TInt err( KErrNone );

    iPutError = KErrNone;

    if ( iBuffer )

        {

        iBuffer->Reset();

        }

    if ( iObject )

        {

        delete iObject;

        iObject = NULL;

        }

    TRAP( err, iObject = CObexBufObject::NewL ( iBuffer ) );

    if ( err != KErrNone )

        {

        return NULL;

        }

    if ( !iFTPHandler )

        {

        LOGGER_WRITE( "Creating iFTPHandler has failed" );

        return NULL;

        }

    TRAP( err, ret = iFTPHandler->PutFileObjectInitL( iObject, iBuffer ) );

    if ( err != KErrNone )

        {

        LOGGER_WRITE_1( "iFTPHandler->PutFileObjectInitL() leaves: %d", err );

        return NULL;

        }

    if ( ret != KErrNone )

        {

        LOGGER_WRITE_1( "PutFileObjectInitL failed - returning error in next PutPacketIndication : %d", ret );

        iPutError = ret;

        }

    iPutPacketIndicationCalled = EFalse;

    if ( !iShutdownWatcher )

        {

        TRAP( err, iShutdownWatcher = CShutdownWatcher::NewL( this ) );

        if ( err == KErrNone )

            {

            iShutdownWatcher->StartShutdownWatcher();

            }

        else

            {

            LOGGER_WRITE_1( "CShutdownWatcher::NewL leaves: %d", err );

            }

        }

    if ( iLinkAdapter.IsOpen() )

        {

        // request active BT mode (high power mode)

        err = iLinkAdapter.ActivateActiveRequester();

        LOGGER_WRITE_1( "iLinkAdapter.ActivateActiveRequester() err: %d", err );

        }

    TRACE_FUNC_EXIT;

    return( iObject );

    }

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

// CSConFTPplugin::PutPacketIndication()

// MObexServerNotify implementation

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

//

TInt CSConFTPplugin::PutPacketIndication()

    {

    TRACE_FUNC_ENTRY;

    TInt ret( KErrNone );

    // always normal file transfer

    if ( (TInt)iObject->Length() > 0 )

        {

        if ( !iPutPacketIndicationCalled )

            {

            // This is first check, need to check only once

            TFileName path;

            iFTPHandler->GetPath( path );

            if ( path.CompareF( K_C_ROOT ) == 0 )

                {

                // path forbidden

                ret = KErrAccessDenied;

                }

            else

                {

                if ( iPutError != KErrNone )

                    {

                    ret = iPutError;

                    LOGGER_WRITE_1( "CSConFTPplugin::PutPacketIndication() : PutError : %d", iPutError );

                    }

                else

                    {

                    // check required free space

                    // if filesize is small ( <65k ) it fits into one package and its already saved to filesystem.

                    // if file is larger, need to check is there enought free space in device.

                    const TUint32  filesize = iObject->Length();

                    LOGGER_WRITE_1( "CSConFTPplugin::PutPacketIndication() filesize %d", filesize );

                    LOGGER_WRITE_1( "CSConFTPplugin::PutPacketIndication() iObject->BytesReceived() %d", iObject->BytesReceived() );

                    if ( filesize > iObject->BytesReceived() )

                        {

                        LOGGER_WRITE( "CSConFTPplugin::PutPacketIndication() : check freespace" );

                        // file does not fit into one obex packet, check is there enought free space in current drive

                        if ( iFTPHandler->IsCurrentDiskSpaceBelowCritical( filesize ) )

                            {

    	                    LOGGER_WRITE( "CSConFTPplugin::PutPacketIndication() : returning KErrNoMemory" );

                            ret = KErrNoMemory;

                            }

                        }

                    }

                }

            }

        if ( iShutdownInProgress )

            {

            LOGGER_WRITE( "ShutdownInProgress, abort" );

            ret = KErrDisconnected;

            }

        }

    if ( !iPutPacketIndicationCalled )

        {

        // Need to check only once

        iPutPacketIndicationCalled = ETrue;

        //Check if filename is too long.

        TFileName path;

        iFTPHandler->GetPath( path );

        if ( ret == KErrNone && path.Length() + iObject->Name().Length() > KMaxFileName )

            {

            LOGGER_WRITE_1( "Name length overflow! : %d", path.Length() + iObject->Name().Length() );

            ret = KErrBadName;

            }

        }

    if ( ret != KErrNone )

        {

        if ( iFTPHandler )

            {

            iFTPHandler->AbortFileTransfer( iObject );

            }

        delete iObject;

        iObject = NULL;

        if ( iLinkAdapter.IsOpen() )

            {

            // Cancel ActivateActiveRequester & allow going to low power mode

            TInt err = iLinkAdapter.CancelLowPowerModeRequester();

            LOGGER_WRITE_1( "iLinkAdapter.CancelLowPowerModeRequester() err: %d", err );

            }