// Copyright (c) 2006-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:
// Definition of PSY request channel component functions.
// 
//

/**
 @file
 @internalTechnology
 @released
*/

#include <e32base.h>
#include <e32debug.h>
#include <lbs/lbslocerrors.h>
#include "lbsdevloggermacros.h"
#include "lbsprocessuiddefs.h"
#include "cpsyrequestchannel.h"


CPsyRequestChannel::CPsyRequestChannel(MPsyRequestObserver& aObserver) : 
    CActive(EPriorityStandard),
    iObserver(aObserver)
    {
    }
    
CPsyRequestChannel::~CPsyRequestChannel()
    {
    Cancel();
    iPsyResponseChannel.Close();
    delete iMsgBuffer;
    }

CPsyRequestChannel* CPsyRequestChannel::NewL(MPsyRequestObserver& aObserver, TUint aChannel)
    {
    CPsyRequestChannel* self = new (ELeave) CPsyRequestChannel(aObserver);
    CleanupStack::PushL(self);
    self->ConstructL(aChannel);
    CleanupStack::Pop(self);
    return self;
    }
    
/**
Opens the channel specified
 
@param aChannel, Net Internal API channel to use for this object
*/
void CPsyRequestChannel::ConstructL(TUint aChannel)
    {
    iPsyResponseChannel.OpenL(static_cast<RLbsNetChannel::TLbsNetChannelId> (aChannel), *this);
    iMsgBuffer = CRequestMessageBuffer::NewL();
    CActiveScheduler::Add(this);
    }
    
/**
Handle the ACK from the SendMessage call.
*/
void CPsyRequestChannel::RunL()
    {
    LBS_RDEBUG_ARGINT("PSY Req Chan", "LBS", "RunL", iStatus.Int());

    User::LeaveIfError(iStatus.Int());
    SendNextBufferedMessage();
    }
    
void CPsyRequestChannel::DoCancel()
    {
    iPsyResponseChannel.CancelSendMessageNotification();
    }
    
TInt CPsyRequestChannel::RunError(TInt aError)
    {
    return aError;
    }

/**
Sends a message to a Network PSY from the Network Gateway
 
@param aChannel, Net Internal API channel to use for this object
*/
void CPsyRequestChannel::SendNetworkResponse(const TLbsNetInternalMsgBase& aMessage)
    {
    LBSLOG(ELogP1, "CPsyRequestChannel::SendNetworkResponse:");
    if (!IsActive())
        {       
        // Immediately send the new message.
        SendMessage(aMessage);
        }
    else
        {
        // Still waiting for acknowledgement that a previous message
        // was read, so buffer this new message.
        TInt err = iMsgBuffer->BufferMessage(aMessage);
        if (err != KErrNone)
            {
            LBSLOG(ELogP1, "BUFFERING MESSAGE FAILED!!");
            }
        }
    }


void CPsyRequestChannel::SendMessage(const TLbsNetInternalMsgBase& aMessage)
    {
    LBSLOG(ELogP1, "CPsyRequestChannel::SendMessage:");
    LBSLOG2(ELogP2, "Sending message : Type %d", aMessage.Type());
    
    iPsyResponseChannel.SendMessage(aMessage, iStatus);
    SetActive();
    }


void CPsyRequestChannel::SendNextBufferedMessage()
    {
    LBSLOG(ELogP1, "CPsyRequestChannel::SendNextBufferedMessage:");
    
    const TLbsNetInternalMsgBase* msg = iMsgBuffer->PeekNextMessage();
    if (msg != NULL)
        {
        // Send the oldest buffered message. This will always
        // be the one at position zero.
        LBSLOG2(ELogP2, "Sending buffered message. Type: %d", msg->Type());
        SendMessage(*msg);
        iMsgBuffer->RemoveMessage(msg);
        }
    }


/**
Passes a message from a Network PSY to the Network Gateway
 
@param aChannel, Net Internal API channel to use for this object
*/
void CPsyRequestChannel::ProcessNetChannelMessage(RLbsNetChannel::TLbsNetChannelId aChannelId, const TLbsNetInternalMsgBase& aMessage)
    {
    LBSLOG(ELogP1, "CPsyRequestChannel::ProcessNetChannelMessage");
    __ASSERT_DEBUG(aChannelId == RLbsNetChannel::EChannelNG2SUPLPSY, User::Panic(KLbsNGFault, ENGUnexpectedNetChannelId));
    (void) aChannelId;
    iObserver.ProcessPsyMessage(aMessage);
    }