/*

* Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies). All rights reserved.

*

* This library is free software; you can redistribute it and/or

* modify it under the terms of the GNU Lesser General Public

* License as published by the Free Software Foundation; either

* version 2 of the License, or (at your option) any later version.

*

* This library is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU

* Lesser General Public License for more details.

*

* You should have received a copy of the GNU Lesser General Public

* License along with this library; if not, write to the

* Free Software Foundation, Inc., 59 Temple Place - Suite 330,

* Boston, MA 02111-1307, USA.

*

* Description:

*

*/

#include "devsoundsrcwrapper.h"

#include <e32base.h>

#include <mmcccodecinformation.h>

#include "debugtracemacros.h"

DevSoundWrapperSrc::DevSoundWrapperSrc()

    {

    //init_complete = 0;

    dev_sound = NULL;

    buffersize = 0;

    dev_count = 0;

    speechbitrate = 0;

    caps.iRate = EMMFSampleRate8000Hz;

    caps.iEncoding = EMMFSoundEncoding16BitPCM;

    caps.iChannels = EMMFMono;

    fourcc = KMMFFourCCCodePCM16;

    iCallbackError = KErrNone;

    iSpeechEncoderConfig = NULL;

    iG711EncoderIntfc = NULL;

    iG729EncoderIntfc = NULL;

    iIlbcEncoderIntfc = NULL;

    }

/*********************************************************/

void DevSoundWrapperSrc::InitializeComplete(TInt aError)

    {

    TRACE_PRN_FN_ENT;

    TRequestStatus* stat = &(AL->iStatus);

    iCallbackError = aError;

    User::RequestComplete(stat, aError);

    TRACE_PRN_FN_EXT;

    }

/************************************************************/

void DevSoundWrapperSrc::BufferToBeFilled(CMMFBuffer* /*aBuffer*/)

    {

    }

/***********************************************************/

void DevSoundWrapperSrc::PlayError(TInt /*aError*/)

    {

    }

/*******************************************************/

void DevSoundWrapperSrc::BufferToBeEmptied(CMMFBuffer* aBuffer)

    {

    buffer = aBuffer;

    bufferreadpos = 0;

    CMMFDataBuffer* buf = STATIC_CAST (CMMFDataBuffer*, buffer);

    buffersize = buf->Data().Length();

    TRACE_PRN_N1(_L("DevSoundWrapperSrc::BufferToBeEmptied->buffersize [%d]"), buffersize);

    TRequestStatus* stat = &(AL->iStatus);

    if (aBuffer)

        {

        User::RequestComplete(stat, KErrNone);

        iCallbackError = KErrNone;

        }

    else

        {

        User::RequestComplete(stat, KErrNotFound);

        iCallbackError = KErrNotFound;

        }

    }

/********************************************************/

void DevSoundWrapperSrc::RecordError(TInt aError)

    {

    TRACE_PRN_FN_ENT;

    TRACE_PRN_N1(_L("DevSoundWrapperSrc::RecordError %d"),aError);

    iCallbackError = aError;

    TRequestStatus* stat = &(AL->iStatus);

    /// need to check this, error can occure before and after calling 

    /// the StartActiveScheduler and might and might not be waiting for 

    /// completing the request

    if( AL->IsActive() )

        {

    /// need to complete the request for coming out from blocking call.

        User::RequestComplete(stat, aError);

        iCallbackError = aError;    

        }

    TRACE_PRN_FN_EXT;

    }

/**********************************************************/

void DevSoundWrapperSrc::ConvertError(TInt /*aError*/)

    {

    }

/***********************************************************/

void DevSoundWrapperSrc::DeviceMessage(TUid /*aMessageType*/, const TDesC8& /*aMsg*/)

    {

    }

/***********************************************************/

void DevSoundWrapperSrc::SendEventToClient(const TMMFEvent& /*aEvent*/)

    {

    }

/************************************************************/

void DevSoundWrapperSrc::ToneFinished(TInt /*aError*/)

    {

    }

