// NodeMonitoringEvent.cpp

#include <Message.h>
#include <NodeMonitor.h>

#include "DebugSupport.h"
#include "NodeMonitoringEvent.h"

// NodeMonitoringEvent

// constructor
NodeMonitoringEvent::NodeMonitoringEvent()
        : BReferenceable(),
          time(system_time()),
          queryHandler(NULL),
          remotePort(-1),
          remoteToken(-1)
{
}

// destructor
NodeMonitoringEvent::~NodeMonitoringEvent()
{
        if (queryHandler)
                queryHandler->ReleaseReference();
}


// EntryCreatedEvent

// Init
status_t
EntryCreatedEvent::Init(const BMessage* message)
{
        opcode = B_ENTRY_CREATED;
        const char* localName;
        if (message->FindInt32("device", &volumeID) != B_OK
                || message->FindInt64("directory", &directoryID) != B_OK
                || message->FindInt64("node", &nodeID) != B_OK
                || message->FindString("name", &localName) != B_OK) {
                return B_BAD_VALUE;
        }
        if (!name.SetTo(localName))
                return B_NO_MEMORY;
        return B_OK;
}


// EntryRemovedEvent

// Init
status_t
EntryRemovedEvent::Init(const BMessage* message)
{
        opcode = B_ENTRY_REMOVED;
        if (message->FindInt32("device", &volumeID) != B_OK
                || message->FindInt64("directory", &directoryID) != B_OK
                || message->FindInt64("node", &nodeID) != B_OK) {
                return B_BAD_VALUE;
        }
        nodeVolumeID = volumeID;
        return B_OK;
}


// EntryMovedEvent

// Init
status_t
EntryMovedEvent::Init(const BMessage* message)
{
        opcode = B_ENTRY_MOVED;
        const char* localName;
        if (message->FindInt32("device", &volumeID) != B_OK
                || message->FindInt64("from directory", &fromDirectoryID) != B_OK
                || message->FindInt64("to directory", &toDirectoryID) != B_OK
                || message->FindInt64("node", &nodeID) != B_OK
                || message->FindString("name", &localName) != B_OK) {
                return B_BAD_VALUE;
        }
        nodeVolumeID = volumeID;
        if (!toName.SetTo(localName))
                return B_NO_MEMORY;
        return B_OK;
}


// StatChangedEvent

// Init
status_t
StatChangedEvent::Init(const BMessage* message)
{
        opcode = B_STAT_CHANGED;
        if (message->FindInt32("device", &volumeID) != B_OK
                || message->FindInt64("node", &nodeID)) {
                return B_BAD_VALUE;
        }
        return B_OK;
}


// AttributeChangedEvent

// Init
status_t
AttributeChangedEvent::Init(const BMessage* message)
{
        opcode = B_ATTR_CHANGED;
        const char* localName;
        if (message->FindInt32("device", &volumeID) != B_OK
                || message->FindInt64("node", &nodeID)
                || message->FindString("attr", &localName) != B_OK) {
                return B_BAD_VALUE;
        }
        if (!attribute.SetTo(localName))
                return B_NO_MEMORY;
        return B_OK;
}


// VolumeMountedEvent

// Init
status_t
VolumeMountedEvent::Init(const BMessage* message)
{
        opcode = B_DEVICE_MOUNTED;
        if (message->FindInt32("new device", &newVolumeID) != B_OK
                || message->FindInt32("device", &volumeID) != B_OK
                || message->FindInt64("directory", &directoryID) != B_OK) {
                return B_BAD_VALUE;
        }
        return B_OK;
}


// VolumeUnmountedEvent

// Init
status_t
VolumeUnmountedEvent::Init(const BMessage* message)
{
        opcode = B_DEVICE_UNMOUNTED;
        if (message->FindInt32("device", &volumeID) != B_OK)
                return B_BAD_VALUE;
        return B_OK;
}