/*
* Copyright (c) 2009 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:  
*
*/

// INCLUDE FILES
#include    "presencecacheexpiry.h"
#include    "presencecachebuddystore.h"
#include    "presencecacheserver.h"
#include    "presencecachesession.h"
#include    "mpresencebuddyinfo2.h"
#include    "presencecacheservicestore.h"


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

// -----------------------------------------------------------------------------
// CPresenceCacheExpiry::CPresenceCacheExpiry
// -----------------------------------------------------------------------------
//
inline CPresenceCacheExpiry::CPresenceCacheExpiry(
        CPresenceCacheServer& aServer )
: iAsyncCallBack( TCallBack( CPresenceCacheExpiry::ExpiryCheck, this ),
        CActive::EPriorityIdle),
  iServer( aServer )
    {
    }

// -----------------------------------------------------------------------------
// CPresenceCacheExpiry::NewL
// -----------------------------------------------------------------------------
//
CPresenceCacheExpiry* CPresenceCacheExpiry::NewL(
        CPresenceCacheServer& aServer )
    {
    return new( ELeave ) CPresenceCacheExpiry(aServer);
    }


// Destructor
CPresenceCacheExpiry::~CPresenceCacheExpiry()
    {
    iAsyncCallBack.Cancel();
    }

// -----------------------------------------------------------------------------
// CPresenceCacheExpiry::ExpiryCheck
// -----------------------------------------------------------------------------
//
TInt CPresenceCacheExpiry::ExpiryCheck(TAny *aPtr)
    {
    CPresenceCacheExpiry* self = static_cast<CPresenceCacheExpiry*>(aPtr);
    TRAP_IGNORE(self->DoExpiryCheckL());
    return EFalse;
    }

// -----------------------------------------------------------------------------
// CPresenceCacheExpiry::NotifySubscribersL
// -----------------------------------------------------------------------------
//
void CPresenceCacheExpiry::NotifySubscribersL( 
        CPresenceCacheBuddyStore& aBuddyStore )
    {
    RPointerArray<CPresenceCacheSession> sessions = 
            aBuddyStore.GetSubscribedSessions();
    const TInt sessionCount( sessions.Count() );
    MPresenceBuddyInfo2* buddyInfoTemp =  MPresenceBuddyInfo2::NewLC();
    buddyInfoTemp->SetIdentityL( aBuddyStore.BuddyId() );
    
    for( TInt i = 0 ; i < sessionCount ; ++i )
        {
        CPresenceCacheSession* session = sessions[i];
        if (iServer.SessionExists(session))
            {
            session->NotifyPresenceChangeL( buddyInfoTemp );
            }
        }
    CleanupStack::PopAndDestroy(); // buddyInfoTemp
    }

// -----------------------------------------------------------------------------
// CPresenceCacheExpiry::DoExpiryCheckL
// -----------------------------------------------------------------------------
//
void CPresenceCacheExpiry::DoExpiryCheckL()
    {
    RPointerArray<CPresenceCacheServiceStore>& presenceCache = 
            iServer.iPresenceCache;
    
    RPointerArray<CPresenceCacheBuddyStore> buddyStores;
    
    const TInt serviceCount(presenceCache.Count());
    for( TInt i = 0 ; i < serviceCount ; ++i )
        {
        presenceCache[i]->RemoveExpiredBuddyInfos( buddyStores );
        }
    
    const TInt buddyStoreCount( buddyStores.Count() );
    for( TInt i = 0 ; i < buddyStoreCount ; ++i )
        {
        NotifySubscribersL( *( buddyStores[i] ) );
        }
    }

//  End of File