/*

* Copyright (c) 2006-2008 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:  DUN Infrared plugin

*

*/

#include "DunIrPlugin.h"

#include "DunUtils.h"

#include "DunDebug.h"

_LIT( KIrdaCsy,       "IRCOMM"    );

_LIT( KIrdaCsy0,      "IRCOMM::0" );

_LIT( KIrChannelName, "DUNIR::0"  );

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

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

// CDunIrPlugin::CDunIrPlugin

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

//

CDunIrPlugin::CDunIrPlugin() :

    iServer( NULL ),

    iTransporter( NULL )

    {

    }

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

// Destructor.

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

//

CDunIrPlugin::~CDunIrPlugin()

    {

    FTRACE(FPrint( _L( "CDunIrPlugin::~CDunIrPlugin()" ) ));

    Uninitialize();

    FTRACE(FPrint( _L( "CDunIrPlugin::~CDunIrPlugin() complete" ) ));

    }

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

// Gets state of this plugin

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

//

TDunPluginState CDunIrPlugin::PluginState()

    {

    return iServer->GetPluginStateByUid( KDunIrPluginUid );

    }

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

// Constructs a listener object for this plugin

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

//

TInt CDunIrPlugin::ConstructListener()

    {

    FTRACE(FPrint(_L("CDunIrPlugin::ConstructListenerL()")));

    if ( PluginState() != EDunStateLoaded )

        {

        FTRACE(FPrint(_L("CDunIrPlugin::ConstructListenerL() (not ready) complete")));

        return KErrNotReady;

        }

    ReportStateChangeUp( EDunStateTryListen );

    TInt retTemp = InitPort();

    if ( retTemp != KErrNone )

        {

        FTRACE(FPrint(_L("CDunIrPlugin::ConstructListenerL() (ERROR) complete")));

        return retTemp;

        }

    ReportStateChangeUp( EDunStateListening );

    ReportStateChangeUp( EDunStateTryChannel );

    TRAPD( retTrap, AllocateChannelL() );

    if ( retTrap != KErrNone )

        {

        iTransporter->FreeChannel( &iIrPort );

        FTRACE(FPrint(_L("CDunIrPlugin::ConstructListenerL() (trapped!) complete")));

        return retTrap;

        }

    ReportStateChangeUp( EDunStateChanneled );

    FTRACE(FPrint(_L("CDunIrPlugin::ConstructListenerL() complete")));

    return KErrNone;

    }

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

// Sets new state

// New state must be one more than the old state

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

//

TInt CDunIrPlugin::ReportStateChangeUp( TDunPluginState aPluginState )

    {

    FTRACE(FPrint(_L("CDunIrPlugin::ReportStateChangeUp()")));

    TInt retTemp = iServer->NotifyPluginStateChangeUp( aPluginState,

                                                       KDunIrPluginUid );

    if ( retTemp != KErrNone )

        {

        FTRACE(FPrint(_L("CDunIrPlugin::ReportStateChangeUp() (ERROR) complete")));

        return retTemp;

        }

    FTRACE(FPrint(_L("CDunIrPlugin::ReportStateChangeUp() complete")));

    return KErrNone;

    }

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

// Sets new state

// New state must be one less than the old state

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

//

TInt CDunIrPlugin::ReportStateChangeDown( TDunPluginState aPluginState )

    {

    FTRACE(FPrint(_L("CDunIrPlugin::ReportStateChangeDown()")));

    TInt retTemp = iServer->NotifyPluginStateChangeDown( aPluginState,

                                                         KDunIrPluginUid );

    if ( retTemp != KErrNone )

        {

        FTRACE(FPrint(_L("CDunIrPlugin::ReportStateChangeDown() (ERROR) complete")));

        return retTemp;

        }

    FTRACE(FPrint(_L("CDunIrPlugin::ReportStateChangeDown() complete")));

    return KErrNone;

    }

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

