/*

* Copyright (c) 2006-2010 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:  IETF SIMPLE Protocol implementation for XIMP Framework

*

*/

#include <badesca.h>

#include <ximpbase.h>

#include <ximpserviceinfo.h>

#include <protocolpresencefeatures.h>

#include <cprotocolimfeatures.h>

#include <protocolpresencedatahost.h>

#include <presenceobjectfactory.h>  

#include <ximpcontextclientinfo.h>		

#include <protocolpresenceauthorization.h>  

#include <ximpprotocolconnectionhost.h>			   

#include <ximpfeatureinfo.h> //for etc. KPublish

#include <msimpleconnection.h> //Part of Registration API from SIMPLE engine

#include <msimpleconnectionobserver.h>//Connection callback methods

#include <presenceinfo.h>

#include "presencepluginconnection.h"

#include "presencepluginsession.h" 

#include "mpresencepluginconnectionobs.h"   

#include "presencepluginwatcher.h"

#include "presencepluginauthorization.h"

#include "presencepluginwinfo.h"

#include "presencepluginpublisher.h"

#include "presenceplugingroup.h"

#include "presencepluginxdmutils.h"

#include "presencepluginvirtualgroup.h"

#include "presenceconnectioninfo.h"

#include "presenceplugindata.h"

#include "simpleimpluginuids.hrh" //KImplUidSimpleImPlugin

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

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

// CPresencePluginConnection::CPresencePluginConnection()

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

//

CPresencePluginConnection::CPresencePluginConnection( ): 

	CActive( CActive::EPriorityHigh ), iSipPresentity(NULL),

    iStopPublishState( EFalse ), iGrantListSubs( EFalse ), iStopPublishCall( EFalse ),

    iTerminatedCall( EFalse )

    {

    DP_SDA("CPresencePluginConnection::CPresencePluginConnection");

    CActiveScheduler::Add(this);

    iOwnTupleId = 0;

    }

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

// CPresencePluginConnection::NewL()

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

//

CPresencePluginConnection* CPresencePluginConnection::NewL(

    const MXIMPServiceInfo& aServiceInfo,

    const MXIMPContextClientInfo& aClientCtxInfo )

    {

    DP_SDA("CPresencePluginConnection::NewL");

    CPresencePluginConnection* self = 

        new( ELeave ) CPresencePluginConnection( );

    CleanupStack::PushL( self );

    self->ConstructL( aServiceInfo, aClientCtxInfo );

    CleanupStack::Pop( self );    

    return self;

    }

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

// CPresencePluginConnection::NewL() loaded

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

//

CPresencePluginConnection* CPresencePluginConnection::NewL(

    const MXIMPServiceInfo& aServiceInfo,

    const MXIMPContextClientInfo& aClientCtxInfo,

    const TDesC8& aETag )

    {

    DP_SDA("CPresencePluginConnection::NewL loaded");

    CPresencePluginConnection* self = 

        new( ELeave ) CPresencePluginConnection( );

    CleanupStack::PushL( self );

    self->ConstructL( aServiceInfo, aClientCtxInfo, aETag );

    CleanupStack::Pop( self );    

    return self;

    }

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

// CPresencePluginConnection::ConstructL() loaded

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

//

