/*
* Copyright (c) 2007-2008 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:  VOIP Audio Services
*
*/


#include <e32base.h>
#include <voipuplinkstream.h>
#include <voipdownlinkstream.h>
#include "VoIPAudioSession.h"
#include "VoIPDtmfTonePlayerImpl.h"


// ---------------------------------------------------------------------------
// CDTMFTonePlayerImpl::NewL
// ---------------------------------------------------------------------------
//
CDTMFTonePlayerImpl* CDTMFTonePlayerImpl::NewL()
    {
    CDTMFTonePlayerImpl* self = new (ELeave) CDTMFTonePlayerImpl();
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self);
    return self;
    }

// ---------------------------------------------------------------------------
// CDTMFTonePlayerImpl::~CDTMFTonePlayerImpl
// ---------------------------------------------------------------------------
//
CDTMFTonePlayerImpl::~CDTMFTonePlayerImpl()
    {
    Close();

    if (iMsgQComHandler)
        {
        iMsgQComHandler->Cancel();
        delete iMsgQComHandler;
        }

    if (iMsgComQueue.Handle() > 0)
        {
        iMsgComQueue.Close();
        }
    }

// ---------------------------------------------------------------------------
// CDTMFTonePlayerImpl::CDTMFTonePlayerImpl
// ---------------------------------------------------------------------------
//
CDTMFTonePlayerImpl::CDTMFTonePlayerImpl()
    {
    }

// ---------------------------------------------------------------------------
// CDTMFTonePlayerImpl::ConstructL
// ---------------------------------------------------------------------------
//
void CDTMFTonePlayerImpl::ConstructL()
    {
    // Pass ownership to the parent class
    CDTMFTonePlayer::ConstructL(this);
    }

// ---------------------------------------------------------------------------
// CDTMFTonePlayerImpl::Open
// ---------------------------------------------------------------------------
//
TInt CDTMFTonePlayerImpl::Open(MDTMFToneObserver& aObserver)
    {
    TInt err = KErrNotReady;
    iObserver = &aObserver;

    TRAP(err, StartMsgQueueL());
    if (iVoIPAudioSession && err == KErrNone)
        {
        err = iVoIPAudioSession->OpenDTMFTonePlayer();
        }

    return err;
    }

// ---------------------------------------------------------------------------
// CDTMFTonePlayerImpl::Play
// ---------------------------------------------------------------------------
//
TInt CDTMFTonePlayerImpl::Play(const TPtr aTones)
    {
    TInt err = KErrNotReady;

    if (iVoIPAudioSession)
        {
        err = iVoIPAudioSession->PlayDTMFTone(aTones);
        }

    return err;
    }

// ---------------------------------------------------------------------------
// CDTMFTonePlayerImpl::Stop
// ---------------------------------------------------------------------------
//
TInt CDTMFTonePlayerImpl::Stop()
    {
    TInt err = KErrNotReady;

    if (iVoIPAudioSession)
        {
        err = iVoIPAudioSession->StopDTMFTonePlay();
        }

    return err;
    }

// ---------------------------------------------------------------------------
// CDTMFTonePlayerImpl::Close
// ---------------------------------------------------------------------------
//
void CDTMFTonePlayerImpl::Close()
    {
    if (iVoIPAudioSession)
        {
        iVoIPAudioSession->CloseDTMFTonePlayer();
        }
    }

// ---------------------------------------------------------------------------
// CDTMFTonePlayerImpl::AddVoIPAudioUplinkStream
// ---------------------------------------------------------------------------
//
TInt CDTMFTonePlayerImpl::AddVoIPAudioUplinkStream(
                          CVoIPAudioUplinkStream& /*aStream*/,
                          RVoIPAudioSession* aSession)
    {
    TInt err = KErrNone;
    iVoIPAudioSession = aSession;

    if (!iVoIPAudioSession)
        {
        err = KErrNotFound;
        }
    else
        {
        iStreamType = EUplink;
        }

    return err;
    }

// ---------------------------------------------------------------------------
// CDTMFTonePlayerImpl::RemoveVoIPAudioUplinkStream
// ---------------------------------------------------------------------------
//
TInt CDTMFTonePlayerImpl::RemoveVoIPAudioUplinkStream(
                          CVoIPAudioUplinkStream& /*aStream*/)
    {
    iVoIPAudioSession = NULL;
    return KErrNone;
    }

// ---------------------------------------------------------------------------
// CDTMFTonePlayerImpl::AddVoIPAudioDownlinkStream
// ---------------------------------------------------------------------------
//
TInt CDTMFTonePlayerImpl::AddVoIPAudioDownlinkStream(
                          CVoIPAudioDownlinkStream& /*aStream*/,
                          RVoIPAudioSession* aSession)
    {
    TInt err = KErrNone;
    iVoIPAudioSession = aSession;

    if (!iVoIPAudioSession)
        {
        err = KErrNotFound;
        }
    else
        {
        iStreamType = EDownlink;
        }

    return err;
    }

// ---------------------------------------------------------------------------
// CDTMFTonePlayerImpl::RemoveVoIPAudioDownlinkStream
// ---------------------------------------------------------------------------
//
TInt CDTMFTonePlayerImpl::RemoveVoIPAudioDownlinkStream(
                          CVoIPAudioDownlinkStream& /*aStream*/)
    {
    iVoIPAudioSession = NULL;
    return KErrNone;
    }

// ---------------------------------------------------------------------------
// CDTMFTonePlayerImpl::StrartMsgQueueL
//
// ---------------------------------------------------------------------------
//
void CDTMFTonePlayerImpl::StartMsgQueueL()
    {
    TInt err = KErrNone;

    if (iMsgComQueue.Handle() <= 0)
        {
        if (iStreamType == EDownlink)
            {
            err = iMsgComQueue.CreateGlobal(KDTMFToneComQueueDNL,
                                            KVoIPMsgComQSlots);
            }
        else
            {
            err = iMsgComQueue.CreateGlobal(KDTMFToneComQueueUPL,
                                            KVoIPMsgComQSlots);
            }

        User::LeaveIfError(err);
        }

    ReceiveMsgQComHandlerEventsL();
    }

// ---------------------------------------------------------------------------
// CDTMFTonePlayerImpl::ReceiveMsgQComHandlerEventsL
// Starts message queue handler (A/O) to monitor server side events
// ---------------------------------------------------------------------------
//
void CDTMFTonePlayerImpl::ReceiveMsgQComHandlerEventsL()
    {
    if (iMsgQComHandler)
        {
        iMsgQComHandler->Cancel();
        }
    else
        {
        iMsgQComHandler = CQueueHandler::NewL(this, &iMsgComQueue);
        }

    iMsgQComHandler->Start();
    }


// ======== CALLBACK FUNCTIONS ========


// ---------------------------------------------------------------------------
// CDTMFTonePlayerImpl::Event
//
// From MQueueHandlerObserver
// ---------------------------------------------------------------------------
//
void CDTMFTonePlayerImpl::Event(TInt aEventType, TInt aError)
    {
    iObserver->Event(*this, aEventType, aError);
    }


// End of file