/*
 * Copyright (c) 2010 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:
 *     The source file for mde tone fetcher.
 *
 */

// SYSTEM INCLUDES
#include <XQConversions>
#include <pathinfo.h>
#include <bautils.h>
#include <centralrepository.h>
#include <ProfileEngineDomainCRKeys.h>

// USER INCLUDES
#include "msgaudioselectionengine.h"

// CONSTANTS
_LIT( KAmrMime, "audio/amr" );

MsgAudioSelectionEngine::MsgAudioSelectionEngine():iQuery(NULL)
    {

    }

MsgAudioSelectionEngine::~MsgAudioSelectionEngine()
    {
    delete iQuery;
    delete iSession;
    }


void MsgAudioSelectionEngine::CreateMetaDataSession()
{
    QT_TRAP_THROWING(iSession = CMdESession::NewL(*this));
}


void MsgAudioSelectionEngine::HandleSessionOpened(CMdESession& /*aSession*/,
        TInt aError)
    {
    if (aError != KErrNone)
        {
        delete iSession;
        iSession = 0;
        iSessionOpen = EFalse;
        emit mdeSessionError(aError);
        }
    else
        {
        iSessionOpen = ETrue;
        TRAP_IGNORE( AddObjectObserverL() );
        emit mdeSessionOpened();
        }
    }

void MsgAudioSelectionEngine::HandleSessionError(CMdESession& /*aSession*/,
        TInt aError)
    {
    if (aError == KErrNone)
        {
        return;
        }

    delete iSession;
    iSession = 0;
    iSessionOpen = EFalse;
    emit mdeSessionError(aError);
    }

void MsgAudioSelectionEngine::HandleQueryNewResults(CMdEQuery& /*aQuery*/,
        TInt /*aFirstNewItemIndex*/, TInt /*aNewItemCount*/)
    {
    }

void MsgAudioSelectionEngine::HandleObjectNotification(
        CMdESession& /*aSession*/, TObserverNotificationType aType,
        const RArray<TItemId>& /*aObjectIdArray*/)
    {
    if (aType == ENotifyAdd || aType == ENotifyModify || aType
            == ENotifyRemove)
        {
        emit notifyObjectChanged();
        }
    }

void MsgAudioSelectionEngine::AddObjectObserverL()
    {
    if (iSessionOpen)
        {
        TUint32 notificationType = ENotifyAdd | ENotifyModify | ENotifyRemove;
        q_check_ptr(iSession);
        CMdENamespaceDef& defNS = iSession->GetDefaultNamespaceDefL();
        iSession->AddObjectObserverL(*this, 0, notificationType, &defNS);
        iSession->AddObjectPresentObserverL(*this);
        }
    }

void MsgAudioSelectionEngine::HandleObjectPresentNotification(
        CMdESession& /*aSession*/, TBool /*aPresent*/,
        const RArray<TItemId>& aObjectIdArray)
    {
    if (aObjectIdArray.Count() > 0)
        {
        emit notifyObjectChanged();
        }
    }

void MsgAudioSelectionEngine::HandleQueryCompleted(CMdEQuery& aQuery,
        TInt aError)
    {
    TRAP_IGNORE(HandleQueryCompletedL(aQuery, aError));
    }

void MsgAudioSelectionEngine::HandleQueryCompletedL(CMdEQuery& aQuery,
        TInt aError)
    {
    iNameList.clear();
    iUriList.clear();
    if (aError == KErrCancel)
        {
        emit queryError(aError);
        return;
        }
    else
        {
        CMdEObjectQuery* query = static_cast<CMdEObjectQuery*> (&aQuery);
        TInt count = query->Count();
        for (TInt i = 0; i < count; ++i)
            {
            CMdEObject* object =
                    (CMdEObject*) query->TakeOwnershipOfResult(i);
            CleanupStack::PushL(object);
            CMdEPropertyDef& propDef = MsgAudioSelectionEngine::PropertyDefL(
                    iSession, MsgAudioSelectionEngine::EAttrFileName);

            CMdEProperty* property = 0;
            TInt err = object->Property(propDef, property, 0);
            if (err != KErrNotFound && property)
                {
                QString songName(XQConversions::s60DescToQString(
                        property->TextValueL()));
                QString uriValue(XQConversions::s60DescToQString(
                        object->Uri()));
                iNameList.append(songName);
                iUriList.append(uriValue);
                }
            CleanupStack::PopAndDestroy(object);
            }
        emit queryComplete(iNameList, iUriList);
        }
    }

