/*

* Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of the License "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: 

*

*/

#include <iscapi.h>                 //For ISC

#include <iscnokiadefinitions.h>    //isc definitions

#include <pn_const.h>

#ifndef NCP_COMMON_BRIDGE_FAMILY       

#include <nsisi.h>

#endif

#include <tisi.h>                   //for isimessage

#include "cmodematpipecontroller.h"    

#include "cmodemathandler.h"

#include <at_modemisi.h>            //redirectreq error codes

#include "modemattrace.h"

#include "cmodematsrv.h"

#ifndef NCP_COMMON_BRIDGE_FAMILY

const TUint8 KFiller = 0;

#endif

CModemAtPipeController* CModemAtPipeController::NewL( RIscApi& aIscApi,

    TUint& aObjId,

    CModemAtHandler& aHandler )

    {

    CModemAtPipeController* self = new (ELeave) CModemAtPipeController( aIscApi,aObjId, aHandler );

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    return self;

    }

void CModemAtPipeController::ConstructL()

    {

    C_TRACE (( _T("CModemAtPipeController::ConstructL()") ));

    }

CModemAtPipeController::~CModemAtPipeController() 

     {

     C_TRACE((_L(">>CModemAtPipeController::~CModemAtPipeController()")));

     if( iSchedulerWait )

        {

        C_TRACE((_L("CModemAtPipeController::~CModemAtPipeController() iSchedulerWait->Stop")));

        iSchedulerWait->AsyncStop();

        delete iSchedulerWait;

        iSchedulerWait = NULL;

        }

     C_TRACE((_L("<<CModemAtPipeController::~CModemAtPipeController()")));

     }

CModemAtPipeController::CModemAtPipeController( RIscApi& aIscApi,

    TUint& aObjId,

    CModemAtHandler& aHandler ) : 

    iIscApi( aIscApi ),

    iModemAtObjId( aObjId ),

    iModemAtDevId( THIS_DEVICE ),

    iDataportDevId( 0 ),

    iDataportObjId( 0 ),

    iAtHandler( aHandler ),

    {

    }

#ifndef NCP_COMMON_BRIDGE_FAMILY

 void CModemAtPipeController::HandleNameServiceMessage( const TIsiReceiveC& aReceivedMessage )

     {

     C_TRACE (( _T("CModemAtPipeController::HandleNameServiceMessage()") ));

     switch( aReceivedMessage.Get8bit( ISI_HEADER_OFFSET_MESSAGEID ) )

        {

        case PNS_NAME_QUERY_RESP: 

            C_TRACE(_L("PNS_NAME_QUERY_RESP"));

            HandleNameQueryResp( aReceivedMessage );

            break;

        case PNS_NAME_ADD_IND:

            C_TRACE(_L("PNS_NAME_ADD_IND"));

            HandleNameAddInd( aReceivedMessage );

            break;

        case PNS_NAME_REMOVE_IND:

            C_TRACE(_L("PNS_NAME_REMOVE_IND")); 

            HandleNameRemoveInd( aReceivedMessage );

            break;

        default:

            TRACE_ASSERT_ALWAYS;

            break;

        }

     }

 void CModemAtPipeController::HandlePipeServiceMessage( const TIsiReceiveC& aReceivedMessage)

     {

     C_TRACE (( _T("CModemAtPipeController::HandlePipeServiceMessage()") ));

     C_TRACE((_L("message id: %d") , aReceivedMessage.Get8bit( ISI_HEADER_OFFSET_MESSAGEID ) ));

     switch( aReceivedMessage.Get8bit( ISI_HEADER_OFFSET_MESSAGEID ) )

        {

        case PNS_PIPE_CREATE_RESP:

            HandlePipeCreateResp( aReceivedMessage );

            break;

        case PNS_PIPE_REDIRECT_RESP:

            C_TRACE(_L("PNS_PIPE_REDIRECT_RESP"));

            HandlePipeRedirectResp( aReceivedMessage );

            break;

        case PNS_PIPE_REMOVE_RESP:

            C_TRACE(_L("PNS_PIPE_REMOVE_RESP"));

            HandlePipeRemoveResp( aReceivedMessage );

            break;

        case PNS_PIPE_ENABLE_RESP:

            C_TRACE(_L("PNS_PIPE_ENABLE_RESP"));

            HandlePipeEnabledResp( aReceivedMessage );

            break;

        case PNS_PEP_STATUS_IND :

            HandlePepStatusInd( aReceivedMessage );

            break;

        default:

            TRACE_ASSERT_ALWAYS;

            break;

        }                            

     }

