/*
* Copyright (c) 2003-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:   IKEv2 protocol plugin
*
*/

#include <random.h>
#include <in_sock.h>

#include "ikev2plugin.h"
#include "ikedebug.h"
#include "ikev2pluginsession.h"
#include "ipsecpolicyutil.h"


EXPORT_C MIkePluginIf* Ikev2PlugInL( MKmdEventLoggerIf& aEventLogger,
                                     MIkeDebug& aDebug )
    {
    return CIkev2PlugIn::NewL(aEventLogger, aDebug);
    }

CIkev2PlugIn* CIkev2PlugIn::NewL( MKmdEventLoggerIf& aEventLogger,
                                  MIkeDebug& aDebug )
    {
    CIkev2PlugIn* self = new (ELeave) CIkev2PlugIn(aEventLogger, aDebug);
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self);
    return self;
    }
    

CIkev2PlugIn::CIkev2PlugIn( MKmdEventLoggerIf& aEventLogger,
                            MIkeDebug& aDebug )
: iEventLogger(aEventLogger), iDebug(aDebug)
    {
    }


void CIkev2PlugIn::ConstructL()
    {    
    iPfKeySocketIf = CPFKeySocketIf::NewL(this, iDebug);    
    iIpsecPolicyUtil = CIpsecPolicyUtil::NewL();
    }
    
    
CIkev2PlugIn::~CIkev2PlugIn()
    {
    delete iIpsecPolicyUtil;
    delete iPfKeySocketIf;
    
    __ASSERT_DEBUG( iPluginSessions.Count() == 0,
                    User::Invariant() );       
    iPluginSessions.Close();    	  
    }


MIkePluginSessionIf* CIkev2PlugIn::CreateSessionL( TUint32 aVpnIapId,
                                                   TUint32 aVpnNetId,
                                                   TUint32 aVpnInterfaceIndex,
                                                   MIkeDataInterface& aIkeDataInterface )
    {
    CIkev2PluginSession* pluginSession = CIkev2PluginSession::NewL( aVpnIapId,
                                                                    aVpnNetId,
                                                                    aVpnInterfaceIndex,
                                                                    aIkeDataInterface,
                                                                    *this,
                                                                    *iPfKeySocketIf,
                                                                    *iIpsecPolicyUtil,
                                                                    iEventLogger,
                                                                    iDebug ); 
    TInt err = iPluginSessions.Append( pluginSession );
    
    if ( err != KErrNone )
        {
        delete pluginSession;
        pluginSession = NULL;
        User::Leave( err );
        }
    
    return pluginSession;    
    }

void CIkev2PlugIn::PluginSessionDeleted(const MIkePluginSessionIf* aDeletedSession)
    {
    for (TInt i = 0; i < iPluginSessions.Count(); ++i)
        {
            if (iPluginSessions[i] == aDeletedSession)
                {
                iPluginSessions.Remove(i);
                }
        }
    }

void CIkev2PlugIn::PfkeyMessageReceived( const TPfkeyMessage& aPfkeyMessage )
    {    
    switch ( aPfkeyMessage.iBase.iMsg->sadb_msg_type )
        {
        case SADB_ADD: // Fall through
        case SADB_ACQUIRE:
            {
            for ( TInt i=0; i< iPluginSessions.Count(); i++ )
                {
                if ( iPluginSessions[i]->MatchDestinationAddress( aPfkeyMessage.iDstAddr.Address() ) )                
                    {
                    iPluginSessions[i]->PfkeyMessageReceived( aPfkeyMessage );
                    break;
                    }
                }
            break;
            }
            
        case SADB_EXPIRE:
            {
            for ( TInt i=0; i< iPluginSessions.Count(); i++ )
                {
                if ( iPluginSessions[i]->MatchDestinationAddress( aPfkeyMessage.iSrcAddr.Address() ) )                
                    {
                    iPluginSessions[i]->PfkeyMessageReceived( aPfkeyMessage );
                    break;
                    }
                }
            break;                        
            }
        default:
            break;
        }        
    }