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

#include "chswiplugin.h"

#include <e32std.h>

#include <ecom/implementationproxy.h>
#include <contentharvesterpluginuids.hrh>
#include <liwservicehandler.h>

#include "cpglobals.h"
#include "chswiusbhandler.h"
#include "chswiusbobserver.h"

_LIT( KHSTemplate, "hstemplate" );
_LIT8( KWidgetUid, "widget_uid");

const TInt KWidgetArrayGran = 8;

// Map the interface UIDs to implementation factory functions
// ============================= LOCAL FUNCTIONS ===============================

// Map the interface UIDs to implementation factory functions
const TImplementationProxy ImplementationTable[] = 
    {
      {{KCHSwiPluginUidImpl}, (TProxyNewLPtr)CCHSwiPlugin::NewL},
    };

// ----------------------------------------------------------------------------
// Exported proxy for instantiation method resolution
// ----------------------------------------------------------------------------
//
EXPORT_C const TImplementationProxy* ImplementationGroupProxy(
                                                TInt& aTableCount )
    {
    aTableCount = sizeof(ImplementationTable) / sizeof(TImplementationProxy);
    return ImplementationTable;
    }

// ============================ MEMBER FUNCTIONS ==============================

// ----------------------------------------------------------------------------
// CCHSwiPlugin::CCHSwiPlugin
// Constructor
// ----------------------------------------------------------------------------
//
CCHSwiPlugin::CCHSwiPlugin( MLiwInterface* aInterface )
	{
	iCPSInterface = aInterface;
    }

// ----------------------------------------------------------------------------
// CADatSwi::ConstructL
// Symbian 2nd phase constructor can leave.
// ----------------------------------------------------------------------------
//
void CCHSwiPlugin::ConstructL()
    {
    iNotifier = CApaAppListNotifier::NewL( this, CActive::EPriorityStandard );
    User::LeaveIfError( iApaLsSession.Connect() );
    User::LeaveIfError( iFs.Connect() );
    
    iUsbHandler = CCHSwiUsbHandler::NewL( this, iFs );
    
    iUsbObserver = CCHSwiUsbObserver::NewL( iUsbHandler, iFs );
    iUsbObserver->Start();
    }

// ----------------------------------------------------------------------------
// CADatSwi::NewL
// Two-phased constructor.
// ----------------------------------------------------------------------------
//
CCHSwiPlugin* CCHSwiPlugin::NewL(  MLiwInterface* aInterface)
    {
    CCHSwiPlugin* self = new (ELeave) CCHSwiPlugin( aInterface );
    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop( self );
    return self;
    }

// ----------------------------------------------------------------------------
// CCHSwiPlugin::~CCHSwiPlugin
// Destructor.
// ----------------------------------------------------------------------------
//
CCHSwiPlugin::~CCHSwiPlugin()
    {
    delete iNotifier;
    delete iUsbHandler;
    delete iUsbObserver;
    iApaLsSession.Close();
    iFs.Close();
    }

// ----------------------------------------------------------------------------
// CCHSwiPlugin::UpdateL
// (other items were commented in a header).
// ----------------------------------------------------------------------------
//  
void CCHSwiPlugin::UpdateL()
    {
    UpdateWidgetsL();
    }

// ----------------------------------------------------------------------------
// CCHSwiPlugin::HandleAppListEvent
// (other items were commented in a header).
// ----------------------------------------------------------------------------
//  
void CCHSwiPlugin::HandleAppListEvent( TInt /*aEvent*/ )
    {
    TRAP_IGNORE( UpdateWidgetsL() );
    }

// ----------------------------------------------------------------------------
// CCHSwiPlugin::HandleMassStorageModeEndEvent
// (refer to MCHSwiMassModeObserver declaration).
// ----------------------------------------------------------------------------
//  
void CCHSwiPlugin::HandleMassStorageModeEndEvent()
	{
	TRAP_IGNORE( UpdateWidgetsL() );
	}

// ----------------------------------------------------------------------------
// CCHSwiPlugin::HandleSuccessfulAsynchDriveScan
// (refer to MCHSwiMassModeObserver declaration).
// ----------------------------------------------------------------------------
//  
void CCHSwiPlugin::HandleSuccessfulAsynchDriveScan()
	{
	iUsbObserver->Start();
	}

