// AppRunner.h

#ifndef APP_RUNNER_H
#define APP_RUNNER_H

#include <stdio.h>

#include <DataIO.h>
#include <Entry.h>
#include <Locker.h>

class AppRunner {
public:
	AppRunner(bool requestQuitOnDestruction = false);
	~AppRunner();

	status_t Run(const char *command, const char *args = NULL,
				 bool findCommand = true);
	bool HasQuitted();
	void WaitFor(bool requestQuit = false);
	team_id Team();
	port_id AppLooperPort();
	status_t GetRef(entry_ref *ref);
	status_t RequestQuit();

	status_t GetOutput(BString *buffer);
	ssize_t ReadOutput(void *buffer, size_t size);
	ssize_t ReadOutputAt(off_t position, void *buffer, size_t size);

private:
	static int32 _ReaderEntry(void *data);
	int32 _ReaderLoop();

	static bool _LockTeamPort();
	static void _UnlockTeamPort();
	static port_id _ReadPortID(BMessenger &messenger);

private:
	BLocker		fOutputLock;
	port_id		fRemotePort;
	BMallocIO	fOutput;
	thread_id	fReader;
	team_id		fTeam;
	entry_ref	fRef;
	BMessenger	fMessenger;
	bool		fRequestQuitOnDestruction;

	static port_id	fTeamPort;
	static BLocker	fTeamPortLock;
};

status_t find_test_app(const char *testApp, BString *path);
status_t find_test_app(const char *testApp, entry_ref *ref);

#endif	// APP_RUNNER_H