TUint CModemAtPipeController::MatchDataportName( TUint aName)

    {

    /*

    See from dataport: 

    void CDpMif::SendNameAddReqL():

        case KDpDialUpPort:

        case KDpPort4:

        case KDpPort5:

            {

            messageData.Append( aUnit );                //name

            messageData.Append( KDpPadding );           //name

            messageData.Append( PN_PEP_TYPE_COMM );     //name

            messageData.Append( PN_PIPE );              //name

            break;

    Only 3 last bytes count

    */

    TUint KDpDialUpPort = 1;

    TUint KDpPadding = 0;

    TUint dataportName(0);

    dataportName = (

    ( (TUint)PN_PIPE ) | 

    ( (TUint)PN_PEP_TYPE_COMM << 8 ) | 

    ( KDpPadding << 16) | 

    ( KDpDialUpPort << 24 ) 

    );

    if( aName == dataportName )

        {

        return ETrue;

        }

    return EFalse;

    }

void CModemAtPipeController::HandleNameAddInd( const TIsiReceiveC& aReceivedMessage )     

     {

     C_TRACE (( _T("CModemAtPipeController::HandleNameAddInd()") ));

     TInt matchesInThisMsg = aReceivedMessage.Get16bit( ISI_HEADER_SIZE +

       PNS_NAME_ADD_IND_OFFSET_MATCHESINMSG );

     C_TRACE((_L("matchesInThisMsg: %d") ,matchesInThisMsg ));

     TUint name = 0;

     for( TInt i = 1; i <= matchesInThisMsg; i++ ) 

         {

         name = aReceivedMessage.Get32bit(ISI_HEADER_SIZE +

           PNS_NAME_ADD_IND_OFFSET_NAMEENTRYTBL * i);

         C_TRACE((_L("name [%d] 0x%x"), i ,name));

         if( MatchDataportName(name) )

             {

             iDataportDevId = aReceivedMessage.Get8bit( ISI_HEADER_SIZE + 

               PNS_NAME_ADD_IND_OFFSET_NAMEENTRYTBL * i +

               PN_NAME_SRV_ITEM_STR_OFFSET_DEV );

             iDataportObjId = aReceivedMessage.Get8bit( ISI_HEADER_SIZE + 

               PNS_NAME_ADD_IND_OFFSET_NAMEENTRYTBL * i +

               PN_NAME_SRV_ITEM_STR_OFFSET_OBJ);

                {

                }

             else

                {

                TRACE_ASSERT_ALWAYS;

                }

             }

         }

     }

void CModemAtPipeController::HandleNameRemoveInd( const TIsiReceiveC& aReceivedMessage )     

    {

    C_TRACE (( _T("CModemAtPipeController::HandleNameRemoveInd()") ));

    TInt matchesInThisMsg = aReceivedMessage.Get16bit( ISI_HEADER_SIZE +

      PNS_NAME_REMOVE_IND_OFFSET_MATCHESINMSG );

    C_TRACE((_L("matchesInThisMsg: %d"), matchesInThisMsg ));

    TUint name = 0;

    for( TInt i = 1; i <= matchesInThisMsg; i++ ) 

        {

        name = aReceivedMessage.Get32bit(ISI_HEADER_SIZE +

          PNS_NAME_REMOVE_IND_OFFSET_NAMEENTRYTBL * i);

        C_TRACE((_L("name [%d] 0x%x"), i ,name));

        if( MatchDataportName(name) )

            {

            TUint devId = aReceivedMessage.Get8bit( ISI_HEADER_SIZE + 

              PNS_NAME_REMOVE_IND_OFFSET_NAMEENTRYTBL * i +

              PN_NAME_SRV_ITEM_STR_OFFSET_DEV );

            TUint objId = aReceivedMessage.Get8bit( ISI_HEADER_SIZE + 

              PNS_NAME_REMOVE_IND_OFFSET_NAMEENTRYTBL * i +

              PN_NAME_SRV_ITEM_STR_OFFSET_OBJ);

            if( iDataportDevId == devId && iDataportObjId == objId )

               {

               C_TRACE((_L("Dataport removed from name service (devid %x  o-bjid %x) "), iDataportDevId, iDataportObjId));

               iDataportDevId = 0;

               iDataportObjId = 0;

               }

            else

               {

               C_TRACE((_L("Unused dataport removed from name service. DevId: 0x%x or ObjId 0x%x"), iDataportDevId, iDataportObjId ));

               TRACE_ASSERT_ALWAYS;

               }

            }

        }

    }

