// Copyright (c) 1999-2010 Nokia Corporation and/or its subsidiary(-ies).

#include "OstTraceDefinitions.h"

#ifdef OST_TRACE_COMPILER_IN_USE

#include "ws_prvdrTraces.h"

#endif

#include "smsstacklog.h"

    // CWapSmsProvider policies

    static _LIT_SECURITY_POLICY_C1(wapSmsProviderSetLocalNamePolicy, ECapabilityNetworkServices );

    static _LIT_SECURITY_POLICY_C1(wapSmsProviderSetOptionPolicy, ECapability_None);

    static _LIT_SECURITY_POLICY_C1(wapSmsProviderGetLengthIoctlPolicy,ECapability_None);

    static _LIT_SECURITY_POLICY_C1(wapSmsProviderGetMessageParamLengthIoctlPolicy,ECapability_None);

    static _LIT_SECURITY_POLICY_C1(wapSmsProviderGetMessageParametersIoctlPolicy,ECapabilityReadDeviceData);

    static _LIT_SECURITY_POLICY_C1(wapSmsProviderWritePolicy,ECapabilityNetworkServices);

    {

    OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_NEWL_1, "CWapSmsProvider::NewL()");

    CWapSmsProvider* provider=new(ELeave) CWapSmsProvider(aProtocol);

    CleanupStack::PushL(provider);

    provider->iWapSmsProviderWrite = CWapSmsProviderWrite::NewL(*provider);

    CleanupStack::Pop();

    return provider;

    } // CWapSmsProvider::NewL

    ,iIoctlOutstanding(EFalse)

    ,iIsNewStyleClient(EFalse)

    ,iStatusReportScheme(EWapSmsDefault)

    {

    OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_GETOPTION_1, "CWapSmsProvider::GetOption");

    TInt ret=KErrNone;

    if (TInt(aLevel)==KWapSmsOptionLevel && TInt(aName)==KWapSmsOptionNameDCS)

        aOption = TPtrC8((TText8*)&iDataCodingScheme,sizeof(TWapSmsDataCodingScheme));

    else

        ret=iProtocol->GetOption(aLevel,aName,aOption,NULL);

    return ret;

    } // CWapSmsProvider::GetOption

    {

    OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_SETOPTION_1, "CWapSmsProvider::SetOption");

    if(!iSecurityChecker || (iSecurityChecker->CheckPolicy(wapSmsProviderSetOptionPolicy,"CWapSmsProvider SetOption policy check") != KErrNone))

        {

        return KErrPermissionDenied;

        }

    TInt ret=KErrNone;

    if (TInt(aLevel)==KWapSmsOptionLevel)

    {

        switch(TInt(aName))

        {

        case KWapSmsOptionNameDCS:

            {

            iDataCodingScheme = static_cast<TWapSmsDataCodingScheme>(*aOption.Ptr());

            break;

            }

        case KWapSmsOptionWapDatagram:

            {

            iMessageType=EWapDatagram;

            break;

            }

        case KWapSmsStatusReportScheme:

            {

            iStatusReportScheme = static_cast<TWapSmsStatusReportScheme>(*aOption.Ptr());

            break;              

            }

        case KWapSmsOptionNewStyleClient:

            {

            iIsNewStyleClient = ETrue;

            break;

            }

        case KWapSmsOptionOKToDeleteMessage:

            {

            //Get the first message from the queue

            CWapDatagram* msg = iRecvdMsgQueue.First();

            //Find and delete from SAR

            TBool found=iProtocol->FindAndDeleteMsg(*msg);

            if(!found)

                {

                OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_SETOPTION_2, "CWapSmsProvider::SetOption: Error. Couldn't find the message in the SAR for deletion");

                break;

                }

            //Remove from the queue

            iRecvdMsgQueue.Remove(*msg);

            delete msg;

            break;

            }

        default:

            ret=KErrNotSupported;

        }

    }

    else

    {

        ret=iProtocol->SetOption(aLevel,aName,aOption,NULL);

    }

    return ret;

    } // CWapSmsProvider::SetOption

    {

    OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_SHUTDOWN_1, "CWapSmsProvider::Shutdown");

    if (aType!=CServProviderBase::EImmediate)

        iSocket->CanClose();

    } // CWapSmsProvider::Shutdown

    {

    OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_WRITE_1, "CWapSmsProvider::Write()");

        if(!iSecurityChecker || (iSecurityChecker->CheckPolicy(wapSmsProviderWritePolicy,"CWapSmsProvider Write policy check") != KErrNone))

        {

        return KErrPermissionDenied;

        }

    // @note: LOGIFH2A2 macro for logging esock write

    TInt length = aBufChain.Length();

    OstTraceDef1(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_WRITE_2, "CWapSmsProvider::Write [%d bytes]", length);

    TBuf8<0x100> dumpBuf;

    if(length > 0x100)

        {

        TInt parts=0;

        TInt offset = 0;

        while (offset < length)

            {

            aBufChain.CopyOut(dumpBuf, offset);

            offset += length;

            LOGIF2(_L8("ESock WAP concantonated part: %d"),parts++);

            LOGIF2(_L8("ESOCK WRITE: %S"),&dumpBuf);

            LOGIFH2A2(_L8("ESOCK WRITE: "),dumpBuf);

            }

    }

    else

    {

        aBufChain.CopyOut(dumpBuf, 0);

        LOGIF2(_L8("ESOCK WRITE: %S"),&dumpBuf);

        LOGIFH2A2(_L8("ESOCK WRITE: "),dumpBuf);

    }

    // Note that if this fails somehow it still frees the buf chain and sets itself active - it's

    // not clear to me whether this is good behaviour but it's the pre-mbuf behaviour too

    iWapSmsProviderWrite->Start(aBufChain, *aAddr);

    return KErrNone;

    } // CWapSmsProvider::Write

    {

    OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_GETDATA_1, "CWapSmsProvider::GetData()");

    CWapDatagram* msg = iRecvdMsgQueue.First();

    if(!iIsNewStyleClient)

        {

        iRecvdMsgQueue.Remove(*msg);

        }

    TInt err = msg->WapDatagram(aBufChain, aLength);

    //@note: LOGIFH2A2 macro for logging esock getdata

    OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_GETDATA_2, "CWapSmsProvider::GetData");

    // Logging migrated to WapDatagram() for ease of descriptor ref

    if (err > 0 && aAddr)

        {

        TWapAddr* wapAddr = reinterpret_cast<TWapAddr*>(aAddr);

        TInt toPort,fromPort;

        msg->Ports(fromPort,toPort);

        wapAddr->SetWapPort(static_cast<TWapPortNumber>(fromPort));

        TBuf8<KMaxSockAddrSize> addrBuf;

        addrBuf.Copy(msg->FromAddress());

        wapAddr->SetWapAddress(addrBuf);

        }

    if(!iIsNewStyleClient)

        {

        delete msg;

        }

    return err > 0? 1: err;     // datagrams are atoms not byte counts

    } // CWapSmsProvider::GetData

    {

    TBool notifyEsock = EFalse;

    OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_NEWDATA_1, "CWapSmsProvider::NewData");

    if(iIoctlOutstanding && iName==KSOGetLength && iIsNewStyleClient)

        {

        TPckgBuf<TInt> buf= aMsg->WapDatagramLength();

        iSocket->IoctlComplete(&buf);

        iIoctlOutstanding= EFalse;

        iName= NULL;

        notifyEsock = ETrue;

        }

    else if(iIoctlOutstanding && iName==KSOGetMessageParametersLength && iIsNewStyleClient)

        {

        CBufFlat* buffer = aMsg->SmsExternalisedStream();

        TPckgBuf<TInt> buf = buffer->Size();

        iSocket->IoctlComplete(&buf);

        iIoctlOutstanding= EFalse;

        iName= NULL;

        notifyEsock = ETrue;

        }

    else if(iIoctlOutstanding && iName==KSOGetMessageParameters && iIsNewStyleClient)

        {

        CBufFlat* buffer = aMsg->SmsExternalisedStream();

        TPtr8 buf = buffer->Ptr(0);

        iSocket->IoctlComplete(&buf);

        iIoctlOutstanding= EFalse;

        iName= NULL;

        notifyEsock = ETrue;

        }

    else if(iName!=KSOGetLength && iName!=KSOGetMessageParametersLength && iName!=KSOGetMessageParameters && iIsNewStyleClient)

        {

        notifyEsock= EFalse;

        }

    if(!iIsNewStyleClient || notifyEsock)

        iSocket->NewData(1);

    //else we notify ESock in IOCTL for new client

    } // CWapSmsProvider::NewData

    {

    OstTraceDefExt2(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_ERROR_1, "CWapSmsProvider::Error [aError=%d, mask=%u] ", aError, aOperationMask);

    iSocket->Error(aError, aOperationMask);

    } // CWapSmsProvider::Error

    {

    OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_LINKOFFSET_1, "CWapSmsProvider::LinkOffset");

    return _FOFF(CWapSmsProvider,iSAPLink);

    } // CWapSmsProvider::LinkOffset

    {

    OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_LOCALNAME_1, "CWapSmsProvider::LocalName");

    Mem::Copy(&aAddr,&iLocalAddress,sizeof(TSockAddr));

    } // CWapSmsProvider::LocalName

    {

    OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_SETLOCALNAME_1, "CWapSmsProvider::SetLocalName()");

        if(!iSecurityChecker || (iSecurityChecker->CheckPolicy(wapSmsProviderSetLocalNamePolicy,"CWapSmsProvider SetLocalName policy check") != KErrNone))

        {

        return KErrPermissionDenied;

        }

    TWapAddr* wapAddr = reinterpret_cast<TWapAddr*>(&aAddr);

    OstTraceDef1(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_SETLOCALNAME_2, "CWapSmsProvider::SetLocalName %d",wapAddr->WapPort());

    // Due ESOCK interface port EWapPortUnspecified value (-1)  can be transferred as a maximum unsigned 16 int

    if (wapAddr->WapPort()==EWapPortUnspecified || wapAddr->WapPort()==static_cast<TUint16>(EWapPortUnspecified))

        {

        if(!iProtocol->AllocateLocalAddress(iLocalAddress))

            return KErrInUse;

        else return KErrNone;

        }

    TInt ret=iProtocol->AddrAlreadyUsedByWAP(*wapAddr,this);

    if(ret == KErrInUse) return ret;

    else if(ret == KErrAlreadyExists) return KErrNone;

    TSmsAddr addr;

    if(wapAddr->Port() <=255)

        addr.SetSmsAddrFamily(ESmsAddrApplication8BitPort);

    else

        addr.SetSmsAddrFamily(ESmsAddrApplication16BitPort);

    addr.SetPort(wapAddr->Port());

    if((iProtocol->SmsProtocol()->SmsAddrIsAlreadyUsed(NULL,addr)))

        return KErrInUse;

    Mem::Copy(&iLocalAddress,&aAddr,sizeof(TSockAddr));

    TInt err;

    TRAP(err,ret = iProtocol->CheckSarL(*wapAddr,this));

    if(err!=KErrNone)

            return err;

    if(ret!=KErrNone)

        {

        Error(ret,MSocketNotify::EErrorAllOperations);

        }

    return KErrNone;

    } // RSocket::Bind

    {

    OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_MATCHESLOCALADDRESS_1, "CWapSmsProvider::MatchesLocalAddress");

    return (iLocalAddress == aAddr);

    } // CWapSmsProvider::MatchesLocalAddress

    {

    OstTraceDefExt2(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_IOCTL_1, "CWapSmsProvider::Ioctl [aLevel=%u, aName=%u]", aLevel, aName);

    OstTraceDef1(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, CWAPSMSPROVIDER_IOCTL_2, "CWapSmsProtocol::Ioctl [provider=0x%08x]",this);

    iName=aName;

    switch (aLevel)

        {

        case KSolWapProv:

            {

            if(iIoctlOutstanding || !iIsNewStyleClient)

                {

                Error(KErrInUse,MSocketNotify::EErrorIoctl);

                break;

                }

            switch (iName)

                {

                case KSOGetLength:

                //

                // Get the length

                //

                    {

                    if(!iSecurityChecker || (iSecurityChecker->CheckPolicy(wapSmsProviderGetLengthIoctlPolicy,"CWapSmsProvider GetLength Ioctl policy check") != KErrNone))

                        {

                        Error(KErrPermissionDenied,MSocketNotify::EErrorIoctl);

                        return;

                        }

                    iIoctlOutstanding = ETrue;

                    //check the queue for any other message for this client and call new data if any exist

                    if(!iRecvdMsgQueue.IsEmpty())

                        {

                        CWapDatagram* msg = iRecvdMsgQueue.First();

                        //check the datagram.

                        if(msg->IsComplete())

                            {

                            NewData(msg);

                            }

                        else

                            {

                            //  else notify the client with error.

                            //  Note:this can happen if client uses 8-Bit port number for 7-Bit datagram

                            Error(KErrGeneral,MSocketNotify::EErrorIoctl);

                            iIoctlOutstanding = EFalse;

                            }

                        }

                    break;

                    }

                case KSOGetMessageParametersLength:

                //

                // Get the Message Parameters Length

                //

                    {

                    if(!iSecurityChecker || (iSecurityChecker->CheckPolicy(wapSmsProviderGetMessageParamLengthIoctlPolicy,"CWapSmsProvider KSOGetMessageParametersLength Ioctl policy check") != KErrNone))

                        {

                        Error(KErrPermissionDenied,MSocketNotify::EErrorIoctl);

                        return;

                        }

                    iIoctlOutstanding = ETrue;

                    //check the queue for any other message for this client and call new data if any exist

                    if(!iRecvdMsgQueue.IsEmpty())

                        {

                        CWapDatagram* msg = iRecvdMsgQueue.First();

                        //check the datagram.

                        if(msg->IsComplete())