FCL/sf/mw/web: comparison codhandler/codeng/src/FileSaver.cpp

equal deleted inserted replaced

-:79859ed3eea9
+:919f36ff910f
 * Initial Contributors:
 * Nokia Corporation - initial contribution.
 *
 * Contributors:
 *
 * Description:
 *      Implementation of class CFileSaver.
 *
 *
 */
 // INCLUDE FILES
-//#include <platform/mw/Browser_platform_variant.hrh>
+#include <browser_platform_variant.hrh>
-#include <Browser_platform_variant.hrh>
 #include "FileSaver.h"
 #include "CodBuffStorage.h"
 #include "CodLoadObserver.h"
 #include "RFeatMgr.h"
 #include "CodUtil.h"
 #include "CodPanic.h"
 #include "DrmHandler.h"
 #include "CodData.h"
 #include <f32file.h>
-#include <HttpDownloadMgrCommon.h>
+#include <httpdownloadmgrcommon.h>
 #include <DocumentHandler.h>
 #include <pathinfo.h>
-// following one line is temporary: AVKON dependency removal
-#undef BRDO_APP_GALLERY_SUPPORTED_FF
 #ifdef BRDO_APP_GALLERY_SUPPORTED_FF
 #include <MGXFileManagerFactory.h>
 #include <CMGXFileManager.h>
 #endif
 #include <DcfEntry.h>
 #include <DcfRep.h>