// ----------------------------------------------------------------------------
// CCHSwiPlugin::UpdateWidgetsL
// MMC watcher callback.
// ----------------------------------------------------------------------------
//
void CCHSwiPlugin::UpdateWidgetsL()
    {
	CLiwGenericParamList* inparam = CLiwGenericParamList::NewLC( );
	CLiwGenericParamList* outparam = CLiwGenericParamList::NewLC( );
	inparam->AppendL( TLiwGenericParam( KType, TLiwVariant( KPublisher ) ) );
	CLiwDefaultMap* filter = CLiwDefaultMap::NewLC();
	
	filter->InsertL( KContentType, TLiwVariant( KHSTemplate ));
	inparam->AppendL( TLiwGenericParam( KFilter, TLiwVariant( filter ) ) );
	
	iCPSInterface->ExecuteCmdL( KGetList, *inparam, *outparam );
	
	RemoveWidgetsL( outparam );
	
	CleanupStack::PopAndDestroy( filter );
	CleanupStack::PopAndDestroy( outparam );
	CleanupStack::PopAndDestroy( inparam );  
    }

// ----------------------------------------------------------------------------
// CCHSwiPlugin::RemoveWidgetsL
// MMC watcher callback.
// ----------------------------------------------------------------------------
//
void CCHSwiPlugin::RemoveWidgetsL( CLiwGenericParamList* aWidgets )
    {
    TInt pos ( 0 );
    aWidgets->FindFirst( pos, KResults ); 	
    
    if ( pos != KErrNotFound )
        {
        CDesC16ArrayFlat* notFoundWidgets = new (ELeave) CDesC16ArrayFlat( KWidgetArrayGran ); 
        CleanupStack::PushL( notFoundWidgets );
        
        TLiwVariant variant = (*aWidgets)[pos].Value();
        variant.PushL();
        CLiwIterable* iterable = variant.AsIterable();
        iterable->Reset();
        
        while ( iterable->NextL( variant ) )
            {
            CLiwDefaultMap *map = CLiwDefaultMap::NewLC();
            variant.Get( *map );
            if ( map->FindL( KDataMap, variant) )
                {
                CLiwDefaultMap *dataMap = CLiwDefaultMap::NewLC();
                variant.Get( *dataMap );
                if ( dataMap->FindL( KWidgetUid, variant ) )
                    {
                    TApaAppInfo appInfo;
                    
                    if( KErrNotFound == iApaLsSession.GetAppInfo( 
                            appInfo, TUid::Uid( variant.AsTInt32() ) ) )
                        {
                        if( map->FindL( KPublisherId, variant ) )
                            {
                            notFoundWidgets->AppendL( variant.AsDes() );
                            }
                        }
                    }
                CleanupStack::PopAndDestroy( dataMap );
                }
            CleanupStack::PopAndDestroy( map );
            }
        
        if ( notFoundWidgets->Count() > 0 )
        	{
        	iUsbHandler->SynchronousDriveScan();
        			
        	if ( !IsMassStorageMode() )
        		{
        		for ( TInt i = 0; i < notFoundWidgets->Count(); i++ )
        			{
        			RemoveWidgetL( KPublisher, (*notFoundWidgets)[i] );
        			RemoveWidgetL( KCpData, (*notFoundWidgets)[i] );
        			}
        	   	}
        	}
        
        CleanupStack::PopAndDestroy( &variant );
        CleanupStack::PopAndDestroy( notFoundWidgets );
        }
    	

    }

// ----------------------------------------------------------------------------
// CCHSwiPlugin::RemoveWidgetL
// MMC watcher callback.
// ----------------------------------------------------------------------------
//
void CCHSwiPlugin::RemoveWidgetL( const TDesC& aType, 
        const TDesC& aPublisherId )
    {
    CLiwGenericParamList* inparam = CLiwGenericParamList::NewLC( );
    CLiwGenericParamList* outparam = CLiwGenericParamList::NewLC( );
    inparam->AppendL( TLiwGenericParam( KType, TLiwVariant( aType ) ) );
    CLiwDefaultMap* filter = CLiwDefaultMap::NewLC();
    
    filter->InsertL( KPublisherId, TLiwVariant( aPublisherId ));
    inparam->AppendL( TLiwGenericParam( KFilter, TLiwVariant( filter ) ) );
    
    iCPSInterface->ExecuteCmdL( KDelete, *inparam, *outparam );
    
    CleanupStack::PopAndDestroy( filter );
    CleanupStack::PopAndDestroy( outparam );
    CleanupStack::PopAndDestroy( inparam );
    }

// ----------------------------------------------------------------------------
// CCHSwiPlugin::SetMassStorageMode
// Sets Mass Storage mode.
// ----------------------------------------------------------------------------
//
void CCHSwiPlugin::SetMassStorageMode( TBool aMode )
	{
	iMassStorageMode = aMode;
	}

// ----------------------------------------------------------------------------
// CCHSwiPlugin::IsMassStorageMode
// Gets Mass Storage mode.
// ----------------------------------------------------------------------------
//
TBool CCHSwiPlugin::IsMassStorageMode()
	{
	return iMassStorageMode;
	}

//  End of File