/*
* Copyright (c) 2006 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:  XIMP Framework PSC Server context session.
 *
*/

#include "ximpsrvcontextclient.h"
#include "ximpprocessstarter.h"
#include "ximpserverdefs.h"

#include <e32base.h>

//Import NXIMPSrv
using namespace NXIMPSrv;


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

// ---------------------------------------------------------------------------
// RXIMPSrvContextClient::RXIMPSrvContextClient()
// ---------------------------------------------------------------------------
//
EXPORT_C RXIMPSrvContextClient::RXIMPSrvContextClient()
    {
    }


// ---------------------------------------------------------------------------
// RXIMPSrvContextClient::Connect()
// ---------------------------------------------------------------------------
//
EXPORT_C void RXIMPSrvContextClient::ConnectL( TUid aProtocolImpUid )
    {
    iMyUid = aProtocolImpUid;

    // create the server name: "!XIMPCtxSrv9bde667a" 
    HBufC* serverName = HBufC::NewLC( NName::KSymbianServer().Length() + 
            NStartupParam::KProtocolUidMaxLen + 
            1 );

    serverName->Des().Copy( NName::KSymbianServer );
    serverName->Des().AppendNumFixedWidth( iMyUid.iUid, 
            EHex, 
            NStartupParam::KProtocolUidMaxLen );

    // Pass the UID to server side.
    // For security reasons it was not allowed to pass the complete 
    // server name descriptor but just the UID part
    RArray< TXIMPProcessStartupParam > params;
    CleanupClosePushL( params );

    TXIMPProcessStartupParam paramUid;
    paramUid.Set( NStartupParam::KProtocolUidIndex, 
            iMyUid.iUid );

    User::LeaveIfError( params.Append( paramUid ) );
    TArray< TXIMPProcessStartupParam > array = params.Array();


    //Get path to correct exe to launch
    TFileName fullExePath;
    XIMPProcessStarter::FullExePathForClienLocation( NName::KExecutable,
            fullExePath );

    //Create a connection
    TInt ret = XIMPProcessStarter::ConnectToServer( fullExePath,
            KNullDesC,
            &array,
            *this,
            *serverName,
            TVersion( NVersion::KMajor,
                      NVersion::KMinor,
                      NVersion::KBuild ),
                      NRequest::KMsgSlotCount );
    User::LeaveIfError( ret );
    CleanupStack::PopAndDestroy( 2, serverName ); // params, serverName

    //Mutate the server side session to correct type
    User::LeaveIfError( SendReceive( NRequest::EBecomeCtxSession ) );
    }



// ---------------------------------------------------------------------------
// RXIMPSrvContextClient::Close()
// ---------------------------------------------------------------------------
//
EXPORT_C void RXIMPSrvContextClient::Close()
    {
    RSessionBase::Close();
    #if _BullseyeCoverage
    cov_write();
    #endif
    }


// ---------------------------------------------------------------------------
// RXIMPSrvContextClient::DoQueueOperation()
// ---------------------------------------------------------------------------
//
EXPORT_C TInt RXIMPSrvContextClient::DoQueueOperation(
    TInt aOperationType, 
    const TDesC8& aOperationParams,
    TXIMPRequestId& aReqId )
    {
    TPckgBuf< TXIMPRequestId > reqIdPck;

    TIpcArgs msgArgs;
    msgArgs.Set( 0, aOperationType );
    msgArgs.Set( 1, &aOperationParams );
    msgArgs.Set( 2, &reqIdPck );

    TInt err = SendReceive( NRequest::ECtxSsQueueOperation, msgArgs );

    aReqId = reqIdPck();
    return err;
    }

// ---------------------------------------------------------------------------
// RXIMPSrvContextClient::DoQueueOperation2()
// ---------------------------------------------------------------------------
//
EXPORT_C TInt RXIMPSrvContextClient::DoQueueOperation2(
    TInt aOperationType, 
    const TDesC8& aOperationParams,
    TXIMPRequestId& aReqId )
    {
    TPckgBuf< TXIMPRequestId > reqIdPck;

    TIpcArgs msgArgs;
    msgArgs.Set( 0, aOperationType );
    msgArgs.Set( 1, &aOperationParams );
    msgArgs.Set( 2, &reqIdPck );

    TInt err = SendReceive( NRequest::ECtxSsQueueBindOperation, msgArgs );
    aReqId = reqIdPck();
    return err;
    }

