/*
* 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:  DriveObserverImpl - platform S60 specific
*
*/


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

#include "driveobserverclient.h"
#include "driveobservermessages.h"

using java::comms::CommsClientEndpoint;

namespace java
{
namespace fileutils
{

DriveObserverClient::DriveObserverClient()
        :mEventsSubscribed(false), mComms(0), mCommsOwner(false)
{
    JELOG2(EJavaFile);
}

DriveObserverClient::~DriveObserverClient()
{
    JELOG2(EJavaFile);

    // Clear listeners collection
    mListeners.clear();
    disableEvents();
}

int DriveObserverClient::registerListener(DriveListenerInterface* aListener,
        const int& aServerCommsAddress)
{
    JELOG2(EJavaFile);
    std::set<DriveListenerInterface*>::iterator iter = mListeners.find(aListener);
    if (iter == mListeners.end())
    {
        mListeners.insert(aListener);
    }

    enableEvents(aServerCommsAddress);

    return mListeners.size();
}

int DriveObserverClient::unregisterListener(DriveListenerInterface* aListener,
        const int& /*aServerCommsAddress*/)
{
    JELOG2(EJavaFile);
    std::set<DriveListenerInterface*>::iterator iter = mListeners.find(aListener);
    if (iter != mListeners.end())
    {
        mListeners.erase(iter);
    }
    return mListeners.size();
}

void DriveObserverClient::enableEvents(const int& aServerCommsAddress)
{
    if (!mEventsSubscribed)
    {
        int connecStatus = 0;

        // Create CommsEndpoint either use find or create a new one
        if (aServerCommsAddress == java::comms::IPC_ADDRESS_JAVA_CAPTAIN_C)
        {
            mComms = CommsClientEndpoint::find(L"javacaptain");

            if (mComms == 0)
            {
                mComms = new CommsClientEndpoint;
                mCommsOwner = true;

                connecStatus = mComms->connect(java::comms::IPC_ADDRESS_JAVA_CAPTAIN_C);
            }
        }
        else
        {
            mComms = new CommsClientEndpoint;
            mCommsOwner = true;
            connecStatus = mComms->connect(aServerCommsAddress);
        }

        if (0 == connecStatus)
        {
            // Register moduleId
            mComms->registerListener(java::comms::PLUGIN_ID_DRIVE_OBSERVER_NATIVE_C, this);

            // Subscribe to events
            CommsMessage msg;
            setSubscribeParams(msg, java::comms::PLUGIN_ID_DRIVE_OBSERVER_NATIVE_C);
            if (0 == mComms->send(msg))
            {
                mEventsSubscribed = true;
            }
        }
    }
}

void DriveObserverClient::disableEvents()
{
    if (mEventsSubscribed)
    {
        // Unsubscribe to events
        CommsMessage msg;
        setUnsubscribeMessage(msg, java::comms::PLUGIN_ID_DRIVE_OBSERVER_NATIVE_C);
        mComms->send(msg);

        // Unregister moduleId
        mComms->unregisterListener(java::comms::PLUGIN_ID_DRIVE_OBSERVER_NATIVE_C, this);

        // Close and delete CommsEndpoint if our creation
        if (mCommsOwner)
        {
            mComms->disconnect();
            delete mComms;
            mComms = 0;
            mCommsOwner = false;
        }
        mEventsSubscribed = false;
    }
}

void DriveObserverClient::processMessage(java::comms::CommsMessage& aMessage)
{
    JELOG2(EJavaFile);
    switch (aMessage.getMessageId())
    {
    case DRIVEOBSERVER_MSG_DRIVE_CHANGED_EVENT:
    {
        int operation;
        driveInfo di;
        getDriveChangedParams(aMessage, operation, di);
        std::set<DriveListenerInterface*>::iterator iter;
        for (iter = mListeners.begin(); iter != mListeners.end(); ++iter)
        {
            (*iter)->driveChanged(operation, di);
        }
    }
    break;

    default:
        ELOG1(EJavaFile, "Unknown message received %d", aMessage.getMessageId());
    }
}

} // end of namespace fileutils
} // end of namespace java