/*

 * 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: Telephony Multimedia Service

 *

 */

#include <tms.h>

#include <S60FourCC.h>

#include <AudioPreference.h>

#include <TelephonyAudioRouting.h>

#include "tmscsuplink.h"

#include "tmscsdownlink.h"

#include "tmscallcsadpt.h"

#include "tmsutility.h"

#include "tmsshared.h"

#include "tmsclientserver.h"

#include "tmstarsettings.h"

#include "tmssyncvol.h"

using namespace TMS;

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

// TMSCallCSAdpt::NewL

// Symbian constructor.

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

//

TMSCallCSAdpt* TMSCallCSAdpt::NewL()

    {

    TMSCallCSAdpt* self = new (ELeave) TMSCallCSAdpt();

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

    }

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

// TMSCallCSAdpt::ConstructL

// 2-nd phase constructor.

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

//

void TMSCallCSAdpt::ConstructL()

    {

    TRACE_PRN_FN_ENT;

    iCSDownlink = NULL;

    iCSUplink = NULL;

    iRouting = NULL;

    iTarSettings = NULL;

    iResetVolNotifier = NULL;

    TRACE_PRN_FN_EXT;

    }

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

// TMSCallCSAdpt::TMSCallCSAdpt

//

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

//

TMSCallCSAdpt::TMSCallCSAdpt()

    {

    }

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

// TMSCallCSAdpt::~TMSCallCSAdpt

//

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

//

TMSCallCSAdpt::~TMSCallCSAdpt()

    {

    TRACE_PRN_FN_ENT;

    delete iRouting;

    delete iTarSettings;

    delete iCSUplink;

    delete iCSDownlink;

    delete iResetVolNotifier;

    if (iMsgQueueUp.Handle() > 0)

        {

        iMsgQueueUp.Close();

        }

    if (iMsgQueueDn.Handle() > 0)

        {

        iMsgQueueDn.Close();

        }

    TRACE_PRN_FN_EXT;

    }

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

// TMSCallCSAdpt::PostConstruct

//

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

//

gint TMSCallCSAdpt::PostConstruct()

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_SUCCESS);

    iNextStreamId = 1;

    iUplState = EIdle;

    iDnlState = EIdle;

    TRACE_PRN_FN_EXT;

    return status;

    }

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

// TMSCallCSAdpt::CreateStream

//

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

//

gint TMSCallCSAdpt::CreateStream(const TMSCallType /*callType*/,

        const TMSStreamType strmType, gint& outStrmId)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_SUCCESS);

    switch (strmType)

        {

        case TMS_STREAM_UPLINK:

            {

            status = TMS_RESULT_ALREADY_EXIST;

            if (iUplState == EIdle)

                {

                iUplinkStreamId = iNextStreamId;

                outStrmId = iUplinkStreamId;

                iNextStreamId++;

                status = TMS_RESULT_SUCCESS;

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            status = TMS_RESULT_ALREADY_EXIST;

            if (iDnlState == EIdle)

                {

                iDnlinkStreamId = iNextStreamId;

                outStrmId = iDnlinkStreamId;

                iNextStreamId++;

                status = TMS_RESULT_SUCCESS;

                }

            break;

            }

        default:

            {

            status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED;

            break;

            }

        }

    TRACE_PRN_FN_EXT;

    return status;

    }

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

// TMSCallCSAdpt::InitStream

//

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

//

gint TMSCallCSAdpt::InitStream(const TMSCallType /*callType*/,

        const TMSStreamType strmType, const gint strmId,

        const TMSFormatType /*frmtType*/, const gint retrytime,

        const RMessage2& message)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_SUCCESS);

    switch (strmType)

        {

        case TMS_STREAM_UPLINK:

            {

            status = TMS_RESULT_DOES_NOT_EXIST;

            if (strmId == iUplinkStreamId)

                {

                // Open message queue handling client-server communication

                if (iMsgQueueUp.Handle() <= 0)

                    {

                    // Third argument in TMSCallProxy::InitStream

                    status = iMsgQueueUp.Open(message, 1);

                    }

                if (status == TMS_RESULT_SUCCESS)

                    {

                    status = InitUplink(retrytime);

                    }

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            status = TMS_RESULT_DOES_NOT_EXIST;

            if (strmId == iDnlinkStreamId)

                {

                // Open message queue handling client-server communication

                if (iMsgQueueDn.Handle() <= 0)

                    {

                    // Third argument in TMSCallProxy::InitStream

                    status = iMsgQueueDn.Open(message, 1);

                    }

                if (status == TMS_RESULT_SUCCESS)

                    {

                    status = InitDownlink(retrytime);

                    }

                }

            break;

            }

        default:

            {

            status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED;

            break;

            }

        }

    TRACE_PRN_IF_ERR(status);

    TRACE_PRN_FN_EXT;

    return status;

    }

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

// TMSCallCSAdpt::InitUplink

//

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

//

gint TMSCallCSAdpt::InitUplink(const gint retrytime)

    {

    gint status(TMS_RESULT_SUCCESS);

    if (!iCSUplink)

        {

        TRAP(status, iCSUplink = TMSCSUplink::NewL(*this, retrytime));

        }

    return status;

    }

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

// TMSCallCSAdpt::InitDownlink

//

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

//

gint TMSCallCSAdpt::InitDownlink(const gint retrytime)

    {

    gint status(TMS_RESULT_SUCCESS);

    if (!iCSDownlink)

        {

        TRAP(status, iCSDownlink = TMSCSDownlink::NewL(*this, retrytime));

        }

    if (!iRouting && status == TMS_RESULT_SUCCESS)

        {

        TRAP(status, iRouting = CTelephonyAudioRouting::NewL(*this));

        }

    if (!iTarSettings && status == TMS_RESULT_SUCCESS)

        {

        TRAP(status, iTarSettings = TMSTarSettings::NewL());

        }

    return status;

    }

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

