/*
* Copyright (c) 2006 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:   Launches SendUiServiceResolver in the events of:
*                At all times:
*                - mtm installation/removal
*                - Message Server events:
*                    * EMsvEntryCreated
*                    * EMsvEntryDeleted
*                    * EMsvCorruptedIndexRebuilt
*                    * EMsvMediaChanged
*                - Ecom service event arrives and SendUI Ecom service count has 
*                  changed since last boot.
*
*/




#include <implementationproxy.h>
#include <msvapi.h>
#include <data_caging_path_literals.hrh> 
#include <msvids.h>                     // for KMsvRootIndexEntryId
#include <coemain.h>
#include <apgcli.h>
#include <apacmdln.h>
#include <eikdll.h>
#include <apaflrec.h>
#include <bldvariant.hrh>
#include <e32property.h>
#include <e32base.h>
#include <centralrepository.h>
#include <mtudreg.h>
#include <featmgr.h>

#include "senduiwatcher.h"
#include "senduiecomobserver.h"
#include "senduipropertyobserver.h"
#include "senduiproperty.h"
#include "SendUiPrivateCRKeys.h"
#include "senduiserviceslog.h"

_LIT( KSendUiLauncherApp, "SendUiServiceResolver.exe");

const TImplementationProxy ImplementationTable[] = 
    {
    IMPLEMENTATION_PROXY_ENTRY( 0x102823B6, CSendUiWatcher::NewL )
    };

EXPORT_C const TImplementationProxy* ImplementationGroupProxy( TInt& aTableCount )
    {
    aTableCount = sizeof( ImplementationTable ) / sizeof( TImplementationProxy );
    return ImplementationTable;
    }


// ======== LOCAL FUNCTIONS ========

// ---------------------------------------------------------------------------
// NewL
// ---------------------------------------------------------------------------
//
CSendUiWatcher* CSendUiWatcher::NewL( TAny* /*aWatcherParams */)
    {
    CSendUiWatcher* self=new (ELeave) CSendUiWatcher();
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self);
    return self;
    }

// ---------------------------------------------------------------------------
// Destructor
// ---------------------------------------------------------------------------
//
CSendUiWatcher::~CSendUiWatcher()
    {
    delete iPropertyObserver;
    delete iTimer;
    }

// ---------------------------------------------------------------------------
// DoTask
// ---------------------------------------------------------------------------
//
TInt CSendUiWatcher::DoTaskL( TAny* aThis )
	{
    LOGTEXT(_L("CSendUiWatcher::DoTask >>"));
    CSendUiWatcher* watcher = static_cast<CSendUiWatcher*>( aThis );
    // We've waited long enough. Try to set to done. Ignore error.
    RProperty::Set(
        KPSUidSendUiProperty, 
        KSendUiUpdateOperation, 
        KSendUiUpdateOperationDone );
    watcher->HandleUpdateServicesL();
    LOGTEXT(_L("CSendUiWatcher::DoTask <<"));
	return KErrNone;
	}

// ---------------------------------------------------------------------------
// HandleUpdateServicesL
// ---------------------------------------------------------------------------
//
void CSendUiWatcher::HandleUpdateServicesL()
    {
    LOGTEXT(_L("CSendUiWatcher::HandleUpdateServicesL >>"));
    TInt value;
    delete iTimer;
	iTimer = NULL;

    RProperty::Get( KPSUidSendUiProperty, KSendUiUpdateOperation, value );
    if ( value != KSendUiUpdateOperationDone )
        {
        // try again later
        SetTimerL();
        }
    else
        {
        // Run SendUiSr
        RApaLsSession ls;
        
        CApaCommandLine *cmd = CApaCommandLine::NewL();
        CleanupStack::PushL( cmd );

        cmd->SetExecutableNameL( KSendUiLauncherApp ); 
        cmd->SetCommandL( EApaCommandBackground );
        User::LeaveIfError( ls.StartApp( *cmd ) );
        CleanupStack::PopAndDestroy( cmd );
        }
    LOGTEXT(_L("CSendUiWatcher::HandleUpdateServicesL <<"));
    }
    
// ---------------------------------------------------------------------------
// Constructor
// ---------------------------------------------------------------------------
//
CSendUiWatcher::CSendUiWatcher() // first-phase C++ constructor
    {
    }

// ---------------------------------------------------------------------------
// ConstructL
// ---------------------------------------------------------------------------
//
void CSendUiWatcher::ConstructL() // second-phase constructor
    {
    if ( !iSession )
        {
        iSession = CMsvSession::OpenSyncL( *this );
        }
    TInt result( KErrNone );        
    
    result = RProperty::Define(
        KPSUidSendUiProperty, 
        KSendUiUpdateRequest,
        RProperty::EInt,
        TSecurityPolicy( ECapabilityReadUserData ),
        TSecurityPolicy( ECapabilityWriteUserData ));
    
    if ( result && result != KErrAlreadyExists )
        {
        User::LeaveIfError( result ); 
        }
   
    result = RProperty::Define(
        KPSUidSendUiProperty, 
        KSendUiUpdateOperation,
        RProperty::EInt,
        TSecurityPolicy( ECapabilityReadUserData ),
        TSecurityPolicy( ECapabilityWriteUserData  ));
    
    if ( result && result != KErrAlreadyExists )
        {
        User::LeaveIfError( result ); 
        }
    
    User::LeaveIfError( 
        RProperty::Set(KPSUidSendUiProperty, KSendUiUpdateOperation, KSendUiUpdateOperationDone) );
                
    iPropertyObserver = CSendUiPropertyObserver::NewL( this );

    iEcomObserver = CSendUiEcomObserver::NewL();  
    
    CheckIfUpdateNeededL();
    }

