// pipe_line.h
// 
// Copyright (c) 2006 - 2010 Accenture. All rights reserved.
// This component and the accompanying materials are made available
// under the terms of the "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:
// Accenture - Initial contribution
//

#ifndef __PIPE_LINE_H__
#define __PIPE_LINE_H__

#include <e32base.h>
#include "command_wrappers.h"

class TError;
class CPipeLine;
class MConsole;
class CCommandFactory;
namespace IoUtils
	{
	class CEnvironment;
	}


class MPipeLineObserver
	{
public:
	virtual void HandlePipeLineComplete(CPipeLine& aPipeLine, const TError& aError) = 0;
	};


class RPipeSection
	{
public:
	RPipeSection();
	void Close();
	HBufC* GetCommandArguments() const;
public:
	class TRedirection
		{
	public:
		enum TType
			{
			ENotRedirected,
			EFile,
			EFileAppend,
			EHandle,
			ENull
			};
		enum THandle
			{
			EUnknown,
			EStdin,
			EStdout,
			EStderr
			};
	public:
		TRedirection();
		void SetFileNameL(const TDesC& aCwd, const TDesC& aName);
	public:
		TType iType;
		IoUtils::TFileName2* iFileName;
		THandle iHandle;
		};
public:
	TPtrC iFullName;
	TPtrC iCommandName;
	RArray<TPtrC> iCommandArguments;
	TRedirection iStdinRedirection;
	TRedirection iStdoutRedirection;
	TRedirection iStderrRedirection;
private:
	mutable HBufC* iCommandArgumentsBuf;
	};


class CPipeLine : public CBase, public MCommandObserver
	{
public:
	static CPipeLine* NewL(RIoSession& aIoSession, RIoReadHandle& aStdin, RIoWriteHandle& aStdout, RIoWriteHandle& aStderr, IoUtils::CEnvironment& aEnv, CCommandFactory& aFactory, const RArray<RPipeSection>& aPipeSections, TBool aBackground, MPipeLineObserver* aObserver, TError& aErrorContext);
	static CPipeLine* NewLC(RIoSession& aIoSession, RIoReadHandle& aStdin, RIoWriteHandle& aStdout, RIoWriteHandle& aStderr, IoUtils::CEnvironment& aEnv, CCommandFactory& aFactory, const RArray<RPipeSection>& aPipeSections, TBool aBackground, MPipeLineObserver* aObserver, TError& aErrorContext);
	~CPipeLine();
	void Kill();
	TInt Suspend();
	TInt Resume();
	TInt BringToForeground();
	void SendToBackground();
	const TDesC& Name() const;
	TInt Reattach(RIoEndPoint& aStdinEndPoint, RIoEndPoint& aStdoutEndPoint, RIoEndPoint& aStderrEndPoint);
	TBool IsDisownable() const;
	void Disown();
private:
	CPipeLine(RIoSession& aIoSession, RIoReadHandle& aStdin, RIoWriteHandle& aStdout, RIoWriteHandle& aStderr, IoUtils::CEnvironment& aEnv, CCommandFactory& aFactory, MPipeLineObserver* aObserver);
	void ConstructL(const RArray<RPipeSection>& aPipeSections, TBool aBackground, TError& aErrorContext);
	static TInt CompletionCallBack(TAny* aSelf);
private:	// From MCommandObserver.
	virtual void HandleCommandComplete(MCommand& aCommand, TInt aError);
private:
	class RPipedCommand
		{
	public:
		RPipedCommand();
		void Close();
	public:
		MCommand* iCommand;
		TInt iCompletionError;
		HBufC* iCommandName;
		TBool iStdinRedirected;
		TBool iStdoutRedirected;
		TBool iStderrRedirected;
		};
private:
	TPtrC iName;
	RIoSession& iIoSession;
	RIoReadHandle& iStdin;
	RIoWriteHandle& iStdout;
	RIoWriteHandle& iStderr;
	IoUtils::CEnvironment& iEnv;
	CCommandFactory& iFactory;
	MPipeLineObserver* iObserver;
	RArray<RPipedCommand> iCommands;
	CAsyncCallBack* iCompletionCallBack;
	TError iCompletionError;
	};


#endif // __PIPE_LINE_H__