// Initializes one infrared port with role DCE

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

//

TInt CDunIrPlugin::InitPort()

    {

    FTRACE(FPrint( _L( "CDunIrPlugin::InitPort()" ) ));

    TInt retTemp;

    retTemp = CDunUtils::ConnectCommsServer( iCommServer );

    if ( retTemp != KErrNone )

        {

        FTRACE(FPrint( _L( "CDunIrPlugin::InitPort() (ERROR) complete" ) ));

        return retTemp;

        }

    retTemp = iCommServer.LoadCommModule( KIrdaCsy );

    if ( retTemp != KErrNone )

        {

        FTRACE(FPrint(_L("CDunIrPlugin::InitPort() (load module) failed!") ));

        return retTemp;

        }

    if ( iIrPort.SubSessionHandle() )

        {

        FTRACE(FPrint(_L("CDunIrPlugin::InitPort (already exists!) complete") ));

        return KErrAlreadyExists;

        }

    retTemp = iIrPort.Open( iCommServer,

                            KIrdaCsy0,

                            ECommExclusive,

                            ECommRoleDCE );

    if ( retTemp != KErrNone )

        {

        FTRACE(FPrint(_L("CDunIrPlugin::InitPort() (open) failed!") ));

        return retTemp;

        }

    return KErrNone;

    }

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

// Allocates a channel

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

//

void CDunIrPlugin::AllocateChannelL()

    {

    FTRACE(FPrint(_L("CDunIrPlugin::AllocateChannelL()")));

    HBufC8* channelName = HBufC8::NewMaxLC( KIrChannelName().Length() );

    TPtr8 channelNamePtr = channelName->Des();

    channelNamePtr.Copy( KIrChannelName );

    iTransporter->AllocateChannelL( &iIrPort,

                                    KDunIrPluginUid,

                                    channelNamePtr,

                                    ETrue );

    iTransporter->AddConnMonCallbackL( &iIrPort,

                                       this,

                                       EDunReaderUpstream,

                                       EFalse );

    iTransporter->AddConnMonCallbackL( &iIrPort,

                                       this,

                                       EDunWriterUpstream,

                                       EFalse );

    iTransporter->AddConnMonCallbackL( &iIrPort,

                                       this,

                                       EDunReaderDownstream,

                                       EFalse );

    iTransporter->AddConnMonCallbackL( &iIrPort,

                                       this,

                                       EDunWriterDownstream,

                                       EFalse );

    iTransporter->IssueTransferRequestsL( &iIrPort );

    CleanupStack::PopAndDestroy( channelName );

    FTRACE(FPrint(_L("CDunIrPlugin::AllocateChannelL() complete")));

    }

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

// Uninitializes this plugin

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

//

TInt CDunIrPlugin::Uninitialize()

    {

    FTRACE(FPrint(_L("CDunIrPlugin::Uninitialize()" )));

    ReportStateChangeDown( EDunStateTryUninitialize );

    if ( iIrPort.SubSessionHandle() )

        {

        iTransporter->FreeChannel( &iIrPort );

        iIrPort.SetSignals( 0, KSignalDCEOutputs );

        iIrPort.Close();

        }

    if ( iCommServer.Handle() )

        {

        iCommServer.UnloadCommModule( KIrdaCsy );

        iCommServer.Close();

        }

    ReportStateChangeUp( EDunStateUninitialized );

    ReportStateChangeUp( EDunStateTryLoad );

    ReportStateChangeUp( EDunStateLoaded );

    FTRACE(FPrint(_L("CDunIrPlugin::Uninitialize() complete" )));

    return KErrNone;

    }

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

// From class MDunLocalMediaPlugin.

// CDunIrPlugin::ConstructL

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

//

