/*

* 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 <e32std.h>

#include <ximpdatasubscriptionstate.h>

#include <protocolpresentitygroupsdatahost.h>

#include <protocolpresencedatahost.h>

#include <ximpobjectfactory.h>

#include <presenceobjectfactory.h>

#include <ximpstatus.h>

#include <ximpidentity.h>

#include <ximpobjectcollection.h>

#include <xdmerrors.h>

#include <presentitygroupinfo.h>

#include <presentitygroupmemberinfo.h>

#include <utf.h>

#include <avabilitytext.h>

#include "mpresencepluginconnectionobs.h"

#include "presenceplugingroup.h"

#include "presencepluginxdmutils.h"

#include "presenceplugincommon.h"

#include "presencepluginvirtualgroup.h"

#include "presenceplugindata.h"

#include "presencepluginwatcher.h"

#include "presencepluginauthorization.h"

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

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

// CPresencePluginGroups::CPresencePluginGroups

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

//

CPresencePluginGroups::CPresencePluginGroups(

    MPresencePluginConnectionObs& aObs,

    CPresencePluginVirtualGroup* aSubscribedBuddies,

    CPresencePluginData* aPresenceData ):

  	CActive( CActive::EPriorityStandard ),

  	iConnObs(aObs),

  	iOperation( ENoOperation),

  	iState( EPluginIdle ), iCompleted( ETrue ),

  	iSubscribedBuddies( aSubscribedBuddies ),

  	iPresenceData( aPresenceData )

    {

    CActiveScheduler::Add( this );

    }

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

// CPresencePluginGroups::NewL

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

//

CPresencePluginGroups* CPresencePluginGroups::NewL(

    MPresencePluginConnectionObs& aObs,

    CPresencePluginVirtualGroup* aSubscribedBuddies,

    CPresencePluginData* aPresenceData )

    {

    CPresencePluginGroups* self =

        CPresencePluginGroups::NewLC( 

             aObs,

             aSubscribedBuddies,

             aPresenceData );    

    CleanupStack::Pop( self );

    return self;

    }

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

// CPresencePluginGroups::NewLC

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

//

CPresencePluginGroups* CPresencePluginGroups::NewLC(

    MPresencePluginConnectionObs& aObs,

    CPresencePluginVirtualGroup* aSubscribedBuddies,

    CPresencePluginData* aPresenceData )

    {

    CPresencePluginGroups* self =

        new( ELeave ) CPresencePluginGroups( 

             aObs,

             aSubscribedBuddies,

             aPresenceData );

    CleanupStack::PushL( self );

    return self;

    }

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

// CPresencePluginGroups::~CPresencePluginGroups

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

//

CPresencePluginGroups::~CPresencePluginGroups()

    {

    DP_SDA("CPresencePluginGroups::~CPresencePluginGroups");

    Cancel();

    delete iPresIdentity;

    delete iDisplayName;

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

    }

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

// CPresencePluginGroups::DoSubscribePresentityGroupListL

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

//

void CPresencePluginGroups::DoSubscribePresentityGroupListL(

    TXIMPRequestId aReqId )

    {

    DP_SDA("CPresencePluginGroups::DoSubscribePresentityGroupListL");

    iCompleted = EFalse;

    // List of lists under buddylist

    StartXdmOperationL( aReqId, EGetListOfLists );

    }

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

// CPresencePluginGroups::DoUnsubscribePresentityGroupListL

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

//

void CPresencePluginGroups::DoUnsubscribePresentityGroupListL(

    TXIMPRequestId /*aReqId*/ )

    {

    User::Leave( KErrNotSupported );

    }

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

// CPresencePluginGroups::DoCreatePresentityGroupL

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

//

void CPresencePluginGroups::DoCreatePresentityGroupL(

    const MXIMPIdentity& /*aGroupId*/,

    const TDesC16& /*aDisplayName*/,

    TXIMPRequestId /*aReqId*/ )

    {

    User::Leave( KErrNotSupported );

    }

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

// CPresencePluginGroups::DoDeletePresentityGroupL

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

//

void CPresencePluginGroups::DoDeletePresentityGroupL(

    const MXIMPIdentity& /*aGroupId*/,

    TXIMPRequestId /*aReqId*/ )

    {

    User::Leave( KErrNotSupported );

    }

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

