/*
 * Copyright (c) 2010 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: QT Bindings for TMS
 *
 */

#include <tmssource.h>
#include <tmsformat.h>
#include <tmsstream.h>
#include <qtmseffect.h>
#include <qtmsstream.h>
#include "qtmsstreamimpl.h"
#include "qtmssource.h"
#include "qtmsclientsourceimpl.h"
#include "qtmsmodemsourceimpl.h"
#include "qtmsmicsourceimpl.h"
#include "qtmsclientsinkimpl.h"
#include "qtmsmodemsinkimpl.h"
#include "qtmsspeakersinkimpl.h"
#include "qtmspcmimpl.h"
#include "qtmsamrimpl.h"
#include "qtmsg711impl.h"
#include "qtmsg729impl.h"
#include "qtmsilbcimpl.h"
#include "qtmsvolumeeffectimpl.h"
#include "qtmsgaineffectimpl.h"
#include "qtmswrapperexport.h"

using namespace QTMS;
using namespace TMS;

QTMSStream::QTMSStream(void) :
    iStream(NULL)
    {
    }

QTMSStream::~QTMSStream()
    {
    //delete iStream;
    //delete (static_cast<QTMSStreamImpl*> (iStream));
    }

gint QTMSStream::AddSource(QTMSSource* qsource)
    {
    gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);

    if (iStream && qsource)
        {
        QTMSSourceType qsrctype;
        TMSSource* tmssource(NULL);

        qsource->GetType(qsrctype);

        switch (qsrctype)
            {
            case QTMS_SOURCE_CLIENT:
                status = static_cast<QTMSClientSourceImpl*>
                    (qsource)->GetSource(tmssource);
                break;
            case QTMS_SOURCE_MODEM:
                status = static_cast<QTMSModemSourceImpl*>
                    (qsource)->GetSource(tmssource);
                break;
            case QTMS_SOURCE_MIC:
                status = static_cast<QTMSMicSourceImpl*>
                    (qsource)->GetSource(tmssource);
                break;
            default:
                break;
            }
        if (status == QTMS_RESULT_SUCCESS && tmssource)
            {
            status = iStream->AddSource(tmssource);
            }
        }
    return status;
    }

gint QTMSStream::RemoveSource(QTMSSource* qsource)
    {
    gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);

    if (iStream && qsource)
        {
        QTMSSourceType qsrctype;
        TMSSource* tmssource(NULL);

        qsource->GetType(qsrctype);

        switch (qsrctype)
            {
            case QTMS_SOURCE_CLIENT:
                status = static_cast<QTMSClientSourceImpl*>
                    (qsource)->GetSource(tmssource);
                break;
            case QTMS_SOURCE_MODEM:
                status = static_cast<QTMSModemSourceImpl*>
                    (qsource)->GetSource(tmssource);
                break;
            case QTMS_SOURCE_MIC:
                status = static_cast<QTMSMicSourceImpl*>
                    (qsource)->GetSource(tmssource);
                break;
            default:
                break;
            }
        if (status == QTMS_RESULT_SUCCESS && tmssource)
            {
            status = iStream->RemoveSource(tmssource);
            }
        }

    return status;
    }

gint QTMSStream::AddSink(QTMSSink* qsink)
    {
    gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);

    if (iStream && qsink)
        {
        QTMSSinkType qsinktype;
        TMSSink* tmssink(NULL);

        qsink->GetType(qsinktype);

        switch (qsinktype)
            {
            case QTMS_SINK_CLIENT:
                status = static_cast<QTMSClientSinkImpl*>
                    (qsink)->GetSink(tmssink);
                break;
            case QTMS_SINK_MODEM:
                status = static_cast<QTMSModemSinkImpl*>
                    (qsink)->GetSink(tmssink);
                break;
            case QTMS_SINK_SPEAKER:
                status = static_cast<QTMSSpeakerSinkImpl*>
                    (qsink)->GetSink(tmssink);
                break;
            default:
                break;
            }
        if (status == QTMS_RESULT_SUCCESS && tmssink)
            {
            status = iStream->AddSink(tmssink);
            }
        }
    return status;
    }

gint QTMSStream::RemoveSink(QTMSSink* qsink)
    {
    gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);

    if (iStream && qsink)
        {
        QTMSSinkType qsinktype;
        TMSSink* tmssink(NULL);

        qsink->GetType(qsinktype);

        switch (qsinktype)
            {
            case QTMS_SINK_CLIENT:
                status = static_cast<QTMSClientSinkImpl*>
                    (qsink)->GetSink(tmssink);
                break;
            case QTMS_SINK_MODEM:
                status = static_cast<QTMSModemSinkImpl*>
                    (qsink)->GetSink(tmssink);
                break;
            case QTMS_SINK_SPEAKER:
                status = static_cast<QTMSSpeakerSinkImpl*>
                    (qsink)->GetSink(tmssink);
                break;
            default:
                break;
            }
        if (status == QTMS_RESULT_SUCCESS && tmssink)
            {
            status = iStream->RemoveSink(tmssink);
            }
        }

    return status;
    }

