/*

* 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 "afstorageclientimp.h"

#include <fbs.h>

#include <s32mem.h>

#include "afstorageglobals.h"

#include "afglobals.h"

#include "afentry.h"

#include "afasyncrequest_p.h"

#include "afthumbnailrequest_p.h"

// -----------------------------------------------------------------------------

/**

 * Furst phase constructor 

 */

RAfStorageClientImplementation::RAfStorageClientImplementation(MAfAsyncRequestObserver &observer)

:

mObserver(observer)

{}

// -----------------------------------------------------------------------------

/**

 * Destructor

 */

RAfStorageClientImplementation::~RAfStorageClientImplementation()

{

    Close();

}

// -----------------------------------------------------------------------------

void RAfStorageClientImplementation::Close()

{

    mAsyncTasks.ResetAndDestroy();

    RSessionBase::Close();

}

// -----------------------------------------------------------------------------

/**

 * Function establish connection to activity server

  */

void RAfStorageClientImplementation::connectL()

{

    const int asyncMessageSlots(12);

    const int maxRetry(4);

    TInt retry = maxRetry;

    TInt errNo(KErrNone);

    do {

        errNo = CreateSession(KActivityServerName, 

                              TVersion(0, 0, 0), 

                              asyncMessageSlots);

        if (KErrNotFound != errNo && KErrServerTerminated != errNo) {

            retry =0;

        } else {

            TRAP(errNo, startServerL());

            if (KErrNone != errNo && KErrAlreadyExists != errNo) {

                retry =0;

                errNo = CreateSession(KActivityServerName, 

                                      TVersion(0, 0, 0), 

                                      asyncMessageSlots);

            }

        }

    } while (--retry > 0);

    User::LeaveIfError(errNo);

}

// -----------------------------------------------------------------------------

void RAfStorageClientImplementation::startServerL()

{

    RProcess server;

    const TUidType uid(KNullUid, KNullUid, KActivityServerUid);

    User::LeaveIfError(server.Create(KActivityServerName, KNullDesC, uid));

    TRequestStatus stat;

    server.Rendezvous(stat);

    if (stat != KRequestPending) {

        server.Kill(0);

    } else {

        server.Resume();

    }

    User::WaitForRequest(stat);

    int errNo = (EExitPanic == server.ExitType()) ?

                KErrGeneral : stat.Int();

    if (KErrCancel == errNo) {

        errNo = KErrNone;

    }

    server.Close();

    User::LeaveIfError(errNo);

}

// -----------------------------------------------------------------------------

void RAfStorageClientImplementation::executeL(int function)

{

    switch (function) {

    case WaitActivity:

    case NotifyChange:

        CAfAsyncRequestPrivate::NewLD(mObserver, *this, static_cast<ActivityCmd>(function));

        break;

    default:

        User::LeaveIfError(SendReceive(function, TIpcArgs()));

    }

}

// -----------------------------------------------------------------------------

void RAfStorageClientImplementation::executeL(int function, 

                                              const CAfEntry &entry,

                                              int userData)

{

    TPckgBuf<TInt> data(userData);

    RBuf8 serializedEntry;

    CleanupClosePushL(serializedEntry);

    serializedEntry.CreateL(entry.Size());

    RDesWriteStream stream(serializedEntry);

    CleanupClosePushL(stream);

    stream << entry;

    CleanupStack::PopAndDestroy(&stream);

    User::LeaveIfError(SendReceive(function, TIpcArgs(&serializedEntry, &data)));

    CleanupStack::PopAndDestroy(&serializedEntry);

}

// -----------------------------------------------------------------------------

void RAfStorageClientImplementation::executeL(int function, RPointerArray<CAfEntry> &resultsList, const CAfEntry& templateEntry)

{

    resultsList.ResetAndDestroy();

    RBuf8 buffer;

    CleanupClosePushL(buffer);

    CAfEntry::ReallocL(buffer, templateEntry.Size());

    RDesWriteStream writer(buffer);

    CleanupClosePushL(writer);

    writer << templateEntry;

    CleanupStack::PopAndDestroy(&writer);

    TPckgBuf<int> length(0), taskId(0);

    User::LeaveIfError(SendReceive(function,

                                   TIpcArgs(&buffer, &length, &taskId)));

    CAfEntry::ReallocL(buffer, length());

    User::LeaveIfError(SendReceive(GetData, TIpcArgs(&taskId, &buffer)));

    resultsList << buffer;

    CleanupStack::PopAndDestroy(&buffer);

}

// -----------------------------------------------------------------------------

void RAfStorageClientImplementation::getThumbnailL(TSize size, 

                                                   const TDesC& source, 

                                                   TAny *userData )

{

    CAfThumbnailRequestPrivate::NewLD(mObserver, *this, size, source, userData);

}

// -----------------------------------------------------------------------------

void RAfStorageClientImplementation::PushL(CBase* asyncTask)

{

    const TInt offset(mAsyncTasks.Find(asyncTask));

    (KErrNotFound == offset) ? mAsyncTasks.AppendL(asyncTask) : User::Leave(KErrAlreadyExists);

}

// -----------------------------------------------------------------------------

void RAfStorageClientImplementation::Pop(CBase* asyncTask)

{

    const TInt offset(mAsyncTasks.Find(asyncTask));

    if (KErrNotFound != offset) {

        mAsyncTasks.Remove(offset);

    }

}

// -----------------------------------------------------------------------------

void RAfStorageClientImplementation::sendAsync(int function, 

                                              const TIpcArgs& args, 

                                              TRequestStatus& status)

{

    SendReceive(function, args, status);

}

// -----------------------------------------------------------------------------

void RAfStorageClientImplementation::getDataL(int id, TDes8& buffer)

{

    TPckgBuf<int> requestId(id);

    SendReceive(GetData, TIpcArgs(&requestId, &buffer));

}