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

/**
 @file ss_transporthook.CPP
*/

#include "ss_transporthook.h"
#include <comms-infras/metatype.h>
#include <comms-infras/ss_log.h>
#include <ss_glob.h>
#include <comms-infras/ss_thread.h>
#include <comms-infras/ss_nodeinterfaces.h>


using namespace ESock;
using namespace Meta;
using namespace CommsFW;
using namespace Messages;


//TODO[PROD] - reimplement hooks?
#if 0

#ifdef _DEBUG
// Panic category for "absolutely impossible!" vanilla ASSERT()-type panics from this module
// (if it could happen through user error then you should give it an explicit, documented, category + code)
_LIT(KSpecAssert_ESockSSockstrnsp, "ESockSSockstrnsp");
#endif

//class TCFRegisterMessageHook : public TCFRegisterHookSignal
EXPORT_C TCFRegisterMessageHook::TCFRegisterMessageHook(const TNodeId& aSenderId, TUint aActivityId, const TNodeSignal::TMessageId& aMessageId):
    TCFRegisterHookSignal( Messages::TSignatureBase::TypeId() ),
    iMessageId(aMessageId),
    iActivityId(aActivityId)
    {
    SetClientId(aSenderId());
    }

EXPORT_C CCFHookEntry* TCFRegisterMessageHook::NewHookEntryL() const
    {
    return new(ELeave)CCFMessageHookEntry(iMessageId,iActivityId,TNodeId(iNode),TNodeId(ClientId()));
    }

EXPORT_C void TCFRegisterMessageHook::Error(TAny* aItf, TInt aError)
    {
    Messages::ANode* itf = static_cast<Messages::ANode*>(aItf);
    TNodeId itfid = itf ? itf->NodeId() : TNodeId::NullCommsId();
    TCFMessage::TRegisterHookError(itfid,iActivityId,iMessageId,aError).PostTo(TNodeId(ClientId()));
    }

//class TCFDeregisterMessageHook : public TCFDeregisterHookSignal
EXPORT_C TCFDeregisterMessageHook::TCFDeregisterMessageHook(const TNodeId& aSenderId, const TNodeSignal::TMessageId& aMessageId):
    TCFDeregisterHookSignal(Messages::TSignatureBase::TypeId()),
    iMessageId(aMessageId)
    {
    SetClientId(aSenderId());
    }

//class TTransportHookError : public Messages::TSignatureBase
TInt TTransportHookError::VerifyDestination(const CommsFW::TCookie& aDestination, CommsFW::MTransportReceiver& aTransport)
    {
    //deregister local tag if any
    TCFDeregisterMessageHook dereg(static_cast<const TNodeId&>(TNodeId(aDestination)),iHookedMessageId);
    dereg.DeregisterLocalTag(aTransport);
    return Messages::TSignatureBase::VerifyDestination(aDestination, aTransport);
    }

//class CCFMessageHooks : public CCFTransportHooks
void CCFMessageHooks::WalkHooks( const TCFSignalBase& aMessage, const TCookie& aRecipient )
    {//place to optimise wlak before calling the base class
    CCFTransportHooks::WalkHooks( aMessage, aRecipient );
    }

void CCFMessageHooks::RegisterL( const CommsFW::TCFRegisterHookSignal& aMessage )
    {//place to do some extra stuff for look-up optimisation
    CCFTransportHooks::RegisterL( aMessage );
    }

void CCFMessageHooks::Deregister( const CommsFW::TCFDeregisterHookSignal& aMessage )
    {//place to undo some extra stuff done for look-up optimisation
    CCFTransportHooks::Deregister( aMessage );
    }

//class CCFMessageHookEntry : public CCFHookEntry
EXPORT_C CCFMessageHookEntry::CCFMessageHookEntry( const TNodeSignal::TMessageId& aMessageId, TInt aActivityId, const TNodeId& aNode, const TNodeId& aListener ) :
    CCFHookEntry(Messages::TSignatureBase::TypeId(),aNode(),aListener()),
    iMessageId(aMessageId),
    iActivityId(aActivityId)
    {
	LOG(ESockLog::Printf(KESockMessageHook, _L("CCFMessageHookEntry [this=%08x]:\t Registered [aMessagedId=%d] [aActivityId=%d] [aNode=%08x] [aListener=%08x]"),
	    this, aMessageId.MessageId(), aActivityId, aNode.Printable(), aListener.Printable()));
    }

EXPORT_C TBool CCFMessageHookEntry::Match(const CommsFW::TCFSignalBase& aMessage, const TCookie& aRecipient)
    {
    return CCFHookEntry::Match( aMessage, aRecipient ) && static_cast<const Messages::TSignatureBase&>(aMessage).MessageId() == iMessageId;
    }

EXPORT_C void CCFMessageHookEntry::Notify(const CommsFW::TCFSignalBase& aMessage) const
    {
    __ASSERT_DEBUG(aMessage.IsTypeOf(TNodeSignal::TypeId()), User::Panic(KSpecAssert_ESockSSockstrnsp, 1));
	TNodeSignal& sig = static_cast<TNodeSignal&>(const_cast<CommsFW::TCFSignalBase&>(aMessage));
	TInt activityId = sig.ActivityId();
	sig.SetActivity(iActivityId);
	CCFHookEntry::Notify(sig);
	sig.SetActivity(activityId);
    }

EXPORT_C TBool CCFMessageHookEntry::Match( const TCFDeregisterHookSignal& aReq ) const
    {
    return CCFHookEntry::Match( aReq );
    }

#endif