/*
* 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: 
*       xSP View client-side API.
*
*/


// INCLUDE FILES
#include "xSPViewServices.h"
#include "xSPViewServices_priv.h"

// System includes
#include <w32std.h>
#include <apgtask.h>
#include <apacmdln.h>
#include <apgcli.h>
#include <e32svr.h>


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

EXPORT_C TInt RxSPViewServices::Open()
    {
    if( Handle() != KNullHandle ) return KErrAlreadyExists;
    
    TInt err = CreateSession(KxSPServer, Version());
    if(err == KErrNotFound)
        {
        TRAP(err, StartPhonebookL());
        if(err == KErrNone)
            {
            err = CreateSession(KxSPServer, Version());
            }
        }

    return err;
    }

EXPORT_C void RxSPViewServices::Close()
    {
    RSessionBase::Close();
    }

TVersion RxSPViewServices::Version() const
    {
    return TVersion(KxSPViewServerMajor, KxSPViewServerMinor, KxSPViewServerBuild);
    }

// Show the tab view from plugin aEComID with ID aOriginalViewID.
EXPORT_C TInt RxSPViewServices::Activate(TUint32 aEComID, TInt aOriginalViewID)
    {
    TInt err = Open();

    if( err == KErrAlreadyExists || err == KErrNone )
        {
        TBool close( EFalse );
        if( err == KErrNone )
        	{
        	close = ETrue;
        	}
        
        err = SendReceive( EActivateView1, TIpcArgs( aEComID, aOriginalViewID ) );
        
        if( close )
        	{
        	Close();
        	}        
        }

    return err;    
    }

// Opens the detail view for a contact item
EXPORT_C void RxSPViewServices::ActivateL( TUint32 aEComID,
                                           TInt aOriginalViewID,
                                           MVPbkContactLink* aContactLink,
                                           TInt aFocusedField )
    {
    CPbk2ViewState* pbkViewParam = CPbk2ViewState::NewLC();
    pbkViewParam->SetFocusedContact(aContactLink);

    pbkViewParam->SetFocusedFieldIndex(aFocusedField);
    HBufC8* paramBuf = pbkViewParam->PackLC();

    TPtr8 ptr = paramBuf->Des();

    User::LeaveIfError(Activate(aEComID, aOriginalViewID, ptr));

    CleanupStack::PopAndDestroy(2);  // paramBuf, pbkViewParam
    }

// Opens the detail view for a contact item. The contact item is specified in the HBuf object,
// which is contructed from either CPbk2ViewState on S60 3.2 or CPbkViewState.
EXPORT_C TInt RxSPViewServices::Activate(TUint32 aEComID, TInt aOriginalViewID, TPtr8& aParamBuf)
    {
    TInt err = Open();
    
    if( err == KErrAlreadyExists || err == KErrNone )
        {
        TBool close( EFalse );
        if( err == KErrNone )
        	{
        	close = ETrue;
        	}
        	
        err = SendReceive( EActivateView2, TIpcArgs( aEComID, aOriginalViewID, &aParamBuf ) );
        
        if( close )
        	{
        	Close();
        	}
        }

    return err;
    }

EXPORT_C void RxSPViewServices::Activate( TUint32 aEComID,
                                          TInt aOriginalViewID,
                                          TPtr8& aParamBuf,
                                          TRequestStatus& aStatus )
    {
    SendReceive(EActivateView2Async, TIpcArgs(aEComID, aOriginalViewID, &aParamBuf), aStatus);
    }
    
EXPORT_C TInt RxSPViewServices::CancelActivate() const
	{
	TInt err = SendReceive( ECancelActivateView2Async );
	return err;
	}    
    
EXPORT_C RxSPViewServices::RxSPViewServices() :  
											RSessionBase(),
											iViewCount( NULL, 0, 0 ),
											iPackedViewDataBufferLength( NULL, 0, 0 )
    {
    }
	
EXPORT_C TInt RxSPViewServices::Open( TInt aAsyncMessageSlots,
        									TIpcSessionType aType,
        									TRequestStatus& aStatus )
	{
	if( Handle() != KNullHandle ) return KErrAlreadyExists;
    
    TInt err = CreateSession(KxSPServer,
    							Version(),
    							aAsyncMessageSlots,
    							aType,
    							NULL,
    							&aStatus);
    if(err == KErrNotFound)
        {
        TRAP(err, StartPhonebookL());
        if(err == KErrNone)
            {
            err = CreateSession(KxSPServer,
            					Version(),
    							aAsyncMessageSlots,
    							aType,
    							NULL,
    							&aStatus);
            }
        }

    return err;
	}
	    