// CPresencePluginGroups::DoUpdatePresentityGroupDisplayNameL

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

//

void CPresencePluginGroups::DoUpdatePresentityGroupDisplayNameL(

    const MXIMPIdentity& /*aGroupId*/,

    const TDesC16& /*aDisplayName*/,

    TXIMPRequestId /*aReqId*/ )

    {

    // Notice: later

    User::Leave( KErrNotSupported );

    }

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

// CPresencePluginGroups::DoSubscribePresentityGroupContentL

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

//

void CPresencePluginGroups::DoSubscribePresentityGroupContentL(

    const MXIMPIdentity& aGroupId,

    TXIMPRequestId aReqId )

    {

    DP_SDA("CPresencePluginGroups::DoSubscribePresentityGroupContentL");

    iCompleted = EFalse;

    // List of lists under buddylist

    StartXdmOperationL( aGroupId, aReqId, EGetListContent );

    }

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

// CPresencePluginGroups::DoUnsubscribePresentityGroupContentL

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

//

void CPresencePluginGroups::DoUnsubscribePresentityGroupContentL(

    const MXIMPIdentity& /*aGroupId*/,

    TXIMPRequestId aReqId )

    {

    DP_SDA("CPresencePluginGroups::DoUnsubscribePresentityGroupContentL");

    iXIMPId = aReqId;

    iConnObs.WatcherHandlerL()->UnSubscribeAllL();    

    iCompleted = EFalse;

    CompleteXIMPReq( KErrNone );

    DP_SDA("CPresencePluginGroups::DoUnsubscribePresentityGroupContentL out");

    }

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

// CPresencePluginGroups::DoAddPresentityGroupMemberL

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

//

void CPresencePluginGroups::DoAddPresentityGroupMemberL(

    const MXIMPIdentity& aGroupId,

    const MXIMPIdentity& aMemberId,

    const TDesC16& /*aMemberDisplayName*/,

    TXIMPRequestId aReqId )

    {

    DP_SDA("CPresencePluginGroups::DoAddPresentityGroupMemberL");

    __ASSERT_ALWAYS( !IsActive(), User::Leave( KErrNotReady ) );

    SetPresIdentityL( aMemberId, ETrue );

    iCompleted = EFalse;

    iXIMPId = aReqId;

    if( !aGroupId.Identity().Compare( KPresenceBuddyList ) )

        {

        DP_SDA("CPresencePluginGroups::DoAddPresentityGroupMemberL - buddylist");

        iOperation = EAddPresentityGroupMember;

        // write pending to presence cache

        TBuf<20> buf;

        buf.Copy( KPendingRequestExtensionValue );

        iPresenceData->WriteStatusToCacheL( aMemberId.Identity(), 

            MPresenceBuddyInfo2::ENotAvailable,

            buf,

            KNullDesC() ); 

        iConnObs.WatcherHandlerL()->DoPerformSubscribePresentityPresenceL( 

            aMemberId, iStatus );

        SetActive();

        }

    else if ( !aGroupId.Identity().Compare( KPresenceBlockedList ) )

        {

        DP_SDA("CPresencePluginGroups::DoAddPresentityGroupMemberL - blockedlist");

        iOperation = EBlockPresentityGroupMember;

        iConnObs.InternalPresenceAuthorization().

            DoPerformBlockPresenceForPresentityL( aMemberId, iStatus );

        SetActive();

        }

    else

        {

        DP_SDA("CPresencePluginGroups::DoAddPresentityGroupMemberL - unknown, leave");

        User::Leave( KErrNotSupported );

        }

    DP_SDA("CPresencePluginGroups::DoAddPresentityGroupMemberL out");

    }

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

// CPresencePluginGroups::DoRemovePresentityGroupMemberL

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

//