gint QTMSStream::SetFormat(QTMSFormat* qformat)
    {
    gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);

    if (iStream && qformat)
        {
        QTMSFormatType fmttype;
        TMSFormat* tmsformat(NULL);
        qformat->GetType(fmttype);
        switch (fmttype)
            {
            case QTMS_FORMAT_PCM:
                status = static_cast<QTMSPCMFormatImpl*>
                    (qformat)->GetFormat(tmsformat);
                break;
            case QTMS_FORMAT_AMR:
                status = static_cast<QTMSAMRFormatImpl*>
                    (qformat)->GetFormat(tmsformat);
                break;
            case QTMS_FORMAT_G711:
                status = static_cast<QTMSG711FormatImpl*>
                    (qformat)->GetFormat(tmsformat);
                break;
            case QTMS_FORMAT_G729:
                status = static_cast<QTMSG729FormatImpl*>
                    (qformat)->GetFormat(tmsformat);
                break;
            case QTMS_FORMAT_ILBC:
                status = static_cast<QTMSILBCFormatImpl*>
                    (qformat)->GetFormat(tmsformat);
                break;
            default:
                break;
            }

        status = iStream->SetFormat(tmsformat);
        }
    return status;
    }

gint QTMSStream::ResetFormat(QTMSFormat* qformat)
    {
    gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);

    if (iStream && qformat)
        {
        QTMSFormatType fmttype;
        TMSFormat* tmsformat(NULL);
        qformat->GetType(fmttype);
        switch (fmttype)
            {
            case QTMS_FORMAT_PCM:
                status = static_cast<QTMSPCMFormatImpl*>
                    (qformat)->GetFormat(tmsformat);
                break;
            case QTMS_FORMAT_AMR:
                status = static_cast<QTMSAMRFormatImpl*>
                    (qformat)->GetFormat(tmsformat);
                break;
            case QTMS_FORMAT_G711:
                status = static_cast<QTMSG711FormatImpl*>
                    (qformat)->GetFormat(tmsformat);
                break;
            case QTMS_FORMAT_G729:
                status = static_cast<QTMSG729FormatImpl*>
                    (qformat)->GetFormat(tmsformat);
                break;
            case QTMS_FORMAT_ILBC:
                status = static_cast<QTMSILBCFormatImpl*>
                    (qformat)->GetFormat(tmsformat);
                break;
            default:
                break;
            }

        status = iStream->ResetFormat(tmsformat);
        }
    return status;
    }

gint QTMSStream::AddEffect(QTMSEffect* qeffect)
    {
    gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
    if (iStream && qeffect)
        {
        QTMSEffectType effecttype;
        TMSEffect* tmseffect(NULL);
        qeffect->GetType(effecttype);

        switch (effecttype)
            {
            case QTMS_EFFECT_VOLUME:
                status = static_cast<QTMSVolumeEffectImpl*>
                    (qeffect)->GetEffect(tmseffect);
                break;
            case QTMS_EFFECT_GAIN:
                status = static_cast<QTMSGainEffectImpl*>
                    (qeffect)->GetEffect(tmseffect);
                break;
            default:
                break;
            }
        status = iStream->AddEffect(tmseffect);
        }
    return status;
    }

gint QTMSStream::RemoveEffect(QTMSEffect* qeffect)
    {
    gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
    if (iStream && qeffect)
        {
        QTMSEffectType effecttype;
        TMSEffect* tmseffect(NULL);
        qeffect->GetType(effecttype);

        switch (effecttype)
            {
            case QTMS_EFFECT_VOLUME:
                status = static_cast<QTMSVolumeEffectImpl*>
                    (qeffect)->GetEffect(tmseffect);
                break;
            case QTMS_EFFECT_GAIN:
                status = static_cast<QTMSGainEffectImpl*>
                    (qeffect)->GetEffect(tmseffect);
                break;
            default:
                break;
            }
        status = iStream->RemoveEffect(tmseffect);
        }
    return status;
    }

gint QTMSStream::GetState()
    {
    gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
    if (iStream)
        {
        status = iStream->GetState();
        }
    return status;
    }

gint QTMSStream::GetStreamType()
    {
    gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
    if (iStream)
        {
        status = iStream->GetStreamType();
        }
    return status;
    }

gint QTMSStream::GetStreamId()
    {
    gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
    if (iStream)
        {
        status = iStream->GetStreamId();
        }
    return status;
    }

gint QTMSStream::Init(gint retrytime)
    {
    gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
    if (iStream)
        {
        status = iStream->Init(retrytime);
        }
    return status;
    }

gint QTMSStream::Pause()
    {
    gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
    if (iStream)
        {
        status = iStream->Pause();
        }
    return status;
    }

gint QTMSStream::Start(gint retrytime)
    {
    gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
    if (iStream)
        {
        status = iStream->Start(retrytime);
        }
    return status;
    }

gint QTMSStream::Stop()
    {
    gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
    if (iStream)
        {
        status = iStream->Stop();
        }
    return status;
    }

void QTMSStream::Deinit()
    {
    if (iStream)
        {
        iStream->Deinit();
        }
    }