+#ifdef DOWNLOADMGR_PATH_PLUGIN_ENABLED_FF
+#include <DownloadPathHandler.h>
+#endif
 const TInt KDefaultStorageBufferSize = 128 * 1024;
 const TInt KDefaultStorageBufferSizePD = 16 * 1024;
 // ================= MEMBER FUNCTIONS =======================
 // ---------------------------------------------------------
 // CFileSaver::NewL()
 void CFileSaver::ConstructL()
 {
 CCodSaver::ConstructL();
 iBufferSize =  KDefaultStorageBufferSize ;
 iProgressiveDownload = EFalse ;
 iStorage = CCodBuffStorage::NewL(this);
 }
 // ---------------------------------------------------------
 // CFileSaver::CFileSaver()
 iRootPath( aRootPath ),
 iFname( aFname)
 {
 CLOG(( ECodEng, 2, _L("*** CFileSaver::CFileSaver") ));
 }
 // ---------------------------------------------------------
 // CFileSaver::~CFileSaver()
 // ---------------------------------------------------------
 //
 CFileSaver::~CFileSaver()
 //
 void CFileSaver::OpenStoreL()
 {
 CLOG(( ECodEng, 2, _L("CFileSaver::OpenStoreL") ));
 __ASSERT_DEBUG( iState == EInit, CodPanic( ECodInternal ) );
 // Store (temp file) is not opened now.
 // Opening is deferred until first data chunk arrives.
 TInt err = iFile.Open(  iFs,
 iFname,
 EFileShareAny |
 EFileStream |
 #ifdef BRDO_RFILE_WRITE_DIRECT_IO_FF
 EFileWrite |
 EFileWriteDirectIO );
 #else
 EFileWrite );
 #endif
 	if(err == KErrNotFound)
 	    {
 err = iFile.Replace( iFs,
 iFname,
 EFileShareAny |
 EFileStream |
 #ifdef BRDO_RFILE_WRITE_DIRECT_IO_FF
 EFileWrite |
 EFileWriteDirectIO );
 #else
 EFileWrite );
 #endif
 	    }
 if( !err )
 {
 iFile.Seek( ESeekEnd, pos );
 }
 iSize = 0;
 iState = EStoreOpen;
 }
 // ---------------------------------------------------------
 // CFileSaver::AppendData()
 // ---------------------------------------------------------
 //
 TInt CFileSaver::AppendData( const TDesC8& aData )
 /*if( !iPausable )
 {
 // nothing persisted yet. If there's a file with the same name,
 // delete it.
 err = iFile.Replace( iFs,
 iFname,
 EFileShareAny |
 EFileStream |
 EFileWrite );
 }
 else*/
 }
 if ( !err )
 {
 err = iStorage->WriteOutNextBodyDataL(aData );
 }
 CLOG(( EHttpLoad, 2, _L("<- CFileSaver::AppendData returns (%d)"), err ));
 return err;
 }
 // ---------------------------------------------------------
 // The transport size may also be different, if compression or some
 // packaging format is used."
 //
 // There is a safety upper bound on the transaction size, that is already
 // applied. See SetMaxSize().
 TDataType drm( KOma1DrmMessageContentType );
 TDataType dcf( KOma1DcfContentType );
 if ( iType == drm )
 {
 }
 }
 else
 {
 // Other than DRM stuff arrived. Proper check for MIME type.
-if( !(*aData[aData.ActiveDownload()]).HasType( iType.Des8() ) )
+if( !(*aData[aData.ActiveDownload()]).HasType( iType.Des8() ) && ! iDocHandler.CanSaveL(iType) )
 {
 CLOG(( ECodEng, 4, _L("  mismatch") ));
 User::Leave( KErrCodAttributeMismatch );
 }
 }
 /* check if the PD app has been started (PD appl is responsible for file moving after play is done)
 In this case leave and go to the next state.
 */
 if (!aAttached)
 	    {
 #if 0
 RFs fs;
 TInt err( KErrNone );
 HBufC* filename = HBufC::NewLC(KMaxFileName);
 TPtr filenamePtr = filename->Des();
 filenamePtr = iRootPath;
 CFileMan* file=CFileMan::NewL(fs);
 CleanupStack::PushL(file);
 TInt error = fs.MkDirAll(filenamePtr);
 if (error!=KErrNone && error!=KErrAlreadyExists)
 {
 User::Leave(error);
 }
 // Find a unique name to avoid any conflict.
 // Here iFname has full path of current location of file
 // and filename has destination path.
 FindUniqueDestinationFileNameL( iFname, filename );
 filenamePtr = filename->Des();
 err = file->Move(iFname, filenamePtr, CFileMan::EOverWrite);
 if(err != KErrNone)
 {
 User::Leave(err);
 }
 iFname = filenamePtr;
 NotifyMediaGalleryL( filenamePtr );
 CleanupStack::PopAndDestroy(file);
 CleanupStack::PopAndDestroy(&fs);
 CleanupStack::PopAndDestroy(filename);
 #else
 RFs fs;
 User::LeaveIfError( fs.Connect() );
 CleanupClosePushL(fs);
 CFileMan* file=CFileMan::NewL(fs);
 CleanupStack::PushL(file);
+#ifdef DOWNLOADMGR_PATH_PLUGIN_ENABLED_FF
+CDownloadPathHandler* downloadPathPlugin = NULL;
+if ( aData.Count() )
+{
+// Get the mime type of the first media object
+TPtrC8 mimeType = (*aData[1]).Type();
+downloadPathPlugin = GetDownloadPathPluginInstanceL( mimeType );
+if( downloadPathPlugin )
+{
+CleanupStack::PushL( downloadPathPlugin );
+}
+}
+#endif
 for( TInt i = 1; i <= aData.Count() ; ++i )
 {
 HBufC* filename = HBufC::NewLC(KMaxFileName);
 TPtr filenamePtr = filename->Des();
 filenamePtr = (*aData[i]).iRootPath;
-filenamePtr.Append(_L("download\\"));
+#ifdef DOWNLOADMGR_PATH_PLUGIN_ENABLED_FF
+if( downloadPathPlugin )
+{
+TFileName iTempFlName = (*aData[i]).iFullName->Des();
+GetUpdatedPathFromPluginL( downloadPathPlugin,iTempFlName, filenamePtr );
+}
+else
+{
+filenamePtr.Append( _L( "download\\" ) );
+}
+#else
+filenamePtr.Append( _L( "download\\" ) );
+#endif
 TInt error = fs.MkDirAll(filenamePtr);
 if (error!=KErrNone && error!=KErrAlreadyExists)
 {
 User::Leave(error);
 }
 iFname = (*aData[i]).iFullName->Des();
 // Find a unique name to avoid any conflict.
 // Here iFname has full path of current location of file
 // and filename has destination path.
 FindUniqueDestinationFileNameL( iFname, filename );
 filenamePtr = filename->Des();
 TInt err = file->Move(iFname, filenamePtr, CFileMan::EOverWrite);
 if(err != KErrNone)
 	{
 	User::LeaveIfError(err);
 	}
 iFname = filenamePtr;
 NotifyMediaGalleryL( filenamePtr );
 (*aData[i]).iFileName = iFname;
 (*aData[i]).iFullName = NameL();
 CleanupStack::PopAndDestroy(filename);
 }
+#ifdef DOWNLOADMGR_PATH_PLUGIN_ENABLED_FF
+if( downloadPathPlugin )
+{
+CleanupStack::PopAndDestroy( downloadPathPlugin );
+}
+#endif
 CleanupStack::PopAndDestroy(file);
 CleanupStack::PopAndDestroy(&fs);
 #endif // RD_MULTIPLE_DRIVE
 // TODO set iType to that of the packaged object (??)
 /* check if the PD app has been started (PD appl is responsible for file moving after play is done)
 In this case leave and go to the next state.
 */
 if (!aAttached)
 	    {
 #ifdef RD_MULTIPLE_DRIVE
 RFs fs;
 TInt err( KErrNone );
 HBufC* filename = HBufC::NewLC(KMaxFileName);
 TPtr filenamePtr = filename->Des();
 filenamePtr = iRootPath;
-filenamePtr.Append(_L("download\\"));
+#ifdef DOWNLOADMGR_PATH_PLUGIN_ENABLED_FF
+// Get the mime type of the content
+TPtrC8 mimeType( iType.Des8() );
+CDownloadPathHandler* downloadPathPlugin = NULL;
+downloadPathPlugin = GetDownloadPathPluginInstanceL( mimeType );
+if( downloadPathPlugin )
+{
+CleanupStack::PushL( downloadPathPlugin );
+GetUpdatedPathFromPluginL( downloadPathPlugin,iFname, filenamePtr );
+CleanupStack::PopAndDestroy( downloadPathPlugin );
+}
+else
+{
+filenamePtr.Append( _L( "download\\" ) );
+}
+#else
+filenamePtr.Append( _L( "download\\" ) );
+#endif
 User::LeaveIfError( fs.Connect() );
 CleanupClosePushL(fs);
 CFileMan* file=CFileMan::NewL(fs);
 CleanupStack::PushL(file);
 TInt error = fs.MkDirAll(filenamePtr);
 if (error!=KErrNone && error!=KErrAlreadyExists)
 {
 User::Leave(error);
 }
 // Find a unique name to avoid any conflict.
 // Here iFname has full path of current location of file
 // and filename has destination path.
 FindUniqueDestinationFileNameL( iFname, filename );
 filenamePtr = filename->Des();
 err = file->Move(iFname, filenamePtr, CFileMan::EOverWrite);
 if(err != KErrNone)
 {
 User::Leave(err);
 }
 iFname = filenamePtr;
 NotifyMediaGalleryL( filenamePtr );
 CleanupStack::PopAndDestroy(file);
 CleanupStack::PopAndDestroy(&fs);
 CleanupStack::PopAndDestroy(filename);
 #else
 RFs fs;
 CFileMan* file=CFileMan::NewL(fs);
 CleanupStack::PushL(file);
 TInt error = fs.MkDirAll(filenamePtr);
 if (error!=KErrNone && error!=KErrAlreadyExists)
 {
 User::Leave(error);
 }
 // Find a unique name to avoid any conflict.
 // Here iFname has full path of current location of file
 // and filename has destination path.
 FindUniqueDestinationFileNameL( iFname, filename );
 filenamePtr = filename->Des();
 TInt err = file->Move(iFname, filenamePtr, CFileMan::EOverWrite);
 if(err != KErrNone)
 {
 User::Leave(err);
 }
 iFname = filenamePtr;
 NotifyMediaGalleryL( filenamePtr );
 CleanupStack::PopAndDestroy(file);
 CleanupStack::PopAndDestroy(&fs);
 CleanupStack::PopAndDestroy(filename);
 #endif // RD_MULTIPLE_DRIVE
 CLOG(( ECodEng, 2, _L("-> CFileSaver::Cleanup") ));
 // Clean up the temporary file, ignore errors.
 // Expected error: KErrNotFound (if there is no temp file).
 // Unexpected error: all the rest -> nothing we can do with them.
 CloseStore();
 	if( aDeleteFile )
 	    {
 #ifdef __TEST_COD_LOG
 TInt err =  // ('Log-only' variable.)
 #endif /* def __TEST_COD_LOG */
 }
 iState = EInit;
 CLOG(( ECodEng, 2, _L("<- CFileSaver::Cleanup") ));
 }
 // ---------------------------------------------------------
 // CFileSaver::UpdateDCFRepositoryL()
 // Update saved file to DCFRepository
 // ---------------------------------------------------------
 //
 void CFileSaver::UpdateDCFRepositoryL( const TDesC& aFileName )
 {
 CDcfEntry* dcfEntry = NULL;
 dcfEntry = CDcfEntry::NewL();
 CleanupStack::PushL( dcfEntry );
 CDcfRep* dcfRep = NULL;
 dcfRep = CDcfRep::NewL();
 CleanupStack::PushL( dcfRep );
 dcfEntry->SetLocationL( aFileName, 0 );
 dcfRep->UpdateL( dcfEntry );
 CleanupStack::PopAndDestroy(2); // dcfEntry, dcfRep
 }
 // ---------------------------------------------------------
 // CFileSaver::UpdateMediaGalleryIfNeededL()
 // Calls MediaGallery Update method so that media gallery
 // knows update its view.
 // ---------------------------------------------------------
 //
 void CFileSaver::UpdateMediaGalleryIfNeededL( const TDesC& aFileName )
 {
 #ifdef BRDO_APP_GALLERY_SUPPORTED_FF
 CMGXFileManager* fm = MGXFileManagerFactory::NewFileManagerL( iFs );
 CleanupStack::PushL(fm);
 fm->UpdateL(aFileName);
 CleanupStack::PopAndDestroy(); // fm
 #endif
 }
 // ---------------------------------------------------------
 // CFileSaver::NotifyMediaGalleryL()
 // Notify media gallery about the new file.
 // ---------------------------------------------------------
 //
 void CFileSaver::NotifyMediaGalleryL( const TDesC& aFileName )
 {
 #ifdef BRDO_APP_GALLERY_SUPPORTED_FF
 CMGXFileManager* mgFileManager = MGXFileManagerFactory::NewFileManagerL( iFs );
 CleanupStack::PushL( mgFileManager );
 TRAP_IGNORE( mgFileManager->UpdateL() );
 CleanupStack::PopAndDestroy( mgFileManager );
 // Notify Media Gallery
 TRAP_IGNORE( UpdateMediaGalleryIfNeededL( aFileName ) );
 #endif
 // Notify DCF repository
 TRAP_IGNORE( UpdateDCFRepositoryL( aFileName ) );
 }
 // ---------------------------------------------------------
 // CFileSaver::DownloadedFileSize()
 TInt CFileSaver::DownloadedFileSize()
 {
 // check how many bytes are already persisted
 TInt DownloadedSize(0);
 TInt err = iFile.Size( (TInt&)DownloadedSize );
 CLOG(( ECodStorage, 2, _L("CFileSaver::DownloadedFileSize  Downloaded size = %d  error = %d"), \
 DownloadedSize,err ));
 if(err != KErrNone)
 return err;
 return DownloadedSize;
 }
 /**
 * Discard the old contents
 */
 void CFileSaver::ResetL()
 {
 iFile.Close();
 User::LeaveIfError( iFile.Replace(  iFs,
 iFname,
 EFileShareAny |
 EFileStream |
 EFileWrite ) );
 }
 // -----------------------------------------------------------------------------
 iProgressiveDownload = aValue;
 if( iProgressiveDownload )
 {
 iBufferSize = KDefaultStorageBufferSizePD;
 }
 if( iBufferSize != iStorage->CurrentBufferSize())
 {
 FlushL();
 }
 if ( iFile.SubSessionHandle() )
 {
 if( iProgressiveDownload )
 {
 if( iLength != KDefaultContentLength )
 {
 iFile.SetSize( iLength );
 }
 }
 else
 // Called if download completed.
 // -----------------------------------------------------------------------------
 //
 void CFileSaver::OnComplete()
 {
 CLOG(( ECodEng, 2, _L("-> CFileSaver::OnComplete") ));
 FlushL();
 iStorage->ClearErrors();
 iFile.Close();
 CLOG(( ECodEng, 2, _L("<- CFileSaver::OnComplete") ));
 }
 // ---------------------------------------------------------
 HBufC* CFileSaver::NameL() const
 {
 return iFname.AllocL();
 }
+#ifdef DOWNLOADMGR_PATH_PLUGIN_ENABLED_FF
+// ---------------------------------------------------------
+// CFileSaver::GetDownloadPathPluginInstanceL
+// ---------------------------------------------------------
+CDownloadPathHandler* CFileSaver::GetDownloadPathPluginInstanceL(TPtrC8& mimetype )
+{
+CDownloadPathHandler* downloadPathPlugin = NULL;
+TRAPD( kErr, downloadPathPlugin = CDownloadPathHandler::NewL( mimetype ) );
+if( kErr != KErrNone )
+{
+downloadPathPlugin = NULL;
+}
+return downloadPathPlugin;
+}
+// ---------------------------------------------------------
+// CFileSaver::GetUpdatedPathFromPluginL
+// ---------------------------------------------------------
+void CFileSaver::GetUpdatedPathFromPluginL(CDownloadPathHandler* downloadPathPlugin,TFileName& fname, TPtr& fileNamePtr)
+{
+TRAPD( kErr, downloadPathPlugin->GetUpdatedPathL( fname, fileNamePtr ) );
+if( kErr == KErrNone )
+{
+fileNamePtr.Append( _L( "\\" ) );
+}
+else
+{
+fileNamePtr.Append( _L( "download\\" ) );
+}
+}
+#endif
+//EOF

branch	RCL_3
changeset 94	919f36ff910f
parent 93	79859ed3eea9