void CPresencePluginConnection::ConstructL(

    const MXIMPServiceInfo& aServiceInfo,

    const MXIMPContextClientInfo& /*aClientCtxInfo*/,

    const TDesC8& aETag )

    {

    DP_SDA("CPresencePluginConnection::ConstructL loaded");

    iETag = aETag.AllocL();                  

    iSession = CPresencePluginSession::NewL( aServiceInfo, *this );

    // create instance from data class

    iPresenceData = CPresencePluginData::NewL( *this,

        aServiceInfo.IapId() ); 

    DP_SDA("ConstructL create subscribed buddy list loaded ");  

    // create another virtual group for all subscribed buddyes

    iSubscribedBuddys =

        CPresencePluginVirtualGroup::NewL( *this, 

        KPresenceBuddyList(),

        iPresenceData );

    iAuth = CPresencePluginAuthorization::NewL( *this, iPresenceData );

    iPublisher = CPresencePluginPublisher::NewL(

               *this,        

               *iSession->SimpleConnection(),

               iPresenceData );

    iWatcher = CPresencePluginWatcher::NewL(

               *this,

               *iSession->SimpleConnection(),

               iPresenceData ); 

    iGroups = CPresencePluginGroups::NewL( 

        *this, iSubscribedBuddys, iPresenceData );

    iPluginWinfo = CPresencePluginWinfo::NewL( 

                 *this, *(iSession->SimpleConnection() ));

    }    

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

// CPresencePluginConnection::ConstructL()

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

//

void CPresencePluginConnection::ConstructL(

    const MXIMPServiceInfo& aServiceInfo,

    const MXIMPContextClientInfo& /*aClientCtxInfo*/ )

    {

    DP_SDA("CPresencePluginConnection::ConstructL");

    iETag = KNullDesC8().AllocL();                  

    iSession = CPresencePluginSession::NewL( aServiceInfo, *this );

    // create instance from data class

    iPresenceData = CPresencePluginData::NewL( *this, 

        aServiceInfo.IapId() ); 

    DP_SDA("ConstructL create subscribed buddy list");	

    // create another virtual group for all subscribed buddyes

    iSubscribedBuddys =

    	CPresencePluginVirtualGroup::NewL( 

    	    *this, KPresenceBuddyList(), iPresenceData );

    iAuth = CPresencePluginAuthorization::NewL( *this, iPresenceData );

    iPublisher = CPresencePluginPublisher::NewL(

               *this,        

               *iSession->SimpleConnection(),

               iPresenceData );

    iWatcher = CPresencePluginWatcher::NewL(

               *this,

               *iSession->SimpleConnection(),

               iPresenceData ); 

    iGroups = CPresencePluginGroups::NewL( 

        *this, iSubscribedBuddys, iPresenceData );

    iPluginWinfo = CPresencePluginWinfo::NewL( 

                 *this, *(iSession->SimpleConnection() ));   

    }    

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

// CPresencePluginConnection::~CPresencePluginConnection()

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

//

CPresencePluginConnection::~CPresencePluginConnection()

    {

    DP_SDA("CPresencePluginConnection::~CPresencePluginConnection");

    delete iSipPresentity;

    iSipPresentity = NULL;

    delete iPluginWinfo;

    iPluginWinfo = NULL;

    delete iWatcher;

    iWatcher = NULL;

    delete iPublisher;

    iPublisher = NULL;

    delete iAuth;

    iAuth = NULL;

    delete iGroups;

    iGroups = NULL;

    delete iSession;

    iSession = NULL;

    delete iImFeatures;

    REComSession::FinalClose();

    delete iSubscribedBuddys;

    delete iPresenceData;

    delete iETag;

    iETag = NULL;

    DP_SDA("CPresencePluginConnection::~CPresencePluginConnection end");

    }

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

// CPresencePluginConnection::PrimeHost

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

//  

void CPresencePluginConnection::PrimeHost( 

    MXIMPProtocolConnectionHost& aHost )

    {

    DP_SDA("CPresencePluginConnection::PrimeHost");

    iConnectionHost = &aHost;

    iAuth->SetDataHost( 

        iConnectionHost->ProtocolPresenceDataHost().AuthorizationDataHost() );  

    }

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

// CPresencePluginConnection::GetOnlineBuddyGroup()

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

//

CPresencePluginVirtualGroup* CPresencePluginConnection::SubscribedContacts( )

    {

    return iSubscribedBuddys;

    }

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

// CPresencePluginConnection::GetSessionStatus()

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

//

TBool CPresencePluginConnection::GetSessionStatus( )

    {

    return iSession->ConnectionStatus();

    }

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

