#ifndef _PROCESSEXECUTE_H
#define _PROCESSEXECUTE_H

struct PipeReaderArgs;

class ProcessExecute
{
public:

	ProcessExecute();
	~ProcessExecute();

	DWORD execute(const TCHAR *commandLine,  boost::python::object pyStdout, boost::python::object pyStderr, boost::python::object pyStdin, bool spoolToFile = false);

protected:
	static bool isWindowsNT();
	static const int STREAM_NAME_LENGTH = 3;
	static const char *STREAM_NAME_STDOUT;
	static const char *STREAM_NAME_STDERR;

private:
	static DWORD WINAPI pipeReader(void *args);
	void writeToPython(PipeReaderArgs *pipeReaderArgs, DWORD bytesRead, char *buffer);
	void writeToFile(PipeReaderArgs *pipeReaderArgs, DWORD bytesRead, char *buffer);
	void spoolFile(std::fstream* file, boost::python::object pyStdout, boost::python::object pyStderr);

};

struct PipeReaderArgs
{
	ProcessExecute* processExecute;
	HANDLE hPipeRead;
	HANDLE hPipeWrite;
	HANDLE stopEvent;
	HANDLE completedEvent;
	boost::python::object pythonFile;
	
	/// Set if the output should be spooled to the fileHandle member
	/// if false, then write directly to pythonFile
	bool toFile;
	std::fstream *file;
	HANDLE fileMutex;

	const char *streamName;
};

class process_start_exception
{
public:
	explicit process_start_exception(const char *desc)
		: m_desc(desc) 
		{};
	
	const char *what() const
	{ return m_desc.c_str();
	}
	
private:
	process_start_exception(); // default constructor disabled

	std::string m_desc;
};

#endif