void CModemAtPipeController::HandleNameQueryResp( const TIsiReceiveC& aReceivedMessage )

    {

    C_TRACE((_L("CModemAtPipeHandler::HandleNameQueryResp")));

    TUint16 matchesInThisMsg( aReceivedMessage.Get16bit(

        ISI_HEADER_SIZE + PNS_NAME_QUERY_RESP_OFFSET_MATCHESINMSG ) );

    C_TRACE((_L("matchesInThisMsg: %d"), matchesInThisMsg ));

    TBool found = EFalse;

    if( 0 < matchesInThisMsg )

        {

        for( TInt i = 0; i < matchesInThisMsg; i++ )

            {

            TInt recordIndex( i * SIZE_PN_NAME_SRV_ITEM_STR );

            TUint8 name( aReceivedMessage.Get8bit(

                ISI_HEADER_SIZE + PNS_NAME_QUERY_RESP_OFFSET_NAMEENTRYTBL +

                recordIndex + ( PN_NAME_SRV_ITEM_STR_OFFSET_NAME + KLastByteIndex ) ) );

            C_TRACE((_L("name [%d] 0x%x"), i, name ));

            if( PN_AT_MODEM == name )

                {

                C_TRACE((_L("PN_AT_MODEM found.")));

                i = matchesInThisMsg;

                found = ETrue;

                }

            }

        }

    iAtHandler.SetModemAtExistsInCmt( found );

    }

void CModemAtPipeController::SendCreatePipeMessage( const TUint8 aDevId, const TUint8 aObjId ) 

     {

     C_TRACE (( _T("CModemAtPipeController::SendCreatePipeMessage() DevId: 0x%x ObjId: 0x%x"), aDevId, aObjId ));

     HBufC8* message = HBufC8::New( ISI_HEADER_SIZE + SIZE_PNS_PIPE_CREATE_REQ );

     TRACE_ASSERT(message);

     TPtr8 messageptr = message->Des();

     TIsiSend isimessage( messageptr, ISI_HEADER_SIZE + SIZE_PNS_PIPE_CREATE_REQ );

     isimessage.Set8bit( ISI_HEADER_OFFSET_RESOURCEID, PN_PIPE );

     isimessage.Set8bit( ISI_HEADER_SIZE + PNS_PIPE_CREATE_REQ_OFFSET_UTID, 0);

     isimessage.Set8bit( ISI_HEADER_SIZE + PNS_PIPE_CREATE_REQ_OFFSET_SUBFUNCTION, PNS_PIPE_CREATE_REQ );

     isimessage.Set8bit( ISI_HEADER_SIZE + PNS_PIPE_CREATE_REQ_OFFSET_STATEAFTERCREATION ,PN_PIPE_DISABLE );

     isimessage.Set8bit( ISI_HEADER_SIZE + PNS_PIPE_CREATE_REQ_OFFSET_PRIORITY ,0 );

     isimessage.Set8bit( ISI_HEADER_SIZE + PNS_PIPE_CREATE_REQ_OFFSET_FIRSTPEPDEV, aDevId );

     isimessage.Set8bit( ISI_HEADER_SIZE + PNS_PIPE_CREATE_REQ_OFFSET_FIRSTPEPOBJ, aObjId );

     isimessage.Set8bit( ISI_HEADER_SIZE + PNS_PIPE_CREATE_REQ_OFFSET_FIRSTPEPTYPE, PN_PEP_TYPE_COMMON );

     isimessage.Set8bit( ISI_HEADER_SIZE + PNS_PIPE_CREATE_REQ_OFFSET_FILLERBYTE1, KFiller );

     isimessage.Set8bit( ISI_HEADER_SIZE + PNS_PIPE_CREATE_REQ_OFFSET_SECONDPEPDEV, THIS_DEVICE );

     isimessage.Set8bit( ISI_HEADER_SIZE + PNS_PIPE_CREATE_REQ_OFFSET_SECONDPEPOBJ, iModemAtObjId );

     isimessage.Set8bit( ISI_HEADER_SIZE + PNS_PIPE_CREATE_REQ_OFFSET_SECONDPEPTYPE, PN_PEP_TYPE_COMMON );

     isimessage.Complete();

     C_TRACE(_L("Created ISI-message"));

     DUMP_MESSAGE( messageptr );

     TInt retVal = iIscApi.Send( messageptr );

     TRACE_ASSERT( retVal == KErrNone );

     delete message;

     }

 void CModemAtPipeController::HandlePipeCreateResp( const TIsiReceiveC& aReceivedMessage )

    {

    C_TRACE (( _T("CModemAtPipeController::HandlePipeCreateResp()") ));

    C_TRACE((_L("Pipe create resp: %d"), error ));

    if( error == PN_PIPE_NO_ERROR)

        {

          PNS_PIPE_CREATE_RESP_OFFSET_PIPEHANDLE );

        }

    else

        {

        ASSERT_ALWAYS;

        }

    }