// CPresencePluginConnection::TupleIdGet()

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

//

TInt CPresencePluginConnection::GetTupleId() const

    {

    DP_SDA("CPresencePluginConnection::TupleIdGet");

    return iOwnTupleId;

    }

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

// CPresencePluginConnection::GetEtag()

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

//    

const TDesC8& CPresencePluginConnection::GetETag() const

    {

    DP_SDA("CPresencePluginConnection::GetETag");

    if( !iETag )

        {

        DP_SDA2("CPresencePluginConnection::GetETag empty ??? %S", iConnectionArray->GetConnectionEtag() );

        return  KNullDesC8();

        }

    return *iETag;

    }

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

// CPresencePluginConnection::SetETag()

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

//    

void CPresencePluginConnection::SetETag( const TDesC8& aETag )

    {

    DP_SDA("CPresencePluginConnection::SetETag");

    delete iETag;

    iETag = NULL;

    TRAP_IGNORE( ( iETag = aETag.AllocL() ) );

    //Add etag also in connectionArray

    iConnectionArray->SetConnectionETag( *iETag );

    }

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

// CPresencePluginConnection::SetConnectionArray()

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

//    

void CPresencePluginConnection::SetConnectionArray( 

		CPresenceConnectionInfo* aArray )

    {

    DP_SDA("CPresencePluginConnection::SetConnectionArray");

    iConnectionArray = aArray;

    iConnectionArray->SetConnectionStatus( EActive );

    }

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

// CPresencePluginConnection::GetConnectionArray()

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

//    

CPresenceConnectionInfo* CPresencePluginConnection::GetConnectionArray( )

    {

    DP_SDA("CPresencePluginConnection::GetConnectionArray");

    return iConnectionArray;

    }

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

// CPresencePluginConnection::TupleIdGet()

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

//

TInt32 CPresencePluginConnection::GetPresenceSetId() const

    {

    DP_SDA("CPresencePluginConnection::GetPresenceSetId");

    return iSession->GetPresenceSetId();

    }

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

// CPresencePluginConnection::TupleIdGet()

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

//

void CPresencePluginConnection::SetTupleId( const TInt aTupleId )

    {

    DP_SDA("CPresencePluginConnection::TupleIdSet");

    iOwnTupleId = aTupleId;

    }

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

// CPresencePluginConnection::GetStopPublishState()

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

//    

TBool CPresencePluginConnection::GetStopPublishState()

    {

    DP_SDA2("::GetStopPublishState = %d", (TInt)iStopPublishState );

    return iStopPublishState;

    }

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

// CPresencePluginConnection::SetStopPublishState()

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

// 

void CPresencePluginConnection::SetStopPublishState( TBool aState )

    {

    DP_SDA2("SetStopPublishState : aState = %d ",  (TInt)aState );

    iStopPublishState = aState;

    }

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

// CPresencePluginConnection::PresenceWatching

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

//    

MProtocolPresenceDataHost& CPresencePluginConnection::ProtocolPresenceHost()

    {

    DP_SDA("CPresencePluginConnection::ProtocolPresenceHost");

    return iConnectionHost->ProtocolPresenceDataHost();

    }

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

// CPresencePluginConnection::PresenceWatching

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

//    

MProtocolPresenceWatching& CPresencePluginConnection::PresenceWatching()

    {

    DP_SDA("CPresencePluginConnection::PresenceWatching");

    return *iWatcher;

    }

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

// CPresencePluginConnection::PresencePublishing

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

//   

 MProtocolPresencePublishing& CPresencePluginConnection::PresencePublishing()

    {

    return *iPublisher;

    }

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

// CPresencePluginConnection::PresentityGroups

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

//   

MProtocolPresentityGroups& CPresencePluginConnection::PresentityGroups()

    {

    return *iGroups;

    }

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

// CPresencePluginConnection::PresenceAuthorization

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

//   