// TMSCallCSAdpt::StartStream

//

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

//

gint TMSCallCSAdpt::StartStream(const TMSCallType /*callType*/,

        const TMSStreamType strmType, const gint strmId, const gint retrytime)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_INVALID_STATE);

    switch (strmType)

        {

        case TMS_STREAM_UPLINK:

            {

            if (iCSUplink && strmId == iUplinkStreamId &&

                    iUplState == EInitialized)

                {

                iCSUplink->Activate(retrytime);

                status = TMS_RESULT_SUCCESS;

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            if(!iResetVolNotifier)

                {

                TRAP(status, iResetVolNotifier = TMSSyncVol::NewL());

                }

            if(iResetVolNotifier)

                {

                iResetVolNotifier->SetSyncVol();

                }

            if (iCSDownlink && strmId == iDnlinkStreamId &&

                    iDnlState == EInitialized)

                {

                iCSDownlink->Activate(retrytime);

                status = TMS_RESULT_SUCCESS;

                }

            break;

            }

        default:

            {

            status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED;

            break;

            }

        }

    TRACE_PRN_FN_EXT;

    return status;

    }

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

// TMSCallCSAdpt::PauseStream

//

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

//

gint TMSCallCSAdpt::PauseStream(const TMSCallType /*callType*/,

        const TMSStreamType /*strmType*/, const gint /*strmId*/)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_FEATURE_NOT_SUPPORTED);

    TRACE_PRN_FN_EXT;

    return status;

    }

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

// TMSCallCSAdpt::StopStream

//

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

//

gint TMSCallCSAdpt::StopStream(const TMSCallType /*callType*/,

        const TMSStreamType strmType, const gint strmId)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_INVALID_STATE);

    switch (strmType)

        {

        case TMS_STREAM_UPLINK:

            {

            if (iCSUplink && strmId == iUplinkStreamId)

                {

                iCSUplink->Deactivate();

                iUplState = EInitialized;

                status = TMS_RESULT_SUCCESS;

                NotifyClient(iUplinkStreamId, ECmdUplinkInitComplete, status);

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            if (iCSDownlink && strmId == iDnlinkStreamId)

                {

                iCSDownlink->Deactivate();

                iDnlState = EInitialized;

                status = TMS_RESULT_SUCCESS;

                NotifyClient(iDnlinkStreamId, ECmdDownlinkInitComplete, status);

                }

            break;

            }

        default:

            {

            status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED;

            break;

            }

        }

    TRACE_PRN_FN_EXT;

    return status;

    }

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

// TMSCallCSAdpt::DeinitStream

//

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

//

gint TMSCallCSAdpt::DeinitStream(const TMSCallType /*callType*/,

        const TMSStreamType strmType, const gint strmId)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_INVALID_STATE);

    switch (strmType)

        {

        case TMS_STREAM_UPLINK:

            {

            if (iCSUplink && strmId == iUplinkStreamId)

                {

                iCSUplink->Deactivate();

                iUplState = EIdle;

                status = TMS_RESULT_SUCCESS;

                NotifyClient(iUplinkStreamId, ECmdUplinkDeInitComplete, status);

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            if (iCSDownlink && strmId == iDnlinkStreamId)

                {

                iCSDownlink->Deactivate();

                iDnlState = EIdle;

                status = TMS_RESULT_SUCCESS;

                NotifyClient(iDnlinkStreamId, ECmdDownlinkDeInitComplete,

                        status);

                }

            break;

            }

        default:

            {

            status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED;

            break;

            }

        }

    TRACE_PRN_FN_EXT;

    return status;

    }

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

// TMSCallCSAdpt::DeleteStream

//

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

//

gint TMSCallCSAdpt::DeleteStream(const TMSCallType /*callType*/,

        const TMSStreamType strmType, const gint strmId)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_SUCCESS);

    switch (strmType)

        {

        case TMS_STREAM_UPLINK:

            {

            if (strmId == iUplinkStreamId)

                {

                iUplinkStreamId = -1;

                iUplState = EIdle;

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            if (strmId == iDnlinkStreamId)

                {

                iDnlinkStreamId = -1;

                iDnlState = EIdle;

                }

            break;

            }

        default:

            {

            status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED;

            break;

            }

        }

    TRACE_PRN_FN_EXT;

    return status;

    }

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

// TMSCallCSAdpt::DataXferBufferEmptied

//

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

//

gint TMSCallCSAdpt::DataXferBufferEmptied(const TMSCallType /*callType*/,

        const TMSStreamType /*strmType*/, const gint /*strmId*/)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_FEATURE_NOT_SUPPORTED);

    TRACE_PRN_FN_EXT;

    return status;

    }

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

// TMSCallCSAdpt::DataXferBufferFilled

//

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

//

gint TMSCallCSAdpt::DataXferBufferFilled(const TMSCallType /*callType*/,

        const TMSStreamType /*strmType*/, const gint /*strmId*/,

        const guint /*datasize*/)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_FEATURE_NOT_SUPPORTED);

    TRACE_PRN_FN_EXT;

    return status;

    }

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

// TMSCallCSAdpt::GetDataXferBufferHndl

//

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

//

gint TMSCallCSAdpt::GetDataXferBufferHndl(const TMSCallType /*callType*/,

        const TMSStreamType /*strmType*/, const gint /*strmId*/,

        const guint32 /*key*/, RChunk& /*chunk*/)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_FEATURE_NOT_SUPPORTED);

    TRACE_PRN_FN_EXT;

    return status;

    }

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

// TMSCallCSAdpt::GetMaxVolume

//

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