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

//

/**

 @file

*/

#include "CCreateReplyTestStep.h"

#include "MSharedData.h"

#include "CentralRepoUtils.h"

#include "smsclnt.h"

#include <smut.h>

#include "MsgingUtils.h"

#include <txtetext.h>

#include <txtfmlyr.h>

#include <txtrich.h>

#include <smuthdr.h>

#include "CAsyncWaiter.h"

using namespace SharedData;

class CSessionObserver1 : public MMsvSessionObserver, public CBase

	{

public: 

	void HandleSessionEventL(TMsvSessionEvent,TAny*,TAny*,TAny*) {};

	};

/**

 Constructor to set test step name

*/

CCreateReplyTestStep::CCreateReplyTestStep(MSharedData& aObj)

:CBasicTestStep(aObj)

	{

	SetTestStepName(KCreateReplyTestStep);

	}

CCreateReplyTestStep::~CCreateReplyTestStep()

	{

	}

TVerdict CCreateReplyTestStep::doTestStepL()

	{

	CActiveScheduler* scheduler = new (ELeave) CActiveScheduler;

	CActiveScheduler::Install(scheduler);

	CleanupStack::PushL(scheduler);

	CSessionObserver1* sessionObserver1 = new (ELeave) CSessionObserver1;

	CleanupStack::PushL(sessionObserver1);

	CMsvSession* session = CMsvSession::OpenSyncL(*sessionObserver1);

	CleanupStack::PushL(session);

	_LIT(KParent, "Parent");

	_LIT(KDestination, "Destination");

	TPtrC tag;

	if ( !GetStringFromConfig(ConfigSection(),KParent,tag))

		{

		ERR_PRINTF1(_L("No Input for Inbox "));

		User::Leave(KErrNotReady);

		}

	TMsvId parentId = MsgingUtils::GetLocalFolderId(tag);

	if ( !GetStringFromConfig(ConfigSection(),KDestination,tag))

		{

		ERR_PRINTF1(_L("No Input for OutBox "));

		User::Leave(KErrNotReady);

		}

	TMsvId destId = MsgingUtils::GetLocalFolderId(tag);

	_LIT(KDetails,"Details");

	TPtrC detailsTag;

	if ( !GetStringFromConfig(ConfigSection(),KDetails,detailsTag))

	{

	ERR_PRINTF1(_L("No Input for Details"));

	User::Leave(KErrNotReady);

	}

//Details = +358408415528

//Description = Reply Address message. Message

	TMsvId id = MsgingUtils::GetEntryByNameL(detailsTag, parentId, *session);

	CMsvEntry* entry = session->GetEntryL(id);

	CleanupStack::PushL(entry);

	CClientMtmRegistry* iMtmRegistry = CClientMtmRegistry::NewL(*session);

	CSmsClientMtm* smsMtm = (CSmsClientMtm*)CentralRepoUtils::CreateMtmL(KUidMsgTypeSMS, iMtmRegistry);

	CleanupStack::PushL(smsMtm);

	entry->SetEntryL(id);

//Creating reply

	smsMtm->SwitchCurrentEntryL(id); // Lets point at the received message

	smsMtm->LoadMessageL();

	CAsyncWaiter* waiter = CAsyncWaiter::NewL();

	CleanupStack::PushL(waiter);

	TMsvPartList part=0;

	CMsvOperation* op=smsMtm->ReplyL(destId, part, waiter->iStatus);

	CleanupStack::PushL(op);

	waiter->StartAndWait();

	User::LeaveIfError(waiter->Result());

	TPckgBuf<TMsvId> pkg;

	pkg.Copy(op->ProgressL());

	TMsvId progress = pkg();

	smsMtm->SwitchCurrentEntryL(progress);

	smsMtm->LoadMessageL();

	smsMtm->Body().InsertL(0,_L("This is reply"));

	smsMtm->SaveMessageL();

	CleanupStack::PopAndDestroy(3,smsMtm); //op, waiter, smsMtm

	delete iMtmRegistry;

	CleanupStack::PopAndDestroy(entry);

//End of Reply Creation

	CleanupStack::PopAndDestroy(3, scheduler); // session, sessionObserver1, scheduler

	return TestStepResult();

	}