MProtocolPresenceAuthorization& 

    CPresencePluginConnection::PresenceAuthorization()

    {

    DP_SDA2("CPresencePluginConnection::PresenceAuthorization %x", iAuth);

    return *iAuth;

    }

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

// CPresencePluginConnection::InternalPresenceAuthorization

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

//       

CPresencePluginAuthorization& 

    CPresencePluginConnection::InternalPresenceAuthorization()

    {

    DP_SDA2("CPresencePluginConnection::InternalPresenceAuthorization %x", iAuth);

    return *iAuth;

    }

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

// CPresencePluginConnection::OpenSessionL

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

//     

void CPresencePluginConnection::OpenSessionL( 

    const MXIMPContextClientInfo& /*aClientCtxInfo*/,

    TXIMPRequestId aReqId )

    {

    DP_SDA("CPresencePluginConnection::OpenSessionL");

    iGrantListSubs = ETrue; 

    iTerminatedCall = EFalse;

    iXIMPId = aReqId;

    iSession->OpenSessionL();         

    }

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

// CPresencePluginConnection::OpenSessionL

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

// 

void CPresencePluginConnection::OpenSessionL( const TInt& /*aSettingsId*/,

    TXIMPRequestId aReqId )

    {

    DP_SDA("CPresencePluginConnection::OpenSessionL 2 ");

    iXIMPId = aReqId;

    iGrantListSubs = ETrue; 

    iTerminatedCall = EFalse;

    iSession->OpenSessionL( ); 

    }

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

// CPresencePluginConnection::CloseSession

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

//    

void CPresencePluginConnection::CloseSession( 

    const MXIMPContextClientInfo& /*aContextClient*/,

    TXIMPRequestId aReqId )

    {

    DP_SDA("CPresencePluginConnection::CloseSession begin");

    TBool completeXimpRequestNow( EFalse );

    iConnectionArray->DecreaseClientCount();

    iXIMPId = aReqId;

    // Client count can´t be negative. Increase if goes negative.

    // This happens for example in network lost case.

    // This method is called then because connection is terminated and

    // for all clients which have done unbind. But here we cannot tell

    // if this method is called by clients unbind or connection termination

    // therefore this workaround needed.

    if ( iConnectionArray->ClientCount() < 0 )

        {        

        completeXimpRequestNow = ETrue;

        iConnectionArray->IncreaseClientCount();

        }

    // In case there is no more clients we cannot complete Ximp request

    // right away. We have to stop publish first, Ximp request completion is

    // handled in RunL after that is done.

    if( KErrNone == iConnectionArray->ClientCount() && 

        (EActive == iConnectionArray->GetConnectionStatus()) )

        {       

        completeXimpRequestNow = EFalse; // request is completed later in RunL

        iGrantListSubs = EFalse;

        //Start stopPublish request

        DeRegister();

        }

    if ( !iStopPublishCall )

       {

       completeXimpRequestNow = ETrue;

       }

    if ( completeXimpRequestNow )

        {

        CompleteReq( iXIMPId, KErrNone );

        }

    DP_SDA("CPresencePluginConnection::CloseSession end");

    }

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

// CPresencePluginConnection::GetSupportedFeaturesL

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

//     

void CPresencePluginConnection::GetSupportedFeaturesL( 

    CDesC8Array& aFeatures ) const

    {

    DP_SDA("CPresencePluginConnection::GetSupportedFeaturesL");

    // first empty the whole array

    aFeatures.Reset();   

    using namespace NXIMPFeature::Presence;    

    aFeatures.AppendL( KPublish );

    aFeatures.AppendL( KSubscribe );    

    aFeatures.AppendL( KUnsubscribe );  

    aFeatures.AppendL( KAddContact );

    aFeatures.AppendL( KDeleteContact );

    aFeatures.AppendL( KFetch );

    aFeatures.AppendL( KBlock );

    aFeatures.AppendL( KUnBlock );