/*

 * Copyright (c) 2007 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 "cautils.h"

#include "caclientnotifiersession.h"

#include "caclientsubsession.h"

#include "cainnerentry.h"

#include "cainnerquery.h"

#include "caidsarray.h"

#include "caentriesarray.h"

#include "caclientnotifierproxy.h"

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

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

//

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

//

TUint32 RCaClientNotifierSession::HashFunc(const TKey& key)

    {

    return reinterpret_cast<TUint>(key.iFilterAddress) + key.iNotifierType;

    }

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

//

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

//

TBool RCaClientNotifierSession::IdentityFunc(const TKey& key1,

        const TKey& key2)

{

    return key1.iFilterAddress == key2.iFilterAddress &&

        key1.iNotifierType == key2.iNotifierType;

}

const THashFunction32<RCaClientNotifierSession::TKey>

        RCaClientNotifierSession::iHashFunction(

            RCaClientNotifierSession::HashFunc);

const TIdentityRelation<RCaClientNotifierSession::TKey>

        RCaClientNotifierSession::iIdentityRelation(

            RCaClientNotifierSession::IdentityFunc);

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

// RCaClientNotifierSession::RCaClientNotifierSession

// C++ default constructor can NOT contain any code, that

// might leave.

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

//

RCaClientNotifierSession::RCaClientNotifierSession() :

    RSessionBase(), iSubsessions(iHashFunction, iIdentityRelation)

{

    // No implementation required

}

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

// RCAClientSession::Connect

// Connect to Content publisher server session.

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

//

TInt RCaClientNotifierSession::Connect()

{

    TInt error =

            CreateSession(KCaSrvName, Version(), KDefaultMessageSlots);

    if (error == KErrNone) {

        ShareAuto();

    }

    return error;

}

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

//

//

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

//

void RCaClientNotifierSession::Close()

{

    RHashMap<TKey, RCaClientSubSession*>::TIter iter(iSubsessions);

    while(iter.NextValue()) {

        (*iter.CurrentValue())->Close();

    }

    iSubsessions.Close();

    RSessionBase::Close();

}

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

//

//

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

//

TInt RCaClientNotifierSession::RegisterNotifier(

        CCaInnerNotifierFilter* innerNotifierFilter,

        const TAny* notifierFilter,

        const CaClientNotifierProxy* notifierProxy)

{

    TRAPD(error, RegisterNotifierL(innerNotifierFilter,

                    notifierFilter,

                    notifierProxy));

    return error;

}

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

//

//

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

//

void RCaClientNotifierSession::RegisterNotifierL(

        CCaInnerNotifierFilter* innerNotifierFilter,

        const TAny* notifierFilter,

        const CaClientNotifierProxy *notifierProxy)

{

    RCaClientSubSession* subsession = new RCaClientSubSession(this,

            notifierProxy, innerNotifierFilter);

    CleanupClosePushL(*subsession);

    subsession->CreateL();

    TKey key(notifierFilter, innerNotifierFilter->GetNotifierType());

    iSubsessions.InsertL(key, subsession);

    CleanupStack::Pop(subsession);

}

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

//

//

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

//

void RCaClientNotifierSession::UnregisterNotifier(

        const TAny* notifierFilter,

        CCaInnerNotifierFilter::TNotifierType innerNotifierType)

{

    TKey key(notifierFilter, innerNotifierType);

    RCaClientSubSession** subsession = iSubsessions.Find(key);

    if (subsession) {

        (*subsession)->Close();

        delete (*subsession);

        iSubsessions.Remove(key);

    }

}

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

//

//

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

//

TInt RCaClientNotifierSession::SubsessionsCount() const

{

    return iSubsessions.Count();

}

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

//

//

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

//

TBool RCaClientNotifierSession::ContainsSubsession(

        const TAny* notifierFilter,

        CCaInnerNotifierFilter::TNotifierType innerNotifierType) const

{

    TKey key(notifierFilter, innerNotifierType);

    return iSubsessions.Find(key) != NULL;

}

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

// RCPServerClient::Version

// Version information.

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

//

TVersion RCaClientNotifierSession::Version() const

{

    return (TVersion(KCaMajorVersion, KCaMinorVersion, KCaBuild));

}