void CPresencePluginGroups::DoRemovePresentityGroupMemberL(

    const MXIMPIdentity& aGroupId,

    const MXIMPIdentity& aMemberId,

    TXIMPRequestId aReqId )

    {

    DP_SDA("CPresencePluginGroups::DoRemovePresentityGroupMemberL");

    __ASSERT_ALWAYS( !IsActive(), User::Leave( KErrNotReady ) );

    SetPresIdentityL( aMemberId, ETrue );

    iCompleted = EFalse;

    iXIMPId = aReqId;

    iOperation = ERemovePresentityGroupMember;

    if( !aGroupId.Identity().Compare( KPresenceBuddyList ) )

        {

        DP_SDA(" DoRemovePresentityGroupMemberL - buddylist");

        iConnObs.WatcherHandlerL()->DoPerformUnsubscribePresentityPresenceL( 

            aMemberId, iStatus );

        SetActive();

        }

    else if ( !aGroupId.Identity().Compare( KPresenceBlockedList ) )

        {

        DP_SDA(" DoRemovePresentityGroupMemberL - blockedlist");

        iOperation = EUnblockPresentityGroupMember;

        iConnObs.InternalPresenceAuthorization().

            DoPerformCancelPresenceBlockFromPresentityL( aMemberId, iStatus );

        SetActive();

        }

    else

        {

        DP_SDA("DoRemovePresentityGroupMemberL - unknown, leave");

        User::Leave( KErrNotSupported );

        }

    DP_SDA("CPresencePluginGroups::DoRemovePresentityGroupMemberL out");    

    }

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

// CPresencePluginGroups::DoUpdatePresentityGroupMemberDisplayNameL

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

//

void CPresencePluginGroups::DoUpdatePresentityGroupMemberDisplayNameL(

    const MXIMPIdentity& /*aGroupId*/,

    const MXIMPIdentity& /*aMemberId*/,

    const TDesC16& /*aMemberDisplayName*/,

    TXIMPRequestId /*aReqId*/ )

    {

    DP_SDA("CPresencePluginGroups::DoUpdatePresentityGroupMemberDisplayNameL");

    // Notice: Later

    User::Leave( KErrNotSupported );

    }

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

// CPresencePluginGroups::DoCancel()

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

//

void CPresencePluginGroups::DoCancel(  )

    {

    if ( iOperation != ENoOperation )

        {

        iXdmUtils->Cancel();

        }

    }

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

// CPresencePluginGroups::RunL()

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

//

void CPresencePluginGroups::RunL()

    {

    DP_SDA("CPresencePluginGroups::RunL");

    TInt myStatus = iStatus.Int();

    DP_SDA2("CPresencePluginGroups::RunL myStatus %d", myStatus );

    if ( !myStatus && !iCompleted )

        {

        DP_SDA("CPresencePluginGroups::RunL !myStatus");

        // OK response

        CallActualXdmOperationL( myStatus );

        }

    else if ( !myStatus && iCompleted )

        {

        DP_SDA("CPresencePluginGroups::RunL SEND COMPLETE");

        CompleteXIMPReq( myStatus );

        }

    else

        {

        if ( iOperation == EDeletePresentityGroup && iState ==

        	EPluginCommitRls )

            {

            DP_SDA("CPresencePluginGroups::RunL CallActualXdmOperation");

            CallActualXdmOperationL( myStatus );

            }

        else

            {

            DP_SDA("CPresencePluginGroups::RunL SEND COMPLETE 2");

            // Other errors terminated the show

            CompleteXIMPReq( myStatus );

            }

        }

    }

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

// CPresencePluginGroups::CallActualXdmOperationL

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

//

