/*
* Copyright (c) 2006 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:    Simple Engine
*
*/




// INCLUDE FILES

#include <e32std.h>
#include <s32mem.h>

// own simple
#include "msimpleconnection.h"
#include "simpleconnection.h"
#include "simplecommon.h"
#include "simpleenginerequest.h"
#include "simplesipconnection.h"
#include "simpleengineutils.h"
#include "simpleclient.h"
#include "simpleerrors.h"

#ifdef _DEBUG
#include "simpledebugutils.h"
#endif

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

// ----------------------------------------------------------
// CSimpleClient::CSimpleClient
// ----------------------------------------------------------
//
CSimpleClient::CSimpleClient(
    MSimpleConnection& aConn )
: iConn( aConn ),
  iOpId(0),
  iSipStatus(0),
  iRetryAfterTime(0),
  iRequestList( CSimpleEngineRequest::LinkOffset()), 
  iRequest( MSimpleEngineRequest::ENone ),
  iDestroyedPtr( NULL )
    {
    }

// ----------------------------------------------------------
// CSimpleClient::~CSimpleClient
// ----------------------------------------------------------
//
CSimpleClient::~CSimpleClient()
    {
    DeleteRequests();
    
    if ( iDestroyedPtr )
        {
        // We are called inside callback
        *iDestroyedPtr = ETrue;
        iDestroyedPtr = NULL;
        }
    
    }

// ----------------------------------------------------------
// CSimpleClient::BaseConstructL
// ----------------------------------------------------------
//
void CSimpleClient::BaseConstructL()
    {
    iLimitLowerValue = TSimpleEngineUtils::OpIdRange();
    iLimitUpperValue = iLimitLowerValue + KRangeSize;
    iOpId = iLimitLowerValue;
    }

// ----------------------------------------------------------------------------
// CSimpleClient::IncreaseOpId
// ----------------------------------------------------------------------------
void CSimpleClient::IncreaseOpId( )
    {
    iOpId++;
    if( iOpId >= iLimitUpperValue )
        {
        iOpId = iLimitLowerValue;
        }
    }

// -----------------------------------------------------------------------------
// CSimpleClient::DeleteRequests
// -----------------------------------------------------------------------------
void CSimpleClient::DeleteRequests()
    {
#ifdef _DEBUG
    TSimpleLogger::Log(_L("SimpleClient: DeleteRequests this=%d" ), (TInt)this );
#endif
    // Delete all buffered transaction requests
    TDblQueIter<CSimpleEngineRequest> rIter( iRequestList );
    rIter.SetToFirst();

    while ( rIter )
        {
        CSimpleEngineRequest* req = rIter;
        rIter++; //lint !e1757
        // delete corresponding request from another DLL too.
        req->ModifyType( MSimpleEngineRequest::EDestroy );
        TRAP_IGNORE( SendReqL( *req ) );
        // delete request from this DLL.
        req->Destroy();
        }
    }

// -----------------------------------------------------------------------------
// CSimpleClient::SearchRequests
// -----------------------------------------------------------------------------
CSimpleEngineRequest* CSimpleClient::SearchRequests( TInt aOpId )
    {
#ifdef _DEBUG
    TSimpleLogger::Log(_L("SimpleClient: SearchRequests this=%d" ), (TInt)this );
#endif
    // Delete all buffered transaction requests
    TDblQueIter<CSimpleEngineRequest> rIter( iRequestList );
    rIter.SetToFirst();

    while ( rIter )
        {
        CSimpleEngineRequest* req = rIter;
        rIter++; //lint !e1757
        if ( req->OpId() == aOpId )
            {
            return req;
            }
        }
    return (CSimpleEngineRequest*)NULL;
    }

// -----------------------------------------------------------------------------
// CSimpleClient::SendReqL
// -----------------------------------------------------------------------------
void CSimpleClient::SendReqL( MSimpleEngineRequest& aReq )
    {
    CSimpleConnection* conn = STATIC_CAST( CSimpleConnection*, &iConn); //lint !e826
    CSimpleSipConnection* engine = conn->Connection();
    engine->DispatchReqL( aReq );
    }

// ----------------------------------------------------------
// CSimpleClient::ResponseReason
// ----------------------------------------------------------
//
TInt CSimpleClient::ResponseReason(
    MSimpleEngineRequest& aR )
    {
    switch ( aR.ResponseReason() )
        {
        case MSimpleEngineRequest::ENoReason:
            return KErrNone;

        case MSimpleEngineRequest::ERejected:
            return KSimpleErrRejected;

        case MSimpleEngineRequest::ETimeout:
            return KSimpleErrTimeout;

        case MSimpleEngineRequest::EDeactivated:
            return KSimpleErrDeactivated;

        case MSimpleEngineRequest::EProbation:
            return KSimpleErrProbation;

        case MSimpleEngineRequest::ENoresource:
            return KSimpleErrNoresource;

        case MSimpleEngineRequest::EGiveup:
            return KSimpleErrGiveup;

        default:
            return KErrNone;
        }; //lint !e960
    }
    
// ----------------------------------------------------------
// CSimpleClient::DoSIPStatus
// ----------------------------------------------------------
//
TUint CSimpleClient::DoSIPStatus( )
    {
    return iSipStatus;    
    }
    
// ----------------------------------------------------------
// CSimpleClient::DoRetryAfter
// ----------------------------------------------------------
//
TUint CSimpleClient::DoRetryAfter( )
    {
    return iRetryAfterTime;
    }    
    
// ----------------------------------------------------------
// CSimpleClient::GetSIPStatus
// ----------------------------------------------------------
//
void CSimpleClient::GetSIPStatus( TInt aOpId )
    {    
    CSimpleConnection* conn = STATIC_CAST( CSimpleConnection*, &iConn); //lint !e826
    CSimpleSipConnection* engine = conn->Connection();
    iSipStatus = engine->SIPStatus( aOpId, iRetryAfterTime );
    }