/*

* 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:  PC Connectivity Plug-in implementation

*

*/

// INCLUDE FILES

#ifdef SYMBIAN_ENABLE_SPLIT_HEADERS

#include <obexconstantsinternal.h>

#endif

#include "sconpcconnplugin.h"

#include "sconftp.h"

#include "sconpcconnpluginutils.h"

#include "sconservicetimer.h"

#include "catalogspcconnectivityplugin.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" );

// Folder listing type from IrObex specification

_LIT8( KSConCapabilityObjectType, "x-obex/capability" );

// PCD types

_LIT8( KSConPCDObjectType, "application/vnd.nokia.pcd" );

_LIT8( KSConPCDXMLObjectType, "application/vnd.nokia.conml+xml" );

_LIT8( KSConPCDWBXMLObjectType, "application/vnd.nokia.conml+wbxml" );

_LIT8( KSConPCDXMLObjectType2, "application/vnd.nokia.pcd+xml" );

_LIT8( KSConPCDWBXMLObjectType2, "application/vnd.nokia.pcd+wbxml" );

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

// PCD header commands

const TInt KSCon_PCD_TAG = 0x003A;

const TInt KSCon_PCD_CMD_COPY = 0x0037;

const TInt KSCon_PCD_CMD_MOVE_OR_RENAME = 0x0038;

const TInt KSCon_PCD_CMD_SET_PERMISSION = 0x0039;

// PCD header parameters

const TInt KSCon_PCD_PAR_FULL_PERMISSION = 0x0040;

const TInt KSCon_PCD_PAR_READ_ONLY_PERMISSION = 0x0041;

const TInt KSConBufSize = 262144; // 256KB

// Time (in milliseconds) for the timer

const TInt KSConTimeOutValue =  180000000;

// Flags used to indicate SetPath commands

const TInt KSConNULLSetPath =   0x00;

const TInt KSConHeaderMaxLength = 256;

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

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

// CSConPCConnplugin::NewL()

// Two-phase constructing

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

//

CSConPCConnplugin* CSConPCConnplugin::NewL()

    {

    TRACE_FUNC_ENTRY;

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

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    TRACE_FUNC_EXIT;

    return( self );

    }

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

// CSConPCConnplugin::~CSConPCConnplugin()

// Destructor

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

//

CSConPCConnplugin::~CSConPCConnplugin()

    {

    TRACE_FUNC_ENTRY;

    // Disconnect from services.

    Disconnect();

    delete iBuffer;

    iBuffer = NULL;

    if ( iServiceTimer )

        {

        iServiceTimer->Cancel();

        }

    delete iServiceTimer;

    iServiceTimer = NULL;

    delete iCatalogs;

    iCatalogs = NULL;

    delete iCatalogsMimeType;

    iCatalogsMimeType = NULL;

    iMimeArray.Reset();

    iMimeArray.Close();

    delete iShutdownWatcher;

    iShutdownWatcher = NULL;

    TRACE_FUNC_EXIT;

    }

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

// CSConPCConnplugin::IsOBEXActive()

// Returns active status of OBEX session

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

//

TBool CSConPCConnplugin::IsOBEXActive()

    {

    TRACE_FUNC;

    return iSessionActive;

    }

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

// CSConPCConnplugin::NotifyShutdown()

// System is shutting down

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

//

void CSConPCConnplugin::NotifyShutdown()

    {

    TRACE_FUNC;

    iShutdownInProgress = ETrue;

    }

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

// CSConPCConnplugin::LoadFTPDllL()

// Loads sconftp.dll module

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

//

void CSConPCConnplugin::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;

    }

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

// CSConPCConnplugin::Disconnect()

// Closes initialized services

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

//

void CSConPCConnplugin::Disconnect()

    {

    TRACE_FUNC_ENTRY;

    iLinkAdapter.Close();

    iSocketServer.Close();

    //Disconnect from server

    iPCConnSession.Close();

    iPCConnSessionConnected = EFalse;

    if ( iStartTimer != EFalse )

        {

        iServiceTimer->Cancel();

        iServiceTimer->StartTimer();

        }

    delete iObject;

    iObject = NULL;

    if ( iFTPHandler )

        {

        delete iFTPHandler;

        iFTPHandler = NULL;

        iFTPlib.Close();

        }

    if ( iFileObject )

        {

        delete iFileObject;

        iFileObject = NULL;

        }

    if ( iCatalogsConnected )

        {

        iCatalogs->Close();

        iCatalogsConnected = EFalse;

        iCatalogsMimeTypesExist = EFalse;

        }

    TRACE_FUNC_EXIT;

    }

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

// CSConPCConnplugin::ErrorIndication( TInt aError )

// MObexServerNotify implementation

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

//

void CSConPCConnplugin::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;

        }

    if ( iPCConnSessionConnected )

        {

        iPCConnSession.ResetServer();

        }

    // Keep compiler happy

    (void)aError;

    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;

    }

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

// CSConPCConnplugin::AbortIndication()