// ---------------------------------------------------------------------------
// UpdateFeature
// ---------------------------------------------------------------------------
//
void CSendUiWatcher::FeatureStatus( TInt aFeature, TInt &aNewFeatures, TInt aFeatureFlag )
    {
    if ( FeatureManager::FeatureSupported( aFeature ) )
        {
        aNewFeatures |= aFeatureFlag;
        }
    }

// ---------------------------------------------------------------------------
// CheckIfUpdateNeededL
// ---------------------------------------------------------------------------
//
void CSendUiWatcher::CheckIfUpdateNeededL()
    {
    LOGTEXT(_L("CSendUiWatcher::CheckIfUpdateNeededL >>"));
    CRepository* repository = CRepository::NewLC( KCRUidSendUi );
    
    TInt storedValue(KErrNotFound);
    TBool updateNeeded( EFalse );
    
    // Request service list update if phone language has changed.
    // KErrNotFound language value also indicates unsuccesfull run of SendUiServiceResolver
    TInt result = repository->Get( KKeySendUiServiceLanguage, storedValue );
    if ( result != KErrNone || storedValue != User::Language() )
    	{
    	updateNeeded = ETrue;
    	}
    
    // Issue service list update if mtm count has changed
    CMtmUiDataRegistry* mtmUiDataRegistry = CMtmUiDataRegistry::NewL( *iSession );
    TInt newMtmCount( KErrNotFound );
    if ( mtmUiDataRegistry )
    	{
    	newMtmCount = mtmUiDataRegistry->NumRegisteredMtmDlls();
	    delete mtmUiDataRegistry;
    	}

    result = repository->Get( KKeySendUiServiceMtmCount, storedValue ) ;
    if ( result != KErrNone || storedValue != newMtmCount )
    	{
    	result = repository->Set( KKeySendUiServiceMtmCount, newMtmCount );
    	updateNeeded = ETrue;
    	}
   
    TInt oldFeatures(0);   
    TInt newFeatures(0);   
    if ( repository->Get( KKeySendUiFeatureManagerServices, oldFeatures ) != KErrNone )
    	{
    	updateNeeded = ETrue;
    	}
    FeatureManager::InitializeLibL();
    FeatureStatus( KFeatureIdMmsPostcard, newFeatures, KSendUiPostcard );
    FeatureStatus( KFeatureIdAudioMessaging, newFeatures, KSendUiAudioMessage );
    FeatureStatus( KFeatureIdSenduiMmsUpload, newFeatures, KSendUiMmsUpload );
    FeatureManager::UnInitializeLib();
    if ( newFeatures != oldFeatures )
        {
        repository->Set( KKeySendUiFeatureManagerServices, newFeatures );    
        updateNeeded = ETrue;
        }

    CleanupStack::PopAndDestroy( repository );

    if ( updateNeeded )
        {
        HandleUpdateServicesL();
        }
    LOGTEXT(_L("CSendUiWatcher::CheckIfUpdateNeededL <<"));
    }

// ---------------------------------------------------------------------------
// SetTimerL
// ---------------------------------------------------------------------------
//
void CSendUiWatcher::SetTimerL()
    {
    LOGTEXT(_L("CSendUiWatcher::SetTimerL >>"));
    if ( !iTimer ) 
        {
        iTimer = CPeriodic::NewL( CActive::EPriorityStandard );    
        iTimer->Start( KSendUiServiceListUpdateDelay,
            KSendUiServiceListUpdateDelay,
            TCallBack( DoTaskL, this));
        }
    LOGTEXT(_L("CSendUiWatcher::SetTimerL <<"));
    }
    
void CSendUiWatcher::HandleSessionEventL(
            TMsvSessionEvent aEvent,
            TAny* /*aArg1*/,
            TAny* aArg2,
            TAny* /*aArg3*/ )
    {   
    // TODO: Reconnect to message server
    switch ( aEvent )
        {
        case EMsvServerReady:
        	{
        	LOGTEXT(_L("Message Server is ready."));
        	break;
        	}
        case EMsvMtmGroupDeInstalled: 
        case EMsvMtmGroupInstalled:
            {
            SetTimerL();
            break;
            }
    
        case EMsvEntriesCreated:// fall through
        case EMsvEntriesDeleted:
            {
            TMsvId folderId = KMsvNullIndexEntryId;
            folderId = (*(TMsvId*) (aArg2));
            if (folderId != KMsvRootIndexEntryId)
                {
                break;
                }
            SetTimerL();
            break;
                
            }
        case EMsvCorruptedIndexRebuilt:
            LOGTEXT2(_L("Watcher event %d"), aEvent);
            HandleUpdateServicesL();
            break;
        case EMsvCloseSession:
        case EMsvServerTerminated:
            delete iSession;
            iSession = NULL;
            LOGTEXT(_L("SendUiWatcher session was terminated"));
        break;
        case EMsvMediaChanged:// Added to handle change of Msg center
            SetTimerL();
            break;        
        default:;
        }
    }
 
// end of file