/*
* 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 the License "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:  CBrowserPushMtmObserver
*
*/


// INCLUDE FILES
#include "BrowserPushMtmObserver.h"
#include "ApiProvider.h"
#include "BrowserAppUi.h"
#include "CommonConstants.h"
#include "Logger.h"


// EXTERNAL DATA STRUCTURES

// EXTERNAL FUNCTION PROTOTYPES

// CONSTANTS
// file monitored by browser
_LIT( KPushMtmUrl, "c:\\system\\temp\\PushMtmUrl.txt" );

// MACROS

// LOCAL CONSTANTS AND MACROS

// MODULE DATA STRUCTURES

// LOCAL FUNCTION PROTOTYPES

// FORWARD DECLARATIONS


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

// -----------------------------------------------------------------------------
// CBrowserPushMtmObserver::CBrowserPushMtmObserver
// C++ default constructor can NOT contain any code, that
// might leave.
// -----------------------------------------------------------------------------
//
CBrowserPushMtmObserver::CBrowserPushMtmObserver(MApiProvider* aApiProvider) : CActive( CActive::EPriorityIdle ),
iApiProvider(aApiProvider)
    {
    CActiveScheduler::Add(this);
    }

// -----------------------------------------------------------------------------
// CBrowserPushMtmObserver::ConstructL
// Symbian 2nd phase constructor can leave.
// -----------------------------------------------------------------------------
//
void CBrowserPushMtmObserver::ConstructL()
    {
    LOG_ENTERFN("CBrowserPushMtmObserver::ConstructL");
    User::LeaveIfError(iFsSession.Connect());
    }

// -----------------------------------------------------------------------------
// CBrowserPushMtmObserver::NewL
// Two-phased constructor.
// -----------------------------------------------------------------------------
//
CBrowserPushMtmObserver* CBrowserPushMtmObserver::NewL( MApiProvider* aApiProvider )
    {
    CBrowserPushMtmObserver* self = new( ELeave ) CBrowserPushMtmObserver(aApiProvider);
    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop();
    return self;
    }

// Destructor
CBrowserPushMtmObserver::~CBrowserPushMtmObserver()
    {
    Cancel();
    iFsSession.Close();
    }

// -----------------------------------------------------------------------------
// CBrowserPushMtmObserver::RunL
//
// -----------------------------------------------------------------------------
//
void CBrowserPushMtmObserver::RunL()
    {
    LOG_ENTERFN("CBrowserPushMtmObserver::RunL");
    HBufC8* url8 = NULL;
    TRAP_IGNORE( url8 = ReadMsgFileL() );
    StartObserver();
    if( url8 != NULL )
        {
        CleanupStack::PushL( url8 );
	    CBrowserAppUi* appUi = STATIC_CAST(CBrowserAppUi*, iApiProvider);
        appUi->ParseAndProcessParametersL( url8->Des() );
        BROWSER_LOG( (_L( "CBrowserPushMtmObserver::RunL appUi->ParseAndProcessParametersL with url8: %S" ), url8 ));
        appUi->SetLastActiveViewId( KUidBrowserContentViewId );
        appUi->SetViewToBeActivatedIfNeededL( appUi->LastActiveViewId() );
        // view activation and bringing the browser to foreground are two 
        // distinct actions.
        appUi->ActivateLocalViewL( KUidBrowserContentViewId );
        appUi->HandleForegroundEventL( ETrue ); 		
        BROWSER_LOG( (_L( "CBrowserPushMtmObserver::RunL appUi->HandleForegroundEventL") ));
        CleanupStack::PopAndDestroy(/*url8*/);
        }
    }

// -----------------------------------------------------------------------------
// CBrowserPushMtmObserver::RunError
//
// -----------------------------------------------------------------------------
//
TInt CBrowserPushMtmObserver::RunError(TInt /*aError*/)
    {
    return KErrNone;
    }

// -----------------------------------------------------------------------------
// CBrowserPushMtmObserver::DoCancel
//
// -----------------------------------------------------------------------------
//
void CBrowserPushMtmObserver::DoCancel()
    {
    iFsSession.NotifyChangeCancel(iStatus);
    }

// -----------------------------------------------------------------------------
// CBrowserPushMtmObserver::StartObserver
//
// -----------------------------------------------------------------------------
//
void CBrowserPushMtmObserver::StartObserver()
    {
    LOG_ENTERFN("CBrowserPushMtmObserver::StartObserver");
    if (!IsActive())
        {
        iFsSession.NotifyChange( ENotifyWrite, iStatus, KPushMtmUrl() );
        SetActive();
        BROWSER_LOG( (_L( "CBrowserPushMtmObserver::StartObserver iFsSession.NotifyChange") ));
        }
    }


// -----------------------------------------------------------------------------
// CBrowserPushMtmObserver::ReadMsgFileL
//
// -----------------------------------------------------------------------------
//
HBufC8* CBrowserPushMtmObserver::ReadMsgFileL()
    {
    LOG_ENTERFN("CBrowserPushMtmObserver::ReadMsgFileL");

    RFs             rfs;
    RFile           file;
    TInt            size;
    HBufC8*         buffer = NULL;
    TPtr8           bufferPtr(NULL, 0);
    TInt            err = KErrNone;

    // Open the file.
    User::LeaveIfError(rfs.Connect());
    CleanupClosePushL(rfs);

    TInt tryCount = 0;
    for (tryCount = 0; tryCount < 5; tryCount++) 
        {
        err = file.Open( rfs, KPushMtmUrl, EFileRead | EFileShareExclusive );
        if (err == KErrInUse)
            {
            // wait 50 miliseconds and try again
            User::After(50000);
            }
        else
            {
            break;
            }
        }
        
    BROWSER_LOG( (_L( "CBrowserPushMtmObserver::ReadMsgFileL file.Open return: %d" ), err ));
    User::LeaveIfError( err );
    CleanupClosePushL(file);

    // Read file
    err = file.Size(size);
    BROWSER_LOG( (_L( "CBrowserPushMtmObserver::ReadMsgFileL file.Size: %d, err: %d" ), size, err ));
    User::LeaveIfError( err );
    
    buffer = HBufC8::NewLC(size);
    bufferPtr.Set(buffer->Des());

    err = file.Read( bufferPtr, size );
    BROWSER_LOG( (_L( "CBrowserPushMtmObserver::ReadMsgFileL file.Read: %d" ), err ));
    User::LeaveIfError( err );

    // Clean up.
    CleanupStack::Pop(/*buffer*/);
    CleanupStack::PopAndDestroy(/*file*/);

    // don't need to leave due to this error
    err = rfs.Delete( KPushMtmUrl );
    BROWSER_LOG( (_L( "CBrowserPushMtmObserver::ReadMsgFileL rfs.Delete: %d" ), err ));
    CleanupStack::PopAndDestroy(/*rfs*/);

    BROWSER_LOG( (_L( "CBrowserPushMtmObserver::ReadMsgFileL return: %S" ), buffer ));
    return buffer;
    }


//  End of File