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


#ifndef SCHSENDEXE_H_
#define SCHSENDEXE_H_

#ifdef _DEBUG
#undef _MSG_NO_LOGGING
#endif


#include <msvschedulesend.h> //for SCHSENDLOG and KSchSendLogDir

#ifdef _DEBUG
//#define _SCHSENDEXE_TEST //undefine when submitting code
#endif

#ifdef _SCHSENDEXE_TEST
#pragma message("WARNING: Test code enabled")
const TInt KMsvSendExeOneMinute = 1000000 * 60 / 30;
#else
const TInt KMsvSendExeOneMinute = 1000000 * 60;
#endif

const TInt KSendExeActiveTimeout = KMsvSendExeOneMinute / 12; // 10 secs
const TInt KSchSendExeMinReschedule = KMsvSendExeOneMinute * 1; // 1 mins
const TInt KSchSendExeMaxReschedule = KMsvSendExeOneMinute * 3; // 4 mins
const TInt KDefaultPriority = CActive::EPriorityStandard;
const TInt KMsvSendExeGrowth = 5;

class CScheduledTask;

//
//
//	Local Function Declarations
//
//

enum TSchSendExePanic
	{
	EMultipleMtms,
	ENoMessagesInSelection,
	ENoSendCommand,
	EOperationCompletedTooSoon,
	ETooManyOperationsCompleted,
	EObjectNotNull
	};

void gPanic(TSchSendExePanic aPanic);
void gPanic(TInt aPanic);

TInt Execute(const TDesC& aFileName, RFile& aFile );
void DoExecuteL(const TDesC& aFileName, RFile& aFile );

class CMsvSendExeActive;


/**

The CProgressTimer class
Calls iOperation.ProgressL() every iPollInterval microseconds.
Used by CMsvSendExeActive.

*/
class CProgressTimer : public CTimer
	{
public:
	static CProgressTimer* NewL(CMsvOperation& aOperation, const TTimeIntervalMicroSeconds32& aPollInterval);
	void Start();
	~CProgressTimer();
	
private:
	CProgressTimer(CMsvOperation& aOperation, const TTimeIntervalMicroSeconds32& aPollInterval);
	void RunL();
	CMsvOperation& iOperation;
	TTimeIntervalMicroSeconds32 iPollInterval;
	};



/**

The CMsvSendExe class
Reads the task file and starts the corresponding messaging operations.

*/
class CMsvSendExe : public MMsvSessionObserver, CActive
	{
public:
	
	static CMsvSendExe* StartLC(const TDesC& aFileName, RFile& aFile );

	~CMsvSendExe();

	void HandleSessionEventL(MMsvSessionObserver::TMsvSessionEvent /*aEvent*/, TAny* /*aArg1*/, TAny* /*aArg2*/, TAny* /*aArg3*/) {};
	TBool IsSendActive(); // {return IsActive();}
	void OperationComplete(const CMsvSendExeActive& aActive, TInt aError);

#ifndef _MSG_NO_LOGGING
	static void FLog(const TDesC& aFileName, TRefByValue<const TDesC16> aFmt, ...);
#endif

private:

	CMsvSendExe(const TDesC& aFileName, RFile& aFile );

	void ConstructL();

	void DoCancel();
	void RunL();

	void ProcessFileL();
	void CallMtmL();
	
	void RetrievePackagesL();
	void AddPackageL(const CScheduledTask& aTask);

	void RetrieveMessagesL();

	void AddTaskL(const TMsvSchedulePackage& aPackage);
	void AddTaskL(const TMsvSchedulePackage& aPackage, const TUid& aMtm);

	void RescheduleOnError(const CMsvSendExeActive& aActive, TInt aError);
	void RescheduleOnError(const CMsvEntrySelection& aSelection, const TMsvSchedulePackage& aPackage, TInt aError);
	void RescheduleAllL(TInt aError);
	void CompleteReschedule(RScheduler& aScheduler, const TSchedulerItemRef& aRef, TInt aCount);
	
	void DoResheduleOnErrorL(RScheduler& aScheduler, const CMsvEntrySelection& aSelection, const TMsvSchedulePackage& aPackage, TInt aError, TSchedulerItemRef& aRef, TInt& aCount, TTime& aStartTime);
	void FailOnError(const CMsvEntrySelection& aActive, TInt aError);
	void RestoreScheduleSettingsL(TMsvId aServiceId, const TUid& aMtm, CMsvScheduleSettings& aSettings);
	TBool FindorCreateScheduleL(RScheduler& aScheduler, TTime& aStartTime, const CMsvScheduleSettings& aSettings, TSchedulerItemRef& aRef);
	void UpdateEntryL(CMsvEntry& aMsvEntry, TMsvEntry& aEntry, const TSchedulerItemRef& aRef, const TTaskInfo& aInfo, const TTime& aStartTime);

	CMsvSession* iSession;
	const TDesC& iFileName;
	
	RFile& iTaskFile;

	TTime iCreated;
	RPointerArray<CMsvSendExeActive> iOperations;
	RArray<TMsvSchedulePackage> iPackages;
	CActiveSchedulerWait iActiveSchedulerWait;
	
#ifdef _DEBUG
	TInt iOperationsComplete;
#endif
	};

class CMsvSendExeActive : public CActive
	{
	public:
		static CMsvSendExeActive* NewLC(CMsvSession& aSession, CMsvSendExe& aParent, const TMsvSchedulePackage& aPackage, const TUid& aMtm, TInt aPriority = EPriorityStandard);
		~CMsvSendExeActive();
		void StartL();
		void AppendL(TMsvId aId);
		inline TInt MsgCount() const;
		inline const TMsvSchedulePackage& Package() const;
		inline const TUid& Mtm() const;
		inline const CMsvEntrySelection& Selection() const;
		
	private:
		CMsvSendExeActive(CMsvSession& aSession, CMsvSendExe& aParent, const TMsvSchedulePackage& aPackage, const TUid& aMtm, TInt aPriority);
		void ConstructL();
		void RunL();
		void DoCancel();

	private:

		CMsvSession& iSession;
		CMsvSendExe& iParent;
		CProgressTimer* iTimer;
		CMsvOperation* iOperation;
		CMsvEntrySelection* iSelection;
		TMsvSchedulePackage iPackage;
		TUid iMtm;
	};

inline TInt CMsvSendExeActive::MsgCount() const
	{
	return iSelection->Count();
	}

inline const CMsvEntrySelection& CMsvSendExeActive::Selection() const
	{
	return *iSelection;
	}

inline const TMsvSchedulePackage& CMsvSendExeActive::Package() const
	{
	return iPackage;
	}

inline const TUid& CMsvSendExeActive::Mtm() const
	{
	return iMtm;
	}

#endif