// ---------------------------------------------------------------------------
// RXIMPSrvContextClient::GetContextCapabilitiesL()
// ---------------------------------------------------------------------------
//
EXPORT_C HBufC8* RXIMPSrvContextClient::GetContextFeaturesL() const
    {
    return PrepareAndGetDataL( NRequest::ECtxSsPrepareContextFeatures );
    }


// ---------------------------------------------------------------------------
// RXIMPSrvContextClient::ListenEvent()
// ---------------------------------------------------------------------------
//
EXPORT_C void RXIMPSrvContextClient::ListenEvent( TRequestStatus& aStatus )
    {
    SendReceive( NRequest::ECtxSsSetEventListenScout, aStatus );
    }


// ---------------------------------------------------------------------------
// RXIMPSrvContextClient::CancelListening()
// ---------------------------------------------------------------------------
//
EXPORT_C void RXIMPSrvContextClient::CancelListening()
    {
    SendReceive( NRequest::ECtxSsCancelEventListenScout );
    }


// ---------------------------------------------------------------------------
// RXIMPSrvContextClient::InstallEventFilterL()
// ---------------------------------------------------------------------------
//
EXPORT_C void RXIMPSrvContextClient::InstallEventFilterL(
        const TDesC8& aFilterData )
    {
    TIpcArgs msgArgs;
    msgArgs.Set( 0, &aFilterData );
    User::LeaveIfError( SendReceive( NRequest::ECtxSsInstallEventFilter, 
                                     msgArgs ) );
    }


// ---------------------------------------------------------------------------
// RXIMPSrvContextClient::FetchTopEventDataLC()
// ---------------------------------------------------------------------------
//
EXPORT_C HBufC8* RXIMPSrvContextClient::FetchTopEventDataLC()
    {
    TInt bufSize = SendReceive( NRequest::ECtxSsFetchTopEventDataSize );
    User::LeaveIfError( bufSize );

    HBufC8* eventBuf = HBufC8::NewLC( bufSize );
    TPtr8 ptrBuf( eventBuf->Des() );

    TIpcArgs msgArgs;
    msgArgs.Set( 0, &ptrBuf );

    User::LeaveIfError( SendReceive( NRequest::ECtxSsFetchTopEventData, 
                                     msgArgs ) );
    return eventBuf;
    }


// ---------------------------------------------------------------------------
// RXIMPSrvContextClient::FetchTopEventReqId()
// ---------------------------------------------------------------------------
//
EXPORT_C TInt RXIMPSrvContextClient::FetchTopEventReqId( 
    TXIMPRequestId& aReqId )
    {
    TPckgBuf< TXIMPRequestId > reqIdPck;

    TIpcArgs msgArgs;
    msgArgs.Set( 0, &reqIdPck );

    TInt err = SendReceive( NRequest::ECtxSsFetchTopEventReqId, msgArgs );

    aReqId = reqIdPck();
    return err;
    }



// ---------------------------------------------------------------------------
// RXIMPSrvContextClient::DropTopEvent()
// ---------------------------------------------------------------------------
//
EXPORT_C TInt RXIMPSrvContextClient::DropTopEvent()
    {
    TInt err = SendReceive( NRequest::ECtxSsDropTopEvent );
    return err;
    }



// ---------------------------------------------------------------------------
// RXIMPSrvContextClient::PrepareAndGetDataL()
// ---------------------------------------------------------------------------
//
HBufC8* RXIMPSrvContextClient::PrepareAndGetDataL( TInt aMsg ) const
    {
    TInt bufSize = SendReceive( aMsg );
    User::LeaveIfError( bufSize );

    HBufC8* buf = HBufC8::NewLC( bufSize );
    TPtr8 ptrBuf( buf->Des() );

    TIpcArgs msgArgs;
    msgArgs.Set( 0, &ptrBuf );

    User::LeaveIfError( SendReceive( NRequest::ECtxSsGetPreparedData, 
                                     msgArgs ) );

    CleanupStack::Pop( buf );
    return buf;
    }


// End of file