void CDunIrPlugin::ConstructL( MDunServerCallback* aServer,

                               CDunTransporter* aTransporter )

    {

    FTRACE(FPrint(_L("CDunIrPlugin::ConstructL()")));

    if ( !aServer || !aTransporter )

        {

        FTRACE(FPrint(_L("CDunIrPlugin::ConstructL() not initialized!")));

        User::Leave( KErrGeneral );

        }

    iServer = aServer;

    iTransporter = aTransporter;

    FTRACE(FPrint(_L("CDunIrPlugin::ConstructL() complete")));

    }

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

// From class MDunLocalMediaPlugin.

// Gets called when server changes a plugin's state

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

//

TInt CDunIrPlugin::NotifyServerStateChange( TDunPluginState aPluginState )

    {

    FTRACE(FPrint(_L("CDunIrPlugin::NotifyServerStateChange()")));

    TInt retTemp;

    switch ( aPluginState )

        {

        case EDunStateTryListen:

            if ( PluginState() != EDunStateLoaded )

                {

                FTRACE(FPrint(_L("CDunIrPlugin::NotifyServerStateChange() (not ready) complete")));

                return KErrNotReady;

                }

            // Change to listening mode

            retTemp = ConstructListener();

            if ( retTemp != KErrNone )

                {

                FTRACE(FPrint(_L("CDunIrPlugin::NotifyServerStateChange() (ERROR) complete (%d)"), retTemp));

                return retTemp;

                }

            break;

        case EDunStateTryUninitialize:

            if ( PluginState() == EDunStateUninitialized )

                {

                FTRACE(FPrint(_L("CDunIrPlugin::NotifyServerStateChange() (not ready) complete")));

                return KErrNotReady;

                }

            // Uninitialize

            retTemp = Uninitialize();

            if ( retTemp != KErrNone )

                {

                FTRACE(FPrint(_L("CDunIrPlugin::NotifyServerStateChange() (ERROR) complete (%d)"), retTemp));

                return retTemp;

                }

            break;

        default:

            FTRACE(FPrint(_L("CDunIrPlugin::NotifyServerStateChange() (unknown state) complete")));

            return KErrNotSupported;

        }

    FTRACE(FPrint(_L("CDunIrPlugin::NotifyServerStateChange() complete")));

    return KErrNone;

    }

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

// From class MDunLocalMediaPlugin.

// Gets called when server needs to know the active connection

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

//

TConnId CDunIrPlugin::ActiveConnection()

    {

    FTRACE(FPrint(_L("CDunIrPlugin::ActiveConnection()")));

    FTRACE(FPrint(_L("CDunIrPlugin::ActiveConnection() (not found) complete")));

    return NULL;

    }

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

// From class MDunConnMon.

// Gets called when line status changes or when any type of error is detected

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

//

void CDunIrPlugin::NotifyProgressChangeL(

    TConnId aConnId,

    TDunConnectionReason /*aConnReason*/ )

    {

    FTRACE(FPrint( _L( "CDunIrPlugin::NotifyProgressChangeL()" ) ));

    RComm* irConn = static_cast<RComm*>( aConnId );

    if ( &iIrPort != irConn )

        {

        FTRACE(FPrint( _L( "CDunIrPlugin::NotifyProgressChangeL() (not found) complete")) );

        User::Leave( KErrNotFound );

        }

    // Now indications are down indications from local media side

    FTRACE(FPrint( _L( "CDunIrPlugin::NotifyProgressChangeL() restart plugin" ) ));

    iServer->NotifyPluginRestart( KDunIrPluginUid );

    FTRACE(FPrint( _L( "CDunIrPlugin::NotifyProgressChangeL() complete")) );

    }

// ======== GLOBAL FUNCTIONS ========

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

// NewLocalPluginL implements factory construction for

// the class CDunIrPlugin.

// The function is exported at ordinal 1.

// Returns: Pointer: The new instance of CDunIrPlugin

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

//

EXPORT_C MDunLocalMediaPlugin* NewLocalPluginL()

    {

    return new (ELeave) CDunIrPlugin;

    }