// MObexServerNotify implementation

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

//

void CSConPCConnplugin::AbortIndication()

    {

    TRACE_FUNC_ENTRY;

    if ( iFTPHandler )

        {

        iFTPHandler->AbortFileTransfer( iObject );

        }

    if ( iObject )

        {

        delete iObject;

        iObject = NULL;

        }

    if ( iFileObject )

        {

        iFileObject->Reset();

        delete iFileObject;

        iFileObject = NULL;

        }

    if ( iPCConnSessionConnected )

        {

        iPCConnSession.ResetServer();

        }

    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;

    }

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

// CSConPCConnplugin::TransportUpIndication()

// MObexServerNotify implementation

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

//

void CSConPCConnplugin::TransportUpIndication()

    {

    TRACE_FUNC;

    }

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

// CSConPCConnplugin::ObexConnectIndication( const TObexConnectInfo&

// aRemoteInfo, const TDesC8& aInfo )

// MObexServerNotify implementation

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

//

TInt CSConPCConnplugin::ObexConnectIndication( const TObexConnectInfo&

                                    /*aRemoteInfo*/, const TDesC8& /*aInfo*/ )

    {

    TRACE_FUNC_ENTRY;

    TInt err( KErrNone );

    TInt catalogsErr( 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;

        }

    //Connect to server

    if ( !iPCConnSessionConnected )

        {

        LOGGER_WRITE("Try to connect to iPCConnSession");

        err = iPCConnSession.Connect();

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

        if ( err == KErrNone )

            {

            iPCConnSessionConnected = ETrue;

            }

        }

    if ( err == KErrNone && !iFTPHandler )

        {

        TRAP( err, LoadFTPDllL() );

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

        }

    if ( err == KErrNone )

        {

        iFTPHandler->SetProfile( EProprietary );

        LOGGER_WRITE( "iServiceTimer->StopTimer()" );

        iServiceTimer->Cancel();

        iServiceTimer->StopTimer();

        }

    if ( !iCatalogsConnected )

        {

        LOGGER_WRITE( "CSConPCConnplugin::ObexConnectIndication() before iCatalogs->Connect()" );

        catalogsErr = iCatalogs->Connect();

        LOGGER_WRITE_1( "CSConPCConnplugin::ObexConnectIndication() iCatalogs->Connect() err: %d", catalogsErr );

        if ( catalogsErr == KErrNone )

            {

            LOGGER_WRITE( "CSConPCConnplugin::ObexConnectIndication() iCatalogs->Connect() success" );

            iCatalogsConnected = ETrue;

            TRAPD( ret, iMimeArray = iCatalogs->SupportedMimeTypesL() );

            if ( ret == KErrNone )

                {

                LOGGER_WRITE_1( "iCatalogs->SupportedMimeTypesL count: %d", iMimeArray.Count() );

                iCatalogsMimeTypesExist = ETrue;

                }

            }

        }

    TRACE_FUNC_EXIT;

    return TPCConnpluginUtils::ConvertFTPResponseCode( err );

    }

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

// CSConPCConnplugin::ObexDisconnectIndication( const TDesC8& )

// MObexServerNotify implementation

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

//

void CSConPCConnplugin::ObexDisconnectIndication( const TDesC8& )

    {

    TRACE_FUNC_ENTRY;

    Disconnect();

    TRACE_FUNC_EXIT;

    }

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

// CSConPCConnplugin::TransportDownIndication()

// MObexServerNotify implementation

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

//

void CSConPCConnplugin::TransportDownIndication()

    {

    TRACE_FUNC_ENTRY;

    Disconnect();

    if ( iBuffer )

        {

        iBuffer->Reset();

        }

    TRACE_FUNC_EXIT;

    }

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

// CSConPCConnplugin::PutRequestIndication()

// MObexServerNotify implementation

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

//

CObexBufObject* CSConPCConnplugin::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 );

    }

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

// CSConPCConnplugin::PutPacketIndication()

// MObexServerNotify implementation

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

//

TInt CSConPCConnplugin::PutPacketIndication()

    {

    TRACE_FUNC_ENTRY;

    TInt ret( KErrNone );

    TBool catalogsMime( EFalse );

    if ( iObject->Type().Length() > KSConHeaderMaxLength )

        {

        LOGGER_WRITE("TypeHeader too big, return KErrNotSupported");

        return TPCConnpluginUtils::ConvertFTPResponseCode( KErrNotSupported );

        }

    TBuf8<KSConHeaderMaxLength> typeHeader( iObject->Type() );

    TrimRightSpaceAndNull( typeHeader );

    if ( iCatalogsConnected && IsCatalogsMimeType( TDataType( typeHeader ) ) )

        {

        catalogsMime = ETrue;

        }

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

        && typeHeader != KSConPCDWBXMLObjectType

        && typeHeader != KSConPCDWBXMLObjectType2

        && !catalogsMime

        && typeHeader != KSConPCDObjectType )

        {

        // normal file transfer

        if ( !iPutPacketIndicationCalled )