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

/**
 @file
 @internalTechnology
*/

//
#include <mdequery.h>
#include <mdeconstants.h>

#include "cmediasyncdatabase.h"
#include "cmediasyncobserver.h"

__FLOG_STMT(_LIT8(KComponent,"MediaSyncObserver");)

CMediaSyncObserver*  CMediaSyncObserver::NewL(CMediaSyncDatabase* aDb)
    {       
    CMediaSyncObserver* self = new (ELeave) CMediaSyncObserver(aDb);
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self);
    return self;
    }

void CMediaSyncObserver::ConstructL()
    {
    __FLOG_OPEN(KMSSSubsystem, KComponent);
    __FLOG(_L8("CMediaSyncObserver::ConstructL - Entry"));
    
    iSessionWait = new (ELeave) CActiveSchedulerWait();
    iSession = CMdESession::NewL(*this);
    iSessionWait->Start();
    
    User::LeaveIfError(iMdeSessionError);    
    
//    SubscribeForChangeNotificationL();
    
    __FLOG(_L8("CMediaSyncObserver::ConstructL - Exit"));
    }

CMediaSyncObserver::CMediaSyncObserver(CMediaSyncDatabase* aDb)
    :iDb(aDb),
    iSubscribed(EFalse)
    {    
    }

CMediaSyncObserver::~CMediaSyncObserver()
    {
    __FLOG(_L8("CMediaSyncObserver::~CMediaSyncObserver - Entry"));  
    
//    TRAP_IGNORE(UnsubscribeForChangeNotificationL());
    
    delete iSession;
    delete iSessionWait;
	
    __FLOG(_L8("CMediaSyncObserver::~CMediaSyncObserver - Exit"));
    __FLOG_CLOSE;
    }

void CMediaSyncObserver::SubscribeForChangeNotificationL()
    {
    __FLOG(_L8("CMediaSyncObserver::SubscribeForChangeNotificationL - Entry"));
    
    if (!iSubscribed)
        {        
        CMdENamespaceDef& def = iSession->GetDefaultNamespaceDefL();
        CMdEObjectDef& imageObjDef = def.GetObjectDefL(MdeConstants::Image::KImageObject);
        
        // add observer        
        CMdELogicCondition* addCondition = CMdELogicCondition::NewLC(ELogicConditionOperatorAnd);          
        CMdEPropertyDef& itemTypePropDef = imageObjDef.GetPropertyDefL(MdeConstants::Object::KItemTypeProperty);       
        addCondition->AddPropertyConditionL(itemTypePropDef, ETextPropertyConditionCompareEndsWith, _L("jpeg"));                       
        iSession->AddObjectObserverL(*this, addCondition, ENotifyAdd);
        CleanupStack::Pop(addCondition);
        
        // modify observer
        CMdELogicCondition* modifyCondition = CMdELogicCondition::NewLC(ELogicConditionOperatorAnd);          
        CMdEPropertyDef& titlePropDef = imageObjDef.GetPropertyDefL(MdeConstants::Object::KTitleProperty);
        modifyCondition->AddPropertyConditionL(titlePropDef);
        iSession->AddObjectObserverL(*this, modifyCondition, ENotifyModify);
        CleanupStack::Pop(modifyCondition);
        
        // remove observer
        iSession->AddObjectObserverL(*this, NULL, ENotifyRemove);
        
        // present observer
        iSession->AddObjectPresentObserverL(*this);
                        
        iSubscribed = ETrue;               
        }

    __FLOG(_L8("CMediaSyncObserver::SubscribeForChangeNotificationL - Exit"));
    }

void CMediaSyncObserver::UnsubscribeForChangeNotificationL()
    {
    __FLOG(_L8("CMediaSyncObserver::UnsubscribeForChangeNotificationL - Entry"));
    
    if (iSubscribed)
        {
        iSession->RemoveObjectObserverL(*this);//add observer
        iSession->RemoveObjectObserverL(*this);//modify observer
        iSession->RemoveObjectObserverL(*this);//remove observer
        iSession->RemoveObjectPresentObserverL(*this);
        iSubscribed = EFalse;
        }
    
    __FLOG(_L8("CMediaSyncObserver::UnsubscribeForChangeNotificationL - Exit"));
    }

// From MMdESessionObserver
void CMediaSyncObserver::HandleSessionOpened(CMdESession& /*aSession*/, TInt aError)
    {
    __FLOG(_L8("CMediaSyncObserver::HandleSessionOpened - Entry"));
    
    HandleSessionCallback(aError);
    
    __FLOG(_L8("CMediaSyncObserver::HandleSessionOpened - Exit"));
    }

void CMediaSyncObserver::HandleSessionError(CMdESession& /*aSession*/, TInt aError)
    {
    __FLOG(_L8("CMediaSyncObserver::HandleSessionError - Entry"));
    
    HandleSessionCallback(aError);
    
    __FLOG(_L8("CMediaSyncObserver::HandleSessionError - Exit"));
    }

void CMediaSyncObserver::HandleSessionCallback(TInt aError)
    {
    __ASSERT_DEBUG(iSessionWait, User::Invariant());
    iMdeSessionError = aError;    
    if (iSessionWait->IsStarted())
        {
        iSessionWait->AsyncStop();
        }
    }

/*
 * After receiving object change notification, check if there is any dp subscribed right now.
 * if none, store change into database
 * if yes, check the type of file with subscribed providers, if there is any match, just forward
 * the change to that dp, if none, store change into database.
 */
void CMediaSyncObserver::HandleObjectNotification(CMdESession& aSession,
                                            TObserverNotificationType aType,
                                            const RArray<TItemId>& aObjectIdArray)
    {
    TRAPD(err, HandleObjectNotificationL(aSession, aType, aObjectIdArray));
    
    if (err != KErrNone)
        {
        __FLOG(_L8("CMediaSyncObserver::HandleObjectNotification - Rollback database"));        
        iDb->Rollback();
        }
    }

/*
 * L Function
 */
void CMediaSyncObserver::HandleObjectNotificationL(CMdESession& /*aSession*/,
                                                   TObserverNotificationType aType,
                                                   const RArray<TItemId>& aObjectIdArray)
    {
    __FLOG(_L8("CMediaSyncObserver::HandleObjectNotificationL - Entry"));
    
    iDb->SaveNotificationsL(aObjectIdArray, aType, *iSession);
    
    __FLOG(_L8("CMediaSyncObserver::HandleObjectNotificationL - Exit"));
    }

/*
 * Called to notify the observer that objects has been set
 * to present or not present state in the metadata engine database.
 */
void CMediaSyncObserver::HandleObjectPresentNotification(CMdESession& aSession,
                                                        TBool aPresent, 
                                                        const RArray<TItemId>& aObjectIdArray)
    {
    TRAPD(err, HandleObjectPresentNotificationL(aSession, aPresent, aObjectIdArray));
    
    if (err != KErrNone)
        {
        __FLOG(_L8("CMediaSyncObserver::HandleObjectPresentNotification - Rollback database"));
        iDb->Rollback();
        }    
    }

/*
 * L Function
 */
void CMediaSyncObserver::HandleObjectPresentNotificationL(CMdESession& /*aSession*/,
                                                        TBool aPresent, 
                                                        const RArray<TItemId>& aObjectIdArray)
    {
    __FLOG(_L8("CMediaSyncObserver::HandleObjectPresentNotificationL - Entry"));
     
    iDb->SaveNotificationsL(aObjectIdArray, aPresent, *iSession);
       
    __FLOG(_L8("CMediaSyncObserver::HandleObjectPresentNotificationL - Exit"));
    }