/*

* Copyright (c) 2004-2005 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* 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:

*

*

*/

#define TRACE_PREFIX "WSOCK: Agent: "

#include "wsock.h"

#include "WinsockAgent.h"

#include "WinsockAgentCallback.h"

#include "WinsockProtocolFamily.h"

#ifdef SYMBIAN_NETWORKING_PLATSEC

#define ACCESS_METHOD1(_ret,_what,_p1) \

    _ret CWinsockAgent::Do##_what(_p1, const RMessagePtr2* /*aMessage*/ )

#define ACCESS_METHOD2(_ret,_what,_p1,_p2) \

    _ret CWinsockAgent::Do##_what(_p1, _p2, const RMessagePtr2* /*aMessage*/ )

#else /* SYMBIAN_NETWORKING_PLATSEC */

#define ACCESS_METHOD1(_ret,_what,_p1) \

    _ret CWinsockAgent::_what(_p1)

#define ACCESS_METHOD2(_ret,_what,_p1,_p2) \

    _ret CWinsockAgent::_what(_p1,_p2)

#endif /* SYMBIAN_NETWORKING_PLATSEC */

// Settings

_LIT(KIfName,"IfName");                 // IF_NAME

_LIT(KIfNetworks,"IfNetworks");         // SERVICE_IF_NETWORKS

_LIT(KIAPBearerType,"IAP\\IAPBearerType");

_LIT(KIAPServiceType,"IAP\\IAPServiceType");

_LIT(KIAPName,"IAP\\Name");

_LIT(KIAPId,"IAP\\Id");

_LIT(KIAPService,"IAP\\IAPService");

_LIT(KIAPNetwork,"IAP\\IAPNetwork");

_LIT(KLANBearerName,"LANBearer\\Name");

_LIT(KLANBearerLastSocketActivityTimeout,"LANBearer\\LastSocketActivityTimeout");

_LIT(KLANBearerLastSocketActivityTimeout2,"LastSocketActivityTimeout");

_LIT(KLANBearerLastSessionClosedTimeout,"LANBearer\\LastSessionClosedTimeout");

_LIT(KLANBearerLastSessionClosedTimeout2,"LastSessionClosedTimeout");

_LIT(KLANBearerLastSocketClosedTimeout,"LANBearer\\LastSocketClosedTimeout");

_LIT(KLANBearerLastSocketClosedTimeout2,"LastSocketClosedTimeout");

CWinsockAgent* CWinsockAgent::NewL()

{

    CWinsockAgent* self = new(ELeave)CWinsockAgent;

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

}

CWinsockAgent::CWinsockAgent()

{

}

CWinsockAgent::~CWinsockAgent()

{

    if (iConnector)

    {

        iConnector->Cancel();

        delete iConnector;

    }

    if (iDisconnector)

    {

        iDisconnector->Cancel();

        delete iDisconnector;

    }

}

void CWinsockAgent::ConstructL()

{

    WsockCheckCommDbL(iIapId, iIapNetwork, iIapService, iIapBearer);

}

void CWinsockAgent::Info(TNifAgentInfo& aInfo) const

{

    aInfo.iVersion = TVersion(1,0,0);

    aInfo.iName = KWinsockAgent;

}

void CWinsockAgent::Connect(TAgentConnectType aType)

{

    Connect(aType, NULL);

}

void CWinsockAgent::Connect(TAgentConnectType DEBUG_ONLY(aType), 

                            CStoreableOverrideSettings* /*aOverride*/)

{

    TRACE1("Connect(%d)",aType);

    ASSERT(iNotify);

    ScheduleConnectNotification();

    iNotify->ServiceStarted();

}

void CWinsockAgent::CancelConnect()

{

    TRACE("CancelConnect()");

    CancelConnectNotification();

}

void CWinsockAgent::Reconnect()

{

    TRACE("Reconnect()");

    ScheduleConnectNotification();

}

void CWinsockAgent::CancelReconnect()

{

    TRACE("CancelReconnect()");

    CancelConnectNotification();

}

void CWinsockAgent::Authenticate(TDes& /*aUsername*/, TDes& /*aPassword*/)

{

    TRACE("Authenticate()");

    ASSERT(iNotify);

    iNotify->AuthenticateComplete(KErrNone);

}

void CWinsockAgent::CancelAuthenticate()

{

    TRACE("CancelAuthenticate()");

}

void CWinsockAgent::Disconnect(TInt aReason)

{

    TRACE1("Disconnect(%d)",aReason);

    iDisconnectReason = aReason;

    if (!iDisconnector)

    {

        iDisconnector = new CWinsockAgentCallback(this,DisconnectComplete);

    }

    if (iDisconnector)

    {

        // Schedule asynchronous disconnect notification

        ASSERT(iDisconnector->Agent() == this);

        iDisconnector->InvokeLater();

    }

}

TInt CWinsockAgent::GetExcessData(TDes8& aBuffer)

{

    TRACE("GetExcessData()");

    aBuffer.SetLength(0);

    return KErrNone;

}

ACCESS_METHOD2(TInt, ReadInt, const TDesC& aField, TUint32& aValue)

{

    if (aField == KIAPId)

    {

        aValue = iIapId;

    }

    else if (aField == KIAPNetwork)

    {

        aValue = iIapNetwork;

    }

    else if (aField == KIAPService)

    {

        aValue = iIapService;

    }

    else if (aField == KLANBearerLastSocketActivityTimeout ||

             aField == KLANBearerLastSocketActivityTimeout2)

    {

        aValue = KWinsockSocketActivityTimeout;

    }

    else if (aField == KLANBearerLastSessionClosedTimeout ||

             aField == KLANBearerLastSessionClosedTimeout2)

    {

        aValue = KWinsockSessionClosedTimeout;

    }

    else if (aField == KLANBearerLastSocketClosedTimeout ||

             aField == KLANBearerLastSocketClosedTimeout2)

    {

        aValue = KWinsockSocketClosedTimeout;

    }

    else

    {

        TRACE1("ReadInt(%S)  -> KErrNotFound",&aField);

        return KErrNotFound;

    }

    TRACE2("ReadInt(%S) = %d",&aField,aValue);

    return KErrNone;

}

