/*

* Copyright (c) 2002-2005 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: 

* imps client interface.

*

*/

// INCLUDE FILES

#include    "impsImHandler.h"

#include    "ImpsImCli.h"

#include    "ImpsImCommand.h"

#include    "impsServerCommon.h"

#include    "impsutils.h"

// MACROS

#ifndef _DEBUG

#define _NO_IMPS_LOGGING_

#endif

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

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

// RImpsImClient2::RImpsImClient2

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

EXPORT_C RImpsImClient2::RImpsImClient2() :

        RImpsClient2(),

        iImHandlerCallback( NULL ),

        iBlockingHandlerCallback( NULL ),

        iCommand( NULL )

    {

    SetOpIdRange( ); 

    }

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

// RImpsImClient2::RegisterL

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

EXPORT_C void RImpsImClient2::RegisterL(

    RImpsEng& aEngine, 

    MImpsImHandler2* aImpsObserver,

    MImpsBlockingHandler2* aBlockingHandler,

    const TDesC& aClientId,

    TBool aReceiveNew,

    TInt aPriority )

    {

    iImHandlerCallback = aImpsObserver;

    iBlockingHandlerCallback = aBlockingHandler;

    iHandler = CImpsImHandler2::NewL( *this, aPriority );

    iCommand = CImpsImCommand2::NewL( *this );

    iActiveCommand = iCommand;

    // Start the handler

    iHandler->StartRun();

    iHandleNew = aReceiveNew;

    iAnyContent = EFalse;

    // Send registration to the server thread

    TInt err = DoRegister( aEngine, iHandler );

    User::LeaveIfError( err ); 

    (void) DoAssign( aClientId );

    }

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

// RImpsImClient2::Unregister()

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

EXPORT_C void RImpsImClient2::Unregister()

    {

    DoUnregister();

    }

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

// RImpsImClient2::DoRegister()

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

TInt RImpsImClient2::DoRegister(

   RImpsEng& aEngine,

   CImpsHandler2* aHandler )

   {

   return DoRegister2( aEngine, aHandler, EImpsImRegister );

   }

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

// RImpsImClient2::SendTextMessageL()

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

EXPORT_C TInt RImpsImClient2::SendTextMessageL( 

            const TDesC* aSenderSn,     

            const MDesCArray* aUserIds,

            const TDesC* aGroupId,         

            const MDesCArray* aScreenNames, 

            const TDesC& aContent,

            TBool aDeliveryReportWanted )

    {

    IncreaseOpId( );

#ifndef _NO_IMPS_LOGGING_

    CImpsClientLogger::Log(_L("RImpsImClient2: SendTextMessageL opid=%d cli=%d"), 

        iOpId, (TInt)this );

#endif

    iCommand->SetParametersL( 

        aSenderSn, aUserIds, aGroupId, aScreenNames, aContent, aDeliveryReportWanted );

    iMessagePtr.Set( iCommand->iMessageStream->Des() );

    iCommand->StartRunL( iOpId, EImpsServWVSendOnly );

    SendReceive( EImpsServWVSendOnly, 

                 TIpcArgs( &iMessagePtr, iOpId ), iCommand->iStatus );

    return iOpId;

    }

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

// RImpsImClient2::BlockEntityRequestL

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

EXPORT_C TInt RImpsImClient2::BlockEntityRequestL( 

    const MDesCArray* aBlockEntity,

    const MDesCArray* aUnBlockEntity,

    TBool aBlockedListInUse,

    const MDesCArray* aGrantedEntityList,

    const MDesCArray* aUnGrantEntity,

    TBool aGrantedListInUse )

    {

    IncreaseOpId( );

    iCommand->SetParametersL( 

         aBlockEntity, aUnBlockEntity, aBlockedListInUse, 

         aGrantedEntityList, aUnGrantEntity, aGrantedListInUse );

    iMessagePtr.Set( iCommand->iMessageStream->Des() );

    iCommand->StartRunL( iOpId,  EImpsServBlock );

#ifndef _NO_IMPS_LOGGING_

    CImpsClientLogger::Log(_L("RImpsImClient2: BlockEntityRequestL opid=%d cli=%d"), 

        iOpId, (TInt)this );

#endif

    SendReceive( EImpsServBlock, 

                 TIpcArgs( &iMessagePtr, iOpId ), iCommand->iStatus );

    return iOpId;

    }

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

// RImpsImClient2::GetBlockedListRequestL

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

EXPORT_C TInt RImpsImClient2::GetBlockedListRequestL()

    {

    IncreaseOpId( );

#ifndef _NO_IMPS_LOGGING_

    CImpsClientLogger::Log(_L("RImpsImClient2: GetBlockedListRequestL opid=%d cli=%d"), 

        iOpId, (TInt)this );

#endif

    // This has no serialized data, but the message 

    // primitive is created in a server thread to minimize

    // the amount of data transferred between client and server thread.

    iCommand->StartRunL( iOpId,  EImpsServBlock );

    TImpsServRequest req = EImpsServGetBlocked;

    SendReceive( req, TIpcArgs( TIpcArgs::ENothing, iOpId ), iCommand->iStatus );

#ifndef _NO_IMPS_LOGGING_

    CImpsClientLogger::Log(_L("RImpsImClient2: GetBlockedListRequestL opid=%d cli=%d"), 

        iOpId, (TInt)this );

#endif

    return iOpId;

    }

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

// RImpsImClient2::SendContentMessageL

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

EXPORT_C TInt RImpsImClient2::SendContentMessageL( const TDesC* aSenderSn,     

                                           const MDesCArray* aUserIds,

                                           const TDesC* aGroupId,         

                                           const MDesCArray* aScreenNames, 

                                           const TDesC& aContentType, 

                                           const TDesC8& aContent,

                                           TBool aDeliveryReportWanted )

    {

    IncreaseOpId( );

#ifndef _NO_IMPS_LOGGING_

    CImpsClientLogger::Log(_L("RImpsImClient2: SendContentMessageL opid=%d cli=%d"), 

        iOpId, (TInt)this );

#endif

    iCommand->SetParametersL( 

        aSenderSn, aUserIds, aGroupId, aScreenNames, aContentType, aContent, aDeliveryReportWanted );

    iMessagePtr.Set( iCommand->iMessageStream->Des() );

    iCommand->StartRunL( iOpId, EImpsServWVSendOnly );

    SendReceive( EImpsServWVSendOnly, 

                 TIpcArgs( &iMessagePtr, iOpId ), iCommand->iStatus );

    return iOpId;

    }

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

// RImpsImClient2::Handler

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

MImpsImHandler2* RImpsImClient2::Handler( )

   {

    return iImHandlerCallback;

    }

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

// RImpsImClient2::BlockHandler

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

MImpsBlockingHandler2* RImpsImClient2::BlockHandler( )

   {

    return iBlockingHandlerCallback;

    }

// ================= OTHER EXPORTED FUNCTIONS ==============

//  End of File