/*
* Copyright (c) 2002-2005 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 FILES
#include <s32mem.h>
#include <lbs/epos_privacy.h>
#include <lbs/epos_cposrequestor.h>
#include "EPos_CPosPrivacyNotifierExtension.h"
#include "EPos_CPosRequestHandler.h"

// ================= MEMBER FUNCTIONS =======================

// C++ default constructor can NOT contain any code, that
// might leave.
//
CPosPrivacyNotifierExtension::CPosPrivacyNotifierExtension()
    {
    }

// -----------------------------------------------------------------------------
// CPosPrivacyNotifierExtension::ConstructL
// Symbian 2nd phase constructor can leave.
// -----------------------------------------------------------------------------
//
void CPosPrivacyNotifierExtension::ConstructL(
    CPosPrivacyNotifier* aPrivNotifier)
    {
    iRequestHandler = CPosRequestHandler::NewL(aPrivNotifier, this);
    iPrivacyNotifier = aPrivNotifier;
    ResetData();
    }

// Two-phased constructor
CPosPrivacyNotifierExtension* CPosPrivacyNotifierExtension::NewL(
    CPosPrivacyNotifier* aPrivNotifier)
    {
    CPosPrivacyNotifierExtension* self = new (ELeave)
        CPosPrivacyNotifierExtension;
    CleanupStack::PushL(self);
    self->ConstructL(aPrivNotifier);
    CleanupStack::Pop(self);
    return self;
    }

// Destructor
CPosPrivacyNotifierExtension::~CPosPrivacyNotifierExtension()
    {
    iRequestorStack.ResetAndDestroy();
    iRequestArray.Close();
    delete iRequestHandler;
    }

// ---------------------------------------------------------
// CPosPrivacyNotifierExtension::Find
//
// (other items were commented in a header).
// ---------------------------------------------------------
//
TInt CPosPrivacyNotifierExtension::Find(TPosQNRequestId aRequestId) const
    {
    for (TInt index = 0; index < iRequestArray.Count(); index++)
        {
        if (iRequestArray[index].iId == aRequestId)
            {
            return index;
            }
        }
    return KErrNotFound;
    }

// ---------------------------------------------------------
// CPosPrivacyNotifierExtension::ResetData
//
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CPosPrivacyNotifierExtension::ResetData()
    {
    iRequestorStack.ResetAndDestroy();
    iCurrentRequestId = KPosNullQNRequestId;
    }

// ---------------------------------------------------------
// CPosPrivacyNotifierExtension::RemoveRequestFromArray
//
// (other items were commented in a header).
// ---------------------------------------------------------
//
TInt CPosPrivacyNotifierExtension::RemoveRequestFromArray(
    TPosQNRequestId aRequestId)
    {
    TInt index = Find(aRequestId);
    if (index == KErrNotFound)
        {
        return KErrNotFound;
        }

    iRequestArray.Remove(index);
    return index;
    }

// ---------------------------------------------------------
// CPosPrivacyNotifierExtension::PrepareL
//
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CPosPrivacyNotifierExtension::PrepareL(
    TPosQNRequestId aRequestId)
    {
    TInt index = Find(aRequestId);
    __ASSERT_ALWAYS(index != KErrNotFound, User::Leave(KErrNotFound));

    iCurrentRequestId = aRequestId;
    }

// ---------------------------------------------------------
// CPosPrivacyNotifierExtension::CompleteRequest
//
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CPosPrivacyNotifierExtension::CompleteRequest(
    TPosQNRequestId aRequestId,
    TInt aCompletionCode)
    {
    TInt index = Find(aRequestId);
    if (index != KErrNotFound)
        {
        if (iRequestArray[index].iType == TPosQNInputData::EQuery)
            {
            // A verification request and the requestor is expecting a response
            iMessage.Complete(aCompletionCode);
            }
        else
            {
            // Intentionally empty. The request was for displaying a notification
            // The requestor is not expecting a response
            }

        iRequestArray.Remove(index);
        ResetData();
        }
    }

// ---------------------------------------------------------
// CPosPrivacyNotifierExtension::CompleteAllRequests
//
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CPosPrivacyNotifierExtension::CompleteAllRequests(TInt aCompletionCode)
    {
    CompleteRequest(iCurrentRequestId, aCompletionCode);
    }

// ---------------------------------------------------------
// CPosPrivacyNotifierExtension::Release
//
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CPosPrivacyNotifierExtension::Release()
    {
    delete iPrivacyNotifier;
    iPrivacyNotifier = NULL;
    }

// ---------------------------------------------------------
// CPosPrivacyNotifierExtension::RegisterL
//
// (other items were commented in a header).
// ---------------------------------------------------------
//
CPosPrivacyNotifierExtension::TNotifierInfo
    CPosPrivacyNotifierExtension::RegisterL()
    {
    return iNotifierInfo;
    }

// ---------------------------------------------------------
// CPosPrivacyNotifierExtension::Info
//
// (other items were commented in a header).
// ---------------------------------------------------------
//
CPosPrivacyNotifierExtension::TNotifierInfo
    CPosPrivacyNotifierExtension::Info() const
    {
    return iNotifierInfo;
    }

// ---------------------------------------------------------
// CPosPrivacyNotifierExtension::StartL
//
// (other items were commented in a header).
// ---------------------------------------------------------
//
TPtrC8 CPosPrivacyNotifierExtension::StartL(const TDesC8& /*aBuffer*/)
    {
    return TPtrC8();
    }

// ---------------------------------------------------------
// CPosPrivacyNotifierExtension::StartL
//
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CPosPrivacyNotifierExtension::StartL(
    const TDesC8& /*aBuffer*/,
    TInt /*aReplySlot*/,
    const RMessagePtr2& aMessage)
    {
    iMessage = aMessage;
    }

// ---------------------------------------------------------
// CPosPrivacyNotifierExtension::Cancel
//
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CPosPrivacyNotifierExtension::Cancel()
    {
    if (iRequestArray.Count() > 0)
        {
        TPosQNRequestId reqId = iRequestArray[0].iId;
        iPrivacyNotifier->HandleRequestCancelled(reqId);
        CompleteRequest(reqId, KErrCancel);
        }
    }

// ---------------------------------------------------------
// CPosPrivacyNotifierExtension::UpdateL
//
// (other items were commented in a header).
// ---------------------------------------------------------
//
TPtrC8 CPosPrivacyNotifierExtension::UpdateL(const TDesC8& aBuffer)
    {
    TPtrC8 tposQnData = aBuffer.Left(KPosQNInputDataClassSize);

    TPckgBuf<TPosQNInputData> input;
    input.Copy(tposQnData);
    TPosQNInputData update = input();

    TInt index = Find(update.iId);
    if (update.iCancelReason == EPosCancelReasonNotAvailable || 
        (update.iCancelReason == EPosCancelReasonTimeout && 
        update.iNotificationReason == EPosVerificationTimeout) )
        {
        HBufC8* buf = HBufC8::NewLC(update.iDataSize);
        TPtrC8 bufPtr = aBuffer.Mid(KPosQNInputDataClassSize);

        RDesReadStream stream(bufPtr);
        CleanupClosePushL(stream);
        iRequestorStack.InternalizeL(stream);
        CleanupStack::PopAndDestroy(2, buf); //buf, stream

        User::LeaveIfError(iRequestArray.Append(update));
        iRequestHandler->ScheduleRequest(update);
        }
    else
        {
        if (index == KErrNotFound)
            {
            User::Leave(KErrArgument);
            }

        iRequestArray[index].iCancelReason = update.iCancelReason;
        }

    return TPtrC8();
    }

//  End of File