/*
 * Copyright 2004-2010, Haiku, Inc. All rights reserved.
 * Distributed under the terms of the MIT License.
 *
 * Authors:
 *              Andrew Bachmann
 */


#include "AddOnMonitor.h"
#include "AddOnMonitorHandler.h"
#include <Message.h>
#include <MessageRunner.h>
#include <Messenger.h>
#include <stdio.h>


AddOnMonitor::AddOnMonitor()
        :
        BLooper("AddOnMonitor"),
        fInitCheck(B_NO_INIT),
        fPulseRunner(NULL)
{
}


AddOnMonitor::AddOnMonitor(AddOnMonitorHandler* handler)
        :
        BLooper("AddOnMonitor"),
        fInitCheck(B_NO_INIT),
        fPulseRunner(NULL)
{
        SetHandler(handler);

        thread_id id = Run();
        if (id < 0) {
                fInitCheck = (status_t)id;
                fprintf(stderr, "AddOnMonitor() : bad id returned by Run()\n");
                return;
        }
}


AddOnMonitor::~AddOnMonitor()
{
        delete fPulseRunner;
}


status_t
AddOnMonitor::InitCheck()
{
        return fInitCheck;
}


void
AddOnMonitor::SetHandler(AddOnMonitorHandler* handler)
{
        if (handler == NULL)
                return;

        AddHandler(handler);
        SetPreferredHandler(handler);

        delete fPulseRunner;
        fPulseRunner = NULL;

        status_t status;
        BMessenger messenger(handler, this, &status);
        if (status != B_OK) {
                fInitCheck = status;
                return;
        }

        BMessage pulseMessage(B_PULSE);
        fPulseRunner = new(std::nothrow) BMessageRunner(messenger, &pulseMessage,
                1000000);
        if (fPulseRunner == NULL) {
                fInitCheck = B_NO_MEMORY;
                return;
        }

        status = fPulseRunner->InitCheck();
        if (status != B_OK) {
                fInitCheck = status;
                fprintf(stderr, "AddOnMonitor() : bad status returned by "
                        "fPulseRunner->InitCheck()\n");
                return;
        }

        // Send an initial message to process added directories immediately
        messenger.SendMessage(&pulseMessage);

        fInitCheck = B_OK;
}