/*
* Copyright (c) 2009 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:
*
*/


package com.nokia.mj.impl.fileutils;

import com.nokia.mj.impl.comms.CommsEndpoint;
import com.nokia.mj.impl.comms.CommsMessage;
import com.nokia.mj.impl.comms.exception.CommsException;
import com.nokia.mj.impl.utils.Logger;

class DriveObserverMessages
{
    // keep in sync with driveutilities.h!!

    final static int DRIVEOBSERVER_MSG_SUBSCRIBE_EVENTS    = 1;
    final static int DRIVEOBSERVER_MSG_UNSUBSCRIBE_EVENTS  = 2;
    final static int DRIVEOBSERVER_MSG_DRIVE_CHANGED_EVENT = 3;
    final static int DRIVEOBSERVER_MSG_GETDRIVES_REQUEST   = 4;
    final static int DRIVEOBSERVER_MSG_GETDRIVES_RESULT    = 5;

    final static int DRIVEOBSERER_GET_DRIVES_ALL           = 1;
    final static int DRIVEOBSERER_GET_DRIVES_ACCESIBLE     = 2;

    final static int PLUGIN_ID_DRIVE_OBSERVER_NATIVE_C     = 50;
    final static int PLUGIN_ID_DRIVE_OBSERVER_JAVA_C       = 51;


    final static DriveInfo[] getDrives(boolean allDrives)
    {
        DriveInfo[] drives = null;

        try
        {
            CommsEndpoint comms;
            boolean commsOwner = false;
            comms = CommsEndpoint.find("javacaptain");
            if (comms == null)
            {
                comms = new CommsEndpoint();
                comms.connect(CommsEndpoint.JAVA_CAPTAIN);
                commsOwner = true;
            }
            CommsMessage msg = new CommsMessage();
            msg.setMessageId(DRIVEOBSERVER_MSG_GETDRIVES_REQUEST);
            msg.setModuleId(PLUGIN_ID_DRIVE_OBSERVER_NATIVE_C);
            if (allDrives)
            {
                msg.write(DRIVEOBSERER_GET_DRIVES_ALL);
            }
            else
            {
                msg.write(DRIVEOBSERER_GET_DRIVES_ACCESIBLE);
            }

            CommsMessage replyMsg = comms.sendReceive(msg, 5);

            if (commsOwner)
            {
                comms.destroy();
            }

            int numOfDrives = 0;
            numOfDrives = replyMsg.readInt();
            Logger.LOG(Logger.EJavaFile, Logger.EInfo, "extracting " + numOfDrives + " driveInfos");

            if (numOfDrives > 0)
            {
                drives = new DriveInfo[numOfDrives];

                for (int i = 0 ; i < numOfDrives ; ++i)
                {
                    drives[i] = extractDriveInfo(replyMsg);
                }
            }
        }
        catch (CommsException e)
        {
            Logger.ELOG(Logger.EJavaFile, "getDrives failed", e);
        }

        return drives;
    }

    static DriveInfo extractDriveInfo(CommsMessage aMessage)
    {
        DriveInfo drive = new DriveInfo();
        try
        {
            Logger.LOG(Logger.EJavaFile, Logger.EInfo, "extracting drive");

            drive.iRootPath = aMessage.readString();
            Logger.LOG(Logger.EJavaFile, Logger.EInfo, "drives[].iRootPath=" + drive.iRootPath);
            drive.iIsPresent = (aMessage.readInt() != 0);
            Logger.LOG(Logger.EJavaFile, Logger.EInfo, "drives[].iIsPresent=" + drive.iIsPresent);
            drive.iIsRemovable = (aMessage.readInt() != 0);
            Logger.LOG(Logger.EJavaFile, Logger.EInfo, "drives[].iIsRemovable=" + drive.iIsRemovable);
            drive.iIsLocal =(aMessage.readInt() != 0);
            Logger.LOG(Logger.EJavaFile, Logger.EInfo, "drives[].iIsLocal=" + drive.iIsLocal);
            drive.iIsReadOnly =(aMessage.readInt() != 0);
            Logger.LOG(Logger.EJavaFile, Logger.EInfo, "drives[].iIsReadOnly=" + drive.iIsReadOnly);
            drive.iId = aMessage.readInt();
            Logger.LOG(Logger.EJavaFile, Logger.EInfo, "drives[].iId=" + drive.iId);
            drive.iIsExternallyMountable = (aMessage.readInt() != 0);
            Logger.LOG(Logger.EJavaFile, Logger.EInfo, "drives[].iIsExternallyMountable=" + drive.iIsPresent);
        }
        catch (Exception e)
        {
            Logger.LOG(Logger.EJavaFile, Logger.EInfo, "Exception in extraction", e);
        }
        return drive;
    }

    static void subscribeEvents(CommsEndpoint aComms, boolean aUnsubscribe)
    {
        CommsMessage msg = new CommsMessage();
        if (aUnsubscribe)
        {
            msg.setMessageId(DRIVEOBSERVER_MSG_UNSUBSCRIBE_EVENTS);
        }
        else
        {
            msg.setMessageId(DRIVEOBSERVER_MSG_SUBSCRIBE_EVENTS);
        }
        msg.setModuleId(PLUGIN_ID_DRIVE_OBSERVER_NATIVE_C);
        msg.write(PLUGIN_ID_DRIVE_OBSERVER_JAVA_C);
        aComms.send(msg);
    }
}