void MsgAudioSelectionEngine::QueryTones()
    {
    TRAP_IGNORE(QueryTonesL());
    }

void MsgAudioSelectionEngine::QueryTonesL()
    {
    LeaveIfSessionClosedL();
    CMdENamespaceDef& defNS = iSession->GetDefaultNamespaceDefL();
    CMdEObjectDef& musicObjectDef = defNS.GetObjectDefL(
            MdeConstants::Audio::KAudioObject);

    delete iQuery;
    iQuery = 0;
    iQuery = iSession->NewObjectQueryL(defNS, musicObjectDef, this);
    CMdEPropertyDef& titlePropertyDef = musicObjectDef.GetPropertyDefL(
            MdeConstants::Object::KTitleProperty);
    CMdEPropertyDef& typePropertyDef = musicObjectDef.GetPropertyDefL(
            MdeConstants::Object::KItemTypeProperty);

    // set attributes that are included in query result
    iQuery->AddPropertyFilterL(&titlePropertyDef);
    iQuery->AddPropertyFilterL(&typePropertyDef);

    iQuery->SetResultMode(EQueryResultModeItem);


    // get root condition
    CMdELogicCondition& conditions = iQuery->Conditions();
    conditions.AddPropertyConditionL(typePropertyDef,
            ETextPropertyConditionCompareEquals, KAmrMime);

    iQuery->FindL();
    }

void MsgAudioSelectionEngine::LeaveIfSessionClosedL()
    {
    if (!iSession || !iSessionOpen)
        {
        qt_symbian_throwIfError (KErrDisconnected);
        }
    }

CMdEPropertyDef& MsgAudioSelectionEngine::PropertyDefL(TInt aAttr)
    {
    q_check_ptr(iSession);
    return PropertyDefL(iSession, aAttr);
    }

CMdEPropertyDef& MsgAudioSelectionEngine::PropertyDefL(CMdESession* aSession,
        TInt aAttr)
    {
    CMdENamespaceDef& defNS = aSession->GetDefaultNamespaceDefL();

    CMdEObjectDef& objectDef = defNS.GetObjectDefL(
            MdeConstants::Audio::KAudioObject);

    if (aAttr == EAttrFileSize)
        {
        return objectDef.GetPropertyDefL(MdeConstants::Object::KSizeProperty);
        }
    else if (aAttr == EAttrMediaType)
        {
        return objectDef.GetPropertyDefL(
                MdeConstants::Object::KItemTypeProperty);
        }
    else if (aAttr == EAttrSongName || aAttr == EAttrFileName)
        {
        return objectDef.GetPropertyDefL(MdeConstants::Object::KTitleProperty);
        }
    else if (aAttr == EAttrArtist)
        {
        return objectDef.GetPropertyDefL(
                MdeConstants::MediaObject::KArtistProperty);
        }
    else if (aAttr == EAttrAlbum)
        {
        return objectDef.GetPropertyDefL(MdeConstants::Audio::KAlbumProperty);
        }
    else if (aAttr == EAttrGenre)
        {
        return objectDef.GetPropertyDefL(
                MdeConstants::MediaObject::KGenreProperty);
        }
    else if (aAttr == EAttrComposer)
        {
        return objectDef.GetPropertyDefL(
                MdeConstants::Audio::KComposerProperty);
        }
    else
        {
        qt_symbian_throwIfError(KErrNotSupported);
        }

    return objectDef.GetPropertyDefL(MdeConstants::Object::KTitleProperty);
    }


void MsgAudioSelectionEngine::SetAttr(int attr, int value)
    {
    switch (attr)
        {
    case MsgAudioSelectionEngine::EAttrFileSize:
            {
            iMaxFileSize = value;
            break;
            }
    default:
        {
        break;
        }
    }
}
// End of File