/*

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

*

*/

//  CLASS HEADER

#include "testhostlet.h"

//  EXTERNAL INCLUDES

#include <StifTestInterface.h>

#include <SenTransportProperties.h>

//  INTERNAL INCLUDES

#include "senhostletconnectionbctest.h"

namespace

    {

    //_LIT8(KHostletEndpoint, "hostlet://UnitTestHostlet");

    _LIT8(KHostletContract, "urn:nokia.com.serene:unit-test-hostlet");

    }

CTestHostlet* CTestHostlet::NewL(CSenHostletConnectionBCTest* aTestSuite,

                                 TInt (*ap2ServiceL) (CSenHostletConnectionBCTest*, MSenHostletRequest&, MSenHostletResponse&),

                                 TInt (*ap2OnServiceCompleteL) (CSenHostletConnectionBCTest*, const TInt, TInt, const TDesC8&),

                                 void (*ap2DescribeServiceL)(CSenXmlServiceDescription&))

    {

    CTestHostlet* pSelf = CTestHostlet::NewLC(aTestSuite, ap2ServiceL, ap2OnServiceCompleteL, ap2DescribeServiceL);

    CleanupStack::Pop(pSelf);

    return pSelf;

    }

CTestHostlet* CTestHostlet::NewLC(CSenHostletConnectionBCTest* aTestSuite,

                                  TInt (*ap2ServiceL) (CSenHostletConnectionBCTest*, MSenHostletRequest&, MSenHostletResponse&),

                                  TInt (*ap2OnServiceCompleteL) (CSenHostletConnectionBCTest*, const TInt, TInt, const TDesC8&),

                                  void (*ap2DescribeServiceL)(CSenXmlServiceDescription&))

    {

    CTestHostlet* pSelf = new (ELeave) CTestHostlet(aTestSuite, ap2ServiceL, ap2OnServiceCompleteL, ap2DescribeServiceL);

    CleanupStack::PushL(pSelf);

    pSelf->ConstructL();

    return pSelf;

    }

CTestHostlet::CTestHostlet(CSenHostletConnectionBCTest* aTestSuite,

                           TInt (*ap2ServiceL) (CSenHostletConnectionBCTest*, MSenHostletRequest&, MSenHostletResponse&),

                           TInt (*ap2OnServiceCompleteL) (CSenHostletConnectionBCTest*, const TInt, TInt, const TDesC8&),

                           void (*ap2DescribeServiceL)(CSenXmlServiceDescription&))

    : ipTestSuite(aTestSuite),

      ip2ServiceL(ap2ServiceL),

      ip2OnServiceCompleteL(ap2OnServiceCompleteL),

      ip2DescribeServiceL(ap2DescribeServiceL)

    {

    }

CTestHostlet::~CTestHostlet()

    {

    delete ipHostletDescription;

    iRequests.ResetAndDestroy();

    iResponses.ResetAndDestroy();

    iRequestProps.ResetAndDestroy();

    iRequestPropTypes.Reset();

    iResponseProps.ResetAndDestroy();

    iResponseCodes.Reset();

    iTxnIds.Reset();

    iCompletionCodes.Reset();

    }

void CTestHostlet::ConstructL()

    {

    ipHostletDescription = CSenXmlServiceDescription::NewL(KNullDesC8, KHostletContract);

	//ipHostletDescription = CSenXmlServiceDescription::NewL(KHostletEndpoint, KNullDesC8);    	

    ipHostletDescription->SetFrameworkIdL(KDefaultRestServicesFrameworkID);

    }

void CTestHostlet::DescribeServiceL(CSenXmlServiceDescription& aSD) 

    { 

    if( ip2DescribeServiceL ) 

    	{

   		(*ip2DescribeServiceL)(aSD);

    	}

        else

            {

            aSD.SetEndPointL(Endpoint());

            aSD.SetContractL(Contract()); 

            aSD.SetFrameworkIdL(FrameworkId());	

            }

    }

TPtrC8 CTestHostlet::Contract() const

    {

    return ipHostletDescription->Contract();

    }

TPtrC8 CTestHostlet::Endpoint() const

    {

    return ipHostletDescription->Endpoint();

    }

TInt CTestHostlet::ServiceL(MSenHostletRequest& aRequest, MSenHostletResponse& aResponse)

    {

    iTxnIds.Append(aRequest.RequestId());

    iResponseCodes.Append(KErrNone);

    TInt retVal(KErrNone);

    // Setup default response, can be overridden by test case:

    // Dummy response

    TPtrC8 request = aRequest.RequestUtf8();

    iRequests.Append(request.AllocL());

    MSenProperties::TSenPropertiesClassType propType;

    TPtrC8 requestProperties = aRequest.Properties(propType);

    iRequestProps.Append(requestProperties.AllocL());

    iRequestPropTypes.Append(propType);

//    _LIT8(KResponseFmt, "<Response><ReplyMessage>CSenHostletConnectionBCTest is alive.</ReplyMessage><Request>%S</Request></Response>");

  	_LIT8(KResponseFmt, "<S:Envelope xmlns:S=\"http://schemas.xmlsoap.org/soap/envelope/\"><S:Header></S:Header><S:Body>testing text hostlet</S:Body></S:Envelope>");  

    HBufC8* pResponse = HBufC8::NewLC(request.Length()+KResponseFmt().Length());

    TInt appendError = iResponses.Append(pResponse);

    if( appendError )

        {

        CleanupStack::PopAndDestroy(pResponse); // delete orphan HBufC8 / pResponse

        }

    else

        {

        CleanupStack::Pop(pResponse); // now owned by iResponses -array..

        }        

    TPtr8 response = iResponses[iTxnIds.Count()-1]->Des();

    response.Format(KResponseFmt, &request);

    aResponse.SetResponseUtf8L(response, iResponseCodes[iTxnIds.Count()-1]); // by default, all requests are "accepted"

    if ( ip2ServiceL )

        {

        // NOTE(!): if RESPONSE CODE in aResponse is modified in YOUR test case,

        // remember set iResponseCodes for this test hostlet instance in your test

        //  case code (ServiceL callback)

        retVal = (*ip2ServiceL)(ipTestSuite, aRequest, aResponse); 

        }

    TPtrC8 providedResponse = aResponse.ResponseUtf8();

    if ( iResponses[iTxnIds.Count()-1]->Compare(providedResponse) != 0 )

        {

        // response was altered by TEST CASE:

        iResponses.Insert(aResponse.ResponseUtf8().AllocL(),iTxnIds.Count()-1);

        }

    RDebug::Print(_L("CTestHostlet::ServiceL received:"));

    RDebug::RawPrint(request);

    if (ipTestSuite->ipUsedHostletConnection)

    {

    	iRespondRetCode = ipTestSuite->ipUsedHostletConnection->RespondL(aResponse); 

    }

    else

		iRespondRetCode = ipTestSuite->ipHostletConnection->RespondL(aResponse); 

   return retVal;

    }

void CTestHostlet::OnServiceCompleteL(const TInt aTxnId, 

                                      TInt aCompletionCode, 

                                      const TDesC8& aDesc)

    {

    iCompletionCodes.Append(aCompletionCode); 

    if( ip2OnServiceCompleteL )

        {

        (*ip2OnServiceCompleteL)( ipTestSuite, aTxnId, aCompletionCode, aDesc );

        }

    ipTestSuite->StopActiveScheduler(); // service provided

    }

//  END OF FILE