/*
* 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:
*
*/

#include "hsactivitydbasyncrequest_p.h"
#include "hsactivitydbclient_p.h"
#include "hsserializer.h"
// -----------------------------------------------------------------------------
//
// -----------------------------------------------------------------------------
//
HsActivityDbAsyncRequestPrivate*
HsActivityDbAsyncRequestPrivate::NewL(HsActivityDbAsyncRequestObserver &observer,
                                      HsActivityDbClientPrivate &session)
{
    HsActivityDbAsyncRequestPrivate *self =
        HsActivityDbAsyncRequestPrivate::NewLC(observer, session);
    CleanupStack::Pop(self);
    return self;
}
// -----------------------------------------------------------------------------
//
// -----------------------------------------------------------------------------
//
HsActivityDbAsyncRequestPrivate*
HsActivityDbAsyncRequestPrivate::NewLC(HsActivityDbAsyncRequestObserver &observer,
                                       HsActivityDbClientPrivate &session)
{
    HsActivityDbAsyncRequestPrivate *self =
        new(ELeave)HsActivityDbAsyncRequestPrivate(observer, session);
    CleanupStack::PushL(self);
    self->mDataBuf.CreateL(64);
    return self;
}
// -----------------------------------------------------------------------------
//
// -----------------------------------------------------------------------------
//
HsActivityDbAsyncRequestPrivate::HsActivityDbAsyncRequestPrivate(HsActivityDbAsyncRequestObserver &observer,
                                                                 HsActivityDbClientPrivate &session)
    :
    CActive(EPriorityStandard),
    mObserver(observer),
    mSession(session),
    mRequestType(-1),
    mDataSize()
{
    CActiveScheduler::Add(this);
}

// -----------------------------------------------------------------------------
//
// -----------------------------------------------------------------------------
//
HsActivityDbAsyncRequestPrivate::~HsActivityDbAsyncRequestPrivate()
{
    mDataBuf.Close();
    Cancel();
}

// -----------------------------------------------------------------------------
//
// -----------------------------------------------------------------------------
//
void HsActivityDbAsyncRequestPrivate::DoCancel()
{
    if (IsActive()) {
        mSession.cancelWaitActivity();
    }
}

// -----------------------------------------------------------------------------
//
// -----------------------------------------------------------------------------
//
void HsActivityDbAsyncRequestPrivate::RunL()
{
    RBuf8 buff;
    CleanupClosePushL(buff);
    QString data;
    int requestResult(iStatus.Int());
    if (KErrNone == requestResult) {
        if (0 < mDataSize()) {
            buff.CreateL(mDataSize());
        }
        mSession.getData(buff);
        data = QString::fromAscii(reinterpret_cast<const char *>(buff.Ptr()),
                                  buff.Length());
        buff.Close();
    }
    mObserver.asyncRequestCompleated(requestResult, mRequestType, data);
    CleanupStack::PopAndDestroy(&buff);
}

// -----------------------------------------------------------------------------
//
// -----------------------------------------------------------------------------
//
void HsActivityDbAsyncRequestPrivate::waitActivity(const QVariantHash &condition)
{
    mRequestType = WaitActivity;
    iStatus = KRequestPending;
    SetActive();
    mDataBuf << condition;
    mSession.sendDataAsync(mRequestType, TIpcArgs(&mDataBuf, &mDataSize), iStatus);
}