void CModemAtPipeController::HandlePipeRemoveResp( const TIsiReceiveC& aReceivedMessage )

    {

    C_TRACE (( _T(">>CModemAtPipeController::HandlePipeRemoveResp()") ));

    TInt error = aReceivedMessage.Get8bit( ISI_HEADER_SIZE + 

      PNS_PIPE_REMOVE_RESP_OFFSET_ERRORCODE );

    TInt pipehandle = aReceivedMessage.Get8bit( ISI_HEADER_SIZE + 

      PNS_PIPE_REMOVE_RESP_OFFSET_PIPEHANDLE );

        {

        return;

        }

    TRACE_ASSERT( error == PN_PIPE_NO_ERROR )

    if( error != PN_PIPE_NO_ERROR )

        {

        C_TRACE(( _T("CModemAtPipeController::HandlePipeRemoveResp() error %d"), error ));

        return;

        }

    if( iSchedulerWait )

        {

        C_TRACE((_L("CModemAtPipeController::HandlePipeRemoveResp() iSchedulerWait->Stop")));

        iSchedulerWait->AsyncStop();

        delete iSchedulerWait;

        iSchedulerWait = NULL;

        }

    C_TRACE((_L("<<CModemAtPipeController::HandlePipeRemoveResp()")));

    }

void CModemAtPipeController::RemovePipe( const TUint8 aDteId )

    {

    C_TRACE (( _T("CModemAtPipeController::RemovePipe(%d, 0x%x)"), aDteId, this ));

        {

            {

            return;

            }

        }

    else

        {

        C_TRACE((_L("No Pipe to Remove")));

        }

    }

void CModemAtPipeController::SendRemovePipeReq( const TUint8 aPipeHandle ) 

    {

    C_TRACE (( _T(">>CModemAtPipeController::SendRemovePipeReq()") ));

    C_TRACE((_L("Remove pipe handle %d"), aPipeHandle));

    TInt size = ISI_HEADER_SIZE + SIZE_PNS_PIPE_REMOVE_REQ;

    HBufC8* message = HBufC8::New( size );

    TRACE_ASSERT( message );

    TPtr8 messageptr = message->Des();

    TIsiSend isimessage( messageptr, size );

    isimessage.Set8bit( ISI_HEADER_OFFSET_RESOURCEID, PN_PIPE );

    isimessage.Set8bit( ISI_HEADER_SIZE + PNS_PIPE_REMOVE_REQ_OFFSET_UTID, 0 );

    isimessage.Set8bit( ISI_HEADER_SIZE + PNS_PIPE_REMOVE_REQ_OFFSET_SUBFUNCTION, 

      PNS_PIPE_REMOVE_REQ );

    isimessage.Set8bit( ISI_HEADER_SIZE + PNS_PIPE_REMOVE_REQ_OFFSET_PIPEHANDLE,

      aPipeHandle ); //disabled

    isimessage.Set8bit( ISI_HEADER_SIZE + PNS_PIPE_REMOVE_REQ_OFFSET_FILLERBYTE1 ,0 );

    isimessage.Complete();

    C_TRACE(_L("Created ISI-message"));

    TInt retVal = iIscApi.Send( messageptr );

    TRACE_ASSERT( retVal == KErrNone );

    delete message;

    if( !iSchedulerWait )

        {

        C_TRACE(_L("CModemAtPipeController::SendRemovePipeReq() iSchedulerWait->Start()"));

        TRAPD(err, iSchedulerWait = new (ELeave) CActiveSchedulerWait);

        ASSERT_PANIC_ALWAYS( err == KErrNone );

        iSchedulerWait->Start();

        }

    C_TRACE (( _T("<<CModemAtPipeController::SendRemovePipeReq()") ));

    }

void CModemAtPipeController::RedirectPipe( const TUint8 aDteId,

    const TUint8 aNewDevId,

    const TUint8 aNewObjId ) 

    {

    C_TRACE((_L("CModemAtPipeController::RedirectPipe() New pep, deviceId: 0x%x objId: 0x%x "), aNewDevId, aNewObjId));

        {

        C_TRACE(( _T("CModemAtPipeController::RedirectPipe() illegal dteid %d"), aDteId ));

        return;

        }

        {

        return;

        }

        {

        C_TRACE(_L("CModemAtPipeController::RedirectPipe() Pipe is already removed -> cant redirect"));

        return;

        }

    if( aNewDevId == THIS_DEVICE && aNewObjId == iModemAtObjId )

        {

        C_TRACE((_L("CModemAtPipeController::RedirectPipe() EPipeDisabled. iModemAtObjId: 0x%x"), iModemAtObjId));