/*
* Copyright (c) 2008 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of "Eclipse Public License v1.0"
* which accompanies this distribution, and is available
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
*
* Initial Contributors:
* Nokia Corporation - initial contribution.
*
* Contributors:
*
* Description:  DriveObserverMessages
*
*/

#ifndef DRIVEOBSERVERMESSAGES_H
#define DRIVEOBSERVERMESSAGES_H

#include "logger.h"
#include "comms.h"
#include "commsmessage.h"

#include "driveutilities.h"

using java::comms::CommsMessage;

namespace java
{
namespace fileutils
{
const int DRIVEOBSERVER_MSG_SUBSCRIBE_EVENTS    = 1;
const int DRIVEOBSERVER_MSG_UNSUBSCRIBE_EVENTS  = 2;
const int DRIVEOBSERVER_MSG_DRIVE_CHANGED_EVENT = 3;
const int DRIVEOBSERVER_MSG_GETDRIVES_REQUEST   = 4;
const int DRIVEOBSERVER_MSG_GETDRIVES_RESULT    = 5;

const int DRIVEOBSERER_GET_DRIVES_ALL           = 1;
const int DRIVEOBSERER_GET_DRIVES_ACCESIBLE     = 2;

inline void setSubscribeParams(CommsMessage& aMessage, int moduleId)
{
    aMessage.setMessageId(DRIVEOBSERVER_MSG_SUBSCRIBE_EVENTS);
    aMessage.setModuleId(java::comms::PLUGIN_ID_DRIVE_OBSERVER_NATIVE_C);
    aMessage << moduleId;
}
inline void getSubscribeParams(CommsMessage& aMessage, int& moduleId)
{
    if (aMessage.getMessageId() == DRIVEOBSERVER_MSG_SUBSCRIBE_EVENTS)
    {
        aMessage >> moduleId;
    }
    else
    {
        moduleId = 0;
    }
}

inline void setUnsubscribeMessage(CommsMessage& aMessage, int moduleId)
{
    aMessage.setMessageId(DRIVEOBSERVER_MSG_UNSUBSCRIBE_EVENTS);
    aMessage.setModuleId(java::comms::PLUGIN_ID_DRIVE_OBSERVER_NATIVE_C);
    aMessage << moduleId;
}

inline void getUnsubscribeParams(CommsMessage& aMessage, int& moduleId)
{
    if (aMessage.getMessageId() == DRIVEOBSERVER_MSG_UNSUBSCRIBE_EVENTS)
    {
        aMessage >> moduleId;
    }
    else
    {
        ELOG2(EJavaFile, "wrong messageId was %d expecting %d",
              aMessage.getMessageId(), DRIVEOBSERVER_MSG_UNSUBSCRIBE_EVENTS);
        moduleId = 0;
    }
}

inline void appendDriveInfo(CommsMessage& aMessage, const driveInfo& aDriveInfo)
{
    aMessage << aDriveInfo.iRootPath;
    aMessage << (aDriveInfo.iIsPresent ? 1 : 0);
    aMessage << (aDriveInfo.iIsRemovable ? 1 : 0);
    aMessage << (aDriveInfo.iIsLocal ? 1 : 0);
    aMessage << (aDriveInfo.iIsReadOnly ? 1 : 0);
    aMessage << (int) aDriveInfo.iId;
    aMessage << (aDriveInfo.iIsExternallyMountable ? 1 : 0);
}

inline void extractDriveInfo(CommsMessage& aMessage, driveInfo& aDriveInfo)
{
    aMessage >> aDriveInfo.iRootPath;

    int tempInt = 0;
    aMessage >> tempInt;
    aDriveInfo.iIsPresent = (tempInt == 1 ? true : false);

    aMessage >> tempInt;
    aDriveInfo.iIsRemovable = (tempInt == 1 ? true : false);

    aMessage >> tempInt;
    aDriveInfo.iIsLocal = (tempInt == 1 ? true : false);

    aMessage >> tempInt;
    aDriveInfo.iIsReadOnly = (tempInt == 1 ? true : false);

    aMessage >> tempInt;
    aDriveInfo.iId = tempInt;
    aMessage >> tempInt;
    aDriveInfo.iIsExternallyMountable = (tempInt == 1 ? true : false);
}

inline void setDriveChangedParams(CommsMessage& aMessage,
                                  int aReceiver,
                                  int aModuleId,
                                  int aOperation,
                                  const driveInfo& aDriveInfo)
{
    aMessage.setMessageId(DRIVEOBSERVER_MSG_DRIVE_CHANGED_EVENT);
    aMessage.setReceiver(aReceiver);
    aMessage.setModuleId(aModuleId);
    aMessage << aOperation;
    appendDriveInfo(aMessage, aDriveInfo);
}

inline void getDriveChangedParams(CommsMessage& aMessage, int& aOperation,
                                  driveInfo& aDriveInfo)
{
    if (aMessage.getMessageId() == DRIVEOBSERVER_MSG_DRIVE_CHANGED_EVENT)
    {
        aMessage >> aOperation;
        extractDriveInfo(aMessage, aDriveInfo);
    }
    else
    {
        ELOG2(EJavaFile, "wrong messageId was %d expecting %d",
              aMessage.getMessageId(), DRIVEOBSERVER_MSG_DRIVE_CHANGED_EVENT);
    }
}

inline void setGetDrivesParams(CommsMessage& aMessage, const int& aDriveTypes)
{
    aMessage.setMessageId(DRIVEOBSERVER_MSG_GETDRIVES_REQUEST);
    aMessage.setModuleId(java::comms::PLUGIN_ID_DRIVE_OBSERVER_NATIVE_C);
    aMessage << aDriveTypes;
}

inline void getGetDrivesParams(CommsMessage& aMessage, int& aDriveTypes)
{
    if (aMessage.getMessageId() == DRIVEOBSERVER_MSG_GETDRIVES_REQUEST)
    {
        aMessage >> aDriveTypes;
    }
    else
    {
        ELOG2(EJavaFile, "wrong messageId was %d expecting %d",
              aMessage.getMessageId(), DRIVEOBSERVER_MSG_GETDRIVES_REQUEST);
    }
}

inline void setGetDrivesResultParams(CommsMessage& aMessage,
                                     const driveInfos& aDriveInfos)
{
    aMessage.setMessageId(DRIVEOBSERVER_MSG_GETDRIVES_RESULT);
    aMessage.setModuleId(java::comms::PLUGIN_ID_DRIVE_OBSERVER_NATIVE_C);
    int numOfDrives = aDriveInfos.size();
    aMessage << numOfDrives;
    for (int i = 0 ; i < numOfDrives ; i++)
    {
        appendDriveInfo(aMessage, aDriveInfos[i]);
    }
}

inline void getGetDrivesResultParams(CommsMessage& aMessage,
                                     driveInfos& aDriveInfos)
{
    aDriveInfos.clear();

    if (aMessage.getMessageId() == DRIVEOBSERVER_MSG_GETDRIVES_RESULT)
    {
        int numOfDrives = 0;
        aMessage >> numOfDrives;
        if (numOfDrives > 0)
        {
            driveInfo di;
            for (int i = 0 ; i < numOfDrives ; i++)
            {
                extractDriveInfo(aMessage, di);
                aDriveInfos.push_back(di);
            }
        }
    }
    else
    {
        ELOG2(EJavaFile, "wrong messageId was %d expecting %d",
              aMessage.getMessageId(), DRIVEOBSERVER_MSG_GETDRIVES_RESULT);
    }
}

} // namespace fileutils
} // namespace java
#endif // DRIVEOBSERVERMESSAGES_H