/*
 * Copyright 2006, Haiku, Inc. All Rights Reserved.
 * Distributed under the terms of the MIT License.
 *
 * Authors:
 *		Axel Dörfler, axeld@pinc-software.de
 */


#include <Entry.h>
#include <File.h>
#include <Looper.h>
#include <NodeMonitor.h>

#include <stdio.h>
#include <string.h>


class Looper : public BLooper {
	public:
		Looper(node_ref& nodeRef);
		virtual ~Looper();

		virtual void MessageReceived(BMessage* message);

	private:
		node_ref	fNodeRef;
};


Looper::Looper(node_ref& nodeRef)
	:
	fNodeRef(nodeRef)
{
	status_t status = watch_node(&fNodeRef, B_WATCH_DIRECTORY, this);
	if (status != B_OK) {
		fprintf(stderr, "Could not watch file.\n");
		PostMessage(B_QUIT_REQUESTED);
	}
}


Looper::~Looper()
{
	status_t status = watch_node(&fNodeRef, B_STOP_WATCHING, this);
	if (status != B_OK)
		fprintf(stderr, "Could not stop watching: %s\n", strerror(status));
}


void
Looper::MessageReceived(BMessage* message)
{
	if (message->what == B_NODE_MONITOR)
		message->PrintToStream();
}


int
main()
{
	BEntry entry("/tmp", true);
	node_ref nodeRef;
	if (entry.GetNodeRef(&nodeRef) != B_OK) {
		fprintf(stderr, "Could not open /tmp.\n");
		return -1;
	}

	//printf("device: %ld, node: %lld\n", nodeRef.device, nodeRef.node);

	// start looper
	Looper& looper = *new Looper(nodeRef);
	looper.Run();

	// run tests
	entry.SetTo("/tmp/_watch_test_");

	BFile file;
	status_t status = file.SetTo(&entry, B_CREATE_FILE | B_READ_WRITE);
	if (status != B_OK)
		fprintf(stderr, "could not create watch test.\n");
	file.Write("test", 4);
	file.Unset();

	if (entry.Remove() != B_OK)
		fprintf(stderr, "could not remove watch test.\n");

	snooze(500000LL);

	// quit looper
	looper.PostMessage(B_QUIT_REQUESTED);
	wait_for_thread(looper.Thread(), &status);

	return 0;
}