/***********************************************************

 *********C interface functions******************************

 ************************************************************/

/******************************************************/

int get_databuffer(DevSoundWrapperSrc *handle, const TUint8** buffer)

    {

    int ret = 0;

    CMMFDataBuffer* buf = STATIC_CAST (CMMFDataBuffer*, handle->buffer);

    *buffer = buf->Data().Ptr();

    if (buffer)

        {

        ret = KErrNone;

        }

    else

        {

        ret = KErrNotFound;

        }

    return ret;

    }

/*********************************************************/

int get_databuffer_size(DevSoundWrapperSrc *handle)

    {

    CMMFDataBuffer* buf = STATIC_CAST (CMMFDataBuffer*, handle->buffer);

    return buf->Data().Length();

    }

/*********************************************************/

int open_devsound(DevSoundWrapperSrc **handle)

    {

    TRACE_PRN_FN_ENT;

    int ret = 0;

    *handle = new DevSoundWrapperSrc();

    if (handle)

        {

        ret = open_device(handle);

        }

    else

        {

        ret = KErrNoMemory;

        }

    TRACE_PRN_FN_EXT;

    return ret;

    }

/*******************************************************/

int initialize_devsound(GstDevsoundSrc* ds)

    {

    TRACE_PRN_FN_ENT;

    DevSoundWrapperSrc* handle = (DevSoundWrapperSrc*) ds->handle;

    handle->AL->InitialiseActiveListener();

        TRAP(handle->iCallbackError, handle->dev_sound->InitializeL(*handle, handle->fourcc, EMMFStateRecording));

    if ( handle->iCallbackError )

        {

        TRACE_PRN_FN_EXT;

        return handle->iCallbackError;

        }

    handle->AL->StartActiveScheduler();

    if (KErrNone == handle->iCallbackError )

        {

        TMMFPrioritySettings temp;

        temp.iPref = (TMdaPriorityPreference) ds->preference;

        temp.iPriority = ds->priority;

        handle->dev_sound->SetPrioritySettings(temp);

        handle->iCallbackError = SetConfigurations(handle);

        }

    TRACE_PRN_IF_ERR(handle->iCallbackError);

    TRACE_PRN_FN_EXT;

    return handle->iCallbackError;

    }

/*********************************************************/

int stop_devsound(GstDevsoundSrc *ds)

    {

    TRACE_PRN_FN_ENT;

    DevSoundWrapperSrc* handle = (DevSoundWrapperSrc*) ds->handle;

    handle->dev_sound->Stop();

    TRACE_PRN_FN_EXT;

    return 0;

    }

int pause_devsound(GstDevsoundSrc *ds)

    {

    TRACE_PRN_FN_ENT;

    DevSoundWrapperSrc* handle = (DevSoundWrapperSrc*) ds->handle;

    TRACE_PRN_FN_EXT;

    return 0;

    }

int resume_devsound(GstDevsoundSrc *ds)

    {

    TRACE_PRN_FN_ENT;

    DevSoundWrapperSrc* handle = (DevSoundWrapperSrc*) ds->handle;

    if(handle->dev_sound->IsResumeSupported())

        {

        handle->iCallbackError = handle->dev_sound->Resume();

        }

    else

        {

        if( KErrNone == recordinit(handle) )

            initproperties(ds);

        }

    TRACE_PRN_FN_EXT;

    return 0;

    }