EXPORT_C TInt RxSPViewServices::GetViewCount( TInt& aCount ) const
	{
	TPckg<TInt> countBuf( aCount );
	TInt err = SendReceive( EGetViewCount, TIpcArgs( &countBuf ) );
	return err;
	}
	
EXPORT_C TInt RxSPViewServices::GetViewCount( TInt& aCount, TRequestStatus& aStatus )
	{
	iViewCount.Set(reinterpret_cast<TUint8*>(&aCount), sizeof(aCount), sizeof(aCount));
	SendReceive( EGetViewCountAsync, TIpcArgs( &iViewCount ), aStatus );	
	return KErrNone;
	}
	
EXPORT_C TInt RxSPViewServices::CancelGetViewCount() const
	{
	TInt err = SendReceive( ECancelGetViewCountAsync );
	return err;
	}
	
EXPORT_C TInt RxSPViewServices::GetPackedViewDataBufferLength( TInt aIndex, 
														TInt& aLength ) const
	{
	TPckg<TInt> lengthBuf( aLength );
	TInt err = SendReceive( EGetViewDataPackLength, TIpcArgs( aIndex, &lengthBuf ) );
	return err;
	}																
	
EXPORT_C TInt RxSPViewServices::GetPackedViewDataBufferLength( TInt aIndex,
														TInt& aLength,
														TRequestStatus& aStatus )
	{
	iPackedViewDataBufferLength.Set(reinterpret_cast<TUint8*>(&aLength), 
										sizeof(aLength),
										sizeof(aLength));
	SendReceive( EGetViewDataPackLengthAsync, 
										TIpcArgs( aIndex, &iPackedViewDataBufferLength ), 
										aStatus );	
	return KErrNone;
	}															

EXPORT_C TInt RxSPViewServices::CancelGetPackedViewDataBufferLength() const
	{
	TInt err = SendReceive( ECancelGetViewDataPackLengthAsync );
	return err;
	}		
		
EXPORT_C TInt RxSPViewServices::GetPackedViewData( TInt aIndex,
											TDes8& aPackedViewData ) const
	{
	TInt err = SendReceive( EGetViewData, TIpcArgs( aIndex, &aPackedViewData ) );			
	return err;
	}												
										
EXPORT_C TInt RxSPViewServices::GetPackedViewData( TInt aIndex,
											TDes8& aPackedViewData,
											TRequestStatus& aStatus ) 
	{		
	SendReceive( EGetViewDataAsync, TIpcArgs( aIndex, &aPackedViewData ), aStatus );	
	return KErrNone;
	}
	
EXPORT_C TInt RxSPViewServices::CancelGetPackedViewData() const
	{
	TInt err = SendReceive( ECancelGetViewDataAsync );
	return err;
	}    
												      

// Starts Phonebook in the background if it is not already running.
void RxSPViewServices::StartPhonebookL()
    {
    RMutex mutex;
    TInt err = mutex.CreateGlobal(KxSPServer);
    if(err == KErrAlreadyExists)
        {
        err = mutex.OpenGlobal(KxSPServer);
        }
    User::LeaveIfError(err);
    CleanupClosePushL(mutex);

    mutex.Wait();

    RWsSession ws;
    User::LeaveIfError(ws.Connect());
    CleanupClosePushL(ws);
    TApaTaskList list(ws);
    TUid uid = { KUid };
    TApaTask task(list.FindApp(uid));
    if(!task.Exists())
        {
        // Phonebook is not running => we are going to launch it.
        RSemaphore semaphore;
        User::LeaveIfError(semaphore.CreateGlobal(KxSPServer, 0));
        CleanupClosePushL(semaphore);

        // Launch Phonebook
        CApaCommandLine* cmd = CApaCommandLine::NewLC();
        cmd->SetExecutableNameL(KPhonebookExe);
        cmd->SetCommandL(EApaCommandBackground);
        RApaLsSession ls;
        User::LeaveIfError(ls.Connect());
        CleanupClosePushL(ls);
        User::LeaveIfError(ls.StartApp(*cmd));

        // Wait here until server has started or timeout occurs.
        semaphore.Wait(KTimeoutActivate);
        CleanupStack::PopAndDestroy(3); // ls, cmd, semaphore
        }
    CleanupStack::PopAndDestroy(); // ws

    mutex.Signal();
    CleanupStack::PopAndDestroy(); // mutex
    }

// End of file.