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


#include <Directory.h>
#include <Entry.h>
#include <File.h>
#include <Looper.h>
#include <Path.h>
#include <PathMonitor.h>

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

using BPrivate::BPathMonitor;


class Looper : public BLooper {
        public:
                Looper(const char* path);
                virtual ~Looper();

                virtual void MessageReceived(BMessage* message);

        private:
                BPath   fPath;
};


Looper::Looper(const char* path)
        : BLooper("path monitor test"),
        fPath(path)
{
        status_t status = BPathMonitor::StartWatching(path, B_WATCH_ALL, this);
        if (status != B_OK) {
                fprintf(stderr, "Could not watch path \"%s\": %s.\n", path, strerror(status));
                PostMessage(B_QUIT_REQUESTED);
        }
}


Looper::~Looper()
{
        status_t status = BPathMonitor::StopWatching(fPath.Path(), this);
        if (status != B_OK)
                fprintf(stderr, "Could not stop watching: %s\n", strerror(status));
}


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


//      #pragma mark -


void
create_file(const char* path)
{
        printf("******* create file %s *******\n", path);
        BFile file;
        status_t status = file.SetTo(path, B_CREATE_FILE | B_READ_WRITE);
        if (status != B_OK)
                fprintf(stderr, "could not create watch test.\n");
        file.Write("test", 4);
}


void
remove_file(const char* path)
{
        printf("******* remove file %s *******\n", path);
        remove(path);
}


void
create_directory(const char* path)
{
        printf("******* create directory %s *******\n", path);
        create_directory(path, 0755);
}


void
remove_directory(const char* path)
{
        printf("******* remove directory %s *******\n", path);
        rmdir(path);
}


//      #pragma mark -


void
test_a()
{
        puts("******************* test A ********************");

        create_directory("/tmp/a");
        create_directory("/tmp/ab");
        create_directory("/tmp/a/b");
        create_directory("/tmp/a/bc");
        create_directory("/tmp/a/b/c");
        create_directory("/tmp/a/b/cd");

        create_file("/tmp/a/b/c/d");
        snooze(100000);
        remove_file("/tmp/a/b/c/d");

        remove_directory("/tmp/a/b/cd");
        remove_directory("/tmp/a/bc");
        remove_directory("/tmp/ab");

        snooze(100000);
}


void
test_b()
{
        puts("******************* test B ********************");
        remove_directory("/tmp/a/b/c");
        snooze(100000);
        create_file("/tmp/a/b/c");
        snooze(100000);
        remove_file("/tmp/a/b/c");
}


void
test_c()
{
        puts("******************* test C ********************");
        create_directory("/tmp/a/b/c");
        create_directory("/tmp/a/b/c/d");
        snooze(100000);
        remove_directory("/tmp/a/b/c/d");
        remove_directory("/tmp/a/b/c");
}


void
test_d()
{
        puts("******************* test D ********************");
        remove_directory("/tmp/a/b");
        remove_directory("/tmp/a");
}


int
main()
{
        // start looper
        Looper& looper = *new Looper("/tmp/a/b/c");
        looper.Run();

        // run tests
        test_a();
        test_b();
        test_c();
        test_d();

#if 0
        char b[2100];
        gets(b);
#endif

        snooze(500000LL);

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

        return 0;
}