int open_device(DevSoundWrapperSrc **handle)

    {

    (*handle)->iCallbackError = KErrNone;

    TRACE_PRN_FN_ENT;

    (*handle)->dev_count++;

    (*handle)->as = CActiveScheduler::Current();

    if (!((*handle)->as))

        {

        (*handle)->as = new CActiveScheduler();

        if ((*handle)->as)

            {

            CActiveScheduler::Install((*handle)->as);

            }

        }

    (*handle)->AL = new CActiveListener;

    ((*handle)->AL)->asw = new CActiveSchedulerWait();

        TRAP( (*handle)->iCallbackError,(*handle)->dev_sound = CMMFDevSound::NewL() );

    if (!(*handle)->AL || !((*handle)->AL)->asw || !(*handle)->dev_sound

            || !(*handle)->as)

        {

        return KErrNoMemory;

        }

    TRAP((*handle)->iCallbackError ,(*handle)->iAudoInputRecord = CAudioInput::NewL(*(*handle)->dev_sound));

    if ( KErrNone == (*handle)->iCallbackError )

	{

	RArray<CAudioInput::TAudioInputPreference> inputArray;

    inputArray.Append( CAudioInput::EDefaultMic );

    // Set Audio Input

    (*handle)->iAudoInputRecord->SetAudioInputL( inputArray.Array( ) );

    inputArray.Close();

	}

    TRACE_PRN_FN_EXT;

    return (*handle)->iCallbackError;

    }

/*********************************************************/

int close_devsound(GstDevsoundSrc *ds)

    {

    TRACE_PRN_FN_ENT;

    CMMFDevSound    *dev_sound= 0;

    dev_sound = (STATIC_CAST(DevSoundWrapperSrc*, ds->handle))->dev_sound;

    dev_sound->Stop();

    g_list_foreach(ds->supportedbitrates, (GFunc) g_free, NULL);

    g_list_free(ds->supportedbitrates);

    g_list_foreach(ds->fmt, (GFunc) g_free, NULL);

    g_list_free(ds->fmt);

    ds->fmt = NULL;

    delete (STATIC_CAST(DevSoundWrapperSrc*, ds->handle))->iAudoInputRecord;

    delete dev_sound;

    delete ds->handle;

    TRACE_PRN_FN_EXT;

    return 0;

    }

/************************************************************/

void update_devsound_speech_bitrate(DevSoundWrapperSrc *handle, TUint bitrate)

    {

    handle->speechbitrate = bitrate;

    }

/************************************************************/

int SetConfigurations(DevSoundWrapperSrc *handle)

    {

    TRACE_PRN_FN_ENT;

    int ret = 0;

    TMMFCapabilities temp_caps;

    temp_caps = (handle->dev_sound)->Capabilities();

    handle->gain = (handle->dev_sound)->MaxGain();

    (handle->dev_sound)->SetGain(handle->gain);

    handle->caps.iBufferSize = temp_caps.iBufferSize;

    switch (handle->fourcc)

        {

        case KMccFourCCIdG711:

            {

            if (!handle->iG711EncoderIntfc)

                {

                    TRAP( ret, handle->iG711EncoderIntfc

                            = CG711EncoderIntfc::NewL(*handle->dev_sound) );

                }

            break;

            }

        case KMccFourCCIdG729:

            {

            if (!handle->iG729EncoderIntfc)

                {

                    TRAP( ret, handle->iG729EncoderIntfc

                            = CG729EncoderIntfc::NewL(*handle->dev_sound));

                }

            break;

            }

        case KMccFourCCIdILBC:

            {

            if (!handle->iIlbcEncoderIntfc)

                {

                    TRAP( ret, handle->iIlbcEncoderIntfc

                            = CIlbcEncoderIntfc::NewL(*handle->dev_sound));

                }

            break;

            }

        default:

            {

            break;

            }

        }

    if (ret)

        return ret;

    if (!handle->iSpeechEncoderConfig && handle->fourcc

            != KMMFFourCCCodePCM16)

        {

            TRAP(ret, handle->iSpeechEncoderConfig

                    = CSpeechEncoderConfig::NewL(*handle->dev_sound));

        if (ret)

            return ret;

        if(handle->speechbitrate > 0)

            {

            ret = set_speech_encoder_bit_rate(handle,handle->speechbitrate);

            if(ret)

                return ret;

            }

        }

     TRAP(ret, (handle->dev_sound)->SetConfigL(handle->caps) );

     if (ret)

         {

         return ret;

         }

     (handle->caps) = (handle->dev_sound)->Config();

    TRACE_PRN_FN_EXT;

    return ret;

    }

