diff -r 0efa10d348c0 -r a5a39a295112 contentpublishingsrv/contentharvester/contentharvesterswiplugin/src/chswiplugin.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/contentpublishingsrv/contentharvester/contentharvesterswiplugin/src/chswiplugin.cpp	Wed Sep 01 12:22:09 2010 +0100
@@ -0,0 +1,326 @@
+/*
+* 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 <driveinfo.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() );
+    
+    iMassMemoryAvailable = InternalMassMemoryAvailable();
+    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()
+	{
+    if (iMassMemoryAvailable)
+    	{
+    	return iMassStorageMode;
+    	}
+    else
+    	{
+    	return EFalse;
+    	}
+	}
+
+// ----------------------------------------------------------------------------
+//
+// ----------------------------------------------------------------------------
+//
+TBool CCHSwiPlugin::InternalMassMemoryAvailable( )
+    {
+    TBool result(EFalse);
+    // List all drives in the system
+    TDriveList driveList;
+    TInt error = iFs.DriveList( driveList );
+    
+    if ( KErrNone == error )
+        {
+        for ( TInt driveNumber = EDriveY;
+              driveNumber >= EDriveA;
+              driveNumber-- )
+            {
+            TUint status( 0 );
+            TInt error = DriveInfo::GetDriveStatus( iFs, driveNumber, status );
+            if( (KErrNone == error) && ( status & DriveInfo::EDriveExternallyMountable ) 
+            		&& ( status & DriveInfo::EDriveInternal ) )
+                {
+                // Internal Memory
+                result = ETrue;
+                break;
+                }
+            }
+        }
+    return result;
+    }
+
+//  End of File