ACCESS_METHOD2(TInt, WriteInt, const TDesC& DEBUG_ONLY(aField), 

               TUint32 DEBUG_ONLY(aValue))

{

    TRACE2("WriteInt(%S,%d)",&aField,aValue);

    return KErrNotSupported;

}

ACCESS_METHOD2(TInt, ReadDes, const TDesC& DEBUG_ONLY(aField), 

               TDes8& /*aValue*/)

{

    TRACE1("ReadDes8(%S)",&aField);

    return KErrNotFound;

}

ACCESS_METHOD2(TInt, WriteDes, const TDesC& DEBUG_ONLY(aField),

               const TDesC8& /*aValue*/)

{

    TRACE1("WriteDes8(%S)",&aField);

    return KErrNotSupported;

}

ACCESS_METHOD2(TInt, ReadDes, const TDesC& aField, TDes16& aValue)

{

    if (aField == KIfName)

    {

        aValue = KWinsockInterface;

    }

    else if (aField == KIfNetworks)

    {

        CWinsockProtocolFamily::ProtocolNames(aValue);

    }

    else if (aField == KIAPBearerType)

    {

        aValue = KWinsockBearerType;

    }

    else if (aField == KIAPServiceType)

    {

        aValue = KWinsockServiceType;

    }

    else if (aField == KIAPName)

    {

        aValue = KWinsockAPName;

    }

    else if (aField == KLANBearerName)

    {

        aValue = KWinsockBearerName;

    }

    else 

    {

        TRACE1("ReadDes16(%S) -> KErrNotFound",&aField);

        return KErrNotFound;

    }

    TRACE2("ReadDes16(%S) = %S",&aField,&aValue);

    return KErrNone;

}

ACCESS_METHOD2(TInt, WriteDes, const TDesC& DEBUG_ONLY(aField),

               const TDesC16& /*aValue*/)

{

    TRACE1("WriteDes16(%S)",&aField);

    return KErrNotSupported;

}

ACCESS_METHOD2(TInt, ReadBool, const TDesC& DEBUG_ONLY(aField),

               TBool& /*aValue*/)

{

    TRACE1("ReadBool(%S)",&aField);

    return KErrNotFound;

}

ACCESS_METHOD2(TInt, WriteBool, const TDesC& DEBUG_ONLY(aField),

               TBool DEBUG_ONLY(aValue))

{

    TRACE2("WriteBool(%S,%d)",&aField,aValue);

    return KErrNotSupported;

}

ACCESS_METHOD1(HBufC*, ReadLongDesLC, const TDesC& DEBUG_ONLY(aField))

{

    TRACE1("ReadLongDesLC(%S)",&aField);

    return NULL;

}

TInt CWinsockAgent::Notification(TNifToAgentEventType DEBUG_ONLY(aEvent),

                                 TAny* /*aInfo*/)

{

    TRACE1("Notification(%d)",aEvent);

    return KErrNotSupported;

}

TInt CWinsockAgent::IncomingConnectionReceived()

{

    TRACE("IncomingConnectionReceived()");

    return KErrNotSupported;

}

void CWinsockAgent::GetLastError(TInt& aError)

{

    TRACE("GetLastError()");

    aError = KErrNone;

}

TBool CWinsockAgent::IsActive() const

{

    return ETrue;

}

TBool CWinsockAgent::IsReconnect() const

{

    return EFalse;

}

void CWinsockAgent::SetConnectionSettingsL(const TConnectionSettings& aSettings)

{

    TRACE("SetConnectionSettingsL()");

    iSettings = aSettings;

}

TConnectionSettings& CWinsockAgent::ConnectionSettingsL()

{

    TRACE("ConnectionSettingsL()");

    return iSettings;

}

void CWinsockAgent::SetOverridesL(CStoreableOverrideSettings* /*aOverride*/)

{

    TRACE("SetOverridesL()");

}

CStoreableOverrideSettings* CWinsockAgent::OverridesL()

{

    TRACE("OverridesL()");

    User::Leave(KErrNotSupported);

    return NULL;

}

void CWinsockAgent::RequestNotificationOfServiceChangeL(

    MAgentSessionNotify* /*aSession*/)

{

    User::Leave(KErrNotSupported);

}

void CWinsockAgent::CancelRequestNotificationOfServiceChange(

    MAgentSessionNotify* /*aSession*/)

{

}

// Private methods

void CWinsockAgent::ScheduleConnectNotification()

{

    ASSERT(iNotify);

    if (!iConnector && iNotify)

    {

        iConnector = new CWinsockAgentCallback(this,ConnectComplete);

    }

    if (iConnector)

    {

        // Schedule asynchronous connect notification

        ASSERT(iConnector->Agent() == this);

        iConnector->InvokeLater();

    }

}

void CWinsockAgent::CancelConnectNotification()

{

    if (iConnector)

    {

        iConnector->Cancel();

    }

}

void CWinsockAgent::ConnectComplete()

{

    TRACE("firing connection notification");

    iNotify->AgentProgress(KConnectionOpen, KErrNone);

    iNotify->ConnectComplete(KErrNone);

}

void CWinsockAgent::DisconnectComplete()

{

    TRACE("firing disconnect notification");

    iNotify->AgentProgress(KConnectionClosed, iDisconnectReason);

    iNotify->DisconnectComplete();

}