void DevSoundWrapperSrc::GetSpeechEncoderProperties(GstDevsoundSrc* ds)

    {

    DevSoundWrapperSrc* dsPtr = STATIC_CAST(DevSoundWrapperSrc*, ds->handle);

    get_speech_encoder_supported_bit_rates(ds);

    get_speech_encoder_bit_rate(dsPtr, &ds->speechbitrate);

    get_speech_encoder_vad_mode(dsPtr, &ds->speechvadmode);

    }

/*********************************************************/

int get_speech_encoder_bit_rate(DevSoundWrapperSrc *handle, guint* aBitrate)

    {

    int err = 0;

    if (handle->iSpeechEncoderConfig)

        {

        err = (handle->iSpeechEncoderConfig)->GetBitrate(*aBitrate);

        }

    return err;

    }

/*********************************************************/

int get_speech_encoder_supported_bit_rates(GstDevsoundSrc *ds)

    {

    int err = 0;

    DevSoundWrapperSrc* dsPtr = STATIC_CAST(DevSoundWrapperSrc*, ds->handle);

        TRAP(err, err = dsPtr->GetSupportedBitratesL(ds));

    return err;

    }

int DevSoundWrapperSrc::GetSupportedBitratesL(GstDevsoundSrc* ds)

    {

    int err = 0;

    DevSoundWrapperSrc* dsPtr = STATIC_CAST(DevSoundWrapperSrc*, ds->handle);

    if (dsPtr->iSpeechEncoderConfig)

        {

        RArray<TUint> bitrates;

        CleanupClosePushL(bitrates);

        err = (dsPtr->iSpeechEncoderConfig)->GetSupportedBitrates(bitrates);

        for (TInt i = 0; i < bitrates.Count(); i++)

            {

            guint *ip = g_new (guint, 1);

            *ip = bitrates[i];

            ds->supportedbitrates = g_list_append(ds->supportedbitrates, ip);

            }

        CleanupStack::PopAndDestroy(&bitrates);

        }

    return err;

    }

/*********************************************************/

int get_speech_encoder_vad_mode(DevSoundWrapperSrc *handle,

        gboolean* aVadMode)

    {

    int err = 0;

    if (handle->iSpeechEncoderConfig)

        {

        err = (handle->iSpeechEncoderConfig)->GetVadMode(*aVadMode);

        }

    return err;

    }

/*********************************************************/

int set_speech_encoder_bit_rate(DevSoundWrapperSrc *handle, guint aBitrate)

    {

    int err = 0;

    if (handle->iSpeechEncoderConfig)

        {

        err = (handle->iSpeechEncoderConfig)->SetBitrate(aBitrate);

        }

    return err;

    }

/*********************************************************/

int set_speech_encoder_vad_mode(DevSoundWrapperSrc *handle, gboolean aVadMode)

    {

    int err = 0;

    if (handle->iSpeechEncoderConfig)

        {

        err = (handle->iSpeechEncoderConfig)->SetVadMode(aVadMode);

        }

    return err;

    }

/*********************************************************/

int get_g711_encoder_vad_mode(DevSoundWrapperSrc *handle, gboolean* aVadMode)

    {

    int err = 0;

    if (handle->iG711EncoderIntfc)

        {

        err = (handle->iG711EncoderIntfc)->GetVadMode(*aVadMode);

        }

    return err;

    }

/*********************************************************/

int set_g711_encoder_mode(DevSoundWrapperSrc *handle,

        enum TG711EncodeMode aEncodeMode)

    {

    int err = 0;

    if (handle->iG711EncoderIntfc)

        {

        err = (handle->iG711EncoderIntfc)->SetEncoderMode(

                (CG711EncoderIntfc::TEncodeMode) aEncodeMode);

        }

    return err;

    }

/*********************************************************/

int set_g711_vad_mode(DevSoundWrapperSrc *handle, gboolean aVadMode)

    {

    int err = 0;

    if (handle->iG711EncoderIntfc)

        {

        err = (handle->iG711EncoderIntfc)->SetVadMode(aVadMode);

        }

    return err;

    }