void CPresencePluginGroups::CallActualXdmOperationL( TInt aCompleteStatus )

    {

    DP_SDA("CPresencePluginGroups::CallActualXdmOperationL");

    DP_SDA2("CallActualXdmOperationL iOperation %d", iOperation);

    switch ( iOperation )

        {

        case EGetListOfLists:

            {

            DP_SDA("PluginGroups::CallActualXdmOperationL EGetListOfLists");

            iOperation = EGetListOfLists;

            GetListOfListsL();

            }

            break;

        case EGetListContent:

            {

            DP_SDA("PluginGroups::CallActualXdmOperationL EGetListContent");

            iOperation = EGetListContent;

            GetListContentL();

            }

            break;

        case EAddPresentityGroupMember:

            {

            DP_SDA(" CallActualXdmOperationL EAddPresentityGroupMember");

            iOperation = EGrantPresentityGroupMember;

            MXIMPIdentity* newIdentity = 

                iConnObs.ObjectFactory().NewIdentityLC();

            newIdentity->SetIdentityL( *iPresIdentity );

            iConnObs.InternalPresenceAuthorization().

                DoPerformGrantPresenceForPresentityL( *newIdentity, iStatus );

            CleanupStack::PopAndDestroy(); // >> newIdentity

            SetActive();

            }

            break;

        case ERemovePresentityGroupMember:

            {

            DP_SDA(" CallActualXdmOperationL ERemovePresentityGroupMember");

            iOperation = EWithdrawGrantFromMember;

            MXIMPIdentity* newIdentity = iConnObs.ObjectFactory().NewIdentityLC();

            newIdentity->SetIdentityL( *iPresIdentity );

            iConnObs.InternalPresenceAuthorization().

                DoPerformWithdrawPresGrantFromPresentityL( 

                    *newIdentity, iStatus );

            CleanupStack::PopAndDestroy(); // >> newIdentity

            SetActive();

            }

            break;

        case EGrantPresentityGroupMember:

            {

            DP_SDA(" CallActualXdmOperationL EGrantPresentityGroupMember");

            CompleteXIMPReq( aCompleteStatus );

            }

            break;

        case EWithdrawGrantFromMember:

            {

            DP_SDA(" CallActualXdmOperationL EWithdrawGrantFromMember");

            if ( !aCompleteStatus )

                {

                DP_SDA(" -> succesfully unblocked, store to cache");

                DeletePersonCacheL();                

                DP_SDA(" -> store info to cache done");                

                }            

            CompleteXIMPReq( aCompleteStatus );

            }

            break;

        case EBlockPresentityGroupMember:

            {

            DP_SDA(" CallActualXdmOperationL EBlockPresentityGroupMember");

            if ( !aCompleteStatus )

                {

                DP_SDA(" -> succesfully blocked, store to cache");

                DP_SDA(" -> strip prefix from uri");

                HBufC* withoutPrefix = iPresenceData->RemovePrefixLC( 

                    *iPresIdentity );

                DP_SDA(" -> store info to cache");

                TBuf<20> buf;

                buf.Copy( KBlockedExtensionValue );

                iPresenceData->WriteStatusToCacheL( *withoutPrefix, 

                    MPresenceBuddyInfo2::EUnknownAvailability,

                    buf,

                    KNullDesC() );

                CleanupStack::PopAndDestroy( withoutPrefix );

                DP_SDA(" -> store info to cache done");

                }

            CompleteXIMPReq( aCompleteStatus );

            }

            break;

        case EUnblockPresentityGroupMember:

            {

            DP_SDA(" CallActualXdmOperationL EUnblockPresentityGroupMember");

            if ( !aCompleteStatus )

                {

                DP_SDA(" -> succesfully unblocked, store to cache");

                DeletePersonCacheL();                

                DP_SDA(" -> store info to cache done");                

                }            

            CompleteXIMPReq( aCompleteStatus );

            }

            break;

        default:

            User::Leave( KErrNotSupported );

            break;

        }   

    DP_SDA("CPresencePluginGroups::CallActualXdmOperationL end");

    }

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

// CPresencePluginGroups::RunError

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

//

TInt CPresencePluginGroups::RunError( TInt aError )

    {

    DP_SDA("CPresencePluginGroups::RunError SEND COMPLETE");

    // complete the open request

    CompleteXIMPReq( aError );

    return KErrNone;

    }

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

// CPresencePluginGroups::GetInterface()

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

//

TAny* CPresencePluginGroups::GetInterface(

    TInt32 aInterfaceId,

    TIfGetOps aOptions )

    {

    if ( aInterfaceId == GetInterfaceId() )

        {

        // caller wants this interface

        MProtocolPresentityGroups* myIf = this;

        return myIf;

        }

    if ( aOptions == MXIMPBase::EPanicIfUnknown )

        {

        User::Panic( KPluginName, KErrExtensionNotSupported );

        }

    return NULL;

    }

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

// CPresencePluginGroups::GetInterface()

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

//

const TAny* CPresencePluginGroups::GetInterface(

    TInt32 aInterfaceId,

    TIfGetOps aOptions ) const

    {

    if ( aInterfaceId == GetInterfaceId() )

        {