/*

* 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:  DriveChangedEventGenerator - S60 specific

*

*/

#include "logger.h"

#include "drivechangedeventgenerator.h"

#include "driveutilities.h"

namespace java

{

namespace fileutils

{

DriveChangedEventGenerator::DriveChangedEventGenerator(DriveListenerInterface* aEventDispatcher)

        :iEventDispatcher(aEventDispatcher)

{

    JELOG2(EJavaFile);

}

DriveChangedEventGenerator::~DriveChangedEventGenerator()

{

    JELOG2(EJavaFile);

}

void DriveChangedEventGenerator::startEvents()

{

    JELOG2(EJavaFile);

    driveInfos drives;

    DriveUtilities::getAllDrives(drives);

    if (KErrNone == iFs.Connect())

    {

        for (driveInfos::const_iterator iter = drives.begin() ;

                iter != drives.end() ; ++iter)

        {

            if (iter->iIsRemovable)

            {

                iDriveObjects.push_back(new DriveChangedActive(*iter, this, &iFs));

            }

        }

    }

}

void DriveChangedEventGenerator::stopEvents()

{

    JELOG2(EJavaFile);

    iFs.Close();

}

// DriveListenerInterface

void DriveChangedEventGenerator::driveChanged(const int& aOperation, const driveInfo& aDriveInfo)

{

    JELOG2(EJavaFile);

    iEventDispatcher->driveChanged(aOperation, aDriveInfo);

}

// change notification will be generated for this directory

_LIT(KNotificationDirectory,"mediachange\\");

DriveChangedEventGenerator::DriveChangedActive::DriveChangedActive(driveInfo aDriveInfo,

        DriveListenerInterface* aEventDispatcher, RFs* aFsSession)

        :CActive(EPriorityNormal),

        iDrive(0),

        iDriveInfo(aDriveInfo),

        iEventDispatcher(aEventDispatcher),

        iFs(aFsSession)

{

    JELOG2(EJavaFile);

    CActiveScheduler::Add(this);

    TChar driveChar = (TChar) iDriveInfo.iRootPath[0];

    iFs->CharToDrive(driveChar, iDrive);

    TPath privatePath;

    iFs->PrivatePath(privatePath);

    // obtain notification path

    iNotificationPath.Append(driveChar);

    iNotificationPath.Append(KDriveDelimiter);

    iNotificationPath.Append(privatePath);

    iNotificationPath.Append(KNotificationDirectory);

    iFs->NotifyChange(ENotifyEntry, iStatus, iNotificationPath);

    SetActive();

}

DriveChangedEventGenerator::DriveChangedActive::~DriveChangedActive()

{

    JELOG2(EJavaFile);

    Cancel();

}

void DriveChangedEventGenerator::DriveChangedActive::RunL()

{

    JELOG2(EJavaFile);

    TDriveInfo driveInfo;

    TInt rc = iFs->Drive(driveInfo, iDrive);

    if (KErrNone == rc)

    {

        LOG(EJavaFile, EInfo, "iFs->Drive() returns KErrNone");

        LOG1(EJavaFile, EInfo, "driveInfo.iType = %d", driveInfo.iType);

    }

    TVolumeInfo volumeInfo;

    int operation = 0;

    rc = iFs->Volume(volumeInfo, iDrive);

    if (KErrNone == rc)

    {

        LOG(EJavaFile, EInfo, "iFs->Volume() returns KErrNone");

        operation = DriveListenerInterface::REMOVABLE_MEDIA_INSERTED_C;

        iDriveInfo.iIsPresent = true;

        iDriveInfo.iId = volumeInfo.iUniqueID;

    }

    else

    {

        LOG1(EJavaFile, EInfo, "iFs->Volume() returns %d", rc);

        operation = DriveListenerInterface::REMOVABLE_MEDIA_REMOVED_C;

        iDriveInfo.iIsPresent = false;

    }

    iEventDispatcher->driveChanged(operation, iDriveInfo);

    iFs->NotifyChange(ENotifyEntry, iStatus, iNotificationPath);

    SetActive();

}

void DriveChangedEventGenerator::DriveChangedActive::DoCancel()

{

    JELOG2(EJavaFile);

    iFs->NotifyChangeCancel();

}

} // namespace fileutils

} // namespace java